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=trueprivate 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;}#endregionpublic 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;}}

?

總結

以上是生活随笔為你收集整理的MySQL数据库工具类之——DataTable批量加入MySQL数据库(Net版)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。