锐客网

  1. 首页 > 睿知 > it技术 > >

C#操作MySql数据库帮助类（Dapper,T-Sql）

IT知识mysql数据库

【C#操作MySql数据库帮助类（Dapper,T-Sql）】大鹏一日同风起，扶摇直上九万里。这篇文章主要讲述C#操作MySql数据库帮助类（Dapper,T-Sql）相关的知识，希望能为你提供帮助。

using System.Text; using mysql.Data.MySqlClient; using System.Data; using Dapper; using System.Reflection; namespace DbHelper { public class MySqlHelper { private string connectionStr = "server=localhost; database=fxy; User=root; password=cxk"; //public object connection = GetConnection(connectionStr); /// < summary> /// Dapper查询（包含存储过程及sql语句查询） /// < /summary> /// < typeparam name="T"> 实体类型< /typeparam> /// < param name="sql"> 存储过程名称或者sql语句< /param> /// < param name="param"> 参数化处理< /param> /// < param name="isStoredProcedure"> 是否存储过程查询< /param> /// < returns> < /returns> public List< T> DapperQuery< T> (string sql , object param , bool? isStoredProcedure = false) where T : new() { using(IDbConnection con = new MySqlConnection(connectionStr)) { CommandType cmdType = (isStoredProcedure ?? true) ? CommandType.StoredProcedure : CommandType.Text; try { List< T> queryList = con.Query< T> (sql , param , null, true , null , cmdType).ToList(); return queryList; } catch(Exception e) { throw; } } }/// < summary> /// TSQL查询 /// < /summary> /// < typeparam name="T"> < /typeparam> /// < param name="sql"> < /param> /// < param name="param"> < /param> /// < param name="isStoredProcedure"> < /param> /// < returns> < /returns> public List< T> TSqlQuery< T> (string sql,MySqlParameter[] param,bool? isStoredProcedure = false) where T:new() { using(MySqlConnection con = new MySqlConnection(connectionStr)) { con.Open(); CommandType cmdType = (isStoredProcedure ?? true) ? CommandType.StoredProcedure : CommandType.Text; MySqlCommand command = new MySqlCommand(sql , con ); command.CommandType = cmdType; if(param != null ) { command.Parameters.AddRange(param); } try { MySqlDataReader reader = command.ExecuteReader(); List< T> list = DataReaderToList< T> (reader); return list; } catch(Exception e) { throw; } finally { con.Close(); } } }/// < summary> /// Dapper增删改（包含存储过程及sql语句查询） /// < /summary> /// < param name="sql"> 存储过程名称或者sql语句< /param> /// < param name="param"> 参数化处理< /param> /// < param name="isStoredProcedure"> 是否存储过程查询< /param> /// < returns> < /returns> public bool DapperExcute(string sql , object param , bool? isStoredProcedure=false,int?commandTimeout=null) { bool result = false; using(IDbConnection con = new MySqlConnection(connectionStr)) { con.Open(); IDbTransaction tran = con.BeginTransaction(); CommandType cmdType = isStoredProcedure==true ? CommandType.StoredProcedure : CommandType.Text; try { int query = con.Execute(sql , param , tran , commandTimeout , cmdType); tran.Commit(); result = true; } catch(Exception e) { tran.Rollback(); throw; } finally { con.Close(); } return result; }}/// < summary> /// TSQL增删改操作 /// < /summary> /// < param name="sql"> < /param> /// < param name="param"> < /param> /// < param name="isStoredProcedure"> < /param> /// < returns> < /returns> public bool TSqlExcute(string sql , MySqlParameter[] param , bool? isStoredProcedure=false) { bool result = false; using(MySqlConnection con = new MySqlConnection(connectionStr)) { con.Open(); MySqlTransaction tran = con.BeginTransaction(); CommandType cmdType = isStoredProcedure==true ? CommandType.StoredProcedure : CommandType.Text; MySqlCommand command = new MySqlCommand(sql , con , tran); command.Parameters.AddRange(param); try { int query = command.ExecuteNonQuery(); tran.Commit(); result = true; } catch(Exception e) { tran.Rollback(); throw; } finally { con.Close(); } return result; } }/// < summary> /// 批量数据写入 /// < /summary> /// < typeparam name="T"> < /typeparam> /// < param name="sql"> < /param> /// < param name="dataList"> < /param> /// < returns> < /returns> private bool BulkInsert< T> (string sql , List< T> dataList) where T:new() { bool result = false; //获取T的公共属性 Type type = dataList[ 0 ].GetType(); PropertyInfo[] param = type.GetProperties(); List< string> properotyList = param.Select(p => p.Name).ToList(); using(MySqlConnection con= new MySqlConnection(connectionStr)) { con.Open(); StringBuilder sb = new StringBuilder(); sb.Append(sql); sb.Append(" VALUES"); int i = 0; foreach(var item in dataList) { sb.Append("("); for(int j = 0 ; j < properotyList.Count ; j++) { PropertyInfo properotyInfo = item.GetType().GetProperty(properotyList[ j ]); // 属性的信息 object properotyValue = https://www.songbingjia.com/android/properotyInfo.GetValue(item , null); // 属性的值 string cellValue = properotyValue == null ?"" : properotyValue.ToString(); // 单元格的值 sb.Append("\""); sb.Append(properotyValue); sb.Append("\""); if(j < properotyList.Count - 1) { sb.Append(","); } } sb.Append(")"); if(i++ < dataList.Count - 1) { sb.Append(","); } } sql = sb.ToString(); MySqlTransaction tran = con.BeginTransaction(); MySqlCommand commd = new MySqlCommand(sql , con , tran); try { int query = commd.ExecuteNonQuery(); result = true; } catch(Exception e) { tran.Rollback(); throw; } return result; } }/// < summary> /// DataReader To List /// < /summary> /// < typeparam name="T"> < /typeparam> /// < param name="reader"> < /param> /// < returns> < /returns> private static List< T> DataReaderToList< T> (MySqlDataReader reader) where T : new() { List< T> list = new List< T> (); if(reader.HasRows) { while(reader.Read()) { T t = new T(); Type type = t.GetType(); var properties = type.GetProperties(); foreach(var item in properties) { string name = item.Name; reader.GetSchemaTable().DefaultView.RowFilter = "ColumnName= ‘" + name + "‘"; bool check = reader.GetSchemaTable().DefaultView.Count > 0; if(check) { if(!item.CanWrite) { continue; } var value = https://www.songbingjia.com/android/reader[ name ]; if(value != DBNull.Value) { item.SetValue(t , value , null); } } } list.Add(t); } } return list; } } }

 

    推荐阅读


    上一篇：巧用事件分发机制，和我一起hold住android外围设备

    下一篇：ROS gmapping