using System;
using System.Data;
using System.Collections.Generic;
using System.Data.Common;
using HcUtility.Comm;
using HcUtility.Logging;
using Microsoft.Practices.EnterpriseLibrary.Data;
using System.ComponentModel;
namespace HcUtility.Core
{
///
/// 功能: 保存的底层处理
/// 创建: 吴伟 2009-05-08
///
///
public class ModelObjectDB_Base : IModelObjectDB
{
#region Save
public DBResult Save(ModelObjectBase modData, string dbname = "")
{
DBResult result = new DBResult();
if (modData == null)
{
result.Success = false;
result.Message = "没有输入任何需要修改的数据";
}
List dataList = new List();
dataList.Add(modData);
return Save(dataList, dbname);
}
///
/// 功能: 保存数据的统一处理
/// 创建: ddlucky 2017-03-01
/// 说明:
/// 输入参数:
/// dataList:保存数据的列表
/// 输出参数:(无)
/// 返回:
/// 返回DBResult类
/// .Success:true保存成功,false保存失败
/// .Message:返回的详细说明
///
///
///
///
/* 后期修改提示（wuwei 2009-07-07）: (因程序已基本测试完毕，暂时不做修改)
* 关于微软库Data Access事物的支持可以通过下面的方法使用：
using (DbConnection connection = db.CreateConnection())
{
connection.Open();
DbTransaction transaction = connection.BeginTransaction();
try
{
// Credit the first account.
db.ExecuteNonQuery(creditCommand, transaction);
// Debit the second account.
db.ExecuteNonQuery(debitCommand, transaction);
// Commit the transaction.
transaction.Commit();
result = true;
}
catch
{
// Roll back the transaction.
transaction.Rollback();
}
connection.Close();
return result;
}
*/
public DBResult Save(List dataList, string dbname = "")
{
DBResult result = new DBResult();
result.Success = false;
result.Message = "保存数据出错";
//此主要用于检查前和检查后处理。
//在这些过程中生成的DbCommand因为需要事务控制不能在相应的方法中释放，需要回传后在此过程中释放
List cmdList = new List();
Database db = DatabaseFactory.CreateDatabase();
if (dbname != "") db = DatabaseFactory.CreateDatabase(dbname);
using (DbConnection con = db.CreateConnection())
{
con.Open();
//创建事务
DbTransaction tran = con.BeginTransaction();
try
{
//保存前处理
result = BeforeSaveHandler(dataList, db, con, tran, ref cmdList);
if (!result.Success)
{
throw new ModelDbException(result.Message);
}
//保存数据
foreach (ModelObjectBase modeldata in dataList)
{
result = SaveHeadAndBodyList(cmdList, db, con, tran, modeldata);
if (!result.Success)
throw new ModelDbException(result.Message);
}
//保存后处理
result = AfterSaveHandler(dataList, db, con, tran, ref cmdList);
if (!result.Success)
{
throw new ModelDbException(result.Message);
}
tran.Commit();
result.Success = true;
result.Message = "数据保存成功";
LoggingUtil.Write(result.Message, LoggingCategory.General, LoggingPriority.Lowest);
}
catch (Exception e)
{
tran.Rollback();
result.Success = false;
if (!(e is ModelDbException))
{
result.Message = e.ToString();
}
LoggingUtil.Write(e.ToString(), LoggingCategory.General, LoggingPriority.Normal);
}
finally
{
foreach (DbCommand cmd in cmdList)
{
if (cmd != null)
cmd.Dispose();
}
con.Close();
}
}
return result;
}
private DBResult SaveHeadAndBodyList(List cmdList, Database db, IDbConnection idbConn, IDbTransaction idbTran, ModelObjectBase modeldata)
{
DBResult result = new DBResult();
result.Success = false;
try
{
//主表保存
result = SaveHead(cmdList, db, idbConn, idbTran, modeldata);
if (!result.Success)
{
throw new ModelDbException(result.Message);
}
//明细表保存
if (modeldata.BodyList != null)
{
foreach (List moblist in modeldata.BodyList)
{
result = SaveBodyList(cmdList, db, idbConn, idbTran, moblist);
if (!result.Success)
{
throw new ModelDbException(result.Message);
}
}
}
result.Success = true;
result.Message = "保存成功";
}
catch (Exception se)
{
result.Message = se.Message;
result.Success = false;
}
return result;
}
private DBResult SaveHead(List cmdList, Database db, IDbConnection idbConn, IDbTransaction idbTran, ModelObjectBase modeldata)
{
DBResult result = new DBResult();
result.Success = false;
try
{
DbCommand cmdHead = null;
if (modeldata.DbOperationType == DbOperationType.DbotIns)
{
cmdHead = db.GetSqlStringCommand(modeldata.GenInsertSql());
}
else if (modeldata.DbOperationType == DbOperationType.DbotUpd)
{
cmdHead = db.GetSqlStringCommand(modeldata.GenUpdateSql());
}
else
{
cmdHead = db.GetSqlStringCommand(modeldata.GenDeleteSql());
}
cmdList.Add(cmdHead);
cmdHead.Connection = (DbConnection)idbConn;
cmdHead.Transaction = (DbTransaction)idbTran;
SetDbParam(modeldata, db, cmdHead);
cmdHead.ExecuteNonQuery();
result.Success = true;
result.Message = "保存成功";
}
catch (Exception e)
{
result.Success = false;
if (e is System.Data.OracleClient.OracleException && e.Message.Contains("ORA-00001"))
{
result.Message = "数据保存出现异常：数据已经存在,请刷新后再试";
}
else
{
result.Message = "数据保存出现异常!" + e.ToString();
}
}
return result;
}
private DBResult SaveBodyList(List cmdList, Database db, IDbConnection idbConn, IDbTransaction idbTran, List moblist)
{
DBResult result = new DBResult();
result.Success = false;
try
{
DbCommand cmdUpd = null;
DbCommand cmdIns = null;
DbCommand cmdDel = null;
foreach (ModelObjectBase mob in moblist)
{
//result= SaveHeadAndBodyList(cmdList, db,idbConn,idbTran, mob); //递归调用
//if (!result.Success)
// throw new Exception(result.Message);
switch (mob.DbOperationType)
{
case DbOperationType.DbotIns:
if (cmdIns == null)
{
cmdIns = db.GetSqlStringCommand(mob.GenInsertSql());
cmdIns.Connection = (DbConnection)idbConn;
cmdIns.Transaction = (DbTransaction)idbTran;
cmdList.Add(cmdIns);
}
SetDbParam(mob, db, cmdIns); //查看后台执行的sql语句中的参数数据
cmdIns.ExecuteNonQuery();
break;
case DbOperationType.DbotUpd:
if (cmdUpd == null)
{
cmdUpd = db.GetSqlStringCommand(mob.GenUpdateSql());
cmdUpd.Connection = (DbConnection)idbConn;
cmdUpd.Transaction = (DbTransaction)idbTran;
cmdList.Add(cmdUpd);
}
SetDbParam(mob, db, cmdUpd);
cmdUpd.ExecuteNonQuery();
break;
case DbOperationType.DbotDel:
if (cmdDel == null)
{
cmdDel = db.GetSqlStringCommand(mob.GenDeleteSql());
cmdDel.Connection = (DbConnection)idbConn;
cmdDel.Transaction = (DbTransaction)idbTran;
cmdList.Add(cmdDel);
}
SetDbParam(mob, db, cmdDel);
cmdDel.ExecuteNonQuery();
break;
}
foreach (List mobbodylist in mob.BodyList)
{
result = SaveBodyList(cmdList, db, idbConn, idbTran, mobbodylist);
if (!result.Success)
{
throw new ModelDbException(result.Message);
}
}
}
result.Success = true;
result.Message = "保存成功";
}
catch (Exception e)
{
result.Success = false;
result.Message = "保存出现异常!" + e.Message;
}
return result;
}
///
/// 功能: 用于保存前的处理,继承类可以重写此方法
/// 创建: ddlucky 2017-03-01
/// 说明:
/// 输入参数:
/// dataList:保存数据的列表
/// db: Microsoft.Practices.EnterpriseLibrary.Data.Database操作类
/// idbConn: 数据库连接
/// idbTran: 生成的事务
/// listCmd: DbCommand的列表主要用于在自己的过程中生成的DbCommand因为事务控制不能直接释放,需要回传统一释放
/// 输出参数:(无)
/// 返回:
/// 返回DBResult类
/// .Success:true保存成功,false保存失败
/// .Message:返回的详细说明
///
///
protected virtual DBResult BeforeSaveHandler(List dataList, Database db,
IDbConnection idbConn, IDbTransaction idbTran, ref List listCmd)
{
DBResult result = new DBResult();
result.Success = true;
result.Message = "";
return result;
}
///
/// 功能: 用于保存后的处理,继承类可以重写此方法
/// 创建: ddlucky 2017-03-01
/// 说明:
/// 输入参数:
/// dataList:保存数据的列表
/// db: Microsoft.Practices.EnterpriseLibrary.Data.Database操作类
/// idbConn: 数据库连接
/// idbTran: 生成的事务
/// listCmd: DbCommand的列表主要用于在自己的过程中生成的DbCommand因为事务控制不能直接释放,需要回传统一释放
/// 输出参数:(无)
/// 返回:
/// 返回DBResult类
/// .Success:true保存成功,false保存失败
/// .Message:返回的详细说明
///
virtual protected DBResult AfterSaveHandler(List dataList, Database db,
IDbConnection idbConn, IDbTransaction idbTran, ref List listCmd)
{
DBResult result = new DBResult();
result.Success = true;
result.Message = "";
return result;
}
#endregion
#region Delete
public DBResult Delete(ModelObjectBase modeldata, params string[] sqllist)
{
var result = new DBResult();
if (modeldata == null)
{
result.Success = false;
result.Message = "没有输入任何需要修改的数据";
return result;
}
modeldata.DbOperationType = DbOperationType.DbotDel;
Database db = DatabaseFactory.CreateDatabase();
using (DbConnection conn = db.CreateConnection())
{
conn.Open();
//创建事务
DbTransaction tran = conn.BeginTransaction();
try
{
foreach (var sql in sqllist)
{
var cmdbody = db.GetSqlStringCommand(sql);
db.ExecuteNonQuery(cmdbody, tran);
}
//删除数据
var cmd = db.GetSqlStringCommand(modeldata.GenDeleteSql());
SetDbParam(modeldata, db, cmd);
db.ExecuteNonQuery(cmd, tran);
tran.Commit();
result.Success = true;
result.Message = "删除数据成功";
LoggingUtil.Write(result.Message, LoggingCategory.General, LoggingPriority.Lowest);
}
catch (Exception e)
{
tran.Rollback();
result.Success = false;
if (!(e is ModelDbException))
{
result.Message = e.ToString();
}
LoggingUtil.Write(e.ToString(), LoggingCategory.General, LoggingPriority.Normal);
}
finally
{
conn.Close();
}
}
result.Success = true;
result.Message = "删除数据成功";
return result;
}
#endregion
#region Delete 并非删除，而是将deleted置为1，并记录时间和操作人
public DBResult Delete(ModelObjectBase modeldata, string USERID, bool updelete, params string[] sqllist)
{
var result = new DBResult();
if (modeldata == null)
{
result.Success = false;
result.Message = "没有输入任何需要修改的数据";
return result;
}
modeldata.DbOperationType = DbOperationType.DbotDel;
Database db = DatabaseFactory.CreateDatabase();
using (DbConnection conn = db.CreateConnection())
{
conn.Open();
//创建事务
DbTransaction tran = conn.BeginTransaction();
try
{
foreach (var sql in sqllist)
{
var cmdbody = db.GetSqlStringCommand(sql);
db.ExecuteNonQuery(cmdbody, tran);
}
//删除数据
var cmd = db.GetSqlStringCommand(modeldata.GenDeleteSql(USERID));
SetDbParam(modeldata, db, cmd);
db.ExecuteNonQuery(cmd, tran);
tran.Commit();
result.Success = true;
result.Message = "删除数据成功";
LoggingUtil.Write(result.Message, LoggingCategory.General, LoggingPriority.Lowest);
}
catch (Exception e)
{
tran.Rollback();
result.Success = false;
if (!(e is ModelDbException))
{
result.Message = e.ToString();
}
LoggingUtil.Write(e.ToString(), LoggingCategory.General, LoggingPriority.Normal);
}
finally
{
conn.Close();
}
}
result.Success = true;
result.Message = "删除数据成功";
return result;
}
#endregion
#region 设置sql语句当中的@字段值
virtual protected void SetDbParam(ModelObjectBase data, Database db, DbCommand cmd)
{
var paramName = String.Empty;
DbType dbType;
PropertyDescriptorCollection pdcList = TypeDescriptor.GetProperties(data);
cmd.Parameters.Clear();
foreach (PropertyDescriptor pdc in pdcList)
{
foreach (Attribute attr in pdc.Attributes)
{
if (attr is ModelDBAttribute)
{
ModelDBAttribute a = (ModelDBAttribute)attr;
if (data.DbOperationType == DbOperationType.DbotIns)
{
if (ModelDBOprationType.Insert == (ModelDBOprationType.Insert & a.MDBType))
{
paramName = a.InsParamName == String.Empty ? pdc.Name : a.InsParamName;
dbType = TypeConvertUtil.ConverTypeToDbType(pdc.PropertyType);
db.AddInParameter(cmd, paramName, dbType, pdc.GetValue(data));
}
}
else if (data.DbOperationType == DbOperationType.DbotUpd)
{
if (ModelDBOprationType.Edit == (ModelDBOprationType.Edit & a.MDBType))
{
paramName = a.UpdParamName == String.Empty ? pdc.Name : a.UpdParamName;
dbType = TypeConvertUtil.ConverTypeToDbType(pdc.PropertyType);
db.AddInParameter(cmd, paramName, dbType, pdc.GetValue(data));
}
}
else
{
if (ModelDBOprationType.Delete == (ModelDBOprationType.Delete & a.MDBType))
{
paramName = a.DelParamName == String.Empty ? pdc.Name : a.DelParamName;
dbType = TypeConvertUtil.ConverTypeToDbType(pdc.PropertyType);
db.AddInParameter(cmd, paramName, dbType, pdc.GetValue(data));
}
}
}
}
}
if (data.Extended())
{
foreach (var ed in data.ExtendDataList)
{
if (data.DbOperationType == DbOperationType.DbotIns)
{
if (ed.MDB.needInsert())
{
db.AddInParameter(cmd, ed.Name, DbType.String, ed.Value);
}
}
else if (data.DbOperationType == DbOperationType.DbotUpd)
{
if (ed.MDB.needEdit())
{
db.AddInParameter(cmd, ed.Name, DbType.String, ed.Value);
}
}
else
{
if (ed.MDB.needInsert())
{
db.AddInParameter(cmd, ed.Name, DbType.String, ed.Value);
}
}
}
}
}
#endregion
}
public class ModelObjectDB : ModelObjectDB_Base
{
#region Save
public DBResult Save(ModelObjectBase modData, string dbname = "")
{
DBResult result = new DBResult();
if (modData == null)
{
result.Success = false;
result.Message = "没有输入任何需要修改的数据";
}
List dataList = new List();
dataList.Add(modData);
return Save(dataList, dbname);
}
///
/// 功能: 保存数据的统一处理
/// 创建: ddlucky 2017-03-01
/// 说明:
/// 输入参数:
/// dataList:保存数据的列表
/// 输出参数:(无)
/// 返回:
/// 返回DBResult类
/// .Success:true保存成功,false保存失败
/// .Message:返回的详细说明
///
///
///
///
public DBResult Save(List dataList, string dbname = "")
{
DBResult result = new DBResult();
result.Success = false;
result.Message = "保存数据出错";
//此主要用于检查前和检查后处理。
//在这些过程中生成的DbCommand因为需要事务控制不能在相应的方法中释放，需要回传后在此过程中释放
List cmdList = new List();
Database db = DatabaseFactory.CreateDatabase();
if (dbname != "") db = DatabaseFactory.CreateDatabase(dbname);
using (DbConnection con = db.CreateConnection())
{
con.Open();
//创建事务
DbTransaction tran = con.BeginTransaction();
try
{
//保存前处理
//此处主要进行时间标签的验证
result = BeforeSaveHandler(dataList, db, con, tran, ref cmdList);
if (!result.Success)
{
throw new ModelDbException(result.Message);
}
//保存数据
foreach (ModelObjectBase modeldata in dataList)
{
result = SaveHeadAndBodyList(cmdList, db, con, tran, modeldata);
if (!result.Success)
throw new ModelDbException(result.Message);
}
//保存后处理
//保存后处理用于执行一个存储过程，以进行一些业务存储之后的相关数据处理
//以后改到对象内进行配置 不在此处执行 以提高批量存储速度
//result = AfterSaveHandler(dataList, db, con, tran, ref cmdList);
//if (!result.Success)
//{
// throw new ModelDbException(result.Message);
//}
tran.Commit();
result.Success = true;
result.Message = "数据保存成功";
LoggingUtil.Write(result.Message, LoggingCategory.General, LoggingPriority.Lowest);
}
catch (Exception e)
{
tran.Rollback();
result.Success = false;
if (!(e is ModelDbException))
{
result.Message = e.ToString();
}
LoggingUtil.Write(e.ToString(), LoggingCategory.General, LoggingPriority.Normal);
}
finally
{
foreach (DbCommand cmd in cmdList)
{
if (cmd != null)
cmd.Dispose();
}
con.Close();
}
}
return result;
}
private DBResult SaveHeadAndBodyList(List cmdList, Database db, IDbConnection idbConn, IDbTransaction idbTran, ModelObjectBase modeldata)
{
DBResult result = new DBResult();
result.Success = false;
try
{
//主表保存
result = SaveHead(cmdList, db, idbConn, idbTran, modeldata);
if (!result.Success)
{
throw new ModelDbException(result.Message);
}
//明细表保存
if (modeldata.BodyList != null)
{
foreach (List moblist in modeldata.BodyList)
{
result = SaveBodyList(cmdList, db, idbConn, idbTran, moblist);
if (!result.Success)
{
throw new ModelDbException(result.Message);
}
}
}
result.Success = true;
result.Message = "保存成功";
}
catch (Exception se)
{
result.Message = se.Message;
result.Success = false;
}
return result;
}
private DBResult SaveHead(List cmdList, Database db, IDbConnection idbConn, IDbTransaction idbTran, ModelObjectBase modeldata)
{
DBResult result = new DBResult();
result.Success = false;
try
{
DbCommand cmdHead = null;
if (modeldata.DbOperationType == DbOperationType.DbotIns)
{
cmdHead = db.GetSqlStringCommand(modeldata.GenInsertSql());
}
else if (modeldata.DbOperationType == DbOperationType.DbotUpd)
{
cmdHead = db.GetSqlStringCommand(modeldata.GenUpdateSql());
}
else
{
cmdHead = db.GetSqlStringCommand(modeldata.GenDeleteSql());
}
cmdList.Add(cmdHead);
cmdHead.Connection = (DbConnection)idbConn;
cmdHead.Transaction = (DbTransaction)idbTran;
SetDbParam(modeldata, db, cmdHead);
cmdHead.ExecuteNonQuery();
result.Success = true;
result.Message = "保存成功";
}
catch (Exception e)
{
result.Success = false;
if (e is System.Data.OracleClient.OracleException && e.Message.Contains("ORA-00001"))
{
result.Message = "数据保存出现异常：数据已经存在,请刷新后再试";
}
else
{
result.Message = "数据保存出现异常!" + e.ToString();
}
}
return result;
}
private DBResult SaveBodyList(List cmdList, Database db, IDbConnection idbConn, IDbTransaction idbTran, List moblist)
{
DBResult result = new DBResult();
result.Success = false;
try
{
DbCommand cmdUpd = null;
DbCommand cmdIns = null;
DbCommand cmdDel = null;
foreach (ModelObjectBase mob in moblist)
{
//result= SaveHeadAndBodyList(cmdList, db,idbConn,idbTran, mob); //递归调用
//if (!result.Success)
// throw new Exception(result.Message);
switch (mob.DbOperationType)
{
case DbOperationType.DbotIns:
if (cmdIns == null)
{
cmdIns = db.GetSqlStringCommand(mob.GenInsertSql());
cmdIns.Connection = (DbConnection)idbConn;
cmdIns.Transaction = (DbTransaction)idbTran;
cmdList.Add(cmdIns);
}
SetDbParam(mob, db, cmdIns); //查看后台执行的sql语句中的参数数据
cmdIns.ExecuteNonQuery();
break;
case DbOperationType.DbotUpd:
if (cmdUpd == null)
{
cmdUpd = db.GetSqlStringCommand(mob.GenUpdateSql());
cmdUpd.Connection = (DbConnection)idbConn;
cmdUpd.Transaction = (DbTransaction)idbTran;
cmdList.Add(cmdUpd);
}
SetDbParam(mob, db, cmdUpd);
cmdUpd.ExecuteNonQuery();
break;
case DbOperationType.DbotDel:
if (cmdDel == null)
{
cmdDel = db.GetSqlStringCommand(mob.GenDeleteSql());
cmdDel.Connection = (DbConnection)idbConn;
cmdDel.Transaction = (DbTransaction)idbTran;
cmdList.Add(cmdDel);
}
SetDbParam(mob, db, cmdDel);
cmdDel.ExecuteNonQuery();
break;
}
foreach (List mobbodylist in mob.BodyList)
{
result = SaveBodyList(cmdList, db, idbConn, idbTran, mobbodylist);
if (!result.Success)
{
throw new ModelDbException(result.Message);
}
}
}
result.Success = true;
result.Message = "保存成功";
}
catch (Exception e)
{
result.Success = false;
result.Message = "保存出现异常!" + e.Message;
}
return result;
}
///
/// 功能: 用于保存前的处理,继承类可以重写此方法
/// 创建: ddlucky 2017-03-01
/// 说明:
/// 输入参数:
/// dataList:保存数据的列表
/// db: Microsoft.Practices.EnterpriseLibrary.Data.Database操作类
/// idbConn: 数据库连接
/// idbTran: 生成的事务
/// listCmd: DbCommand的列表主要用于在自己的过程中生成的DbCommand因为事务控制不能直接释放,需要回传统一释放
/// 输出参数:(无)
/// 返回:
/// 返回DBResult类
/// .Success:true保存成功,false保存失败
/// .Message:返回的详细说明
///
///
protected virtual DBResult BeforeSaveHandler(List dataList, Database db,
IDbConnection idbConn, IDbTransaction idbTran, ref List listCmd)
{
DBResult result = new DBResult();
result.Success = true;
result.Message = "";
return result;
}
///
/// 功能: 用于保存后的处理,继承类可以重写此方法
/// 创建: ddlucky 2017-03-01
/// 说明:
/// 输入参数:
/// dataList:保存数据的列表
/// db: Microsoft.Practices.EnterpriseLibrary.Data.Database操作类
/// idbConn: 数据库连接
/// idbTran: 生成的事务
/// listCmd: DbCommand的列表主要用于在自己的过程中生成的DbCommand因为事务控制不能直接释放,需要回传统一释放
/// 输出参数:(无)
/// 返回:
/// 返回DBResult类
/// .Success:true保存成功,false保存失败
/// .Message:返回的详细说明
///
protected virtual DBResult AfterSaveHandler(List dataList, Database db,
IDbConnection idbConn, IDbTransaction idbTran, ref List listCmd)
{
DBResult result = new DBResult();
result.Success = true;
result.Message = "";
return result;
}
#endregion
#region Delete
public DBResult Delete(ModelObjectBase modeldata, params string[] sqllist)
{
var result = new DBResult();
if (modeldata == null)
{
result.Success = false;
result.Message = "没有输入任何需要修改的数据";
return result;
}
modeldata.DbOperationType = DbOperationType.DbotDel;
Database db = DatabaseFactory.CreateDatabase();
using (DbConnection conn = db.CreateConnection())
{
conn.Open();
//创建事务
DbTransaction tran = conn.BeginTransaction();
try
{
foreach (var sql in sqllist)
{
var cmdbody = db.GetSqlStringCommand(sql);
db.ExecuteNonQuery(cmdbody, tran);
}
//删除数据
var cmd = db.GetSqlStringCommand(modeldata.GenDeleteSql());
SetDbParam(modeldata, db, cmd);
db.ExecuteNonQuery(cmd, tran);
tran.Commit();
result.Success = true;
result.Message = "删除数据成功";
LoggingUtil.Write(result.Message, LoggingCategory.General, LoggingPriority.Lowest);
}
catch (Exception e)
{
tran.Rollback();
result.Success = false;
if (!(e is ModelDbException))
{
result.Message = e.ToString();
}
LoggingUtil.Write(e.ToString(), LoggingCategory.General, LoggingPriority.Normal);
}
finally
{
conn.Close();
}
}
result.Success = true;
result.Message = "删除数据成功";
return result;
}
#endregion
#region Delete 并非删除，而是将deleted置为1，并记录时间和操作人
///
/// ///Delete 并非删除，而是将deleted置为1，并记录时间和操作人
///
///
///
///
///
///
public DBResult Delete(ModelObjectBase modeldata, string USERID, bool updelete, params string[] sqllist)
{
var result = new DBResult();
if (modeldata == null)
{
result.Success = false;
result.Message = "没有输入任何需要修改的数据";
return result;
}
modeldata.DbOperationType = DbOperationType.DbotDel;
Database db = DatabaseFactory.CreateDatabase();
using (DbConnection conn = db.CreateConnection())
{
conn.Open();
//创建事务
DbTransaction tran = conn.BeginTransaction();
try
{
foreach (var sql in sqllist)
{
var cmdbody = db.GetSqlStringCommand(sql);
db.ExecuteNonQuery(cmdbody, tran);
}
//删除数据
var cmd = db.GetSqlStringCommand(modeldata.GenDeleteSql(USERID));
SetDbParam(modeldata, db, cmd);
db.ExecuteNonQuery(cmd, tran);
tran.Commit();
result.Success = true;
result.Message = "删除数据成功";
LoggingUtil.Write(result.Message, LoggingCategory.General, LoggingPriority.Lowest);
}
catch (Exception e)
{
tran.Rollback();
result.Success = false;
if (!(e is ModelDbException))
{
result.Message = e.ToString();
}
LoggingUtil.Write(e.ToString(), LoggingCategory.General, LoggingPriority.Normal);
}
finally
{
conn.Close();
}
}
result.Success = true;
result.Message = "删除数据成功";
return result;
}
#endregion
#region 设置sql语句当中的@字段值
protected virtual void SetDbParam(ModelObjectBase data, Database db, DbCommand cmd)
{
var paramName = String.Empty;
DbType dbType;
PropertyDescriptorCollection pdcList = TypeDescriptor.GetProperties(data);
cmd.Parameters.Clear();
foreach (PropertyDescriptor pdc in pdcList)
{
foreach (Attribute attr in pdc.Attributes)
{
if (attr is ModelDBAttribute)
{
ModelDBAttribute a = (ModelDBAttribute)attr;
if (data.DbOperationType == DbOperationType.DbotIns)
{
if (ModelDBOprationType.Insert == (ModelDBOprationType.Insert & a.MDBType))
{
paramName = a.InsParamName == String.Empty ? pdc.Name : a.InsParamName;
dbType = TypeConvertUtil.ConverTypeToDbType(pdc.PropertyType);
db.AddInParameter(cmd, paramName, dbType, pdc.GetValue(data));
}
}
else if (data.DbOperationType == DbOperationType.DbotUpd)
{
if (ModelDBOprationType.Edit == (ModelDBOprationType.Edit & a.MDBType))
{
paramName = a.UpdParamName == String.Empty ? pdc.Name : a.UpdParamName;
dbType = TypeConvertUtil.ConverTypeToDbType(pdc.PropertyType);
db.AddInParameter(cmd, paramName, dbType, pdc.GetValue(data));
}
}
else
{
if (ModelDBOprationType.Delete == (ModelDBOprationType.Delete & a.MDBType))
{
paramName = a.DelParamName == String.Empty ? pdc.Name : a.DelParamName;
dbType = TypeConvertUtil.ConverTypeToDbType(pdc.PropertyType);
db.AddInParameter(cmd, paramName, dbType, pdc.GetValue(data));
}
}
}
}
}
if (data.Extended())
{
foreach (var ed in data.ExtendDataList)
{
if (data.DbOperationType == DbOperationType.DbotIns)
{
if (ed.MDB.needInsert())
{
db.AddInParameter(cmd, ed.Name, DbType.String, ed.Value);
}
}
else if (data.DbOperationType == DbOperationType.DbotUpd)
{
if (ed.MDB.needEdit())
{
db.AddInParameter(cmd, ed.Name, DbType.String, ed.Value);
}
}
else
{
if (ed.MDB.needDelete())
{
db.AddInParameter(cmd, ed.Name, DbType.String, ed.Value);
}
}
}
}
}
#endregion
}
}