我要评论第一种，最常见的executenonquery（返回影响的行数）sql是我的查询插入语句，你可以换成你的！这种方式入库，速度一般，大量数据时不提倡使用
/// <summary>
/// 通过table一个一个的插入
/// </summary>
/// <param name="table"></param>
public static void executenonquery(datatable table)
{
foreach (datarow itemrow in table.rows)
{
//if exists(select * from dbo.id where eng = '')
// begin
// return;
// end
//else
// begin
// insert into id([eng],[gb],[b5],[file],[msg]) values('', '', '', '', '')
// end
string sql = "if exists(select * from " + table.tablename + " where eng = '" + itemrow["eng"].tostring() + "') "+
" begin return; end else begin insert into " + table.tablename + "([eng],[gb],[b5],[file],[msg])" +
"values('" + itemrow["eng"].tostring() + "'" +
",'" + itemrow["gb"].tostring() + "'" +
",'" + itemrow["b5"].tostring() + "'" +
",'" + itemrow["file"].tostring() + "'" +
",'" + itemrow["msg"].tostring() + "') end";
using (sqlconnection sqlconn = new sqlconnection(connectstring))
{
sqlconn.open();
sqlcommand sqlcommand = new sqlcommand(sql, sqlconn);
sqlcommand.executenonquery();
sqlconn.close();
}
}
}2，通过adapter入库，这种入库，起先，你需要先把datatable放入到dataset中然后进行入库，这种方式主要是对库中对应的表进行增删改，方便使用（效率只比第一种方式好点）
/// <summary>
/// 通过adapter更新数据库
/// </summary>
/// <param name="dataset"></param>
public static void dataadapterinssert(dataset dataset)
{
if (dataset.tables.count > 0)
{
foreach (datatable itemtable in dataset.tables)
{
sqlcommand insertcommand = new sqlcommand("if exists(select * from " + itemtable.tablename + " where eng = @eng) begin return; end "+
" else begin insert into " + itemtable.tablename + "([eng],[gb],[b5],[file],[msg])" +
"values(@eng, @gb,@b5,@file,@msg) end", new sqlconnection(connectstring));
insertcommand.parameters.add("@eng", sqldbtype.varchar, 100, "eng");
insertcommand.parameters.add("@gb", sqldbtype.varchar, 100, "gb");
insertcommand.parameters.add("@b5", sqldbtype.varchar, 200, "b5");
insertcommand.parameters.add("@file", sqldbtype.varchar, 200, "file");
insertcommand.parameters.add("@msg", sqldbtype.varchar, 100, "msg");
sqldataadapter sqldataadapter = new sqldataadapter();
sqldataadapter.insertcommand = insertcommand;
sqldataadapter.update(dataset, itemtable.tablename);
}
}
}3，重头戏都在最后，这种方式速度比前两种快很多，适合用于大量数据插入更新，也将datatable放入dataset中然后通过遍历，将datatable复制到数据库中对应的表中，快速便捷
// <summary>
/// 通过sqlbulkcopy复制table数据到数据库
/// </summary>
/// <param name="dataset"></param>
public static void sqlbulkcopyinsert(dataset dataset)
{
string ie;
if (dataset.tables.count > 0)
{
foreach (datatable itemtable in dataset.tables)
{
sqlbulkcopy sqlbulkcopy = new sqlbulkcopy(connectstring, sqlbulkcopyoptions.useinternaltransaction);
sqlbulkcopy.destinationtablename = itemtable.tablename;//数据库中的表名
for (int i = 0; i < itemtable.rows.count; i++)
{
ie = itemtable.rows[i][2].tostring();
}
sqlbulkcopy.writetoserver(itemtable);
}
}
}到此这篇关于c#使用datatable导入sqlserver数据库的三种方法的文章就介绍到这了,更多相关c# datatable导入sql内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！
发表评论