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 执行失败!
    }
}

评论

  1. 120.239.196.*2021-08-23 17:24:10
    有,所有的关系型数据库都差不多,SqlBulkCopy 把这个改成相应的就可以如OledbBulkCopy 改前面一部分就可以,然后引用相应的类就可以

  2. 183.94.149.*2021-08-10 23:25:48
    如操作其他数据如access,oledb去做的化有没有类似的bulkcopy类?