1882 lines
68 KiB
C#
1882 lines
68 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Text;
|
||
using System.Data;
|
||
using System.Data.Common;
|
||
using System.Data.SqlClient;
|
||
using System.ComponentModel;
|
||
using CYQ.Data.SQL;
|
||
using CYQ.Data.Cache;
|
||
using CYQ.Data.Table;
|
||
|
||
using CYQ.Data.Aop;
|
||
using CYQ.Data.Tool;
|
||
using CYQ.Data.UI;
|
||
using CYQ.Data.Json;
|
||
|
||
namespace CYQ.Data
|
||
{
|
||
/// <summary>
|
||
/// Manipulate：table / view / custom statement
|
||
///<para>操作：表/视图/自定义语句</para>
|
||
/// </summary>
|
||
public partial class MAction : IDisposable
|
||
{
|
||
#region 隐式转换
|
||
public static implicit operator MAction(Orm.SimpleOrmBase orm)
|
||
{
|
||
if (orm.Action != null)
|
||
{
|
||
return orm.Action;
|
||
}
|
||
return null;
|
||
}
|
||
public static implicit operator MAction(Orm.OrmBase orm)
|
||
{
|
||
if (orm.Action != null)
|
||
{
|
||
return orm.Action;
|
||
}
|
||
return null;
|
||
}
|
||
#endregion
|
||
#region 全局变量
|
||
|
||
internal DalBase dalHelper;//数据操作
|
||
|
||
private InsertOp _option = InsertOp.ID;
|
||
// private NoSqlAction _noSqlAction = null;
|
||
private MDataRow _Data;//表示一行
|
||
/// <summary>
|
||
/// Archive the rows of the data structure
|
||
/// <para>存档数据结构的行</para>
|
||
/// </summary>
|
||
public MDataRow Data
|
||
{
|
||
get
|
||
{
|
||
return _Data;
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 原始传进来的表名/视图名，未经过[多数据库转换处理]格式化。
|
||
/// </summary>
|
||
private string _sourceTableName;
|
||
private string _TableName; //表名
|
||
/// <summary>
|
||
/// Table name (if the view statement is the operation, the final view of the name)
|
||
///<para>当前操作的表名(若操作的是视图语句，则为最后的视图名字</para> ）
|
||
/// </summary>
|
||
public string TableName
|
||
{
|
||
get
|
||
{
|
||
return _TableName;
|
||
}
|
||
set
|
||
{
|
||
_TableName = value;
|
||
}
|
||
}
|
||
/// <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;
|
||
}
|
||
}
|
||
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;
|
||
}
|
||
set
|
||
{
|
||
if (dalHelper != null)
|
||
{
|
||
dalHelper.DebugInfo.Length = 0;
|
||
dalHelper.DebugInfo.Append(value);
|
||
}
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// The database type
|
||
/// <para>数据库类型</para>
|
||
/// </summary>
|
||
public DataBaseType DataBaseType
|
||
{
|
||
get
|
||
{
|
||
return dalHelper.DataBaseType;
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// The database name
|
||
/// <para>数据库名称</para>
|
||
/// </summary>
|
||
public string DataBaseName
|
||
{
|
||
get
|
||
{
|
||
return dalHelper.DataBaseName;
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// The database version
|
||
/// 数据库的版本号
|
||
/// </summary>
|
||
public string DataBaseVersion
|
||
{
|
||
get
|
||
{
|
||
return dalHelper.Version;
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// The number of rows affected when executing a SQL command (-2 is an exception)
|
||
/// <para>执行SQL命令时受影响的行数（-2则为异常）。</para>
|
||
/// </summary>
|
||
public int RecordsAffected
|
||
{
|
||
get
|
||
{
|
||
return dalHelper.RecordsAffected;
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 是否事务进行中
|
||
/// </summary>
|
||
public bool IsTransation
|
||
{
|
||
get
|
||
{
|
||
return dalHelper.IsOpenTrans;
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// Command Timeout[seconds]
|
||
///<para>命令超时设置[单位秒]</para>
|
||
/// </summary>
|
||
public int TimeOut
|
||
{
|
||
get
|
||
{
|
||
if (dalHelper.Com != null)
|
||
{
|
||
return dalHelper.Com.CommandTimeout;
|
||
}
|
||
return -1;
|
||
}
|
||
set
|
||
{
|
||
if (dalHelper.Com != null)
|
||
{
|
||
dalHelper.Com.CommandTimeout = value;
|
||
}
|
||
}
|
||
}
|
||
private bool _AllowInsertID = false;
|
||
/// <summary>
|
||
/// Whether to allow manual insertion of ids for self-incrementing primary key identification
|
||
///<para>自增主键标识的，是否允许手动插入id</para>
|
||
/// </summary>
|
||
public bool AllowInsertID
|
||
{
|
||
get
|
||
{
|
||
return _AllowInsertID;
|
||
}
|
||
set
|
||
{
|
||
_AllowInsertID = value;
|
||
}
|
||
}
|
||
private bool _isInsertCommand; //是否执行插入命令(区分于Update命令)
|
||
|
||
private bool _setIdentityResult = true;
|
||
/// <summary>
|
||
/// MSSQL插入标识id时开启此选项[事务开启时有效]
|
||
/// </summary>
|
||
internal void SetidentityInsertOn()
|
||
{
|
||
_setIdentityResult = true;
|
||
if (dalHelper != null && dalHelper.IsOpenTrans)
|
||
{
|
||
switch (dalHelper.DataBaseType)
|
||
{
|
||
case DataBaseType.MsSql:
|
||
case DataBaseType.Sybase:
|
||
foreach (var item in _Data.Columns)
|
||
{
|
||
if (item.IsAutoIncrement)
|
||
{
|
||
try
|
||
{
|
||
string lastTable = Convert.ToString(DistributedCache.Local.Get("MAction_identityInsertForSql"));
|
||
if (!string.IsNullOrEmpty(lastTable))
|
||
{
|
||
lastTable = "set identity_insert " + SqlFormat.Keyword(lastTable, dalHelper.DataBaseType) + " off";
|
||
dalHelper.ExeNonQuery(lastTable, false);
|
||
}
|
||
_setIdentityResult = dalHelper.ExeNonQuery("set identity_insert " + SqlFormat.Keyword(_TableName, dalHelper.DataBaseType) + " on", false) > -2;
|
||
if (_setIdentityResult)
|
||
{
|
||
DistributedCache.Local.Set("MAction_identityInsertForSql", _TableName, 30);
|
||
}
|
||
}
|
||
catch
|
||
{
|
||
|
||
}
|
||
break;
|
||
}
|
||
}
|
||
break;
|
||
}
|
||
|
||
}
|
||
_AllowInsertID = true;
|
||
}
|
||
/// <summary>
|
||
/// MSSQL插入标识id后关闭此选项[事务开启时有效]
|
||
/// </summary>;
|
||
internal void SetidentityInsertOff()
|
||
{
|
||
if (_setIdentityResult && dalHelper != null && dalHelper.IsOpenTrans)
|
||
{
|
||
switch (dalHelper.DataBaseType)
|
||
{
|
||
case DataBaseType.MsSql:
|
||
case DataBaseType.Sybase:
|
||
foreach (var item in _Data.Columns)
|
||
{
|
||
if (item.IsAutoIncrement)
|
||
{
|
||
try
|
||
{
|
||
if (dalHelper.ExeNonQuery("set identity_insert " + SqlFormat.Keyword(_TableName, DataBaseType.MsSql) + " off", false) > -2)
|
||
{
|
||
_setIdentityResult = false;
|
||
DistributedCache.Local.Remove("MAction_identityInsertForSql");
|
||
}
|
||
}
|
||
catch
|
||
{
|
||
}
|
||
}
|
||
}
|
||
break;
|
||
}
|
||
|
||
}
|
||
_AllowInsertID = false;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 构造函数
|
||
|
||
/// <summary>
|
||
/// Instantiation
|
||
/// <para>实例化</para>
|
||
/// </summary>
|
||
/// <param name="tableNamesEnum">Parameters: table name, view, custom statement, DataRow
|
||
/// <para>参数：表名、视图、自定义语句、MDataRow</para></param>
|
||
public MAction(object tableNamesEnum)
|
||
{
|
||
Init(tableNamesEnum, null, true, null, true);
|
||
}
|
||
|
||
/// <param name="conn">Database connection statement or configuration key
|
||
/// <para>数据库链接语句或配置Key</para></param>
|
||
public MAction(object tableNamesEnum, string conn)
|
||
{
|
||
Init(tableNamesEnum, conn, true, null, true);
|
||
}
|
||
#endregion
|
||
|
||
#region 初始化
|
||
|
||
private void Init(object tableObj, string conn, bool resetState, string newDbName, bool isFirstInit)
|
||
{
|
||
string tableName = Convert.ToString(tableObj);
|
||
if (tableName == "") { Error.Throw("tableObj can't be null or empty!"); }
|
||
|
||
//if is Enum
|
||
if (string.IsNullOrEmpty(conn))
|
||
{
|
||
if (tableObj is Enum)
|
||
{
|
||
conn = CrossDB.GetConnByEnum(tableObj as Enum);
|
||
}
|
||
if (string.IsNullOrEmpty(conn) && !string.IsNullOrEmpty(ConnName))
|
||
{
|
||
conn = ConnName;
|
||
}
|
||
}
|
||
if (tableObj is String)
|
||
{
|
||
string fixName, dbName;
|
||
conn = CrossDB.GetConn(tableName, out fixName, conn, out dbName);
|
||
tableObj = fixName;
|
||
if (string.IsNullOrEmpty(newDbName) && !string.IsNullOrEmpty(dbName))
|
||
{
|
||
newDbName = dbName;
|
||
}
|
||
|
||
}
|
||
|
||
MDataRow newRow = InitRow(tableObj, conn);//尝试从MDataRow提取新的Conn链接
|
||
InitDalHelper(newRow, newDbName);
|
||
InitRowSchema(newRow, resetState);
|
||
InitGlobalObject(isFirstInit);
|
||
}
|
||
private MDataRow InitRow(object tableObj, string conn)
|
||
{
|
||
MDataRow newRow = null;
|
||
if (tableObj is MDataRow)
|
||
{
|
||
newRow = tableObj as MDataRow;
|
||
}
|
||
else
|
||
{
|
||
newRow = new MDataRow();
|
||
newRow.TableName = SqlFormat.NotKeyword(tableObj.ToString());
|
||
}
|
||
if (!string.IsNullOrEmpty(conn))
|
||
{
|
||
newRow.Conn = conn;
|
||
}
|
||
else if (_Data != null)//新加的处理
|
||
{
|
||
newRow.Conn = _Data.Conn;
|
||
}
|
||
_sourceTableName = newRow.TableName;
|
||
return newRow;
|
||
}
|
||
private void InitDalHelper(MDataRow newRow, string newDbName)
|
||
{
|
||
if (dalHelper == null)// || newCreate
|
||
{
|
||
dalHelper = DalCreate.CreateDal(newRow.Conn);
|
||
//创建错误事件。
|
||
if (dalHelper.IsOnExceptionEventNull)
|
||
{
|
||
dalHelper.OnExceptionEvent += new DalBase.OnException(_DataSqlHelper_OnExceptionEvent);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
dalHelper.ClearParameters();//oracle 11g(某用户的电脑上会出问题，切换表操作，参数未清）
|
||
}
|
||
if (!string.IsNullOrEmpty(newDbName))//需要切换数据库。
|
||
{
|
||
if (string.Compare(dalHelper.DataBaseName, newDbName, StringComparison.OrdinalIgnoreCase) != 0)//数据库名称不相同。
|
||
{
|
||
if (newRow.TableName.Contains(" "))//视图语句，则直接切换数据库链接。
|
||
{
|
||
dalHelper.ChangeDatabase(newDbName);
|
||
}
|
||
else
|
||
{
|
||
bool isWithDbName = newRow.TableName.Contains(".");//是否DBName.TableName
|
||
string fullTableName = isWithDbName ? newRow.TableName : newDbName + "." + newRow.TableName;
|
||
string sourceDbName = dalHelper.DataBaseName;
|
||
DBResetResult result = dalHelper.ChangeDatabaseWithCheck(fullTableName);
|
||
switch (result)
|
||
{
|
||
case DBResetResult.Yes://数据库切换了 (不需要前缀）
|
||
case DBResetResult.No_SaveDbName:
|
||
case DBResetResult.No_DBNoExists:
|
||
if (isWithDbName) //带有前缀的，取消前缀
|
||
{
|
||
_sourceTableName = newRow.TableName = SqlFormat.NotKeyword(fullTableName);
|
||
}
|
||
break;
|
||
case DBResetResult.No_Transationing:
|
||
if (!isWithDbName)//如果不同的数据库，需要带有数据库前缀
|
||
{
|
||
_sourceTableName = newRow.TableName = fullTableName;
|
||
}
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
void _DataSqlHelper_OnExceptionEvent(string msg)
|
||
{
|
||
_aop.OnError(msg);
|
||
}
|
||
// private static DateTime lastGCTime = DateTime.Now;
|
||
private void InitRowSchema(MDataRow row, bool resetState)
|
||
{
|
||
_Data = row;
|
||
_TableName = SqlCompatible.Format(_sourceTableName, dalHelper.DataBaseType);
|
||
// _TableName = DBTool.GetMapTableName(dalHelper.UsingConnBean.ConnName, _TableName);//处理数据库映射兼容。
|
||
if (_Data.Count == 0)
|
||
{
|
||
if (!TableSchema.FillTableSchema(ref _Data, _TableName, _sourceTableName))
|
||
{
|
||
if (!dalHelper.TestConn(AllowConnLevel.MaterBackupSlave))
|
||
{
|
||
Error.Throw(dalHelper.DataBaseType + "." + dalHelper.DataBaseName + ":open database failed! check the connectionstring is be ok!" + AppConst.NewLine + "error:" + dalHelper.DebugInfo.ToString());
|
||
}
|
||
Error.Throw(dalHelper.DataBaseType + "." + dalHelper.DataBaseName + ":check the tablename \"" + _TableName + "\" is exist?" + AppConst.NewLine + "error:" + dalHelper.DebugInfo.ToString());
|
||
}
|
||
}
|
||
else if (resetState)
|
||
{
|
||
_Data.SetState(0);
|
||
}
|
||
_Data.Conn = row.Conn;//FillTableSchema会改变_Row的对象。
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// Toggle Table Action: To switch between other tables, use this method
|
||
/// <para>切换表操作：如需操作其它表，通过此方法切换</para>
|
||
/// </summary>
|
||
/// <param name="tableObj">Parameters: table name, view, custom statement, DataRow
|
||
/// <para>参数：表名、视图、自定义语句、MDataRow</para></param>
|
||
public void ResetTable(object tableObj)
|
||
{
|
||
ResetTable(tableObj, true, null);
|
||
}
|
||
|
||
/// <param name="resetState">Reset Row State (defaultValue:true)
|
||
/// <para>是否重置原有的数据状态（默认true)</para></param>
|
||
public void ResetTable(object tableObj, bool resetState)
|
||
{
|
||
ResetTable(tableObj, resetState, null);
|
||
}
|
||
/// <param name="newDbName">Other DataBaseName
|
||
/// <para>其它数据库名称</para></param>
|
||
public void ResetTable(object tableObj, bool resetState, string newDbName)
|
||
{
|
||
Init(tableObj, null, resetState, newDbName, false);
|
||
}
|
||
|
||
private void InitGlobalObject(bool allowCreate)
|
||
{
|
||
if (_Data != null)
|
||
{
|
||
if (_sqlCreate == null)
|
||
{
|
||
_sqlCreate = new SqlCreate(this);
|
||
}
|
||
if (_UI != null)
|
||
{
|
||
_UI._Data = _Data;
|
||
}
|
||
else if (allowCreate)
|
||
{
|
||
_UI = new MActionUI(ref _Data, dalHelper, _sqlCreate);
|
||
}
|
||
//if (_noSqlAction != null)
|
||
//{
|
||
// _noSqlAction.Reset(ref _Data, _TableName, dalHelper.Con.DataSource, dalHelper.DataBaseType);
|
||
//}
|
||
//else if (allowCreate)
|
||
//{
|
||
// switch (dalHelper.DataBaseType)
|
||
// {
|
||
// case DataBaseType.Txt:
|
||
// case DataBaseType.Xml:
|
||
// _noSqlAction = new NoSqlAction(ref _Data, _TableName, dalHelper.Con.DataSource, dalHelper.DataBaseType);
|
||
// break;
|
||
// }
|
||
//}
|
||
}
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 数据库操作方法
|
||
|
||
private bool InsertOrUpdate(string sqlCommandText)
|
||
{
|
||
bool returnResult = false;
|
||
if (_sqlCreate.isCanDo)
|
||
{
|
||
#region 执行Insert或Update命令
|
||
if (_isInsertCommand) //插入
|
||
{
|
||
_isInsertCommand = false;
|
||
object id;
|
||
switch (dalHelper.DataBaseType)
|
||
{
|
||
case DataBaseType.MsSql:
|
||
case DataBaseType.Sybase:
|
||
case DataBaseType.PostgreSQL:
|
||
case DataBaseType.Txt:
|
||
case DataBaseType.Xml:
|
||
case DataBaseType.DaMeng:
|
||
id = dalHelper.ExeScalar(sqlCommandText, false);
|
||
if (id == null && AllowInsertID && dalHelper.RecordsAffected > -2)
|
||
{
|
||
id = _Data.PrimaryCell.Value;
|
||
}
|
||
break;
|
||
default:
|
||
#region MyRegion
|
||
bool isTrans = dalHelper.IsOpenTrans;
|
||
DataGroupType group = DataType.GetGroup(_Data.PrimaryCell.Struct.SqlType);
|
||
bool isNum = group == DataGroupType.Number && _Data.PrimaryCell.Struct.Scale <= 0;
|
||
if (!isTrans && (isNum || _Data.PrimaryCell.Struct.IsAutoIncrement) && (!AllowInsertID || _Data.PrimaryCell.IsNullOrEmpty)) // 数字自增加
|
||
{
|
||
dalHelper.IsOpenTrans = true;//开启事务。
|
||
dalHelper.TranLevel = IsolationLevel.ReadCommitted;//默认事务级别已是这个，还是设置一下，避免外部调整对此的影响。
|
||
}
|
||
id = dalHelper.ExeNonQuery(sqlCommandText, false);//返回的是受影响的行数
|
||
if (_option != InsertOp.None && id != null && Convert.ToInt32(id) > 0)
|
||
{
|
||
if (AllowInsertID && !_Data.PrimaryCell.IsNullOrEmpty)//手工插id
|
||
{
|
||
id = _Data.PrimaryCell.Value;
|
||
}
|
||
else if (isNum)
|
||
{
|
||
ClearParameters();
|
||
id = dalHelper.ExeScalar(_sqlCreate.GetMaxID(), false);
|
||
}
|
||
else
|
||
{
|
||
id = null;
|
||
returnResult = true;
|
||
}
|
||
|
||
}
|
||
if (!isTrans)
|
||
{
|
||
dalHelper.EndTransaction();
|
||
}
|
||
#endregion
|
||
break;
|
||
}
|
||
if ((id != null && Convert.ToString(id) != "-2") || (dalHelper.RecordsAffected > -2 && _option == InsertOp.None))
|
||
{
|
||
if (_option != InsertOp.None)
|
||
{
|
||
_Data.PrimaryCell.Value = id;
|
||
}
|
||
returnResult = (_option == InsertOp.Fill) ? Fill(id) : true;
|
||
}
|
||
}
|
||
else //更新
|
||
{
|
||
returnResult = dalHelper.ExeNonQuery(sqlCommandText, false) > 0;
|
||
}
|
||
#endregion
|
||
}
|
||
else if (!_isInsertCommand && _Data.GetState() == 1 && dalHelper.RecordsAffected != -2) // 更新操作。
|
||
{
|
||
//输出警告信息
|
||
return true;
|
||
}
|
||
else if (dalHelper.IsOpenTrans && dalHelper.RecordsAffected == -2) // 若事务中，则回滚
|
||
{
|
||
dalHelper.WriteError(_isInsertCommand ? "Insert" : "Update" + "():");
|
||
}
|
||
return returnResult;
|
||
}
|
||
|
||
#region 插入
|
||
|
||
/// <summary>
|
||
/// Insert To DataBase
|
||
/// <para>插入数据</para>
|
||
/// </summary>
|
||
public bool Insert()
|
||
{
|
||
return Insert(false, _option);
|
||
}
|
||
|
||
/// <param name="option">InsertOp
|
||
/// <para>插入选项</para></param>
|
||
public bool Insert(InsertOp option)
|
||
{
|
||
return Insert(false, option);
|
||
}
|
||
|
||
|
||
/// <param name="autoSetValue">Automatic get values from context
|
||
/// <para>自动取值（从上下文环境中）</para></param>
|
||
public bool Insert(bool autoSetValue)
|
||
{
|
||
return Insert(autoSetValue, _option);
|
||
}
|
||
|
||
/// <param name="option">InsertOp
|
||
/// <para>插入选项</para></param>
|
||
public bool Insert(bool autoSetValue, InsertOp option)
|
||
{
|
||
if (CheckDisposed()) { return false; }
|
||
if (autoSetValue)
|
||
{
|
||
_UI.GetAll(!AllowInsertID);//允许插入id时，也需要获取主键。
|
||
}
|
||
AopResult aopResult = AopResult.Default;
|
||
if (_aop.IsLoadAop)
|
||
{
|
||
_aop.Para.MAction = this;
|
||
_aop.Para.TableName = _sourceTableName;
|
||
_aop.Para.Row = _Data;
|
||
_aop.Para.AutoSetValue = autoSetValue;
|
||
_aop.Para.InsertOp = option;
|
||
_aop.Para.IsTransaction = dalHelper.IsOpenTrans;
|
||
aopResult = _aop.Begin(Aop.AopEnum.Insert);
|
||
}
|
||
if (aopResult == AopResult.Default || aopResult == AopResult.Continue)
|
||
{
|
||
ClearParameters();
|
||
string sql = _sqlCreate.GetInsertSql();
|
||
_isInsertCommand = true;
|
||
_option = option;
|
||
_aop.Para.IsSuccess = InsertOrUpdate(sql);
|
||
}
|
||
else if (option != InsertOp.None)
|
||
{
|
||
_Data = _aop.Para.Row;
|
||
InitGlobalObject(false);
|
||
}
|
||
if (_aop.IsLoadAop && (aopResult == AopResult.Break || aopResult == AopResult.Continue))
|
||
{
|
||
_aop.End(Aop.AopEnum.Insert);
|
||
}
|
||
if (dalHelper.RecordsAffected == -2)
|
||
{
|
||
OnError();
|
||
}
|
||
|
||
return _aop.Para.IsSuccess;
|
||
}
|
||
#endregion
|
||
|
||
#region 更新
|
||
/// <summary>
|
||
/// Update to database [Will automatically try to fetch from the UI when conditions are not passed]
|
||
/// <para>更新数据[不传where条件时将自动尝试从UI获取]</para>
|
||
/// </summary>
|
||
public bool Update()
|
||
{
|
||
return Update(null, true);
|
||
}
|
||
|
||
|
||
/// <param name="where">Sql statement where the conditions: 88, "id = 88"
|
||
/// <para>sql语句的where条件：88、"id=88"</para></param>
|
||
public bool Update(object where)
|
||
{
|
||
return Update(where, false);
|
||
}
|
||
|
||
|
||
/// <param name="autoSetValue">Automatic get values from context
|
||
/// <para>自动取值（从上下文环境中）</para></param>
|
||
public bool Update(bool autoSetValue)
|
||
{
|
||
return Update(null, autoSetValue);
|
||
}
|
||
|
||
/// <param name="autoSetValue">Automatic get values from context
|
||
/// <para>自动取值（从上下文环境中）</para></param>
|
||
public bool Update(object where, bool autoSetValue)
|
||
{
|
||
if (CheckDisposed()) { return false; }
|
||
if (autoSetValue)
|
||
{
|
||
_UI.GetAll(false);
|
||
}
|
||
if (where == null || Convert.ToString(where) == "")
|
||
{
|
||
where = _sqlCreate.GetPrimaryWhere();
|
||
}
|
||
AopResult aopResult = AopResult.Default;
|
||
if (_aop.IsLoadAop)
|
||
{
|
||
_aop.Para.MAction = this;
|
||
_aop.Para.TableName = _sourceTableName;
|
||
_aop.Para.Row = _Data;
|
||
_aop.Para.Where = where;
|
||
//_aop.Para.AopPara = aopPara;
|
||
_aop.Para.AutoSetValue = autoSetValue;
|
||
_aop.Para.UpdateExpression = _sqlCreate.updateExpression;
|
||
_aop.Para.IsTransaction = dalHelper.IsOpenTrans;
|
||
aopResult = _aop.Begin(Aop.AopEnum.Update);
|
||
}
|
||
if (aopResult == AopResult.Default || aopResult == AopResult.Continue)
|
||
{
|
||
ClearParameters();
|
||
string sql = _sqlCreate.GetUpdateSql(where);
|
||
_aop.Para.IsSuccess = InsertOrUpdate(sql);
|
||
}
|
||
if (_aop.IsLoadAop && (aopResult == AopResult.Break || aopResult == AopResult.Continue))
|
||
{
|
||
_aop.End(Aop.AopEnum.Update);
|
||
}
|
||
if (dalHelper.RecordsAffected == -2)
|
||
{
|
||
OnError();
|
||
}
|
||
else if (_aop.Para.IsSuccess)
|
||
{
|
||
_Data.SetState();//状态自减1
|
||
}
|
||
return _aop.Para.IsSuccess;
|
||
}
|
||
#endregion
|
||
|
||
#region 删除
|
||
|
||
/// <summary>
|
||
/// Delete from database [Will automatically try to fetch from the UI when conditions are not passed]
|
||
/// <para>删除数据[不传where条件时将自动尝试从UI获取]</para>
|
||
/// </summary>
|
||
public bool Delete()
|
||
{
|
||
return Delete(null, false);
|
||
}
|
||
public bool Delete(object where)
|
||
{
|
||
return Delete(where, false);
|
||
}
|
||
/// <param name="where">Sql statement where the conditions: 88, "id = 88"
|
||
/// <para>sql语句的where条件：88、"id=88"</para></param>
|
||
/// <param name="isIgnoreDeleteField">当DeleteField被设置后（删除转更新操作），如果仍想删除操作（可将此属性置为true）</param>
|
||
public bool Delete(object where, bool isIgnoreDeleteField)
|
||
{
|
||
if (CheckDisposed()) { return false; }
|
||
if (where == null || Convert.ToString(where) == "")
|
||
{
|
||
_UI.PrimayAutoGetValue();
|
||
where = _sqlCreate.GetPrimaryWhere();
|
||
}
|
||
AopResult aopResult = AopResult.Default;
|
||
if (_aop.IsLoadAop)
|
||
{
|
||
_aop.Para.MAction = this;
|
||
_aop.Para.TableName = _sourceTableName;
|
||
_aop.Para.Row = _Data;
|
||
_aop.Para.Where = where;
|
||
//_aop.Para.AopPara = aopPara;
|
||
_aop.Para.IsTransaction = dalHelper.IsOpenTrans;
|
||
aopResult = _aop.Begin(Aop.AopEnum.Delete);
|
||
}
|
||
if (aopResult == AopResult.Default || aopResult == AopResult.Continue)
|
||
{
|
||
string deleteField = AppConfig.DB.DeleteField;
|
||
bool isToUpdate = !isIgnoreDeleteField && !string.IsNullOrEmpty(deleteField) && _Data.Columns.Contains(deleteField);
|
||
ClearParameters();
|
||
string sql = isToUpdate ? _sqlCreate.GetDeleteToUpdateSql(where) : _sqlCreate.GetDeleteSql(where);
|
||
_aop.Para.IsSuccess = dalHelper.ExeNonQuery(sql, false) > 0;
|
||
}
|
||
if (_aop.IsLoadAop && (aopResult == AopResult.Break || aopResult == AopResult.Continue))
|
||
{
|
||
_aop.End(Aop.AopEnum.Delete);
|
||
}
|
||
if (dalHelper.RecordsAffected == -2)
|
||
{
|
||
OnError();
|
||
}
|
||
return _aop.Para.IsSuccess;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 查询 返回 MDataTable
|
||
|
||
/// <summary>
|
||
/// select all data
|
||
///<para>选择所有数据</para>
|
||
/// </summary>
|
||
public MDataTable Select()
|
||
{
|
||
int count;
|
||
return Select(0, 0, null, out count);
|
||
}
|
||
|
||
/// <param name="where">Sql statement where the conditions: 88, "id = 88"
|
||
/// <para>sql语句的where条件：88、"id=88"</para></param>
|
||
public MDataTable Select(object where)
|
||
{
|
||
int count;
|
||
return Select(0, 0, where, out count);
|
||
}
|
||
public MDataTable Select(int topN, object where)
|
||
{
|
||
int count;
|
||
return Select(0, topN, where, out count);
|
||
}
|
||
/// <param name="pageIndex">pageIndex<para>第几页</para></param>
|
||
/// <param name="pageSize">pageSize<para>每页数量[为0时默认选择所有]</para></param>
|
||
public MDataTable Select(int pageIndex, int pageSize)
|
||
{
|
||
int count;
|
||
return Select(pageIndex, pageSize, null, out count);
|
||
}
|
||
public MDataTable Select(int pageIndex, int pageSize, object where)
|
||
{
|
||
int count;
|
||
return Select(pageIndex, pageSize, where, out count);
|
||
}
|
||
|
||
/// <param name="count">The total number of records returned
|
||
/// <para>返回的记录总数</para></param>
|
||
public MDataTable Select(int pageIndex, int pageSize, object where, out int count)
|
||
{
|
||
if (CheckDisposed()) { count = -1; return new MDataTable(_TableName); }
|
||
count = 0;
|
||
AopResult aopResult = AopResult.Default;
|
||
if (_aop.IsLoadAop)
|
||
{
|
||
_aop.Para.MAction = this;
|
||
_aop.Para.PageIndex = pageIndex;
|
||
_aop.Para.PageSize = pageSize;
|
||
_aop.Para.TableName = _sourceTableName;
|
||
_aop.Para.Row = _Data;
|
||
_aop.Para.Where = where;
|
||
_aop.Para.SelectColumns = _sqlCreate.selectColumns;
|
||
//_aop.Para.AopPara = aopPara;
|
||
_aop.Para.IsTransaction = dalHelper.IsOpenTrans;
|
||
aopResult = _aop.Begin(Aop.AopEnum.Select);
|
||
}
|
||
if (aopResult == AopResult.Default || aopResult == AopResult.Continue)
|
||
{
|
||
string primaryKey = SqlFormat.Keyword(_Data.Columns.FirstPrimary.ColumnName, dalHelper.DataBaseType);//主键列名。
|
||
_aop.Para.Table = new MDataTable(_TableName.Contains("(") ? "SysDefaultCustomTable" : _TableName);
|
||
_aop.Para.Table.LoadRow(_Data);
|
||
ClearParameters();//------------------------参数清除
|
||
DbDataReader sdReader = null;
|
||
string whereSql = string.Empty;//已格式化过的原生whereSql语句
|
||
if (_sqlCreate != null)
|
||
{
|
||
whereSql = _sqlCreate.FormatWhere(where);
|
||
}
|
||
else
|
||
{
|
||
whereSql = SqlFormat.Compatible(where, dalHelper.DataBaseType, dalHelper.Com.Parameters.Count == 0);
|
||
}
|
||
bool byPager = pageIndex > 0 && pageSize > 0;//分页查询(第一页也要分页查询，因为要计算总数）
|
||
|
||
#region SQL语句分页执行
|
||
if (byPager)
|
||
{
|
||
count = GetCount(whereSql);//利用自动缓存，避免每次分页都要计算总数。
|
||
_aop.Para.Where = where;//恢复影响的条件，避免影响缓存key
|
||
_aop.isHasCache = false;//不能影响Select的后续操作。
|
||
//rowCount = Convert.ToInt32(dalHelper.ExeScalar(_sqlCreate.GetCountSql(whereSql), false));//分页查询先记算总数
|
||
}
|
||
if (!byPager || (count > 0 && (pageIndex - 1) * pageSize < count))
|
||
{
|
||
string sql = SqlCreateForPager.GetSql(dalHelper.DataBaseType, dalHelper.Version, pageIndex, pageSize, whereSql, SqlFormat.Keyword(_TableName, dalHelper.DataBaseType), count, _sqlCreate.GetColumnsSql(), primaryKey, _Data.PrimaryCell.Struct.IsAutoIncrement);
|
||
sdReader = dalHelper.ExeDataReader(sql, false);
|
||
}
|
||
else if (_sqlCreate.selectColumns != null)
|
||
{
|
||
//没有数据，只返回表结构。
|
||
_aop.Para.Table = _aop.Para.Table.Select(0, 0, null, _sqlCreate.selectColumns);
|
||
}
|
||
#endregion
|
||
|
||
if (sdReader != null)
|
||
{
|
||
_aop.Para.Table = sdReader;
|
||
if (!byPager)
|
||
{
|
||
count = _aop.Para.Table.Rows.Count;
|
||
}
|
||
|
||
_aop.Para.Table.RecordsAffected = count;
|
||
}
|
||
else
|
||
{
|
||
_aop.Para.Table.Rows.Clear();//预防之前的插入操作产生了一个数据行。
|
||
}
|
||
_aop.Para.IsSuccess = _aop.Para.Table.Rows.Count > 0;
|
||
ClearParameters();//------------------------参数清除
|
||
// break;
|
||
//}
|
||
}
|
||
else if (_aop.Para.Table.RecordsAffected > 0)
|
||
{
|
||
count = _aop.Para.Table.RecordsAffected;//返回记录总数
|
||
}
|
||
if (_aop.IsLoadAop && (aopResult == AopResult.Break || aopResult == AopResult.Continue))
|
||
{
|
||
_aop.End(Aop.AopEnum.Select);
|
||
}
|
||
_aop.Para.Table.TableName = TableName;//Aop从Json缓存加载时会丢失表名。
|
||
_aop.Para.Table.Conn = ConnName;
|
||
//修正DataType和Size、Scale
|
||
for (int i = 0; i < _aop.Para.Table.Columns.Count; i++)
|
||
{
|
||
MCellStruct msTable = _aop.Para.Table.Columns[i];
|
||
MCellStruct ms = _Data.Columns[msTable.ColumnName];
|
||
if (ms != null)
|
||
{
|
||
msTable.Load(ms);
|
||
}
|
||
}
|
||
if (_sqlCreate != null)
|
||
{
|
||
_sqlCreate.selectColumns = null;
|
||
}
|
||
return _aop.Para.Table;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 查询 返回 List<T>
|
||
|
||
|
||
/// <summary>
|
||
/// select all data
|
||
///<para>选择所有数据</para>
|
||
/// </summary>
|
||
public List<T> SelectList<T>() where T : class
|
||
{
|
||
int count;
|
||
return SelectList<T>(0, 0, null, out count);
|
||
}
|
||
|
||
/// <param name="where">Sql statement where the conditions: 88, "id = 88"
|
||
/// <para>sql语句的where条件：88、"id=88"</para></param>
|
||
public List<T> SelectList<T>(object where) where T : class
|
||
{
|
||
int count;
|
||
return SelectList<T>(0, 0, where, out count);
|
||
}
|
||
public List<T> SelectList<T>(int topN, object where) where T : class
|
||
{
|
||
int count;
|
||
return SelectList<T>(0, topN, where, out count);
|
||
}
|
||
/// <param name="pageIndex">pageIndex<para>第几页</para></param>
|
||
/// <param name="pageSize">pageSize<para>每页数量[为0时默认选择所有]</para></param>
|
||
public List<T> SelectList<T>(int pageIndex, int pageSize) where T : class
|
||
{
|
||
int count;
|
||
return SelectList<T>(pageIndex, pageSize, null, out count);
|
||
}
|
||
public List<T> SelectList<T>(int pageIndex, int pageSize, object where) where T : class
|
||
{
|
||
int count;
|
||
return SelectList<T>(pageIndex, pageSize, where, out count);
|
||
}
|
||
/// <summary>
|
||
/// 查询后直接返回泛型列表（节省一次转换时间）。
|
||
/// </summary>
|
||
public List<T> SelectList<T>(int pageIndex, int pageSize, object where, out int count) where T : class
|
||
{
|
||
List<T> list = new List<T>();
|
||
if (CheckDisposed()) { count = -1; return list; }
|
||
count = 0;
|
||
AopResult aopResult = AopResult.Default;
|
||
if (_aop.IsLoadAop)
|
||
{
|
||
_aop.Para.MAction = this;
|
||
_aop.Para.PageIndex = pageIndex;
|
||
_aop.Para.PageSize = pageSize;
|
||
_aop.Para.TableName = _sourceTableName;
|
||
_aop.Para.Row = _Data;
|
||
_aop.Para.Where = where;
|
||
_aop.Para.SelectColumns = _sqlCreate.selectColumns;
|
||
_aop.Para.IsTransaction = dalHelper.IsOpenTrans;
|
||
aopResult = _aop.Begin(Aop.AopEnum.SelectList);
|
||
}
|
||
if (aopResult == AopResult.Default || aopResult == AopResult.Continue)
|
||
{
|
||
string primaryKey = SqlFormat.Keyword(_Data.Columns.FirstPrimary.ColumnName, dalHelper.DataBaseType);//主键列名。
|
||
ClearParameters();//------------------------参数清除
|
||
DbDataReader sdReader = null;
|
||
string whereSql = string.Empty;//已格式化过的原生whereSql语句
|
||
if (_sqlCreate != null)
|
||
{
|
||
whereSql = _sqlCreate.FormatWhere(where);
|
||
}
|
||
else
|
||
{
|
||
whereSql = SqlFormat.Compatible(where, dalHelper.DataBaseType, dalHelper.Com.Parameters.Count == 0);
|
||
}
|
||
bool byPager = pageIndex > 0 && pageSize > 0;//分页查询(第一页也要分页查询，因为要计算总数）
|
||
|
||
#region SQL语句分页执行
|
||
if (byPager)
|
||
{
|
||
count = GetCount(whereSql);//利用自动缓存，避免每次分页都要计算总数。
|
||
_aop.Para.Where = where;//恢复影响的条件，避免影响缓存key
|
||
_aop.isHasCache = false;//不能影响Select的后续操作。
|
||
//rowCount = Convert.ToInt32(dalHelper.ExeScalar(_sqlCreate.GetCountSql(whereSql), false));//分页查询先记算总数
|
||
}
|
||
if (!byPager || (count > 0 && (pageIndex - 1) * pageSize < count))
|
||
{
|
||
string sql = SqlCreateForPager.GetSql(dalHelper.DataBaseType, dalHelper.Version, pageIndex, pageSize, whereSql, SqlFormat.Keyword(_TableName, dalHelper.DataBaseType), count, _sqlCreate.GetColumnsSql(), primaryKey, _Data.PrimaryCell.Struct.IsAutoIncrement);
|
||
sdReader = dalHelper.ExeDataReader(sql, false);
|
||
}
|
||
//else if (_sqlCreate.selectColumns != null)
|
||
//{
|
||
// //没有数据，只返回表结构。
|
||
// _aop.Para.Table = _aop.Para.Table.Select(0, 0, null, _sqlCreate.selectColumns);
|
||
//}
|
||
#endregion
|
||
|
||
if (sdReader != null)
|
||
{
|
||
list = ConvertTool.ChangeReaderToList<T>(sdReader);
|
||
_aop.Para.ExeResult = list;
|
||
if (!byPager)
|
||
{
|
||
count = list.Count;
|
||
}
|
||
}
|
||
_aop.Para.TotalCount = count;
|
||
_aop.Para.IsSuccess = list.Count > 0;
|
||
ClearParameters();//------------------------参数清除
|
||
}
|
||
else if (_aop.Para.ExeResult != null)
|
||
{
|
||
object cacheObj = _aop.Para.ExeResult;
|
||
if (cacheObj is MDataTable)
|
||
{
|
||
MDataTable dt = _aop.Para.ExeResult as MDataTable;
|
||
if (dt != null)
|
||
{
|
||
list = dt.ToList<T>();
|
||
count = dt.RecordsAffected;
|
||
}
|
||
}
|
||
else if (cacheObj is string)
|
||
{
|
||
string json = cacheObj.ToString();
|
||
count = JsonHelper.GetValue<int>(json, "total");
|
||
list = JsonHelper.ToList<T>(JsonHelper.GetValue<string>(json, "rows"), EscapeOp.Encode);
|
||
}
|
||
}
|
||
if (_aop.IsLoadAop && (aopResult == AopResult.Break || aopResult == AopResult.Continue))
|
||
{
|
||
_aop.End(Aop.AopEnum.SelectList);
|
||
}
|
||
|
||
if (_sqlCreate != null)
|
||
{
|
||
_sqlCreate.selectColumns = null;
|
||
}
|
||
return list;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 查询 返回 Json
|
||
/// <summary>
|
||
/// select all data
|
||
///<para>选择所有数据</para>
|
||
/// </summary>
|
||
public string SelectJson()
|
||
{
|
||
int count;
|
||
return SelectJson(0, 0, null, out count, false, null);
|
||
}
|
||
|
||
/// <param name="where">Sql statement where the conditions: 88, "id = 88"
|
||
/// <para>sql语句的where条件：88、"id=88"</para></param>
|
||
public string SelectJson(object where)
|
||
{
|
||
int count;
|
||
return SelectJson(0, 0, where, out count, false, null);
|
||
}
|
||
public string SelectJson(int topN, object where)
|
||
{
|
||
int count;
|
||
return SelectJson(0, topN, where, out count, false, null);
|
||
}
|
||
/// <param name="pageIndex">pageIndex<para>第几页</para></param>
|
||
/// <param name="pageSize">pageSize<para>每页数量[为0时默认选择所有]</para></param>
|
||
public string SelectJson(int pageIndex, int pageSize)
|
||
{
|
||
int count;
|
||
return SelectJson(pageIndex, pageSize, null, out count, false, null);
|
||
}
|
||
public string SelectJson(int pageIndex, int pageSize, object where)
|
||
{
|
||
int count;
|
||
return SelectJson(pageIndex, pageSize, where, out count, false, null);
|
||
}
|
||
public string SelectJson(int pageIndex, int pageSize, object where, out int count)
|
||
{
|
||
return SelectJson(pageIndex, pageSize, where, out count, false, null);
|
||
}
|
||
public string SelectJson(int pageIndex, int pageSize, object where, out int count, bool isConvertNameToLower)
|
||
{
|
||
return SelectJson(pageIndex, pageSize, where, out count, isConvertNameToLower, null);
|
||
}
|
||
/// <summary>
|
||
/// 查询后直接返回Json字符串（节省一次转换时间）。
|
||
/// </summary>
|
||
public string SelectJson(int pageIndex, int pageSize, object where, out int count, bool isConvertNameToLower, string dateTimeFormatter)
|
||
{
|
||
if (CheckDisposed()) { count = -1; return "[{}]"; }
|
||
string json = "";
|
||
AopResult aopResult = AopResult.Default;
|
||
count = 0;
|
||
if (_aop.IsLoadAop)
|
||
{
|
||
_aop.Para.MAction = this;
|
||
_aop.Para.PageIndex = pageIndex;
|
||
_aop.Para.PageSize = pageSize;
|
||
_aop.Para.TableName = _sourceTableName;
|
||
_aop.Para.Row = _Data;
|
||
_aop.Para.Where = where;
|
||
_aop.Para.SelectColumns = _sqlCreate.selectColumns;
|
||
_aop.Para.IsTransaction = dalHelper.IsOpenTrans;
|
||
aopResult = _aop.Begin(Aop.AopEnum.SelectJson);
|
||
}
|
||
if (aopResult == AopResult.Default || aopResult == AopResult.Continue) // 无缓存时执行
|
||
{
|
||
string primaryKey = SqlFormat.Keyword(_Data.Columns.FirstPrimary.ColumnName, dalHelper.DataBaseType);//主键列名。
|
||
ClearParameters();//------------------------参数清除
|
||
DbDataReader sdReader = null;
|
||
string whereSql = string.Empty;//已格式化过的原生whereSql语句
|
||
if (_sqlCreate != null)
|
||
{
|
||
whereSql = _sqlCreate.FormatWhere(where);
|
||
}
|
||
else
|
||
{
|
||
whereSql = SqlFormat.Compatible(where, dalHelper.DataBaseType, dalHelper.Com.Parameters.Count == 0);
|
||
}
|
||
bool byPager = pageIndex > 0 && pageSize > 0;//分页查询(第一页也要分页查询，因为要计算总数）
|
||
|
||
#region SQL语句分页执行
|
||
if (byPager)
|
||
{
|
||
count = GetCount(whereSql);//利用自动缓存，避免每次分页都要计算总数。
|
||
_aop.Para.Where = where;//恢复影响的条件，避免影响缓存key
|
||
_aop.isHasCache = false;//不能影响Select的后续操作。
|
||
}
|
||
if (!byPager || (count > 0 && (pageIndex - 1) * pageSize < count))
|
||
{
|
||
string sql = SqlCreateForPager.GetSql(dalHelper.DataBaseType, dalHelper.Version, pageIndex, pageSize, whereSql, SqlFormat.Keyword(_TableName, dalHelper.DataBaseType), count, _sqlCreate.GetColumnsSql(), primaryKey, _Data.PrimaryCell.Struct.IsAutoIncrement);
|
||
sdReader = dalHelper.ExeDataReader(sql, false);
|
||
}
|
||
|
||
#endregion
|
||
|
||
if (sdReader != null)
|
||
{
|
||
JsonHelper js = new JsonHelper(false, false);
|
||
js.IsConvertNameToLower = isConvertNameToLower;
|
||
if (!string.IsNullOrEmpty(dateTimeFormatter))
|
||
{
|
||
js.DateTimeFormatter = dateTimeFormatter;
|
||
}
|
||
json = ConvertTool.ChangeReaderToJson(sdReader, js, true);
|
||
_aop.Para.ExeResult = json;
|
||
if (!byPager)
|
||
{
|
||
count = js.RowCount;
|
||
}
|
||
}
|
||
_aop.Para.TotalCount = count;
|
||
_aop.Para.IsSuccess = json.Length > 4;
|
||
ClearParameters();//------------------------参数清除
|
||
}
|
||
else if (_aop.Para.ExeResult != null) //存在缓存时执行
|
||
{
|
||
object cacheObj = _aop.Para.ExeResult;
|
||
if (cacheObj is MDataTable)
|
||
{
|
||
MDataTable dt = _aop.Para.ExeResult as MDataTable;
|
||
if (dt != null)
|
||
{
|
||
count = dt.RecordsAffected;
|
||
json = dt.ToJson(false, false);
|
||
}
|
||
}
|
||
else if (cacheObj is string)
|
||
{
|
||
string objString = cacheObj.ToString();
|
||
count = JsonHelper.GetValue<int>(objString, "total");
|
||
json = JsonHelper.GetValue<string>(objString, "rows");
|
||
}
|
||
}
|
||
if (_aop.IsLoadAop && (aopResult == AopResult.Break || aopResult == AopResult.Continue))
|
||
{
|
||
_aop.End(Aop.AopEnum.SelectJson);//设置缓存
|
||
}
|
||
|
||
if (_sqlCreate != null)
|
||
{
|
||
_sqlCreate.selectColumns = null;
|
||
}
|
||
return json;
|
||
}
|
||
|
||
#endregion
|
||
|
||
/// <summary>
|
||
/// Select top one row to fill this.Data
|
||
/// <para>选择一行数据，并填充到Data属性[不传where条件时将自动尝试从UI获取]</para>
|
||
/// </summary>
|
||
public bool Fill()
|
||
{
|
||
return Fill(null);
|
||
}
|
||
|
||
/// <param name="where">Sql statement where the conditions: 88, "id = 88"
|
||
/// <para>sql语句的where条件：88、"id=88"</para></param>
|
||
public bool Fill(object where)
|
||
{
|
||
if (CheckDisposed()) { return false; }
|
||
if (where == null || Convert.ToString(where) == "")
|
||
{
|
||
_UI.PrimayAutoGetValue();
|
||
where = _sqlCreate.GetPrimaryWhere();
|
||
}
|
||
AopResult aopResult = AopResult.Default;
|
||
if (_aop.IsLoadAop)
|
||
{
|
||
_aop.Para.MAction = this;
|
||
_aop.Para.TableName = _sourceTableName;
|
||
_aop.Para.Row = _Data;
|
||
_aop.Para.Where = where;
|
||
_aop.Para.SelectColumns = _sqlCreate.selectColumns;
|
||
//_aop.Para.AopPara = aopPara;
|
||
_aop.Para.IsTransaction = dalHelper.IsOpenTrans;
|
||
aopResult = _aop.Begin(Aop.AopEnum.Fill);
|
||
}
|
||
if (aopResult == AopResult.Default || aopResult == AopResult.Continue)
|
||
{
|
||
ClearParameters();
|
||
MDataTable mTable = dalHelper.ExeDataReader(_sqlCreate.GetTopOneSql(where), false);
|
||
// dalHelper.ResetConn();//重置Slave
|
||
if (mTable != null && mTable.Rows.Count > 0)
|
||
{
|
||
_Data.Clear();//清掉旧值。
|
||
_Data.LoadFrom(mTable.Rows[0], RowOp.None, true);//setselectcolumn("aa as bb")时
|
||
_aop.Para.IsSuccess = true;
|
||
}
|
||
else
|
||
{
|
||
_aop.Para.IsSuccess = false;
|
||
}
|
||
// break;
|
||
//}
|
||
}
|
||
else if (_aop.Para.IsSuccess)
|
||
{
|
||
_Data.Clear();//清掉旧值。
|
||
_Data.LoadFrom(_aop.Para.Row, RowOp.None, true);
|
||
}
|
||
|
||
if (_aop.IsLoadAop && (aopResult == AopResult.Break || aopResult == AopResult.Continue))
|
||
{
|
||
_aop.Para.Row = _Data;
|
||
_aop.End(Aop.AopEnum.Fill);
|
||
}
|
||
if (_aop.Para.IsSuccess)
|
||
{
|
||
if (_sqlCreate.selectColumns != null)
|
||
{
|
||
string name;
|
||
string[] items;
|
||
foreach (object columnName in _sqlCreate.selectColumns)
|
||
{
|
||
items = columnName.ToString().Split(' ');
|
||
name = items[items.Length - 1];
|
||
MDataCell cell = _Data[name];
|
||
if (cell != null)
|
||
{
|
||
cell.State = 1;
|
||
}
|
||
}
|
||
items = null;
|
||
}
|
||
else
|
||
{
|
||
_Data.SetState(1, BreakOp.Null);//查询时，定位状态为1
|
||
}
|
||
}
|
||
if (dalHelper.RecordsAffected == -2)
|
||
{
|
||
OnError();
|
||
}
|
||
if (_sqlCreate != null)
|
||
{
|
||
_sqlCreate.selectColumns = null;
|
||
}
|
||
return _aop.Para.IsSuccess;
|
||
}
|
||
/// <summary>
|
||
/// Returns the number of records
|
||
/// <para>返回记录数</para>
|
||
/// </summary>
|
||
public int GetCount()
|
||
{
|
||
return GetCount(null);
|
||
}
|
||
|
||
/// <param name="where">Sql statement where the conditions: 88, "id = 88"
|
||
/// <para>sql语句的where条件：88、"id=88"</para></param>
|
||
public int GetCount(object where)
|
||
{
|
||
if (CheckDisposed()) { return -1; }
|
||
AopResult aopResult = AopResult.Default;
|
||
if (_aop.IsLoadAop)
|
||
{
|
||
_aop.Para.MAction = this;
|
||
_aop.Para.TableName = _sourceTableName;
|
||
_aop.Para.Row = _Data;
|
||
_aop.Para.Where = where;
|
||
_aop.Para.IsTransaction = dalHelper.IsOpenTrans;
|
||
aopResult = _aop.Begin(Aop.AopEnum.GetCount);
|
||
}
|
||
if (aopResult == AopResult.Default || aopResult == AopResult.Continue)
|
||
{
|
||
ClearParameters();//清除系统参数
|
||
string countSql = _sqlCreate.GetCountSql(where);
|
||
object result = dalHelper.ExeScalar(countSql, false);
|
||
|
||
_aop.Para.IsSuccess = result != null;
|
||
if (_aop.Para.IsSuccess)
|
||
{
|
||
_aop.Para.ExeResult = Convert.ToInt32(result);
|
||
}
|
||
else
|
||
{
|
||
_aop.Para.ExeResult = -1;
|
||
}
|
||
}
|
||
if (_aop.IsLoadAop && (aopResult == AopResult.Break || aopResult == AopResult.Continue))
|
||
{
|
||
_aop.End(Aop.AopEnum.GetCount);
|
||
}
|
||
if (dalHelper.RecordsAffected == -2)
|
||
{
|
||
OnError();
|
||
}
|
||
return (int)_aop.Para.ExeResult;
|
||
}
|
||
/// <summary>
|
||
/// Whether or not the specified condition exists
|
||
/// <para>是否存在指定条件的数据</para>
|
||
/// </summary>
|
||
public bool Exists()
|
||
{
|
||
return Exists(null);
|
||
}
|
||
|
||
/// <param name="where">Sql statement where the conditions: 88, "id = 88"
|
||
/// <para>sql语句的where条件：88、"id=88"</para></param>
|
||
public bool Exists(object where)
|
||
{
|
||
if (CheckDisposed()) { return false; }
|
||
if (where == null || Convert.ToString(where) == "")
|
||
{
|
||
_UI.PrimayAutoGetValue();
|
||
where = _sqlCreate.GetPrimaryWhere();
|
||
}
|
||
AopResult aopResult = AopResult.Default;
|
||
if (_aop.IsLoadAop)
|
||
{
|
||
_aop.Para.MAction = this;
|
||
_aop.Para.TableName = _sourceTableName;
|
||
_aop.Para.Row = _Data;
|
||
_aop.Para.Where = where;
|
||
_aop.Para.IsTransaction = dalHelper.IsOpenTrans;
|
||
aopResult = _aop.Begin(Aop.AopEnum.Exists);
|
||
}
|
||
if (aopResult == AopResult.Default || aopResult == AopResult.Continue)
|
||
{
|
||
ClearParameters();//清除系统参数
|
||
string countSql = _sqlCreate.GetExistsSql(where);
|
||
_aop.Para.ExeResult = Convert.ToString(dalHelper.ExeScalar(countSql, false)) == "1" ? true : false;
|
||
_aop.Para.IsSuccess = dalHelper.RecordsAffected != -2;
|
||
}
|
||
if (_aop.IsLoadAop && (aopResult == AopResult.Break || aopResult == AopResult.Continue))
|
||
{
|
||
_aop.End(Aop.AopEnum.Exists);
|
||
}
|
||
if (dalHelper.RecordsAffected == -2)
|
||
{
|
||
OnError();
|
||
}
|
||
return Convert.ToBoolean(_aop.Para.ExeResult);
|
||
}
|
||
#endregion
|
||
|
||
#region 其它方法
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// Get value from this.Data
|
||
/// <para>从Data属性里取值</para>
|
||
/// </summary>
|
||
public T Get<T>(object key)
|
||
{
|
||
return _Data.Get<T>(key);
|
||
}
|
||
|
||
|
||
/// <param name="defaultValue">defaultValue<para>值为Null时的默认替换值</para></param>
|
||
public T Get<T>(object key, T defaultValue)
|
||
{
|
||
return _Data.Get<T>(key, defaultValue);
|
||
}
|
||
/// <summary>
|
||
/// Set value to this.Data
|
||
/// <para>为Data属性设置值</para>
|
||
/// </summary>
|
||
/// <param name="key">columnName<para>列名</para></param>
|
||
/// <param name="value">value<para>值</para></param>
|
||
public MAction Set(object key, object value)
|
||
{
|
||
return Set(key, value, -1);
|
||
}
|
||
|
||
/// <param name="state">set value state (0: unchanged; 1: assigned, the same value [insertable]; 2: assigned, different values [updateable])
|
||
/// <para>设置值状态[0:未更改；1:已赋值,值相同[可插入]；2:已赋值,值不同[可更新]]</para></param>
|
||
public MAction Set(object key, object value, int state)
|
||
{
|
||
if (_Data[key] != null)
|
||
{
|
||
_Data.Set(key, value, state);
|
||
}
|
||
else
|
||
{
|
||
string msg = "MAction Set : can't find the ColumnName:" + key;
|
||
Log.Write(msg, LogType.DataBase.ToString());
|
||
//dalHelper.DebugInfo.Append(AppConst.HR + "Alarm : can't find the ColumnName:" + key);
|
||
}
|
||
return this;
|
||
}
|
||
/// <summary>
|
||
/// 为行连续设置值多个值
|
||
/// </summary>
|
||
/// <param name="startKey">起始行索引||起始列名</param>
|
||
/// <param name="values">多个值</param>
|
||
/// <returns></returns>
|
||
public MAction Sets(object startKey, params object[] values)
|
||
{
|
||
if (_Data[startKey] != null)
|
||
{
|
||
_Data.Sets(startKey, values);
|
||
}
|
||
else
|
||
{
|
||
string msg = "MAction Set : can't find the ColumnName:" + startKey;
|
||
Log.Write(msg, LogType.DataBase.ToString());
|
||
// dalHelper.DebugInfo.Append(AppConst.HR + "Alarm : can't find the ColumnName:" + startKey);
|
||
}
|
||
return this;
|
||
}
|
||
/// <summary>
|
||
/// Sets a custom expression for the Update operation.
|
||
/// <para>为Update操作设置自定义表达式。</para>
|
||
/// </summary>
|
||
/// <param name="updateExpression">as："a=a+1"<para>如："a=a+1"</para></param>
|
||
public MAction SetExpression(string updateExpression)
|
||
{
|
||
_sqlCreate.updateExpression = updateExpression;
|
||
return this;
|
||
}
|
||
/// <summary>
|
||
/// Parameterized pass [used when the Where condition is a parameterized (such as: name = @ name) statement]
|
||
/// <para>参数化传参[当Where条件为参数化(如：name=@name)语句时使用]</para>
|
||
/// </summary>
|
||
/// <param name="paraName">paraName<para>参数名称</para></param>
|
||
/// <param name="value">value<para>参数值</para></param>
|
||
public MAction SetPara(object paraName, object value)
|
||
{
|
||
return SetPara(paraName, value, DbType.String);
|
||
}
|
||
List<AopCustomDbPara> customParaNames = new List<AopCustomDbPara>();
|
||
|
||
/// <param name="dbType">dbType<para>参数类型</para></param>
|
||
public MAction SetPara(object paraName, object value, DbType dbType)
|
||
{
|
||
string name = Convert.ToString(paraName).Replace(":", "").Replace("@", "");
|
||
dalHelper.AddParameters(name, value, dbType, -1, ParameterDirection.Input);
|
||
foreach (AopCustomDbPara item in customParaNames)
|
||
{
|
||
if (item.ParaName.ToLower() == name.ToLower())
|
||
{
|
||
return this;
|
||
}
|
||
}
|
||
|
||
AopCustomDbPara para = new AopCustomDbPara();
|
||
para.ParaName = name;
|
||
para.Value = value;
|
||
para.ParaDbType = dbType;
|
||
customParaNames.Add(para);
|
||
if (_aop.IsLoadAop && _aop.Para.CustomDbPara == null)
|
||
{
|
||
_aop.Para.CustomDbPara = customParaNames;
|
||
}
|
||
|
||
|
||
return this;
|
||
}
|
||
|
||
/// <summary>
|
||
/// Aop scenes can only be used by the parameterization of the Senate
|
||
/// <para>Aop场景才可能使用的参数化传参</para>
|
||
/// </summary>
|
||
/// <param name="customParas">Paras<para>参数列表</para></param>
|
||
public MAction SetPara(List<AopCustomDbPara> customParas)
|
||
{
|
||
if (customParas != null && customParas.Count > 0)
|
||
{
|
||
foreach (AopCustomDbPara para in customParas)
|
||
{
|
||
SetPara(para.ParaName, para.Value, para.ParaDbType);
|
||
}
|
||
}
|
||
return this;
|
||
}
|
||
/// <summary>
|
||
/// Clears paras (from SetPara method)
|
||
/// <para>清除(SetPara设置的)自定义参数</para>
|
||
/// </summary>
|
||
public void ClearPara()
|
||
{
|
||
if (customParaNames.Count > 0)
|
||
{
|
||
if (dalHelper != null && dalHelper.Com.Parameters.Count > 0)
|
||
{
|
||
string paraName = string.Empty;
|
||
foreach (AopCustomDbPara item in customParaNames)
|
||
{
|
||
for (int i = dalHelper.Com.Parameters.Count - 1; i > -1; i--)
|
||
{
|
||
if (string.Compare(dalHelper.Com.Parameters[i].ParameterName.TrimStart(dalHelper.Pre), item.ParaName.ToString()) == 0)
|
||
{
|
||
dalHelper.Com.Parameters.RemoveAt(i);
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
customParaNames.Clear();
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 清除系统参数[保留自定义参数]
|
||
/// </summary>
|
||
private void ClearParameters()
|
||
{
|
||
if (dalHelper != null)
|
||
{
|
||
if (customParaNames.Count > 0)//带有自定义参数
|
||
{
|
||
if (dalHelper.Com.Parameters.Count > 0)
|
||
{
|
||
bool isBreak = false;
|
||
for (int i = dalHelper.Com.Parameters.Count - 1; i > -1; i--)
|
||
{
|
||
for (int j = 0; j < customParaNames.Count; j++)
|
||
{
|
||
if (string.Compare(dalHelper.Com.Parameters[i].ParameterName.TrimStart(dalHelper.Pre), customParaNames[j].ParaName.ToString()) == 0)
|
||
{
|
||
isBreak = true;
|
||
}
|
||
}
|
||
if (!isBreak)
|
||
{
|
||
dalHelper.Com.Parameters.RemoveAt(i);
|
||
isBreak = false;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
dalHelper.ClearParameters();
|
||
}
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// Specifies the column to read
|
||
/// <para>指定读取的列</para>
|
||
/// </summary>
|
||
/// <param name="columnNames">as："columnA","columnB as B"</param>
|
||
public MAction SetSelectColumns(params object[] columnNames)
|
||
{
|
||
bool isSplit = false;
|
||
if (columnNames.Length == 1)
|
||
{
|
||
string column = Convert.ToString(columnNames[0]);
|
||
if (column.IndexOf(" as ", StringComparison.OrdinalIgnoreCase) == -1)//避开"'xx,xx' as A
|
||
{
|
||
string[] items = Convert.ToString(columnNames[0]).Split(',');
|
||
if (items.Length > 1)
|
||
{
|
||
isSplit = true;
|
||
_sqlCreate.selectColumns = items;
|
||
}
|
||
}
|
||
}
|
||
if (!isSplit)
|
||
{
|
||
_sqlCreate.selectColumns = columnNames;
|
||
}
|
||
return this;
|
||
}
|
||
|
||
/// <summary>
|
||
/// Get where statement
|
||
/// <para>根据元数据列组合where条件。</para>
|
||
/// </summary>
|
||
/// <param name="isAnd">connect by and/or<para>true为and连接，反之为or链接</para></param>
|
||
public string GetWhere(bool isAnd, params MDataCell[] cells)
|
||
{
|
||
List<MDataCell> cs = new List<MDataCell>(cells.Length);
|
||
if (cells.Length > 0)
|
||
{
|
||
cs.AddRange(cells);
|
||
}
|
||
return SqlCreate.GetWhere(DataBaseType, isAnd, cs);
|
||
}
|
||
|
||
/// <param name="cells">MDataCell<para>单元格</para></param>
|
||
public string GetWhere(params MDataCell[] cells)
|
||
{
|
||
return GetWhere(true, cells);
|
||
}
|
||
|
||
|
||
|
||
#endregion
|
||
|
||
#region 事务操作
|
||
/// <summary>
|
||
/// Set the transaction level
|
||
/// <para>设置事务级别</para>
|
||
/// </summary>
|
||
/// <param name="level">IsolationLevel</param>
|
||
public MAction 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 成员
|
||
public void Dispose()
|
||
{
|
||
Dispose(false);
|
||
}
|
||
/// <summary>
|
||
/// Dispose
|
||
/// <para>释放资源</para>
|
||
/// </summary>
|
||
internal void Dispose(bool isOnError)
|
||
{
|
||
hasDisposed = true;
|
||
if (dalHelper != null)
|
||
{
|
||
if (!dalHelper.IsOnExceptionEventNull)
|
||
{
|
||
dalHelper.OnExceptionEvent -= new DalBase.OnException(_DataSqlHelper_OnExceptionEvent);
|
||
}
|
||
_debugInfo = dalHelper.DebugInfo.ToString();
|
||
dalHelper.Dispose();
|
||
if (!isOnError)
|
||
{
|
||
dalHelper = null;
|
||
|
||
if (_sqlCreate != null)
|
||
{
|
||
_sqlCreate = null;
|
||
}
|
||
}
|
||
}
|
||
if (!isOnError)
|
||
{
|
||
//if (_noSqlAction != null)
|
||
//{
|
||
// _noSqlAction.Dispose();
|
||
//}
|
||
if (_aop != null)
|
||
{
|
||
_aop = null;
|
||
}
|
||
}
|
||
}
|
||
internal void OnError()
|
||
{
|
||
if (dalHelper != null && dalHelper.IsOpenTrans)
|
||
{
|
||
Dispose(true);
|
||
}
|
||
}
|
||
bool hasDisposed = false;
|
||
private bool CheckDisposed()
|
||
{
|
||
if (hasDisposed || _Data.Columns.Count == 0)
|
||
{
|
||
Error.Throw("The current object 'MAction' has been disposed");
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
#endregion
|
||
|
||
|
||
}
|
||
//AOP 部分
|
||
public partial class MAction
|
||
{
|
||
/// <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;
|
||
}
|
||
}
|
||
}
|
||
#region Aop操作
|
||
private InterAop _aop = new InterAop();
|
||
/// <summary>
|
||
/// Set Aop State
|
||
/// <para>设置Aop状态</para>
|
||
/// </summary>
|
||
public MAction SetAopState(AopOp op)
|
||
{
|
||
_aop.aopOp = op;
|
||
return this;
|
||
}
|
||
/// <summary>
|
||
/// Pass additional parameters for Aop use
|
||
/// <para>传递额外的参数供Aop使用</para>
|
||
/// </summary>
|
||
public MAction SetAopPara(object para)
|
||
{
|
||
_aop.Para.AopPara = para;
|
||
return this;
|
||
}
|
||
|
||
#endregion
|
||
}
|
||
//UI 部分
|
||
public partial class MAction
|
||
{
|
||
private MActionUI _UI;
|
||
/// <summary>
|
||
/// Manipulate UI
|
||
/// <para>UI操作</para>
|
||
/// </summary>
|
||
public MActionUI UI
|
||
{
|
||
get
|
||
{
|
||
return _UI;
|
||
}
|
||
}
|
||
private SqlCreate _sqlCreate;
|
||
/// <summary>
|
||
/// for build where sql easyer
|
||
/// <para>UI操作</para>
|
||
/// </summary>
|
||
internal SqlCreate Sql
|
||
{
|
||
get
|
||
{
|
||
return _sqlCreate;
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|