749 lines
24 KiB
C#
749 lines
24 KiB
C#
|
using CYQ.Data.SQL;
|
|||
|
|
using System.Data.SqlClient;
|
|||
|
|
using System.Data;
|
|||
|
|
using System;
|
|||
|
|
using CYQ.Data.Table;
|
|||
|
|
|
|||
|
|
using CYQ.Data.Aop;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using CYQ.Data.Tool;
|
|||
|
|
using System.Data.Common;
|
|||
|
|
using CYQ.Data.Json;
|
|||
|
|
|
|||
|
|
namespace CYQ.Data
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// Manipulate：sql / procedure
|
|||
|
|
///<para>操作：SQL或存储过程</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public class MProc : IDisposable
|
|||
|
|
{
|
|||
|
|
#region 隐式转换
|
|||
|
|
/// <summary>
|
|||
|
|
/// Change MAction to MProc
|
|||
|
|
/// <para>将一个MAction 转换成一个MProc。</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public static implicit operator MProc(MAction action)
|
|||
|
|
{
|
|||
|
|
return new MProc(action.dalHelper);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public static implicit operator MProc(Orm.SimpleOrmBase orm)
|
|||
|
|
{
|
|||
|
|
if (orm.Action != null)
|
|||
|
|
{
|
|||
|
|
return new MProc(orm.Action.dalHelper);
|
|||
|
|
}
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
public static implicit operator MProc(Orm.OrmBase orm)
|
|||
|
|
{
|
|||
|
|
if (orm.Action != null)
|
|||
|
|
{
|
|||
|
|
return new MProc(orm.Action.dalHelper);
|
|||
|
|
}
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
internal DalBase dalHelper;
|
|||
|
|
private InterAop _aop = new InterAop();
|
|||
|
|
private string _procName = string.Empty;
|
|||
|
|
private bool _isProc = true;
|
|||
|
|
private string _debugInfo = string.Empty;
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// Get or set debugging information [need to set App Config.Debug.Open DebugInfo to ture]
|
|||
|
|
///<para>获取或设置调试信息[需要设置AppConfig.Debug.OpenDebugInfo为ture]</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public string DebugInfo
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
if (dalHelper != null)
|
|||
|
|
{
|
|||
|
|
return dalHelper.DebugInfo.ToString();
|
|||
|
|
}
|
|||
|
|
return _debugInfo;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// The database type
|
|||
|
|
/// <para>数据库类型</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public DataBaseType DataBaseType
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
if (dalHelper != null)
|
|||
|
|
{
|
|||
|
|
return dalHelper.DataBaseType;
|
|||
|
|
}
|
|||
|
|
return AppConfig.DB.DefaultDataBaseType;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// The database name
|
|||
|
|
/// <para>数据库名称</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public string DataBaseName
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
if (dalHelper != null)
|
|||
|
|
{
|
|||
|
|
return dalHelper.DataBaseName;
|
|||
|
|
}
|
|||
|
|
return AppConfig.DB.DefaultDataBaseName;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// The database version
|
|||
|
|
/// 数据库的版本号
|
|||
|
|
/// </summary>
|
|||
|
|
public string DataBaseVersion
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
if (dalHelper != null)
|
|||
|
|
{
|
|||
|
|
return dalHelper.Version;
|
|||
|
|
}
|
|||
|
|
return "";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// The number of rows affected when executing a SQL command (-2 is an exception)
|
|||
|
|
/// <para>执行SQL命令时受影响的行数（-2则为异常）。</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public int RecordsAffected
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
if (dalHelper != null)
|
|||
|
|
{
|
|||
|
|
return dalHelper.RecordsAffected;
|
|||
|
|
}
|
|||
|
|
return 0;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 是否事务进行中
|
|||
|
|
/// </summary>
|
|||
|
|
public bool IsTransation
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
return dalHelper.IsOpenTrans;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// The database connection string
|
|||
|
|
///<para>数据库链接字符串</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public string ConnString
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
if (dalHelper != null && dalHelper.Con != null)
|
|||
|
|
{
|
|||
|
|
return dalHelper.UsingConnBean.ConnStringOrg;
|
|||
|
|
}
|
|||
|
|
return string.Empty;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// The database connection name
|
|||
|
|
///<para>数据库链接配置名称</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public string ConnName
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
if (dalHelper != null && dalHelper.Con != null)
|
|||
|
|
{
|
|||
|
|
return dalHelper.UsingConnBean.ConnName;
|
|||
|
|
}
|
|||
|
|
return string.Empty;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// Command Timeout[seconds]
|
|||
|
|
///<para>命令超时设置[单位秒]</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public int TimeOut
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
if (dalHelper != null && dalHelper.Com != null)
|
|||
|
|
{
|
|||
|
|
return dalHelper.Com.CommandTimeout;
|
|||
|
|
}
|
|||
|
|
return -1;
|
|||
|
|
}
|
|||
|
|
set
|
|||
|
|
{
|
|||
|
|
if (dalHelper != null && dalHelper.Com != null)
|
|||
|
|
{
|
|||
|
|
dalHelper.Com.CommandTimeout = value;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// Instantiation
|
|||
|
|
/// <para>实例化</para>
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="procNameOrSql">Parameters: sql or procedure
|
|||
|
|
/// <para>参数：SQL语句或存储过程名称</para></param>
|
|||
|
|
public MProc(object procNameOrSql)
|
|||
|
|
{
|
|||
|
|
Init(procNameOrSql, null, false);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public MProc(object procNameOrSql, string conn)
|
|||
|
|
{
|
|||
|
|
Init(procNameOrSql, conn, false);
|
|||
|
|
}
|
|||
|
|
internal MProc(DalBase dalBase)
|
|||
|
|
{
|
|||
|
|
_procName = string.Empty;
|
|||
|
|
SetDalBase(dalBase, false);
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
private void Init(object procNameOrSql, string conn, bool isClearPara)
|
|||
|
|
{
|
|||
|
|
#region 分析是Sql或者存储过程
|
|||
|
|
if (procNameOrSql != null)
|
|||
|
|
{
|
|||
|
|
if (string.IsNullOrEmpty(conn))
|
|||
|
|
{
|
|||
|
|
if (procNameOrSql is Enum)
|
|||
|
|
{
|
|||
|
|
conn = CrossDB.GetConnByEnum(procNameOrSql as Enum);
|
|||
|
|
}
|
|||
|
|
if (string.IsNullOrEmpty(conn) && !string.IsNullOrEmpty(ConnName))
|
|||
|
|
{
|
|||
|
|
conn = ConnName;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
if (procNameOrSql is String)
|
|||
|
|
{
|
|||
|
|
string fixName;
|
|||
|
|
conn = CrossDB.GetConn(procNameOrSql.ToString(), out fixName, conn);
|
|||
|
|
}
|
|||
|
|
_procName = procNameOrSql.ToString().Trim();
|
|||
|
|
_isProc = _procName.IndexOf(' ') == -1;//不包含空格
|
|||
|
|
if (string.IsNullOrEmpty(conn) && dalHelper == null)
|
|||
|
|
{
|
|||
|
|
conn = AppConfig.DB.DefaultConn;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
DalBase dalBase = null;
|
|||
|
|
if (conn != null && dalHelper == null)
|
|||
|
|
{
|
|||
|
|
dalBase = DalCreate.CreateDal(conn);
|
|||
|
|
}
|
|||
|
|
SetDalBase(dalBase, isClearPara);
|
|||
|
|
}
|
|||
|
|
private void SetDalBase(DalBase dalBase, bool isClearPara)
|
|||
|
|
{
|
|||
|
|
if (dalHelper == null && dalBase != null)
|
|||
|
|
{
|
|||
|
|
dalHelper = dalBase;
|
|||
|
|
if (dalHelper.IsOnExceptionEventNull)
|
|||
|
|
{
|
|||
|
|
dalHelper.OnExceptionEvent += new DalBase.OnException(helper_OnExceptionEvent);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else if (isClearPara && dalHelper != null)
|
|||
|
|
{
|
|||
|
|
dalHelper.ClearParameters();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// <param name="isClearPara">IsClearParameters
|
|||
|
|
/// <para>是否清除参数</para></param>
|
|||
|
|
/// </summary>
|
|||
|
|
public void ResetProc(object procNameOrSql, bool isClearPara)
|
|||
|
|
{
|
|||
|
|
Init(procNameOrSql, null, isClearPara);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
///<summary>
|
|||
|
|
/// Toggle tProc Action: To switch between other sql/procedure, use this method
|
|||
|
|
/// <para>切换操作：如需操作其它语句或存储过程，通过此方法切换</para>
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="procNameOrSql">Parameters: sql or procedure
|
|||
|
|
/// <para>参数：存储过程名或Sql语句</para></param>
|
|||
|
|
public void ResetProc(object procNameOrSql)
|
|||
|
|
{
|
|||
|
|
ResetProc(procNameOrSql, true);
|
|||
|
|
}
|
|||
|
|
private AopResult SetAopResult(AopEnum action)
|
|||
|
|
{
|
|||
|
|
if (_aop.IsLoadAop)
|
|||
|
|
{
|
|||
|
|
_aop.Para.MProc = this;
|
|||
|
|
_aop.Para.ProcName = _procName;
|
|||
|
|
_aop.Para.IsProc = _isProc;
|
|||
|
|
if (dalHelper.Com != null)
|
|||
|
|
{
|
|||
|
|
_aop.Para.DBParameters = dalHelper.Com.Parameters;
|
|||
|
|
}
|
|||
|
|
_aop.Para.IsTransaction = dalHelper.IsOpenTrans;
|
|||
|
|
return _aop.Begin(action);
|
|||
|
|
}
|
|||
|
|
return AopResult.Default;
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// Get MDataTable
|
|||
|
|
/// </summary>
|
|||
|
|
public MDataTable ExeMDataTable()
|
|||
|
|
{
|
|||
|
|
CheckDisposed();
|
|||
|
|
AopResult aopResult = SetAopResult(AopEnum.ExeMDataTable);
|
|||
|
|
if (aopResult == AopResult.Return)
|
|||
|
|
{
|
|||
|
|
return _aop.Para.Table;
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
if (aopResult != AopResult.Break)
|
|||
|
|
{
|
|||
|
|
_aop.Para.Table = dalHelper.ExeDataReader(_procName, _isProc);
|
|||
|
|
_aop.Para.Table.Columns.DataBaseType = DataBaseType;
|
|||
|
|
_aop.Para.Table.Conn = dalHelper.ConnName;
|
|||
|
|
_aop.Para.IsSuccess = _aop.Para.Table.Rows.Count > 0;
|
|||
|
|
}
|
|||
|
|
if (aopResult != AopResult.Default)
|
|||
|
|
{
|
|||
|
|
_aop.End(AopEnum.ExeMDataTable);
|
|||
|
|
}
|
|||
|
|
return _aop.Para.Table;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 执行并返回泛型列表类型。
|
|||
|
|
/// </summary>
|
|||
|
|
public List<T> ExeList<T>() where T : class
|
|||
|
|
{
|
|||
|
|
CheckDisposed();
|
|||
|
|
List<T> list;
|
|||
|
|
AopResult aopResult = SetAopResult(AopEnum.ExeList);
|
|||
|
|
if (aopResult == AopResult.Return)
|
|||
|
|
{
|
|||
|
|
object cacheObj = _aop.Para.ExeResult;
|
|||
|
|
if (cacheObj is String)
|
|||
|
|
{
|
|||
|
|
return JsonHelper.ToList<T>(cacheObj.ToString(), EscapeOp.Encode);
|
|||
|
|
}
|
|||
|
|
return _aop.Para.ExeResult as List<T>;
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
if (aopResult != AopResult.Break)
|
|||
|
|
{
|
|||
|
|
list = ConvertTool.ChangeReaderToList<T>(dalHelper.ExeDataReader(_procName, _isProc));
|
|||
|
|
_aop.Para.ExeResult = list;
|
|||
|
|
_aop.Para.IsSuccess = list.Count > 0;
|
|||
|
|
}
|
|||
|
|
if (aopResult != AopResult.Default)
|
|||
|
|
{
|
|||
|
|
_aop.End(AopEnum.ExeList);
|
|||
|
|
}
|
|||
|
|
return _aop.Para.ExeResult as List<T>;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 执行列表数据并返回Json格式字符串。
|
|||
|
|
/// </summary>
|
|||
|
|
public string ExeJson()
|
|||
|
|
{
|
|||
|
|
return ExeJson(false, null);
|
|||
|
|
}
|
|||
|
|
public string ExeJson(bool isConvertNameToLower)
|
|||
|
|
{
|
|||
|
|
return ExeJson(isConvertNameToLower, null);
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 执行列表数据并返回Json格式字符串。
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="isConvertNameToLower">字段是否返回小写</param>
|
|||
|
|
/// <param name="dateTimeFormatter">是否需要格式化时间，默认：yyyy-MM-dd HH:mm:ss</param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public string ExeJson(bool isConvertNameToLower, string dateTimeFormatter)
|
|||
|
|
{
|
|||
|
|
CheckDisposed();
|
|||
|
|
string json;
|
|||
|
|
AopResult aopResult = SetAopResult(AopEnum.ExeJson);
|
|||
|
|
if (aopResult == AopResult.Return)
|
|||
|
|
{
|
|||
|
|
object cacheObj = _aop.Para.ExeResult;
|
|||
|
|
return cacheObj as string;
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
if (aopResult != AopResult.Break)
|
|||
|
|
{
|
|||
|
|
JsonHelper js = new JsonHelper(false, false);
|
|||
|
|
js.IsConvertNameToLower = isConvertNameToLower;
|
|||
|
|
if (!string.IsNullOrEmpty(dateTimeFormatter))
|
|||
|
|
{
|
|||
|
|
js.DateTimeFormatter = dateTimeFormatter;
|
|||
|
|
}
|
|||
|
|
json = ConvertTool.ChangeReaderToJson(dalHelper.ExeDataReader(_procName, _isProc), js, false);
|
|||
|
|
_aop.Para.ExeResult = json;
|
|||
|
|
_aop.Para.IsSuccess = json.Length > 4;
|
|||
|
|
}
|
|||
|
|
if (aopResult != AopResult.Default)
|
|||
|
|
{
|
|||
|
|
_aop.End(AopEnum.ExeJson);
|
|||
|
|
}
|
|||
|
|
return JsonHelper.ToJson(_aop.Para.ExeResult);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// Get MDataTables
|
|||
|
|
/// </summary>
|
|||
|
|
public List<MDataTable> ExeMDataTableList()
|
|||
|
|
{
|
|||
|
|
CheckDisposed();
|
|||
|
|
AopResult aopResult = SetAopResult(AopEnum.ExeMDataTableList);
|
|||
|
|
if (aopResult == AopResult.Return)
|
|||
|
|
{
|
|||
|
|
return _aop.Para.TableList;
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
if (aopResult != AopResult.Break)
|
|||
|
|
{
|
|||
|
|
List<MDataTable> dtList = new List<MDataTable>();
|
|||
|
|
switch (dalHelper.DataBaseType)
|
|||
|
|
{
|
|||
|
|
case DataBaseType.Txt:
|
|||
|
|
case DataBaseType.Xml:
|
|||
|
|
case DataBaseType.Oracle:
|
|||
|
|
if (_isProc && dalHelper.DataBaseType == DataBaseType.Oracle)
|
|||
|
|
{
|
|||
|
|
goto isProc;
|
|||
|
|
}
|
|||
|
|
foreach (string sql in _procName.TrimEnd(';').Split(';'))
|
|||
|
|
{
|
|||
|
|
MDataTable dt = dalHelper.ExeDataReader(sql, false);
|
|||
|
|
if (dt != null)
|
|||
|
|
{
|
|||
|
|
dtList.Add(dt);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
isProc:
|
|||
|
|
DbDataReader reader = dalHelper.ExeDataReader(_procName, _isProc);
|
|||
|
|
if (reader != null)
|
|||
|
|
{
|
|||
|
|
do
|
|||
|
|
{
|
|||
|
|
dtList.Add(MDataTable.CreateFrom(reader));
|
|||
|
|
}
|
|||
|
|
while (reader.NextResult());
|
|||
|
|
reader.Close();
|
|||
|
|
reader.Dispose();
|
|||
|
|
reader = null;
|
|||
|
|
}
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
_aop.Para.TableList = dtList;
|
|||
|
|
_aop.Para.IsSuccess = dtList.Count > 0;
|
|||
|
|
}
|
|||
|
|
if (aopResult != AopResult.Default)
|
|||
|
|
{
|
|||
|
|
_aop.End(AopEnum.ExeMDataTableList);
|
|||
|
|
}
|
|||
|
|
return _aop.Para.TableList;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// Returns the number of rows affected [used to insert update or delete], and returns -2 if an exception is executed
|
|||
|
|
/// <para>返回受影响的行数[用于更新或删除]，执行异常时返回-2</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public int ExeNonQuery()
|
|||
|
|
{
|
|||
|
|
CheckDisposed();
|
|||
|
|
AopResult aopResult = SetAopResult(AopEnum.ExeNonQuery);
|
|||
|
|
if (aopResult == AopResult.Return && _aop.Para.ExeResult is int)
|
|||
|
|
{
|
|||
|
|
return (int)_aop.Para.ExeResult;
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
if (aopResult != AopResult.Break)
|
|||
|
|
{
|
|||
|
|
int result = dalHelper.ExeNonQuery(_procName, _isProc);
|
|||
|
|
_aop.Para.ExeResult = result;
|
|||
|
|
_aop.Para.IsSuccess = result > 0;
|
|||
|
|
}
|
|||
|
|
if (aopResult != AopResult.Default)
|
|||
|
|
{
|
|||
|
|
_aop.End(AopEnum.ExeNonQuery);
|
|||
|
|
}
|
|||
|
|
return (int)_aop.Para.ExeResult;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// Returns the value of the first column of the first row
|
|||
|
|
/// <para>返回首行首列的值</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public T ExeScalar<T>()
|
|||
|
|
{
|
|||
|
|
CheckDisposed();
|
|||
|
|
AopResult aopResult = SetAopResult(AopEnum.ExeScalar);
|
|||
|
|
if (aopResult == AopResult.Default || aopResult == AopResult.Continue)
|
|||
|
|
{
|
|||
|
|
_aop.Para.ExeResult = dalHelper.ExeScalar(_procName, _isProc);
|
|||
|
|
_aop.Para.IsSuccess = _aop.Para.ExeResult != null;
|
|||
|
|
}
|
|||
|
|
if (aopResult == AopResult.Continue || aopResult == AopResult.Break)
|
|||
|
|
{
|
|||
|
|
_aop.End(AopEnum.ExeScalar);
|
|||
|
|
}
|
|||
|
|
if (_aop.Para.ExeResult == null || _aop.Para.ExeResult == DBNull.Value)
|
|||
|
|
{
|
|||
|
|
return default(T);
|
|||
|
|
}
|
|||
|
|
return (T)ConvertTool.ChangeType(_aop.Para.ExeResult, typeof(T));
|
|||
|
|
//Type t = typeof(T);
|
|||
|
|
//object value = _aop.Para.ExeResult;
|
|||
|
|
//switch (t.Name)
|
|||
|
|
//{
|
|||
|
|
// case "Int32":
|
|||
|
|
// int intValue = 0;
|
|||
|
|
// if (!int.TryParse(Convert.ToString(value), out intValue))
|
|||
|
|
// {
|
|||
|
|
// return default(T);
|
|||
|
|
// }
|
|||
|
|
// value = intValue;
|
|||
|
|
// break;
|
|||
|
|
// default:
|
|||
|
|
// try
|
|||
|
|
// {
|
|||
|
|
// value = ConvertTool.ChangeType(value, t);
|
|||
|
|
//}
|
|||
|
|
//catch
|
|||
|
|
//{
|
|||
|
|
//}
|
|||
|
|
|
|||
|
|
//break;
|
|||
|
|
|
|||
|
|
//}
|
|||
|
|
//return (T)value;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// <para>Set Input Para</para>
|
|||
|
|
/// <para>设置存储过程Input参数</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public MProc Set(object paraName, object value)
|
|||
|
|
{
|
|||
|
|
dalHelper.AddParameters(Convert.ToString(paraName), value); return this;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public MProc Set(object paraName, object value, DbType dbType)
|
|||
|
|
{
|
|||
|
|
dalHelper.AddParameters(Convert.ToString(paraName), value, dbType, -1, ParameterDirection.Input); return this;
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 设置特殊自定义参数
|
|||
|
|
/// </summary>
|
|||
|
|
public MProc SetCustom(object paraName, ParaType paraType)
|
|||
|
|
{
|
|||
|
|
return SetCustom(paraName, paraType, null, null);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// <para>Set the stored procedure OutPut, the return value and other special types of parameters</para>
|
|||
|
|
/// <para>设置存储过程OutPut、返回值等特殊类型参数</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public MProc SetCustom(object paraName, ParaType paraType, object value)
|
|||
|
|
{
|
|||
|
|
return SetCustom(paraName, paraType, value, null);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/// <param name="typeName">MSSQL The name of the user-defined table type<para>MSSQL的用户定义表类型的名称</para></param>
|
|||
|
|
public MProc SetCustom(object paraName, ParaType paraType, object value, string typeName)
|
|||
|
|
{
|
|||
|
|
dalHelper.AddCustomePara(Convert.ToString(paraName), paraType, value, typeName); return this;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// Clear Parameters
|
|||
|
|
/// <para>清除存储过程参数</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public void Clear()
|
|||
|
|
{
|
|||
|
|
dalHelper.ClearParameters();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// Get Procedure Return Value
|
|||
|
|
/// <para>存储过程的返回值</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public int ReturnValue
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
return dalHelper.ReturnValue;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// The OutPut value for the stored procedure: Dictionary for multiple values
|
|||
|
|
/// <para>存储过程的OutPut值：多个值时为Dictionary</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public object OutPutValue
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
return dalHelper.OutPutValue;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
#region Aop 相关操作
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取或设置当前操作是否使用自动缓存
|
|||
|
|
/// </summary>
|
|||
|
|
public bool IsUseAutoCache
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
return AppConfig.AutoCache.IsEnable && (_aop.aopOp == AopOp.OpenAll || _aop.aopOp == AopOp.OnlyInner);
|
|||
|
|
}
|
|||
|
|
set
|
|||
|
|
{
|
|||
|
|
switch (_aop.aopOp)
|
|||
|
|
{
|
|||
|
|
case AopOp.CloseAll:
|
|||
|
|
_aop.aopOp = value ? AopOp.OnlyInner : AopOp.CloseAll;
|
|||
|
|
break;
|
|||
|
|
case AopOp.OnlyInner:
|
|||
|
|
_aop.aopOp = value ? AopOp.OnlyInner : AopOp.CloseAll;
|
|||
|
|
break;
|
|||
|
|
case AopOp.OnlyOuter:
|
|||
|
|
_aop.aopOp = value ? AopOp.OpenAll : AopOp.OnlyOuter;
|
|||
|
|
break;
|
|||
|
|
case AopOp.OpenAll:
|
|||
|
|
_aop.aopOp = value ? AopOp.OpenAll : AopOp.OnlyOuter;
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// Set Aop State
|
|||
|
|
/// <para>设置Aop状态</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public MProc SetAopState(AopOp op)
|
|||
|
|
{
|
|||
|
|
_aop.aopOp = op;
|
|||
|
|
return this;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// Pass additional parameters for Aop use
|
|||
|
|
/// <para>传递额外的参数供Aop使用</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public MProc SetAopPara(object para)
|
|||
|
|
{
|
|||
|
|
_aop.Para.AopPara = para;
|
|||
|
|
return this;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
void helper_OnExceptionEvent(string errorMsg)
|
|||
|
|
{
|
|||
|
|
_aop.OnError(errorMsg);
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
#region 事务操作
|
|||
|
|
/// <summary>
|
|||
|
|
/// Set the transaction level
|
|||
|
|
/// <para>设置事务级别</para>
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="level">IsolationLevel</param>
|
|||
|
|
public MProc SetTransLevel(IsolationLevel level)
|
|||
|
|
{
|
|||
|
|
dalHelper.TranLevel = level; return this;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// Begin Transation
|
|||
|
|
/// <para>开始事务</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public void BeginTransation()
|
|||
|
|
{
|
|||
|
|
dalHelper.IsOpenTrans = true;
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// Commit Transation
|
|||
|
|
/// <para>提交事务</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public bool EndTransation()
|
|||
|
|
{
|
|||
|
|
if (dalHelper != null && dalHelper.IsOpenTrans)
|
|||
|
|
{
|
|||
|
|
return dalHelper.EndTransaction();
|
|||
|
|
}
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// RollBack Transation
|
|||
|
|
/// <para>事务回滚</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public bool RollBack()
|
|||
|
|
{
|
|||
|
|
if (dalHelper != null && dalHelper.IsOpenTrans)
|
|||
|
|
{
|
|||
|
|
return dalHelper.RollBack();
|
|||
|
|
}
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
#region IDisposable 成员
|
|||
|
|
/// <summary>
|
|||
|
|
/// Dispose
|
|||
|
|
/// <para>释放资源</para>
|
|||
|
|
/// </summary>
|
|||
|
|
public void Dispose()
|
|||
|
|
{
|
|||
|
|
hasDisposed = true;
|
|||
|
|
if (dalHelper != null)
|
|||
|
|
{
|
|||
|
|
if (!dalHelper.IsOnExceptionEventNull)
|
|||
|
|
{
|
|||
|
|
dalHelper.OnExceptionEvent -= new DalBase.OnException(helper_OnExceptionEvent);
|
|||
|
|
}
|
|||
|
|
_debugInfo = dalHelper.DebugInfo.ToString();
|
|||
|
|
dalHelper.Dispose();
|
|||
|
|
dalHelper = null;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
bool hasDisposed = false;
|
|||
|
|
private void CheckDisposed()
|
|||
|
|
{
|
|||
|
|
if (hasDisposed)
|
|||
|
|
{
|
|||
|
|
Error.Throw("The current object 'MProc' has been disposed");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|