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 批量上传

  • 相关阅读:
    MySQL主从复制集群添加slave节点
    GTID主从 与 传统主从复制
    20201207总结
    202011051 每周例行报告
    202011121 每周例行报告
    202010081 每周例行报告
    202011261 每周例行报告
    202010153 每周例行报告
    202010291 每周例行报告
    202011201 每周例行报告
  • 原文地址:https://www.cnblogs.com/zuochanzi/p/9073044.html
Copyright © 2011-2022 走看看