来源于自己的博客小站“虾米成长记”！转载请注明出处，谢谢！
最近在使用.Net Core和MySQL做项目。.Net Core是微软最新推出的轻量级.Net框架，它支持跨平台开发和部署，并且开源，因此十分吸引我。考虑到项目以后可能会运行在Linux环境中，因此我选用了MySQL数据库。目前网络上有关.Net Core和MySQL结合使用的资料较少，更多的是.Net Core和SQL Server。因此在项目的开发过程中遇到了一些大大小小的坑，而那些宝贵的填坑经验就需要“烂笔头”记录下来。1、使用EntityFramework CoreEntityFramework Core是对应于.Net Core推出的ORM框架，它很好的支持了SQLServer，但对MySQL的支持还较弱。这里我使用了第三方的组件：“Pomelo.EntityFrameworkCore.MySql”和“Pomelo.EntityFramework.MySql.Design”，通过命令行脚手架，生成Entity。命令语句如下：
dotnet ef dbcontext scaffold "server=url" "Pomelo.EntityFrameworkCore.Mysql" -o Entity -c MysqlContext -d -f -t "table_name"
2、调用MySQL的存储过程
目前EntityFramework Core对于存储过程的支持还很弱，因此我推荐使用ADO.Net技术来调用存储过程。这里我依然使用了第三方组件:“Pomelo.Data.MySql”，而非MySQL官方的“MySql.Data”，这是因为我在使用”MySql.Data”时遇到了无法读取存储过程结果的问题，经调试发现在Reader的Depth属性里发生了内部异常，不好解决。
首先封装一个执行存储过程的公共方法“ExecuteSP”，代码如下：
public ArrayList ExecuteSP<T>(MasterDbContext context, string spName, MySqlParameter[] parameters) where T : new()
{
try
{
var connectionString = context.Database.GetDbConnection().ConnectionString.Replace("BufferResultSets=True;", "");
using (var conn = new MySqlConnection(connectionString))
{
conn.Open();
using (var cmd = conn.CreateCommand())
{
cmd.CommandText = spName;
cmd.CommandType = CommandType.StoredProcedure;
cmd.Parameters.AddRange(parameters);
using (var reader = cmd.ExecuteReader())
{
var result = new ArrayList();
do
{
if (reader.FieldCount > 1)
{
result.Add(reader.MapToList<T>());
}
else
{
result.Add(reader.MapToEntity<object>());
}
} while (reader.NextResult());
return result;
}
}
}
}
catch (Exception ex)
{
throw ex;
}
}
其次针对返回的不同类型的结果，封装两个方法：“MapToList”和“MapToEntity”，代码如下：
public static List<T> MapToList<T>(this DbDataReader dr) where T : new()
{
if (dr != null && dr.HasRows)
{
var entity = typeof(T);
var entities = new List<T>();
var props = entity.GetProperties(BindingFlags.Instance | BindingFlags.Public);
var propDict = props.ToDictionary(m => m.Name.ToUpper(), m => m);
while (dr.Read())
{
T newObject = new T();
for (int index = 0; index < dr.FieldCount; index++)
{
if (propDict.ContainsKey(dr.GetName(index).ToUpper()))
{
var info = propDict[dr.GetName(index).ToUpper()];
if (info != null && info.CanWrite)
{
var val = dr.GetValue(index);
info.SetValue(newObject, val == DBNull.Value ? null : val, null);
}
}
}
entities.Add(newObject);
}
return entities;
}
return null;
}
public static T MapToEntity<T>(this DbDataReader dr) where T : new()
{
if (dr != null && dr.HasRows)
{
var entity = typeof(T);
if (IsBuiltInType(entity))
{
while (dr.Read())
{
return (T)dr.GetValue(0);
}
}
var props = entity.GetProperties(BindingFlags.Instance | BindingFlags.Public);
var propDict = props.ToDictionary(m => m.Name.ToUpper(), m => m);
var obj = new T();
for (int index = 0; index < dr.FieldCount; index++)
{
if (propDict.ContainsKey(dr.GetName(index).ToUpper()))
{
var info = propDict[dr.GetName(index).ToUpper()];
if (info != null && info.CanWrite)
{
var val = dr.GetValue(index);
info.SetValue(obj, val == DBNull.Value ? null : val, null);
}
}
}
return obj;
}
return default(T);
}
