A. c#sqlbulk 批量写入数据可否回滚
可以，需要使用Transaction登记，给你我以前写的批量导入代码，我稍微修改了一下。
publicboolAddDataTableToDB(DataTableMyTable)
{
SqlTransactiontran=null;//声明一个事务对象
IniTable();
try
{
using(SqlConnectionconn=newSqlConnection("Server=127.0.0.1;user=sa;pwd=sa;database=test"))
{
conn.Open();//打开链接
using(tran=conn.BeginTransaction())
{
using(SqlBulkCopy=newSqlBulkCopy(conn,SqlBulkCopyOptions.Default,tran))
{
.DestinationTableName="TBImei";//指定服务器上目标表的名称
.WriteToServer(MyTable);//执行把DataTable中的数据写入DB
tran.Commit();//提交事务
returntrue;
}
}
}
}
catch(Exceptionex)
{
tran.Rollback();//出错回滚
MessageBox.Show(ex.Message);
returnfalse;
}
}
B. MySQL数据库 写入大量数据如何实现
java">//最快的方法10000记录23MS
publicstaticvoidinsert(){
//开时时间
Longbegin=newDate().getTime();
//sql前缀
Stringprefix="INSERTINTOtb_big_data(count,create_time,random)VALUES";
try{
//保存sql后缀
StringBuffersuffix=newStringBuffer();
//设置事务为非自动提交
conn.setAutoCommit(false);
//Statementst=conn.createStatement();
//比起st，pst会更好些
PreparedStatementpst=conn.prepareStatement("");
//外层循环，总提交事务次数
for(inti=1;i<=100;i++){
//第次提交步长
for(intj=1;j<=10000;j++){
//构建sql后缀
suffix.append("("+j*i+",SYSDATE(),"+i*j
*Math.random()+"),");
}
//构建完整sql
Stringsql=prefix+suffix.substring(0,suffix.length()-1);
//添加执行sql
pst.addBatch(sql);
//执行操作
pst.executeBatch();
//提交事务
conn.commit();
//清空上一次添加的数据
suffix=newStringBuffer();
}
//头等连接
pst.close();
conn.close();
}catch(SQLExceptione){
e.printStackTrace();
}
//结束时间
Longend=newDate().getTime();
//耗时
System.out.println("cast:"+(end-begin)/1000+"ms");
}