|
|
using MySql.Data.MySqlClient;
|
|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Configuration;
|
|
|
using System.Data;
|
|
|
using System.Linq;
|
|
|
using System.Text;
|
|
|
using System.Threading.Tasks;
|
|
|
|
|
|
namespace RS.DBUtility
|
|
|
{
|
|
|
public class MySqlHelper
|
|
|
{
|
|
|
//string MySqlConnectString = "";
|
|
|
//数据库连接字符串
|
|
|
public static readonly string ConnectionString = ConfigurationManager.ConnectionStrings["MySqlConnectString"].ConnectionString;
|
|
|
|
|
|
public MySqlConnection SqlConn;
|
|
|
|
|
|
#region 数据库基本操作
|
|
|
|
|
|
public MySqlHelper()
|
|
|
{
|
|
|
SqlConn = new MySqlConnection(ConnectionString);
|
|
|
}
|
|
|
|
|
|
public MySqlHelper(string conn)
|
|
|
{
|
|
|
SqlConn = new MySqlConnection(conn);
|
|
|
}
|
|
|
|
|
|
public void Dispose()
|
|
|
{
|
|
|
Dispose(true);
|
|
|
GC.SuppressFinalize(true);
|
|
|
}
|
|
|
|
|
|
protected void Dispose(bool disposing)
|
|
|
{
|
|
|
if (disposing)
|
|
|
{
|
|
|
return;
|
|
|
}
|
|
|
if (SqlConn != null)
|
|
|
{
|
|
|
SqlConn.Dispose();
|
|
|
SqlConn = null;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 打开数据库连接
|
|
|
/// </summary>
|
|
|
public void DBConnection()
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
//确认是否已打开连接，为打开则打开连接
|
|
|
if (this.SqlConn.State != ConnectionState.Open)
|
|
|
{
|
|
|
SqlConn.Open();
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw ex;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 关闭数据库连接
|
|
|
/// </summary>
|
|
|
public void DBClose()
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
//确认是否已打开连接，为打开则打开连接
|
|
|
if (this.SqlConn.State == ConnectionState.Open)
|
|
|
{
|
|
|
SqlConn.Close();
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw ex;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获得查询结果
|
|
|
/// </summary>
|
|
|
/// <param name="sqlstr">SQL字符串</param>
|
|
|
/// <returns></returns>
|
|
|
public DataTable QuerySql(string sqlstr)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
DataTable dt = null;
|
|
|
try
|
|
|
{
|
|
|
MySqlDataAdapter sqlda = new MySqlDataAdapter(sqlstr, ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
dt = new DataTable();
|
|
|
sqlda.Fill(dt);
|
|
|
}
|
|
|
catch
|
|
|
{
|
|
|
sqlda.MissingMappingAction = MissingMappingAction.Ignore;
|
|
|
}
|
|
|
}
|
|
|
catch (MySqlException ex)
|
|
|
{
|
|
|
throw ex;
|
|
|
}
|
|
|
|
|
|
return dt;
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw ex;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获得查询结果
|
|
|
/// </summary>
|
|
|
/// <param name="sqlstr">SQL字符串</param>
|
|
|
/// <returns></returns>
|
|
|
public DataTable QuerySql(string sqlstr, string conn)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
DataTable dt = null;
|
|
|
MySqlDataAdapter sqlda = new MySqlDataAdapter(sqlstr, conn);
|
|
|
dt = new DataTable();
|
|
|
sqlda.Fill(dt);
|
|
|
return dt;
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw ex;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 操作数据库(无返回值)
|
|
|
/// </summary>
|
|
|
/// <param name="sqlstr">操作SQL字符串</param>
|
|
|
public int ExecuteNonQuerySQL(string sqlstr)
|
|
|
{
|
|
|
int i = 0;
|
|
|
try
|
|
|
{
|
|
|
//确认是否已打开连接，为打开则打开连接
|
|
|
if (this.SqlConn.State != ConnectionState.Open)
|
|
|
{
|
|
|
SqlConn.Open();
|
|
|
}
|
|
|
MySqlCommand sqlcommand = new MySqlCommand(sqlstr, this.SqlConn);
|
|
|
i = sqlcommand.ExecuteNonQuery();
|
|
|
return i;
|
|
|
}
|
|
|
catch (MySqlException ex)
|
|
|
{
|
|
|
throw ex;
|
|
|
}
|
|
|
finally
|
|
|
{
|
|
|
if (this.SqlConn.State != ConnectionState.Closed)
|
|
|
{
|
|
|
SqlConn.Close();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 操作数据库(无返回值)
|
|
|
/// </summary>
|
|
|
/// <param name="sqlstr">操作SQL字符串</param>
|
|
|
public bool ExecuteBNonQuerySQL(string sqlstr, bool hostConnect = false)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
if (!PingHelper.PingConnectString(ConnectionString)) return false;
|
|
|
using (MySqlConnection conn = new MySqlConnection(ConnectionString))
|
|
|
{
|
|
|
conn.Open();
|
|
|
MySqlCommand sqlcommand = new MySqlCommand(sqlstr, conn);
|
|
|
sqlcommand.ExecuteNonQuery();
|
|
|
return true;
|
|
|
}
|
|
|
}
|
|
|
catch (MySqlException ex)
|
|
|
{
|
|
|
ex.ToString();
|
|
|
throw;
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 操作数据库(无返回值),调用该方法前要先打开数据库
|
|
|
/// </summary>
|
|
|
/// <param name="sqlstr">操作SQL字符串</param>
|
|
|
/// <param name="IsOpen">操作类型：true:已打开数据库;false:数据库关闭</param>
|
|
|
public void ExecuteNonQuerySQL(string sqlstr, bool IsOpen)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
if (IsOpen)
|
|
|
{
|
|
|
MySqlCommand sqlcommand = new MySqlCommand(sqlstr, this.SqlConn);
|
|
|
sqlcommand.ExecuteNonQuery();
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw ex;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 判断是否存在数据
|
|
|
/// </summary>
|
|
|
/// <param name="sqlstr">SQL字符串</param>
|
|
|
/// <returns>查询结果</returns>
|
|
|
public bool b_QuerySql(string sqlstr)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
MySqlCommand command = new MySqlCommand(sqlstr, this.SqlConn);
|
|
|
MySqlDataReader sqlda = command.ExecuteReader(CommandBehavior.CloseConnection);
|
|
|
command.Parameters.Clear();
|
|
|
return sqlda.GetBoolean(0);
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
DBClose();
|
|
|
throw ex;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 批量插入数据
|
|
|
/// </summary>
|
|
|
/// <param name="TableName">数据库中数据表名</param>
|
|
|
/// <param name="dt">数据源(DataTable)</param>
|
|
|
|
|
|
//public void BulkInsert(string TableName, DataTable dt)
|
|
|
//{
|
|
|
// try
|
|
|
// {
|
|
|
// SqlConn.Open();
|
|
|
// using (MySqlBulkCopy bulkcopy = new SqlBulkCopy(this.SqlConn))
|
|
|
// {
|
|
|
// bulkcopy.DestinationTableName = TableName;
|
|
|
// try
|
|
|
// {
|
|
|
//bulkcopy.WriteToServer(dt);
|
|
|
// }
|
|
|
// catch (Exception ex)
|
|
|
// {
|
|
|
//Console.WriteLine(ex.Message);
|
|
|
// }
|
|
|
// }
|
|
|
// }
|
|
|
// catch (SqlException ex)
|
|
|
// {
|
|
|
// throw ex;
|
|
|
// }
|
|
|
// finally
|
|
|
// {
|
|
|
// SqlConn.Close();
|
|
|
// }
|
|
|
//}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 处理存储过程并返回结果
|
|
|
/// </summary>
|
|
|
/// <param name="procName">存储过程名称</param>
|
|
|
/// <param name="prams">存储过程使用的命令参数</param>
|
|
|
/// <returns>返回结果数据表</returns>
|
|
|
public DataTable GetProceResult(string procName, MySqlParameter[] parameters)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
// 确认数据库是否已打开
|
|
|
if (this.SqlConn.State != ConnectionState.Open)
|
|
|
{
|
|
|
SqlConn.Open();
|
|
|
}
|
|
|
|
|
|
MySqlCommand command = new MySqlCommand(procName, this.SqlConn);
|
|
|
command.CommandType = CommandType.StoredProcedure;
|
|
|
|
|
|
// 循环输入存储过程命令参数
|
|
|
if (parameters != null)
|
|
|
{
|
|
|
foreach (MySqlParameter parameter in parameters)
|
|
|
{
|
|
|
command.Parameters.Add(parameter);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
MySqlParameter RtParameter = new MySqlParameter();
|
|
|
RtParameter.Direction = ParameterDirection.ReturnValue;
|
|
|
RtParameter.ParameterName = "ReturnValue";
|
|
|
RtParameter.MySqlDbType = MySqlDbType.Int32;
|
|
|
RtParameter.Size = 4;
|
|
|
RtParameter.IsNullable = false;
|
|
|
RtParameter.Precision = 0;
|
|
|
RtParameter.Scale = 0;
|
|
|
RtParameter.SourceColumn = string.Empty;
|
|
|
RtParameter.SourceVersion = DataRowVersion.Default;
|
|
|
RtParameter.Value = null;
|
|
|
|
|
|
// 增加返回参数
|
|
|
command.Parameters.Add(RtParameter);
|
|
|
|
|
|
DataTable dt = new DataTable();
|
|
|
|
|
|
MySqlDataAdapter adapter = new MySqlDataAdapter(procName, this.SqlConn);
|
|
|
adapter.SelectCommand = command;
|
|
|
adapter.SelectCommand.CommandTimeout = 1000;
|
|
|
adapter.Fill(dt);
|
|
|
|
|
|
if (this.SqlConn.State == ConnectionState.Open)
|
|
|
{
|
|
|
SqlConn.Close();
|
|
|
}
|
|
|
return dt;
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw ex;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 处理存储过程(无返回值)
|
|
|
/// </summary>
|
|
|
/// <param name="procName">存储过程名</param>
|
|
|
/// <param name="parameters">存储过程命令参数</param>
|
|
|
public void ExecuteProcedure(string procName, MySqlParameter[] parameters)
|
|
|
{
|
|
|
// 确认数据库是否连接
|
|
|
if (this.SqlConn.State != ConnectionState.Open)
|
|
|
{
|
|
|
SqlConn.Open();
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
MySqlCommand command = new MySqlCommand(procName, this.SqlConn);
|
|
|
command.CommandType = CommandType.StoredProcedure;
|
|
|
|
|
|
//反复输入命令参数
|
|
|
if (parameters != null)
|
|
|
{
|
|
|
foreach (MySqlParameter parameter in parameters)
|
|
|
{
|
|
|
command.Parameters.Add(parameter);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// 存储过程处理
|
|
|
command.ExecuteNonQuery();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw ex;
|
|
|
}
|
|
|
finally
|
|
|
{
|
|
|
if (this.SqlConn.State == ConnectionState.Open)
|
|
|
{
|
|
|
SqlConn.Close();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public void ExecuteNonQuerySQLTran(List<string> sqlstrlist)
|
|
|
{
|
|
|
//确认是否已打开连接，为打开则打开连接
|
|
|
if (this.SqlConn.State != ConnectionState.Open)
|
|
|
{
|
|
|
SqlConn.Open();
|
|
|
}
|
|
|
MySqlTransaction tran = SqlConn.BeginTransaction();
|
|
|
MySqlCommand sqlcommand = SqlConn.CreateCommand();
|
|
|
sqlcommand.Transaction = tran;
|
|
|
try
|
|
|
{
|
|
|
foreach (string sqlstr in sqlstrlist)
|
|
|
{
|
|
|
sqlcommand.CommandText = sqlstr;
|
|
|
sqlcommand.ExecuteNonQuery();
|
|
|
}
|
|
|
|
|
|
tran.Commit();
|
|
|
}
|
|
|
catch (MySqlException ex)
|
|
|
{
|
|
|
//Console.WriteLine(ex.Message);
|
|
|
tran.Rollback();
|
|
|
throw new Exception(ex.Message.ToString());
|
|
|
}
|
|
|
finally
|
|
|
{
|
|
|
if (this.SqlConn.State != ConnectionState.Closed)
|
|
|
{
|
|
|
SqlConn.Close();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#endregion 数据库基本操作
|
|
|
}
|
|
|
}
|
