111 lines
3.5 KiB
C#
111 lines
3.5 KiB
C#
using System.Data;
|
|
using System.Data.Common;
|
|
using CYQ.Data.Cache;
|
|
using System.Reflection;
|
|
using System.Collections.Generic;
|
|
using System;
|
|
using System.IO;
|
|
namespace CYQ.Data
|
|
{
|
|
internal partial class MySQLDal : DalBase
|
|
{
|
|
private DistributedCache _Cache = DistributedCache.Local;//Cache操作
|
|
public MySQLDal(ConnObject co)
|
|
: base(co)
|
|
{
|
|
|
|
}
|
|
internal static Assembly GetAssembly()
|
|
{
|
|
object ass = DistributedCache.Local.Get("MySqlClient_Assembly");
|
|
if (ass == null)
|
|
{
|
|
if (!File.Exists(AppConst.AssemblyPath + "MySql.Data.dll"))
|
|
{
|
|
Error.Throw("Can't find the MySql.Data.dll");
|
|
}
|
|
try
|
|
{
|
|
if (AppConfig.AssemblyPath.StartsWith("/"))
|
|
{
|
|
ass = Assembly.LoadFrom("MySql.Data.dll");//netcore6 linux 环境限定只能用这种模式加载，其它抛了异常。
|
|
}
|
|
}
|
|
catch
|
|
{
|
|
|
|
}
|
|
if (ass == null)
|
|
{
|
|
ass = Assembly.Load("MySql.Data");
|
|
}
|
|
if (ass != null)
|
|
{
|
|
DistributedCache.Local.Set("MySqlClient_Assembly", ass, 10080);
|
|
}
|
|
|
|
}
|
|
return ass as Assembly;
|
|
}
|
|
protected override DbProviderFactory GetFactory()
|
|
{
|
|
object factory = _Cache.Get("MySqlClient_Factory");
|
|
if (factory == null)
|
|
{
|
|
Assembly ass = GetAssembly();
|
|
factory = ass.CreateInstance("MySql.Data.MySqlClient.MySqlClientFactory");
|
|
if (factory == null)
|
|
{
|
|
throw new System.Exception("Can't Create MySqlClientFactory in MySql.Data.dll");
|
|
}
|
|
else
|
|
{
|
|
_Cache.Set("MySqlClient_Factory", factory, 10080);
|
|
}
|
|
|
|
}
|
|
return factory as DbProviderFactory;
|
|
}
|
|
protected override bool IsExistsDbName(string dbName)
|
|
{
|
|
try
|
|
{
|
|
IsRecordDebugInfo = false || AppDebug.IsContainSysSql;
|
|
bool result = ExeScalar("show databases like '" + dbName + "'", false) != null;
|
|
IsRecordDebugInfo = true;
|
|
return result;
|
|
}
|
|
catch
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
public override char Pre
|
|
{
|
|
get
|
|
{
|
|
return '?';
|
|
}
|
|
}
|
|
}
|
|
internal partial class MySQLDal
|
|
{
|
|
protected override string GetUVPSql(string type)
|
|
{
|
|
if (type == "P")
|
|
{
|
|
return "select ROUTINE_NAME as TableName,'P' as Description from information_schema.ROUTINES where ROUTINE_SCHEMA='" + DataBaseName + "' order by ROUTINE_NAME";
|
|
}
|
|
else
|
|
{
|
|
if (type == "U") { type = "BASE TABLE"; }
|
|
else if (type == "V")
|
|
{
|
|
type = "VIEW";
|
|
}
|
|
return string.Format("select TABLE_NAME as TableName,TABLE_COMMENT as Description from `information_schema`.`TABLES` where TABLE_SCHEMA='{0}' and TABLE_TYPE='{1}' order by TABLE_NAME", DataBaseName, type);
|
|
}
|
|
}
|
|
}
|
|
}
|