\u7b80\u5355\u4f7f\u7528\uff1a<\/p>\n
\r\nprivate void UpdateTitle(DataTable dt)\r\n{ \r\n if (dt != null && dt.Rows.Count > 0)\r\n {\r\n using (SqlBulkCopy sbc = new SqlBulkCopy(SqlHelper.connectionString))\r\n {\r\n sbc.BatchSize = dt.Rows.Count;\/\/\u6bcf\u6279\u6b21\u64cd\u4f5c\u6570\u91cf\r\n sbc.BulkCopyTimeout = 60;\/\/\u64cd\u4f5c\u5141\u8bb8\u7684\u8d85\u65f6\u65f6\u95f4 \u5355\u4f4d:\u79d2 (\u8d85\u65f6\u5219\u4e8b\u52a1\u4e0d\u63d0\u4ea4)\r\n sbc.DestinationTableName = "TB_product_NewTitle"; \/\/\u6570\u636e\u5e93\u5bf9\u5e94\u8868\u540d\r\n sbc.WriteToServer(dt);\r\n }\r\n }\r\n}\r\n<\/pre>\n\u5982\u679c\u51fa\u73b0 DataTable\u4e2d\u7684\u5b57\u6bb5\u548c\u6570\u636e\u5e93\u7684\u5b57\u6bb5\u4e0d\u5bf9\u5e94\u7684\u5f02\u5e38\u4fe1\u606f\uff0c\u9700\u8981\u624b\u52a8\u7684\u4e3aDataTable\u7684\u5217 \u548c \u6570\u636e\u5e93\u4e2d\u7684\u5217 \u7ed1\u5b9a<\/pre>\n\u6ce8\u610f\uff1adataColumns\u7684\u6570\u636e\u7c7b\u578b\uff0c\u4e00\u5b9a\u8981\u548c\u6570\u636e\u5e93\u4e00\u6837\uff0c\u4e0d\u7136\u5404\u79cd\u62a5\u9519
\n\u5b57\u6bb5\u4e5f\u533a\u5206\u5927\u5c0f\u5199\uff0c\u4e00\u5b9a\u8981\u6ce8\u610f<\/p>\n
\r\n \/\/\/ <summary>\r\n \/\/\/ \u6279\u91cf\u66f4\u65b0\u6570\u636e\u5230\u6570\u636e\u5e93(DataTable\u5217\u7ed3\u6784\u4fdd\u6301\u548c\u6570\u636e\u5e93\u8868\u4e00\u81f4)\r\n \/\/\/ <\/summary>\r\n \/\/\/ <param name="dt"><\/param>\r\n public static void BulkCopyData(Queue<QueueMessage> myQ, int SiteID,int max)\r\n {\r\n if (myQ != null && myQ.Count > 0)\r\n {\r\n using (SqlBulkCopy sbc = new SqlBulkCopy(SqlHelper.con))\r\n {\r\n QueueMessage qm = new QueueMessage();\r\n DataTable dt = new DataTable();\r\n dt.Columns.AddRange(\r\n\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000new DataColumn[] { \r\n\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000new DataColumn("Sender", typeof(Int32)), \r\n\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000new DataColumn("Receiver", typeof(Int32)), \r\n\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000new DataColumn("Content", typeof(string)), \r\n\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000new DataColumn("CreateTime", typeof(DateTime)), \r\n\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000new DataColumn("SenderType", typeof(int)) \r\n\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000});\r\n int qcount=0;\r\n if (max > 0)\r\n qcount = max;\r\n else\r\n qcount = myQ.Count();\r\n for (int i = 0; i < qcount; i++)\r\n {\r\n qm = myQ.Dequeue() as QueueMessage;\r\n DataRow dr = dt.NewRow();\r\n dr["Sender"] = qm.Sender;\r\n dr["Receiver"] = qm.Receiver;\r\n dr["Content"] = qm.Content;\r\n dr["CreateTime"] = qm.CreateTime;\r\n dr["SenderType"] = qm.SenderType;\r\n dt.Rows.Add(dr);\r\n }\r\n\u3000\u3000\u3000\u3000\u3000\u3000 \/\/\u628aDataTable\u7684\u5217\u540d\u548c\u6570\u636e\u5e93\u7684\u5217\u540d\u7ed1\u5b9a\r\n sbc.ColumnMappings.Add("Sender", "Sender"); \r\n sbc.ColumnMappings.Add("Receiver", "Receiver");\r\n sbc.ColumnMappings.Add("Content", "Content");\r\n sbc.ColumnMappings.Add("CreateTime", "CreateTime");\r\n sbc.ColumnMappings.Add("SenderType", "SenderType");\r\n sbc.BatchSize = dt.Rows.Count;\/\/\u6bcf\u6279\u6b21\u64cd\u4f5c\u6570\u91cf\r\n sbc.BulkCopyTimeout = 60;\/\/\u64cd\u4f5c\u5141\u8bb8\u7684\u8d85\u65f6\u65f6\u95f4 \u5355\u4f4d:\u79d2 (\u8d85\u65f6\u5219\u4e8b\u52a1\u4e0d\u63d0\u4ea4)\r\n sbc.DestinationTableName = "TB_Message_" + SiteID;\/\/\u6570\u636e\u5e93\u5bf9\u5e94\u8868\u540d\r\n sbc.WriteToServer(dt);\r\n }\r\n }\r\n }\r\n<\/pre>\n","protected":false},"excerpt":{"rendered":"