using System.Data.SqlClient;

 class Program

 {

     static void Main()

     {

         string connectionString = GetConnectionString();

         // Open a sourceConnection to the AdventureWorks database.

         using (SqlConnection sourceConnection =

                    new SqlConnection(connectionString))

         {

             sourceConnection.Open();

             // Perform an initial count on the destination table.

             SqlCommand commandRowCount = new SqlCommand(

                 "SELECT COUNT(*) FROM " +

                 "dbo.BulkCopyDemoMatchingColumns;",

                 sourceConnection);

             long countStart = System.Convert.ToInt32(

                 commandRowCount.ExecuteScalar());

             Console.WriteLine("Starting row count = {0}", countStart);

             // Get data from the source table as a SqlDataReader.

             SqlCommand commandSourceData = new SqlCommand(

                 "SELECT ProductID, Name, " +

                 "ProductNumber " +

                 "FROM Production.Product;", sourceConnection);

             SqlDataReader reader =

                 commandSourceData.ExecuteReader();

             // Open the destination connection. In the real world you would

             // not use SqlBulkCopy to move data from one table to the other

             // in the same database. This is for demonstration purposes only.

             using (SqlConnection destinationConnection =

                        new SqlConnection(connectionString))

             {

                 destinationConnection.Open();

                 // Set up the bulk copy object.

                 // Note that the column positions in the source

                 // data reader match the column positions in

                 // the destination table so there is no need to

                 // map columns.

                 using (SqlBulkCopy bulkCopy =

                            new SqlBulkCopy(destinationConnection))

                 {

                     bulkCopy.DestinationTableName =

                         "dbo.BulkCopyDemoMatchingColumns";

                     try

                     {

                         // Write from the source to the destination.

                         bulkCopy.WriteToServer(reader);

                     }

                     catch (Exception ex)

                     {

                         Console.WriteLine(ex.Message);

                     }

                     finally

                     {

                         // Close the SqlDataReader. The SqlBulkCopy

                         // object is automatically closed at the end

                         // of the using block.

                         reader.Close();

                     }

                 }

                 // Perform a final count on the destination

                 // table to see how many rows were added.

                 long countEnd = System.Convert.ToInt32(

                     commandRowCount.ExecuteScalar());

                 Console.WriteLine("Ending row count = {0}", countEnd);

                 Console.WriteLine("{0} rows were added.", countEnd - countStart);

                 Console.WriteLine("Press Enter to finish.");

                 Console.ReadLine();

             }

         }

     }

     private static string GetConnectionString()

         // To avoid storing the sourceConnection string in your code,

         // you can retrieve it from a configuration file.

     {

         return "Data Source=(local); " +

             " Integrated Security=true;" +

             "Initial Catalog=AdventureWorks;";

     }

 }

 /// <summary>

         /// 将DataTable表数据插入数据库目标表

         /// DataTable Name 和数据库目标表名称一致,DataTable列名为目标数据库目标表字段

         /// </summary>

         /// <param name="dt">数据源</param>

         /// <param name="dbFlag">数据库标识</param>

         /// <returns></returns>

         public static bool MassInsert(DataTable dt, string dbFlag)

         {

             if (dt == null || dt.Rows.Count == )

             {

                 Logger.Write("DataTable为空或无填充行", "大数据操作", "");

                 return false;

             }

             if (String.IsNullOrEmpty(dt.TableName))

             {

                 Logger.Write("DataTableName为空无法确定目标数据库表", "大数据操作", "");

                 return false;

             }

             SqlConnection con = HelpGetSqlCon(dbFlag);//动态获取SqlConnection对象

             DateTime time = DateTime.Now;

             SqlTransaction tra = con.BeginTransaction();//事务

             SqlBulkCopy sqlBC = new SqlBulkCopy(con, SqlBulkCopyOptions.Default, tra);

             try

             {

                 sqlBC.DestinationTableName = dt.TableName;

                 //一次批量的插入的数据量

                 sqlBC.BatchSize = dt.Rows.Count;

                 sqlBC.WriteToServer(dt);

                 Logger.Write("【MassInsert】[" + dt.Rows.Count + "]条数据共耗时[" + (DateTime.Now - time).TotalSeconds.ToString() + "]秒", "", ""); //记录日志

                 tra.Commit();

                 return true;

             }

             catch (Exception ex)

             {

                 tra.Rollback();

                 Logger.WriteException("MassInsert异常", "", ex, "");

                 return false;

             }

             finally

             {

                 dt.Clear();

                 dt.Dispose();

                 sqlBC.Close();

                 con.Dispose();

                 con.Close();

             }

         }