国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 開發設計 > 正文

.net2.0中使用SqlBulkCopy進行大批量數據遷移

2019-11-18 17:08:19
字體:
來源:轉載
供稿:網友

在.Net1.1中無論是對于批量插入整個DataTable中的所有數據到數據庫中,還是進行不同數據源之間的遷移,都不是很方便。而在.Net2.0中,SQLClient命名空間下增加了幾個新類幫助我們通過DataTable或DataReader批量遷移數據。數據源可以來自關系數據庫或者xml文件,甚至WebService返回結果。其中最重要的一個類就是SqlBulkCopy類,使用它可以很方便的幫助我們把數據源的數據遷移到目標數據庫中。
下面我們先通過一個簡單的例子說明這個類的使用:

 

DateTime startTime;
    PRotected void Button1_Click(object sender, EventArgs e)
    {
        startTime = DateTime.Now;
        string SrcConString;
        string DesConString;
        SqlConnection SrcCon = new SqlConnection();
        SqlConnection DesCon = new SqlConnection();
        SqlCommand SrcCom = new SqlCommand();
        SqlDataAdapter SrcAdapter = new SqlDataAdapter();
        DataTable dt = new DataTable();
        SrcConString =
        ConfigurationManager.ConnectionStrings["SrcDBConnectionString"].ConnectionString;
        DesConString =
        ConfigurationManager.ConnectionStrings["DesDBConnectionString"].ConnectionString;
        SrcCon.ConnectionString = SrcConString;
        SrcCom.Connection = SrcCon;
        SrcCom.CommandText = " SELECT * From [SrcTable]";
        SrcCom.CommandType = CommandType.Text;
        SrcCom.Connection.Open();
        SrcAdapter.SelectCommand = SrcCom;
        SrcAdapter.Fill(dt);
        SqlBulkCopy DesBulkOp;
        DesBulkOp = new SqlBulkCopy(DesConString,
        SqlBulkCopyOptions.UseInternalTransaction);
        DesBulkOp.BulkCopyTimeout = 500000000;
        DesBulkOp.SqlRowsCopied +=
        new SqlRowsCopiedEventHandler(OnRowsCopied);
        DesBulkOp.NotifyAfter = dt.Rows.Count;
        try
        {
            DesBulkOp.DestinationTableName = "SrcTable";
            DesBulkOp.WriteToServer(dt);
        }
        catch (Exception ex)
        {
            lblResult.Text = ex.Message;
        }
        finally
        {
            SrcCon.Close();
            DesCon.Close();
        }
    }

    private void OnRowsCopied(object sender, SqlRowsCopiedEventArgs args)
    {
        lblCounter.Text += args.RowsCopied.ToString() + " rows are copied<Br>";
        TimeSpan copyTime = DateTime.Now - startTime;
        lblCounter.Text += "Copy Time:" + copyTime.Seconds.ToString() + "." + copyTime.Milliseconds.ToString() + " seconds";
    }
接著具體分析這幾行代碼:
SqlBulkCopy DesBulkOp;
DesBulkOp = new SqlBulkCopy(DesConString, SqlBulkCopyOptions.UseInternalTransaction);先生成SqlBulkCopy 實例,構造函數指定了目標數據庫,使用SqlBulkCopyOptions.UseInternalTransaction是指遷移動作指定在一個Transaction當中,如果數據遷移中產生錯誤或異常將發生回滾。其他選項請參考MSDN。

DesBulkOp.BulkCopyTimeout = 500000000;
指定操作完成的Timeout時間

        DesBulkOp.SqlRowsCopied += new SqlRowsCopiedEventHandler(OnRowsCopied);
        DesBulkOp.NotifyAfter = dt.Rows.Count;
        try
        {
            DesBulkOp.DestinationTableName = "SrcTable";
            DesBulkOp.WriteToServer(dt);
        }
NotifyAfter屬性指定通知通知事件前處理的數據行數,在這里指定為表的行數,并添加SqlRowsCopied事件輸出整個遷移過程的時間。WriteToServer方法就是將數據源拷備到目標數據庫。在使用WriteToServer方法之前必須先指定DestinationTableName屬性,也就是目標數據庫的表名,

我們還可以自己定義一個Transaction,例如:

SqlTransaction Transaction;
Transaction =
SrcCom.Connection.BeginTransaction();
SqlBulkCopy DesBulkOp;
DesBulkOp = new SqlBulkCopy(new SqlConnection(DesConString),
SqlBulkCopyOptions.Default,
Transaction);

try
{   
//..
}
catch{}   
finally
{
Transaction.Commit();
}
另外還有一個SqlBulkCopyColumnMapping類,可以讓數據源字段映射到目標數據中命名不同的字段上。也就是說如果目標數據和源數據的列名不同時,可以用這個類進行映射:
SqlBulkCopyColumnMapping ColMap = new SqlBulkCopyColumnMapping("SrcCol", "DesCol");
DesBulkOp.ColumnMappings.Add(ColMap);
或者可以直接添加映射:
DesBulkOp.ColumnMappings.Add("SrcCol", "DesCol");
性能問題:
我使用上面的例子測試,遷移了2萬條左右的記錄,花的時間不到一秒,應改說性能還是不錯的。另外,使用SQL Profile監視遷移事件,可以看見請求記錄非常少,只有幾條而已。據說使用SqlBulkCopy可以大大減少數據遷移的時間。

http://justicfu.VEVb.com/archive/2006/06/23/433887.html


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 玉龙| 剑河县| 高台县| 宝应县| 罗江县| 齐河县| 瓦房店市| 家居| 开平市| 汝城县| 乌鲁木齐市| 临桂县| 个旧市| 邓州市| 湖口县| 盐源县| 浠水县| 南川市| 顺昌县| 巴彦县| 河西区| 富源县| 扶沟县| 盐源县| 肇源县| 灵台县| 晋州市| 嫩江县| 商城县| 太康县| 万安县| 西充县| 嵩明县| 托里县| 临西县| 北海市| 银川市| 汶川县| 西乌珠穆沁旗| 台州市| 老河口市|