IBatis.Net 下使用SqlBulkCopy 大批量导入数据问题解决

浏览数：18 / 时间：2015年06月12日

SQLBulkCopy是继承SQLClient空间下的一个特殊类，它可以帮助我们以映射的方式把DataTable和DataReader数据大批量导入到数据库对应表中

 1 public void Inert2DBBySqlBulkCopy(DataTable data, string tableName)
 2 {
 3 BaseDao basdd = new BaseDao();
 4 using (SqlConnection conn = new SqlConnection(basdd.SqlNormMap.DataSource.ConnectionString))
 5 {
 6 if (conn.State != ConnectionState.Open)
 7 conn.Open();
 8 using (SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(conn))
 9 {
10 sqlBulkCopy.ColumnMappings.Add(0, "CarModelID");
11 sqlBulkCopy.ColumnMappings.Add(1, "TranConfID");
12 sqlBulkCopy.ColumnMappings.Add(2, "TranValue");
13 sqlBulkCopy.ColumnMappings.Add(3, "CreatorID");
14 sqlBulkCopy.ColumnMappings.Add(4, "Creator");
15 sqlBulkCopy.ColumnMappings.Add(5, "OptDataType");
16 sqlBulkCopy.BatchSize = data.Rows.Count;
17 sqlBulkCopy.BulkCopyTimeout = 30;
18 sqlBulkCopy.DestinationTableName = tableName;
19 sqlBulkCopy.WriteToServer(data);
20 }
21 if (conn.State != ConnectionState.Closed)
22 conn.Close();
23 }
24 }

其中要注意都是：

Table表中的字段名称，字段顺序，字段类型必须和插入的sqlBulkCopy.ColumnMappings.Add的插入顺序是一模一样的，如下图，自定义一个Class

 public class JJJModel
    {
        public int? CarModelID { get; set; }
        public int TranConfID { get; set; }
        public string TranValue { get; set; }
        public int CreatorID { get; set; }
        public string Creator { get; set; }
        public int OptDataType { get; set; }
    }

插入的时候的代码

 1   //匹配款式Id和配置ID  拼成二维表数据
 2                             for (int i = 0; i < listCarModelID.Count(); i++)
 3                             {
 4                                 msindex = i;
 5                                 for (int j = 0; j < listTranF.Count(); j++)
 6                                 {
 7                                     JJJModel jj = new JJJModel();
 8                                     jj.CarModelID = Convert.ToInt32(listCarModelID[i]);        //款型ID
 9                                     jj.TranConfID = Convert.ToInt32(listTranF[j].ToString());   //配置ID
10                                     jj.TranValue = dtCMTranConf.Rows[i][j + 2].ToString().ToUpper();//值
11                                     jj.CreatorID = UserId;
12                                     jj.Creator = UserName;
13                                     jj.OptDataType = CarConst.OptDataType20;
14                                     listTranExcel.Add(jj);
15                                 }
16                             }