zoukankan      html  css  js  c++  java
  • c#Dapper 批量插入Mysql

     <connectionStrings>
        <add name="sqlconnectionString" connectionString="server=127.0.0.1;database=MyDataBase;User=sa;password=123456;Connect Timeout=1000000"/>
        <add name="mysqlconnectionString" connectionString="Database=zyzs_terminal_info;Data Source=192.168.1.220;User Id=root;Password=root;CharSet=utf8;port=3306"/>
      </connectionStrings>

    插入时格式与sql 不一样格式

    没有方括号[]

     string mysqlconnectionString = ConfigurationManager.ConnectionStrings["mysqlconnectionString"].ToString();
    
            #region 向数据库中添加多条记录 +int Insert(Model.Contacts model)
    
            public int InsertBaseList(List<BaseTable> model)
            {          
            #region SQL语句
            const string sql = @"
               INSERT INTO zyzs_terminal_base (license_number,shop_name,user_name,phone_number,shop_address)
                VALUES (
     @license_number
    ,@shop_name     
    ,@user_name     
    ,@phone_number  
    ,@shop_address  
                );select @@IDENTITY";
    
                using (var connection = new MySqlConnection(mysqlconnectionString))
                {             
                    connection.Open();
                    return connection.Execute(sql, model);
                }
                #endregion
            }
    
    
            /// <summary>
            /// 向数据库中添加一条记录
            /// </summary>
            /// <param name = "model" > 要添加的实体 </ param >
            /// < returns > 插入数据的ID </ returns >
            public int InsertBase(BaseTable model)
            {
                #region SQL语句
                const string sql = @"
                       INSERT INTO zyzs_terminal_base (license_number,shop_name,user_name,phone_number,shop_address)
                VALUES (
     @license_number
    ,@shop_name     
    ,@user_name     
    ,@phone_number  
    ,@shop_address  
                );select @@IDENTITY";
                #endregion
                using (var connection = new MySqlConnection(mysqlconnectionString))
                {
                    connection.Open();
                    return connection.Execute(sql, model);
                }
            }
            #endregion

    MySql.Data.MySqlClient   添加引用

    这个方法就是简单insert的方式插入,速度很慢.数据量大,应使用Mysql MySqlBulkLoader 批量上传

  • 相关阅读:
    微信小程序中,block的作用
    关于小程序 页面中的生命周期函数
    MySQL -- 修改root密码
    Python3 -- time 获取任意前N天的日期
    linux -- 解决配置vim中文乱码的问题
    Linux -- iTem2 长时间保持会话(不断开)
    数据结构与算法 -- Python实现【归并排序算法】
    Git -- 目录
    Linux -- screen 命令
    python3 -- Linux 离线安装pip3方法
  • 原文地址:https://www.cnblogs.com/zuochanzi/p/9073044.html
Copyright © 2011-2022 走看看