How to use BulkLoadCommand method of NBi.Core.Decoration.DataEngineering.Commands.SqlServer.BulkLoadCommand class

Best NBi code snippet using NBi.Core.Decoration.DataEngineering.Commands.SqlServer.BulkLoadCommand.BulkLoadCommand

BulkLoadCommandTest.cs

Source:BulkLoadCommandTest.cs

...10namespace NBi.Testing.Integration.Core.Decoration.DataEngineering.Commands.SqlServer11{12    [TestFixture]13    [Category("LocalSQL")]14    public class BulkLoadCommandTest15	{16        private const string SERVICE_NAME = "MSSQL$SQL2017";17        private const string FILE_CSV = "Load.csv";18        private string FileName { get; set;}19        20        public void CreateTemporaryTable(string tableName, string connectionString)21        {22            //Build the fullpath for the file to read23            FileName = DiskOnFile.CreatePhysicalFile(FILE_CSV, $"{string.Join(".", GetType().Namespace.Split('.').Reverse().Skip(2).Reverse().ToArray())}.{FILE_CSV}");24            //Create the table25            using (var conn = new SqlConnection(connectionString))26            {27                var cmd = new SqlCommand() { Connection = conn };28                conn.Open();29                cmd.CommandText = $"if (exists (select * from INFORMATION_SCHEMA.TABLES where TABLE_SCHEMA = 'dbo' and TABLE_NAME = '{tableName}')) begin drop table dbo.{tableName}; end";30                cmd.ExecuteNonQuery();31                cmd.CommandText = $"create table {tableName} (Id int IDENTITY(1,1), Name varchar (255));";32                cmd.ExecuteNonQuery();33                cmd.CommandText = $"insert into {tableName} values ('No name');";34                cmd.ExecuteNonQuery();35            }36        }37        [SetUp]38        public void EnsureLocalSqlServerRunning()39        {40            var service = new ServiceController(SERVICE_NAME);41            if (service.Status != ServiceControllerStatus.Running)42                Assert.Ignore("Local SQL Server not started.");43        }44        private int CountElementsInTable(string tableName, string connectionString)45        {46            int count = -1;47            using (var conn = new SqlConnection(connectionString))48            {49                var cmd = new SqlCommand()50                {51                    Connection = conn,52                    CommandText = $"select count(*) from {tableName}"53                };54                conn.Open();55                count = (int) cmd.ExecuteScalar();56            }57            return count;58        }59        [Test]60		public void Execute_LoadTemporaryTableBasedOnCSV_TableHasMoreData()61		{62            //Create table63            CreateTemporaryTable("Temporary", ConnectionStringReader.GetLocalSqlClient());64            //Check how many elements are available in the table65            var before = CountElementsInTable("Temporary", ConnectionStringReader.GetLocalSqlClient());66            //Mock the commandXml67            var loadArgs = Mock.Of<ILoadCommandArgs>(68                args => args.ConnectionString== ConnectionStringReader.GetLocalSqlClient()69			        && args.TableName== new LiteralScalarResolver<string>("Temporary")70                    && args.FileName == new LiteralScalarResolver<string>(FileName)71                );72            var command = new BulkLoadCommand(loadArgs);73            command.Execute();74            //Execute Query on temporary table to knwo the new count of elements75            var after = CountElementsInTable("Temporary", ConnectionStringReader.GetLocalSqlClient());76            Assert.That(after, Is.GreaterThan(before));77		}78	}79}...

BulkLoadCommand.cs

Source:BulkLoadCommand.cs

...3using System.Data.SqlClient;4using System.Linq;5namespace NBi.Core.Decoration.DataEngineering.Commands.SqlServer6{7    class BulkLoadCommand : IDecorationCommand8    {9        private readonly ILoadCommandArgs args;10        public BulkLoadCommand(ILoadCommandArgs args) => this.args = args;11        public void Execute()12        {13            Execute(args.ConnectionString, args.TableName.Execute(), args.FileName.Execute());14        }15        internal void Execute(string connectionString, string tableName, string filename)16        {17            using (var connection = new SqlConnection(connectionString))18            {19                // make sure to enable triggers20                // more on triggers in next post21                using (var bulkCopy =22                    new SqlBulkCopy23                    (24                        connection,...

SqlServerDataEngineeringFactory.cs

Source:SqlServerDataEngineeringFactory.cs

...12            if (!(connection is SqlConnection) || connection == null)13                throw new ArgumentException(nameof(connection));14            switch (args)15            {16                case ILoadCommandArgs loadArgs: return new BulkLoadCommand(loadArgs);17                case IResetCommandArgs resetArgs: return new TruncateCommand(resetArgs);18                case IBatchRunCommandArgs batchRunArgs: return new BatchRunCommand(batchRunArgs);19                default: throw new ArgumentException();20            }21        }22    }23}...

BulkLoadCommand

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6using NBi.Core.Decoration.DataEngineering.Commands.SqlServer;7using System.Data.SqlClient;8using System.Data;9{10    {11        static void Main(string[] args)12        {13            var connectionString = @"Data Source=(localdb)\MSSQLLocalDB;Initial Catalog=NBi;Integrated Security=True;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False";14            var tableName = "dbo.TestTable";15            var filePath = "C:\\Users\\user\\Desktop\\test.csv";16            var bulkLoadCommand = new NBi.Core.Decoration.DataEngineering.Commands.SqlServer.BulkLoadCommand(connectionString, tableName, filePath);17            bulkLoadCommand.Execute();18        }19    }20}21using System;22using System.Collections.Generic;23using System.Linq;24using System.Text;25using System.Threading.Tasks;

BulkLoadCommand

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6{7    {8        public void Execute()9        {10            var cmd = new NBi.Core.Decoration.DataEngineering.Commands.SqlServer.BulkLoadCommand();11            cmd.ConnectionString = "Data Source=.;Initial Catalog=AdventureWorks2016CTP3;Integrated Security=True";12            cmd.TableName = "Person.Address";13            cmd.FilePath = "C:\\Users\\Admin\\Documents\\Visual Studio 2015\\Projects\\NBi.Testing\\NBi.Testing.Integration\\Decoration\\DataEngineering\\BulkLoadCommandTest.csv";14            cmd.Execute();15        }16    }17}18using System;19using System.Collections.Generic;20using System.Linq;21using System.Text;22using System.Threading.Tasks;23{24    {25        public void Execute()26        {27            var cmd = new NBi.Core.Decoration.DataEngineering.Commands.SqlServer.BulkLoadCommand();28            cmd.ConnectionString = "Data Source=.;Initial Catalog=AdventureWorks2016CTP3;Integrated Security=True";29            cmd.TableName = "Person.Address";30            cmd.FilePath = "C:\\Users\\Admin\\Documents\\Visual Studio 2015\\Projects\\NBi.Testing\\NBi.Testing.Integration\\Decoration\\DataEngineering\\BulkLoadCommandTest.csv";31            cmd.Execute();32        }33    }34}35using System;36using System.Collections.Generic;37using System.Linq;38using System.Text;39using System.Threading.Tasks;40{41    {42        public void Execute()43        {44            var cmd = new NBi.Core.Decoration.DataEngineering.Commands.SqlServer.BulkLoadCommand();45            cmd.ConnectionString = "Data Source=.;Initial Catalog=AdventureWorks2016CTP3;Integrated Security=True";46            cmd.TableName = "Person.Address";

BulkLoadCommand

Using AI Code Generation

1BulkLoadCommand bulkLoadCommand = new BulkLoadCommand();2bulkLoadCommand.ConnectionString = connectionString;3bulkLoadCommand.Table = "dbo.TestTable";4bulkLoadCommand.File = "C:\\Temp\\TestTable.csv";5bulkLoadCommand.Delimiter = ",";6bulkLoadCommand.Execute();7BulkLoadCommand bulkLoadCommand = new BulkLoadCommand();8bulkLoadCommand.ConnectionString = connectionString;9bulkLoadCommand.Table = "dbo.TestTable";10bulkLoadCommand.File = "C:\\Temp\\TestTable.csv";11bulkLoadCommand.Delimiter = ",";12bulkLoadCommand.Execute();13BulkLoadCommand bulkLoadCommand = new BulkLoadCommand();14bulkLoadCommand.ConnectionString = connectionString;15bulkLoadCommand.Table = "dbo.TestTable";16bulkLoadCommand.File = "C:\\Temp\\TestTable.csv";17bulkLoadCommand.Delimiter = ",";18bulkLoadCommand.Execute();19BulkLoadCommand bulkLoadCommand = new BulkLoadCommand();20bulkLoadCommand.ConnectionString = connectionString;21bulkLoadCommand.Table = "dbo.TestTable";22bulkLoadCommand.File = "C:\\Temp\\TestTable.csv";23bulkLoadCommand.Delimiter = ",";24bulkLoadCommand.Execute();25BulkLoadCommand bulkLoadCommand = new BulkLoadCommand();26bulkLoadCommand.ConnectionString = connectionString;27bulkLoadCommand.Table = "dbo.TestTable";28bulkLoadCommand.File = "C:\\Temp\\TestTable.csv";29bulkLoadCommand.Delimiter = ",";30bulkLoadCommand.Execute();31BulkLoadCommand bulkLoadCommand = new BulkLoadCommand();32bulkLoadCommand.ConnectionString = connectionString;33bulkLoadCommand.Table = "dbo.TestTable";34bulkLoadCommand.File = "C:\\Temp\\TestTable.csv";35bulkLoadCommand.Delimiter = ",";36bulkLoadCommand.Execute();

BulkLoadCommand

Using AI Code Generation

1string connectionString = "Data Source=.;Initial Catalog=AdventureWorks;Integrated Security=True";2string tableName = "DimProduct";3string csvFilePath = "C:\\Temp\\DimProduct.csv";4string columnDelimiter = ",";5";6int firstRowContainsColumnNames = 1;7int numberOfRowsToSkip = 0;8int numberOfRowsToLoad = 0;9int batchSize = 10000;10int timeout = 0;11bool fireTriggers = true;12bool checkConstraints = true;13bool keepIdentity = true;14bool keepNulls = true;15bool tableLock = true;16int rowsPerBatch = 1000;17int notifyAfter = 0;18bool fileStream = false;

BulkLoadCommand

Using AI Code Generation

1BulkLoadCommand bulkLoadCommand = new BulkLoadCommand();2bulkLoadCommand.ConnectionString = @"Server=.\SQLEXPRESS;Database=AdventureWorks2012;Trusted_Connection=True;";3bulkLoadCommand.FilePath = @"C:\Users\Public\Documents\AdventureWorks2012_SalesOrderDetail.csv";4bulkLoadCommand.TableName = "Sales.SalesOrderDetail";5bulkLoadCommand.MatchColumnName = "SalesOrderDetailID";6bulkLoadCommand.Skip = 1;7bulkLoadCommand.Delimiter = ",";8bulkLoadCommand.Quote = "\"";9bulkLoadCommand.Escape = "\"";10bulkLoadCommand.FirstColumn = 1;11bulkLoadCommand.LastColumn = 25;12bulkLoadCommand.Top = 1000;13bulkLoadCommand.CommandTimeout = 60;14bulkLoadCommand.BatchSize = 1000;15bulkLoadCommand.NotifyAfter = 1000;16bulkLoadCommand.RowsPerTransaction = 1000;17bulkLoadCommand.RowsPerBatch = 1000;18bulkLoadCommand.Execute();

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.