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
|
||
}
|
||
|
||
}
|