導航:首頁 > 網路數據 > sql大數據寫入

sql大數據寫入

發布時間:2023-12-23 16:20:04

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");
}

閱讀全文

與sql大數據寫入相關的資料

熱點內容
蘋果6進水讀不了卡什麼原因 瀏覽:68
網盤文件怎麼提取到筆記軟體里 瀏覽:136
java解析簡單json數據類型 瀏覽:750
008神器破解版使用教程 瀏覽:974
word2007密碼設置 瀏覽:593
iPhone5解鎖密碼格圖案 瀏覽:392
微信文件怎麼填 瀏覽:87
燕十八老師精通mysql視頻教程 瀏覽:255
汽車保養數據怎麼清 瀏覽:629
pdf文件圖像打不開 瀏覽:176
msp430時鍾程序 瀏覽:660
查看sd卡文件系統格式 瀏覽:696
c盤中顯示隱藏文件 瀏覽:951
蘋果升級系統白屏 瀏覽:136
三菱gxplc編程軟體如何使用 瀏覽:710
海康威視手機app怎麼看不了 瀏覽:482
wordpress下載中心插件 瀏覽:402
微信限制字數是多少 瀏覽:20
策劃輸出主要從哪些文件來 瀏覽:174
網路營銷找什麼工作 瀏覽:372

友情鏈接