成人午夜激情影院,小视频免费在线观看,国产精品夜夜嗨,欧美日韩精品一区二区在线播放

.net使用SqlBulkCopy極速插入數據到SQL Server

2010-08-28 10:56:04來源:西部e網作者:

剛進公司時,領導說物流水系統有一個問題:發送水票速度很慢,每發送一次就得等10多分鐘,問我有沒有解決方法,時間原因一直沒去研究。

今天早上reader 上收到cnblogs的訂閱里看到一個關于SQL語句快速插入的文章,提到SqlBulkCopy,感覺不錯,按他的測試SqlBulkCopy要比普通插入快近30倍,

按這個來算,我們那個發水票的時間就會由 10分鐘-->20秒,這可太神奇了。

于是乎,下demo,測試,改成自己一般使用的方法測試,NND,還真可以說是極速。

 在此貼上我的Demo:UploadFiles//SqlBulkCopy.rar

using System;
using System.Diagnostics;
using System.Data;
using System.Data.SqlClient;
using Microsoft.ApplicationBlocks.Data;

namespace ConsoleAppInsertTest
{
    class Program
    {
        static int count = 1000000;           //插入的條數
        static void Main(string[] args)
        {

            long sqlBulkCopyInsertRunTime = SqlBulkCopyInsert();
            Console.WriteLine(string.Format("使用SqlBulkCopy插入{1}條數據所用的時間是{0}毫秒", sqlBulkCopyInsertRunTime, count));

            long commonInsertRunTime = CommonInsert();
            Console.WriteLine(string.Format("普通方式插入{1}條數據所用的時間是{0}毫秒", commonInsertRunTime, count));

            Console.ReadKey();

        }

        /// <summary>
        /// 使用普通插入數據
        /// </summary>
        /// <returns></returns>
        private static long CommonInsert()
        {
            Stopwatch stopwatch = new Stopwatch();
            stopwatch.Start();

            for (int i = 0; i < count; i++)
            {
                SqlHelper.ExecuteNonQuery(SqlHelper.SqlConnection, CommandType.Text, "insert into passport(PassportKey) values('" + Guid.NewGuid() + "')");
            }
            stopwatch.Stop();
            return stopwatch.ElapsedMilliseconds;
        }

        /// <summary>
        /// 使用SqlBulkCopy方式插入數據
        /// </summary>
        /// <returns></returns>
        private static long SqlBulkCopyInsert()
        {
            Stopwatch stopwatch = new Stopwatch();
            stopwatch.Start();

            DataTable dataTable = GetTableSchema();
            for (int i = 0; i < count; i++)
            {
                DataRow dataRow = dataTable.NewRow();
                dataRow[2] = Guid.NewGuid();
                dataTable.Rows.Add(dataRow);
            }

            //Console.WriteLine(stopwatch.ElapsedMilliseconds);//初始化數據時間

            SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(SqlHelper.SqlConnection);
            sqlBulkCopy.DestinationTableName = "Passport";

            if (dataTable != null && dataTable.Rows.Count != 0)
            {
                sqlBulkCopy.WriteToServer(dataTable);
            }
            sqlBulkCopy.Close();


            stopwatch.Stop();
            return stopwatch.ElapsedMilliseconds;
        }


        private static DataTable GetTableSchema()
        {
            return SqlHelper.ExecuteDataset(SqlHelper.SqlConnection, CommandType.Text, "select * from Passport where 1=2").Tables[0];
        }

    }
}

原文:http://www.yongfa365.com/Item/SqlBulkCopy.html

 

關鍵詞:vs.netSQLServer

贊助商鏈接:

主站蜘蛛池模板: 峨山| 西乡县| 屏山县| 康定县| 沧源| 北京市| 育儿| 丰宁| 射阳县| 闽清县| 庆城县| 周口市| 岗巴县| 芮城县| 洪泽县| 兴安县| 嘉祥县| 怀柔区| 车险| 海安县| 河池市| 广河县| 武胜县| 满洲里市| 康定县| 华池县| 元氏县| 黄平县| 琼结县| 荥经县| 苏尼特右旗| 吉首市| 黄山市| 沾益县| 车险| 习水县| 临汾市| 抚州市| 兴安县| 浦城县| 肇庆市|