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;";     } }

var dt = bisdal.From<TopBrand>(TopBrand._.ID == -1, OrderByClip.Default).ToDataTable();

foreach (var item in brandselldataitems) {  try  {      TopBrand topbrand = new TopBrand      {   BrandIndex = item.mk,   BrandName = item.c58,   Date = date,   WinnerAmt = item.c60,   WinnerPeople = item.c62,   WinnerProNum = item.c61,   HotTaobaoCategoryID = cid      };      CreateDtByItem<TopBrand>(topbrand, dt);  }  catch (Exception ex)  {      Logger.Error(ex.ToString());      continue;  } }

private void CreateDtByItem<T>(T item, DataTable dt) {     System.Reflection.PropertyInfo[] properties = item.GetType().GetProperties(System.Reflection.BindingFlags.Instance | System.Reflection.BindingFlags.Public);     var newrow = dt.NewRow();     foreach (System.Reflection.PropertyInfo pitem in properties)     {  string name = pitem.Name;  if (name == "children")  {      continue;  }  object value = pitem.GetValue(item, null);  newrow[name] = value == null ? DBNull.Value : value;     }     dt.Rows.Add(newrow); }

BulkWriteToServer(con, "TopBrand", dt);

private void BulkWriteToServer(SqlConnection con, string destinationtablename, DataTable sourcedt) {     try     {  if (con.State == ConnectionState.Closed)  {      con.Open();  }  SqlBulkCopy topbranddtcopy = new SqlBulkCopy(con);  topbranddtcopy.DestinationTableName = destinationtablename;  topbranddtcopy.WriteToServer(sourcedt);  con.Close();     }     catch (Exception ex)     {  Logger.Error("批量新增数据:" + destinationtablename + "," + ex.ToString());     } }

private void CreateTopBrandData(int date, int cid, List<BrandSellDataItem> brandselldataitems) {     try     {  var dt = bisdal.From<TopBrand>(TopBrand._.ID == -1, OrderByClip.Default).ToDataTable();  foreach (var item in brandselldataitems)  {      try      {   TopBrand topbrand = new TopBrand   {       BrandIndex = item.mk,       BrandName = item.c58,       Date = date,       WinnerAmt = item.c60,       WinnerPeople = item.c62,       WinnerProNum = item.c61,       HotTaobaoCategoryID = cid   };   CreateDtByItem<TopBrand>(topbrand, dt);      }      catch (Exception ex)      {   Logger.Error(ex.ToString());   continue;      }  }  BulkWriteToServer(con, "TopBrand", dt);     }     catch (Exception ex)     {  throw new Exception("CreateTopBrandData:" + ex.ToString());     } }