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#程序设计有所帮助。