高效能，大数据量存储方案SqlBulkCopy

时间：2011-03-02 来源：Vincent.Tianjin

/// <summary>
        /// LaborReport Data Import To Database
        /// </summary>
        /// <param name="laborReport">laborReport data table</param>
        /// <param name="laborReportDetail">laborReportDetail data table</param>
        public void LaborReportInsert(DataTable laborReport, DataTable laborReportDetail)
        {
            using (SqlConnection conn = new SqlConnection(this.Connection))
            {
                if (conn.State != ConnectionState.Open)
                    conn.Open();

                using (SqlBulkCopy sqlBCLaborReport = new SqlBulkCopy(conn))
                {
                    sqlBCLaborReport.BatchSize = laborReport.Rows.Count;
                    sqlBCLaborReport.BulkCopyTimeout = 60;
                    sqlBCLaborReport.DestinationTableName = "LaborReport";
                    sqlBCLaborReport.WriteToServer(laborReport);
                }

                using (SqlBulkCopy sqlBCLaborReportDetails = new SqlBulkCopy(conn))
                {
                    sqlBCLaborReportDetails.BatchSize = laborReportDetail.Rows.Count;
                    sqlBCLaborReportDetails.BulkCopyTimeout = 60;
                    sqlBCLaborReportDetails.DestinationTableName = "LaborReportDetails";
                    sqlBCLaborReportDetails.WriteToServer(laborReportDetail);
                }

                if (conn.State != ConnectionState.Closed)
                    conn.Close();
            }
        }

上边的示例代码，将内存中的两个DataTable 数据一次性的存入数据库中，只要内存中的数据表格的结构跟数据库中的表格结构一样，就可以了，如果数据库中包含自增列字段，我们可以不需要在内存表中定义，当数据保存到数据库中的时候，自增列会自动生成数据的。

相关阅读更多 +