C#实现SQL批量插入数据到表的方法
本文实例讲述了C#实现SQL批量插入数据到表的方法。分享给大家供大家参考,具体如下:
#region帮助实例:SQL批量插入数据多种方法 ///<summary> ///SqlBulkCopy往数据库中批量插入数据 ///</summary> ///<paramname="sourceDataTable">数据源表</param> ///<paramname="targetTableName">服务器上目标表</param> ///<paramname="mapping">创建新的列映射,并使用列序号引用源列和目标列的列名称。</param> publicstaticvoidBulkToDB(DataTablesourceDataTable,stringtargetTableName,SqlBulkCopyColumnMapping[]mapping) { /*调用方法-2012年11月16日编写 //DataTabledt=Get_All_RoomState_ByHID(); //SqlBulkCopyColumnMapping[]mapping=newSqlBulkCopyColumnMapping[4]; //mapping[0]=newSqlBulkCopyColumnMapping("Xing_H_ID","Xing_H_ID"); //mapping[1]=newSqlBulkCopyColumnMapping("H_Name","H_Name"); //mapping[2]=newSqlBulkCopyColumnMapping("H_sName","H_sName"); //mapping[3]=newSqlBulkCopyColumnMapping("H_eName","H_eName"); //BulkToDB(dt,"Bak_Tts_Hotel_Name",mapping); */ SqlConnectionconn=newSqlConnection(SQLHelper.ConnectionString); SqlBulkCopybulkCopy=newSqlBulkCopy(conn);//用其它源的数据有效批量加载sqlserver表中 bulkCopy.DestinationTableName=targetTableName;//服务器上目标表的名称 bulkCopy.BatchSize=sourceDataTable.Rows.Count;//每一批次中的行数 try { conn.Open(); if(sourceDataTable!=null&&sourceDataTable.Rows.Count!=0) { for(inti=0;i<mapping.Length;i++) bulkCopy.ColumnMappings.Add(mapping[i]); //将提供的数据源中的所有行复制到目标表中 bulkCopy.WriteToServer(sourceDataTable); } } catch(Exceptionex) { //throwex; Common.WriteTextLog("BulkToDB",ex.Message); } finally { conn.Close(); if(bulkCopy!=null) bulkCopy.Close(); } } ///<summary> ///SQL2008以上方可支持自定义表类型:调用存储过程游标-往数据库中批量插入数据,注意 ///</summary> ///<paramname="sourceDataTable"></param> publicvoidDataTableToHotelDB(DataTablesourceDataTable) { /*-2012年11月15日编写 ALTERPROCEDURE[dbo].[P_InsertSubject] @tempStudentIDint AS DECLARErsCURSORLOCALSCROLLFOR selectH_IDfromTts_Hotel_Name OPENrs FETCHNEXTFROMrsINTO@tempStudentID WHILE@@FETCH_STATUS=0 BEGIN Insertstudent(tempStudentID)values(@tempStudentID) FETCHNEXTFROMrsINTO@tempStudentID END CLOSErs **************************************************************** *createtableOrders ( Orders_IDintidentity(1,1)primarykey, ItemCodenvarchar(50)notnull, UMnvarchar(20)notnull, Quantitydecimal(18,6)notnull, UnitPricedecimal(18,6)notnull ) --创建用户自定义表类型,在可编程性->类型性->用户自定义表类型 createtypeOrdersTableTypeastable ( ItemCodenvarchar(50)notnull, UMnvarchar(20)notnull, Quantitydecimal(18,6)notnull, UnitPricedecimal(18,6)notnull ) go createprocedurePro_Orders ( @OrdersCollectionOrdersTableTypereadonly ) as insertintoOrders([ItemCode],[UM],[Quantity],[UnitPrice]) SELECToc.[ItemCode],oc.[UM],[Quantity],oc.[UnitPrice]FROM@OrdersCollectionASoc; go * */ SqlParameter[]parameters={newSqlParameter("@OrdersCollection",SqlDbType.Structured)}; parameters[0].Value=sourceDataTable; newSQLHelper().ExecuteScalar("P_DataTable_ToHotelDB",parameters,true); } #endregion
更多关于C#相关内容感兴趣的读者可查看本站专题:《C#数据结构与算法教程》、《C#常见控件用法教程》、《C#面向对象程序设计入门教程》及《C#程序设计之线程使用技巧总结》
希望本文所述对大家C#程序设计有所帮助。