zoukankan      html  css  js  c++  java
  • C# 批量插入Mysql zt 武胜

    C# 批量插入Mysql

         string connectString = "server=localhost;user=root;database=dbtest;port=3306;password=;charset=utf8";

           public static void batchSql(List<DataObj> list)
            {
                List<string> sqlList = new List<string>();
                List<MySqlParameter[]> paraList = new List<MySqlParameter[]>();

                foreach (DataObj oh in list)
                {
                    MySqlParameter[] parameters = new MySqlParameter[19];

                    parameters[0] = new MySqlParameter("@param1", MySqlDbType.VarChar, 50);
                    parameters[0].Value = oh.param1;
                    parameters[1] = new MySqlParameter("@param2", MySqlDbType.VarChar, 50);
                    parameters[1].Value = oh.param2;

                    sqlList.Add(sqlInsert);
                    paraList.Add(parameters);
                }

                ExecuteTransaction(sqlList, paraList);

            }     

           /**
             * 执行事务
             * */
            public static void ExecuteTransaction(List<string> sqlList, List<MySqlParameter[]> paraList)
            {
                //Debug.WriteLine(sql);
                using (MySqlConnection connection = new MySqlConnection(connectString))
                {
                    MySqlCommand cmd = new MySqlCommand();
                    MySqlTransaction transaction = null;
                    cmd.Connection = connection;
                    try
                    {
                        connection.Open();
                        transaction = connection.BeginTransaction();
                        cmd.Transaction = transaction;

                        for (int i = 0; i < sqlList.Count; i++)
                        {
                            cmd.CommandText = sqlList[i];
                            if (paraList != null && paraList[i] != null)
                            {
                                cmd.Parameters.Clear();
                                cmd.Parameters.AddRange(paraList[i]);
                            }
                            cmd.ExecuteNonQuery();
                        }
                        transaction.Commit();

                    }
                    catch (Exception e)
                    {
                        try
                        {
                            transaction.Rollback();
                        }
                        catch
                        {

                        }
                        throw e;
                    }
                    finally {
                        if(connection != null){
                            connection.Close();
                        }
                    }

                }
            }

    其中DataObj类定义如下:

    class DataObj{

      string param1;

      string param2;

    }

  • 相关阅读:
    ubuntu server 14.04和18.04挂载vmware共享文件夹
    Ubuntu 无法进行SSH连接,开启22端口
    ubuntu切换到root用户
    VMware Workstation 15 Pro 永久激活密钥
    idea静态资源的访问问题,如HTML,css,js的加载
    idea在Tomcat服务器加载html文件出现乱码的解决方案
    html,js 打开时出现 Uncaught TypeError: Cannot read property 'addEventListener' of null at register.js:24错误的解决方法
    js判断input输入是不是含有中文,或者判断输入是不是全是中文
    PHP连接前端from数据的错误,如源服务器未能找到目标资源的表示或者是不愿公开一个已经存在的资源表示。
    PHP与Tomcat运行前的配置。
  • 原文地址:https://www.cnblogs.com/zeroone/p/2970467.html
Copyright © 2011-2022 走看看