zoukankan      html  css  js  c++  java
  • Sql 批量插入数据

    /// <summary>
            /// 批量插入用户配置
            /// </summary>
            /// <param name="connectionString">目标连接字符</param>
            /// <param name="TableName">目标表</param>
            /// <param name="dt">源数据</param>
            public void SqlBulkCopyByDatatable(string connectionString, string TableName, DataTable dt)
            {
                using (SqlConnection conn = new SqlConnection(connectionString))
                {
                    using (SqlBulkCopy sqlbulkcopy = new SqlBulkCopy(connectionString, SqlBulkCopyOptions.UseInternalTransaction))
                    {
                        try
                        {
                            sqlbulkcopy.DestinationTableName = TableName;
                            for (int i = 0; i < dt.Columns.Count; i++)
                            {
                                sqlbulkcopy.ColumnMappings.Add(dt.Columns[i].ColumnName, dt.Columns[i].ColumnName);
                            }
                            sqlbulkcopy.WriteToServer(dt);
                        }
                        catch (System.Exception ex)
                        {
                            throw ex;
                        }
                    }
                }
            }
    View Code
      #region 将List转换到DataTable
    
                    DataTable dt = new DataTable();
                    dt.Columns.Add("RecordNum", typeof(string));
                    dt.Columns.Add("UserName", typeof(string));
                    dt.Columns.Add("ThemeID", typeof(int));
                    dt.Columns.Add("ThemeName", typeof(string));
                    dt.Columns.Add("TempID", typeof(int));
                    dt.Columns.Add("TempRecordNumberID", typeof(string));
                    dt.Columns.Add("TempUrl", typeof(string));
                    dt.Columns.Add("ConfigDetail", typeof(string));
                    dt.Columns.Add("Remark1", typeof(string));
                    dt.Columns.Add("IsDelete", typeof(bool));
                    dt.Columns.Add("CreateBy", typeof(string));
                    dt.Columns.Add("CreateTime", typeof(DateTime));
                    foreach (var p in ucList)
                    {
                        DataRow row = dt.NewRow();
                        row["RecordNum"] = p.RecordNum;
                        row["UserName"] = p.UserName;
                        row["ThemeID"] = p.ThemeID;
                        row["ThemeName"] = p.ThemeName;
                        row["TempID"] = p.TempID;
                        row["TempRecordNumberID"] = p.TempRecordNumberID;
                        row["TempUrl"] = p.TempUrl;
                        row["ConfigDetail"] = p.ConfigDetail;
                        row["Remark1"] = p.Remark1;
                        row["IsDelete"] = p.IsDelete;
                        row["CreateBy"] = p.CreateBy;
                        row["CreateTime"] = p.CreateTime;
                        dt.Rows.Add(row);
                    }
    
                    #endregion
    
                    //批量保存用户配置
                    string myConn = ConfigurationManager.AppSettings["PortalConnString"].ToString();
                    T_COM_UserConfigBll.Instance.SqlBulkCopyByDatatable(myConn, "T_COM_UserConfig", dt);
    View Code
    <add key="PortalConnString" value="initial catalog=HXPortal;data source=xx.xxx.xx.xx;password=xxxx;User id=xxx;" />
    View Code
    收藏
    关注
    评论
  • 相关阅读:
    撩课-Python-每天5道面试题-第8天
    声明提前、原型、静态方法的一些所得
    梳理ajax
    两数之和、整数反转、回文数
    node 基础API(fs)
    node 基础API(event)
    node 基础API(Buffer)
    node 基础API(path)
    node 调试技巧
    node process(进程) 几个常用属性
  • 原文地址:https://www.cnblogs.com/yidengbone/p/7551723.html
Copyright © 2011-2022 走看看