MySQL数据库工具类之——DataTable批量加入MySQL数据库(Net版)

MySQL数据库工具类之——DataTable批量加入数据库(Net版),MySqlDbHelper通用类希望能对大家有用,代码如下:

using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Linq;
using System.Web;
using System.Text;

public class MySqlDbHelper
{

    #region 私有变量
    private const string defaultConfigKeyName = "MySqlConnection";//连接字符串 Database='数据库';Data Source='IP地址';User Id='sa';Password='sa';pooling=true
    private string connectionString;
    private string providerName;

    #endregion

    #region 构造函数

    /// <summary>
    /// 默认构造函数(DbHelper)
    /// </summary>
    public MySqlDbHelper()
    {
        this.connectionString = ConfigurationManager.ConnectionStrings[defaultConfigKeyName].ConnectionString;
        this.providerName = ConfigurationManager.ConnectionStrings[defaultConfigKeyName].ProviderName;
    }

    /// <summary>
    /// DbHelper构造函数
    /// </summary>
    /// <param name="keyName">连接字符串名</param>
    public MySqlDbHelper(string keyName)
    {
        this.connectionString = ConfigurationManager.ConnectionStrings[keyName].ConnectionString;
        this.providerName = ConfigurationManager.ConnectionStrings[keyName].ProviderName;
    }

    #endregion

    public int ExecuteNonQuery(string sql, params  MySqlParameter[] parameters)
    {
        int res = 0;
        using (MySqlConnection con = new MySqlConnection(connectionString))
        {
            con.Open();
            using (MySqlCommand cmd = new MySqlCommand(sql, con))
            {
                foreach (MySqlParameter parameter in parameters)
                {
                    cmd.Parameters.Add(parameter);
                }
                try
                {
                    res = cmd.ExecuteNonQuery();
                }
                catch
                {
                    res = -1;
                }
            }
        }
        return res;
    }

    public object GetExeScalar(string sql, params MySqlParameter[] parameters)
    {
        object res = null;
        using (MySqlConnection con = new MySqlConnection(connectionString))
        {
            con.Open();
            using (MySqlCommand cmd = new MySqlCommand(sql, con))
            {
                foreach (MySqlParameter parameter in parameters)
                {
                    cmd.Parameters.Add(parameter);
                }
                res = cmd.ExecuteScalar();
            }
        }
        return res;
    }

    public DataTable GetDataTable(string sql, params MySqlParameter[] parameters)
    {
        DataSet dataset = new DataSet();
        using (MySqlConnection con = new MySqlConnection(connectionString))
        {
            con.Open();
            using (MySqlCommand cmd = new MySqlCommand(sql, con))
            {
                foreach (MySqlParameter parameter in parameters)
                {
                    cmd.Parameters.Add(parameter);
                }
                MySqlDataAdapter adapter = new MySqlDataAdapter(cmd);
                adapter.Fill(dataset);
            }
        }
        return dataset.Tables[0];
    }

    /// <summary>
    /// DataTable批量加入MYSQL数据库
    /// </summary>
    /// <param name="dataTable"></param>
    /// <returns></returns>
    public string InsertByDataTable(DataTable dataTable)
    {
        string result = string.Empty;
        if (null == dataTable || dataTable.Rows.Count <= 0)
        {
            return "添加失败!DataTable暂无数据!";
        }
        if (string.IsNullOrEmpty(dataTable.TableName))
        {
            return "添加失败!请先设置DataTable的名称!";
        }
        // 构建INSERT语句
        StringBuilder sb = new StringBuilder();
        sb.Append("INSERT INTO " + dataTable.TableName + "(");
        for (int i = 0; i < dataTable.Columns.Count; i++)
        {
            sb.Append(dataTable.Columns[i].ColumnName + ",");
        }
        sb.Remove(sb.ToString().LastIndexOf(','), 1);
        sb.Append(") VALUES ");
        for (int i = 0; i < dataTable.Rows.Count; i++)
        {
            sb.Append("(");
            for (int j = 0; j < dataTable.Columns.Count; j++)
            {
                sb.Append("'" + dataTable.Rows[i][j] + "',");
            }
            sb.Remove(sb.ToString().LastIndexOf(','), 1);
            sb.Append("),");
        }
        sb.Remove(sb.ToString().LastIndexOf(','), 1);
        sb.Append(";");
        int res = -1;
        using (MySqlConnection con = new MySqlConnection(connectionString))
        {
            con.Open();
            using (MySqlCommand cmd = new MySqlCommand(sb.ToString(), con))
            {
                try
                {
                    res = cmd.ExecuteNonQuery();
                }
                catch (Exception ex)
                {
                    res = -1;
                    // Unknown column 'names' in 'field list' 
                    result = "操作失败!" + ex.Message.Replace("Unknown column", "未知列").Replace("in 'field list'","存在字段集合中!");
                }
            }
        }
        if (res > 0)
        {
            result = "恭喜添加成功!";
        }
        return result;
    }

}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏游戏杂谈

Unity项目中文字的统一管理

一款游戏在研发初期就需要考虑多语言的问题,否则后期在进行多国语言版本时就面临着巨大的成本。鉴于之前页游的经验,其它同事设计出读取Excel的方式来管理所有的文字...

1381
来自专栏逸鹏说道

Dapper逆天入门~强类型,动态类型,多映射,多返回值,增删改查+存储过程案例演示

Dapper的牛逼就不扯蛋了,答应群友做个入门Demo的,现有园友需要,那么公开分享一下: 完整Demo:http://pan.baidu.com/s/1i3T...

3537
来自专栏ASP.NET MVC5 后台权限管理系统

构建ASP.NET MVC4+EF5+EasyUI+Unity2.x注入的后台管理系统(11)-系统日志和异常的处理①

系统需要越来越自动化,我们需要引入日志记录和异常捕获 管理员的操作记录需要被记录,看出哪些模块是频繁操作,分析哪些是不必要的功能,哪些是需要被优化的。 系统的异...

3108
来自专栏草根专栏

用VSCode开发一个asp.net core2.0+angular5项目(5): Angular5+asp.net core 2.0 web api文件上传

这部分就讲从angular5的客户端上传图片到asp.net core 2.0的 web api. 这是需要的源码: https://pan.baidu.com...

4135
来自专栏互联网开发者交流社区

AvalonJS+MVVM实战部分源码

1442
来自专栏ASP.NET MVC5 后台权限管理系统

构建ASP.NET MVC4+EF5+EasyUI+Unity2.x注入的后台管理系统(23)-权限管理系统-角色组模块

接下来我们的目标是 角色组管理 角色组权限设置 用户管理 把角色组授权给用户 给用户分配角色组 所以最少我们还要讲多5讲才能结束这个管理系统,经过之前的样例程序...

3349
来自专栏草根专栏

设计模式学习(二): 观察者模式 (C#)

《深入浅出设计模式》学习笔记第二章 需求: 开发一套气象监测应用,如图: ? 气象站,目前有三种装置,温度、湿度和气压感应装置。 WeatherData对象追踪...

3385
来自专栏菩提树下的杨过

asp.net与asp的session共享 及 asp的请求拦截

asp.net 与 asp 的session是无法直接共享的(底层的处理dll也不一样),要想互通session,只能用变通的办法: 一、asp.net -> ...

2667
来自专栏飞扬的花生

Html5上传插件封装

      前段时间将flash的上传控件替换成使用纯js实现的,在此记录 1.创建标签 <div class="camera-area" style="dis...

3938
来自专栏飞扬的花生

C#实现Excel模板导出和从Excel导入数据

      午休时间写了一个Demo关于Excel导入导出的简单练习 1.窗体 ? 2.引用office命名空间 添加引用-程序集-扩展-Microsoft.O...

6667

扫码关注云+社区

领取腾讯云代金券