zoukankan      html  css  js  c++  java
  • Sql批量提交方法

            #region SqlServer 批量提交
    
    
            /// <summary> 
            /// 注意:DataTable中的列需要与数据库表中的列完全一致。,只支持sql servert
            /// 已自测可用。
            /// </summary> 
            /// <param name="conStr">数据库连接串</param>
            /// <param name="strTableName">数据库中对应的表名</param> 
            /// <param name="dtData">数据集</param> 
            //public void SqlBulkCopyInsert(string conStr, string strTableName, DataTable dtData)
            public void SqlBulkToSQl<T>(string strTableName, List<T> lstDt)
            {
                try
                {
                    DataTable dtList = Com.Domain.Common.DataConvert.ToDataTable<T>(lstDt);
                    SqlBulkCopyInsert(strTableName, dtList);
                }
                catch (Exception ex)
                {
                    throw (ex);
                }
            }
    
    
            /// <summary> 
            /// 注意:DataTable中的列需要与数据库表中的列完全一致。
            /// 已自测可用。
            /// </summary> 
            /// <param name="conStr">数据库连接串</param>
            /// <param name="strTableName">数据库中对应的表名</param> 
            /// <param name="dtData">数据集</param> 
            //public void SqlBulkCopyInsert(string conStr, string strTableName, DataTable dtData)
            public void SqlBulkCopyInsert(string strTableName, DataTable dtData)
            {
                try
                {
                    string conStr = _db.ConnectionString;
                    //conStr = "Server=192.168.0.7;Database=test2;Uid=sa;Pwd=123456;pooling=true;";
                    using (SqlBulkCopy sqlRevdBulkCopy = new SqlBulkCopy(conStr))           //引用SqlBulkCopy 
                    {
                        sqlRevdBulkCopy.DestinationTableName = strTableName;                //数据库中对应的表名 
                        sqlRevdBulkCopy.NotifyAfter = dtData.Rows.Count;                    //有几行数据 
                        sqlRevdBulkCopy.WriteToServer(dtData);                              //数据导入数据库 
                        sqlRevdBulkCopy.Close();                                            //关闭连接 
                    }
                }
                catch (Exception ex)
                {
                    throw (ex);
                }
            }
    
    
            #endregion
  • 相关阅读:
    升级centos6.5系统的gcc为4.8.5的简易步骤
    赛车比赛(洛谷U4566)
    月考(cogs 1176)
    xth的旅行(codevs 1450)
    魔法禁书目录2:回家(codevs 3024)
    交换
    牛的旅行(洛谷 1522)
    长途旅行
    序列问题
    正确答案
  • 原文地址:https://www.cnblogs.com/lhlong/p/15206239.html
Copyright © 2011-2022 走看看