C# DataTable批量写入Sql server数据库

核心代码

/// <summary>
/// 初始化一个DataTable类型的数据源
/// <para/>Author : lqwvje
/// <para/>Date   : 2021-7-24
/// </summary>
/// <returns>Source</returns>
private DataTable InitSource()
{
    DataTable dtUserAdd = new DataTable();
    dtUserAdd.Columns.Add(new DataColumn("ID", typeof(int)));
    dtUserAdd.Columns.Add(new DataColumn("UserName", typeof(string)));
    dtUserAdd.Columns.Add(new DataColumn("UserQQ", typeof(string)));
    dtUserAdd.Columns.Add(new DataColumn("Age", typeof(int)));
    DataRow drTemp = null;
    for (int i = 0; i < 1000; i++)
    {
        drTemp = dtUserAdd.NewRow();
        drTemp["ID"] = 0;
        drTemp["UserName"] = "测试" + (i + 1);
        drTemp["UserQQ"] = "QQ" + (i + 1);
        drTemp["Age"] = (i + 1);
        dtUserAdd.Rows.Add(drTemp);
    }
    return dtUserAdd;
}

/// <summary>
/// 一次性把DataTable中的数据插入数据库
/// <para/>Author : lqwvje
/// <para/>Date   : 2021-7-24
/// </summary>
/// <param name="source">DataTable数据源</param>
/// <returns>true - 成功，false - 失败</returns>
public bool AddDataTableToDB(DataTable source)
{
    SqlTransaction tran = null;//声明一个事务对象
    try
    {
        using (SqlConnection conn = new SqlConnection("Data Source=192.168.0.105; Initial Catalog=testData;User ID=sa;Password=123456"))
        {
            conn.Open();//打开链接
            using (tran = conn.BeginTransaction())
            {
                using (SqlBulkCopy copy = new SqlBulkCopy(conn, SqlBulkCopyOptions.Default, tran))
                {
                    copy.DestinationTableName = "[UserInfo]";  //指定服务器上目标表的名称
                    copy.WriteToServer(source);  //执行把DataTable中的数据写入DB  注意DataTable表结构要与数据库表结构一样
                    tran.Commit();              //提交事务
                    return true;               //返回True 执行成功！
                }
            }
        }
    }
    catch (Exception ex)
    {
        if (null != tran)
            tran.Rollback();
        //LogHelper.Add(ex);
        return false;//返回False 执行失败！
    }
}

今天(2022-06-15)碰到用SqlBulkCopy批量插入数据时提示来自数据源的 String 类型的给定值不能转换为指定目标列的类型 int。经过在网上查资料发现SqlBulkCopy不是根据表的ColumnName来匹配的，而是根据ColumnIndex匹配，因为数据库有int和varchar类型，顺序变了就导致这个异常