SqlBulkCopy.WriteToServer

___

2020-11-3 18:19:01 ,

说明
WriteToServer(DataRow[])
将所提供的 DataRow 数组中的所有行复制到 SqlBulkCopy 对象的 DestinationTableName 属性指定的目标表中。
WriteToServer(DataTable)
将所提供的 DataTable 中的所有行复制到 SqlBulkCopy 对象的 DestinationTableName 属性指定的目标表中。
WriteToServer(IDataReader)
将所提供的 IDataReader 中的所有行复制到 SqlBulkCopy 对象的 DestinationTableName 属性指定的目标表中。
WriteToServer(DataTable, DataRowState)
只将与所提供 DataTable 中所提供行状态匹配的行复制到 SqlBulkCopy 对象的 DestinationTableName 属性指定的目标表中。
通过调用 SqlBulkCopy. WriteToServer 方法来实现对多条记录的插入数 据库,

例如可以通过 SqlBulkCopy. WriteToServer(DataTable)来实现 对 DataTable 的批量插入。

具体示例如下:

SqlBulkCopy objSqlBulkCopy = new SqlBulkCopy(objConn, SqlBulkCopyOptions.Default, objTran);
objSqlBulkCopy.DestinationTableName = "BizRoomDetailsNew";
objSqlBulkCopy.ColumnMappings.Add("TitleID", "BizRoomDetail_TitleID");
objSqlBulkCopy.ColumnMappings.Add("RoomID", "BizRoomDetail_Room");
objSqlBulkCopy.ColumnMappings.Add("PeriodID", "BizRoomDetail_Period");
objSqlBulkCopy.ColumnMappings.Add("StartDateTime", "BizRoomDetail_Begin");
objSqlBulkCopy.ColumnMappings.Add("EndDateTime", "BizRoomDetail_End");
objSqlBulkCopy.ColumnMappings.Add("Time", "BizRoomDetail_Time");
objSqlBulkCopy.ColumnMappings.Add("RoomFeeRuleID", "BizRoomDetail_RoomRule");
objSqlBulkCopy.ColumnMappings.Add("RecipeFeeRuleID", "BizRoomDetail_RecipeRule");
objSqlBulkCopy.ColumnMappings.Add("Discount", "BizRoomDetail_Discount");
objSqlBulkCopy.ColumnMappings.Add("WorkerDiscount", "BizRoomDetail_WorkerDiscount");
objSqlBulkCopy.ColumnMappings.Add("UnitPrice", "BizRoomDetail_UnitPrice");
objSqlBulkCopy.ColumnMappings.Add("Price", "BizRoomDetail_RoomFee");
objSqlBulkCopy.ColumnMappings.Add("PriceAfterDiscount", "BizRoomDetail_DiscountFee");
objSqlBulkCopy.ColumnMappings.Add("ServiceCharge", "BizRoomDetail_Service");
objSqlBulkCopy.ColumnMappings.Add("Notes", "BizRoomDetail_Comment");
objSqlBulkCopy.ColumnMappings.Add("PresentTimeType", "BizRoomDetail_PresentType");
objSqlBulkCopy.ColumnMappings.Add("MemberCardType", "BizRoomDetail_MemberCard");
objSqlBulkCopy.ColumnMappings.Add("Flag", "BizRoomDetail_Free");
objSqlBulkCopy.ColumnMappings.Add("PeriodPrice", "BizRoomDetail_Period_Price");
objSqlBulkCopy.ColumnMappings.Add("CanMemberPrice", "BizRoomDetail_MemberPrice");
objSqlBulkCopy.ColumnMappings.Add("BasicPrice", "BizRoomDetail_Price");
objSqlBulkCopy.ColumnMappings.Add("ServiceChargeRate", "BizRoomDetail_ServiceCharge");
objSqlBulkCopy.BulkCopyTimeout = 1000; objSqlBulkCopy.WriteToServer(dtDetail); //超时时间 //插入数据库


ColumnMappings.Add()方法的前一个参数是 dtDetail 中的字段,而后一 个参数就是数据库表 BizRoomDetailsNew 中的字段名称。 这个方法可以实现 DataTable 的批量插入! 其他重载的方法类似,都可以实现对应对象的批量插入。