///*************************************************************************/
|
///*
|
///* 文件名 ：GenerateSqlCmdByObjectClass.cs
|
///*
|
///* 程序说明 : 由对象实体类模型创建SQL命令生成器
|
///* 原创作者 ：孙中吕
|
///*
|
///* Copyright 2006-2021 C/S框架网 www.csframework.com
|
///*
|
///**************************************************************************/
|
|
using System;
|
using System.Collections;
|
using System.Data;
|
using System.Data.Common;
|
using System.Reflection;
|
|
namespace CSFrameworkV5.Core.CodeGenerator
|
{
|
/// <summary>
|
/// 由对象实体类模型创建SQL命令生成器
|
/// </summary>
|
public class GenerateSqlCmdByObjectClass : GenerateSqlCmdBase
|
{
|
/// <summary>
|
/// 构造器
|
/// </summary>
|
/// <param name="ORM_Model">表结构字段定义类</param>
|
public GenerateSqlCmdByObjectClass(Type ORM_Model, DataTable ORM_Table,
|
ICommandFactory factory)
|
: base(factory)
|
{
|
GenerateSQL(ORM_Model, ORM_Table);
|
}
|
|
/// <summary>
|
/// 构造器
|
/// </summary>
|
/// <param name="ORM_Model">表结构字段定义类</param>
|
public GenerateSqlCmdByObjectClass(Type ORM_Model, DataTable ORM_Table,
|
ICommandFactory factory, GeneratedSQLEventHandle eventHandle)
|
: base(factory)
|
{
|
GenerateSQL(ORM_Model, ORM_Table);
|
|
//触发事件
|
if (eventHandle != null)
|
eventHandle(_sqlInsert, _sqlDelete, _sqlUpdate);
|
}
|
|
/// <summary>
|
/// 构造器
|
/// </summary>
|
/// <param name="ORM_Model">ORM类的类型,如：typeof(tb_PO),typeof(tb_SO)</param>
|
public void GenerateSQL(Type ORM_Model, DataTable ORM_Table)
|
{
|
object[] attrClass;
|
|
//查找ORM的属性定义
|
ORM_TableAttribute classAttribute = null;
|
attrClass =
|
ORM_Model.GetCustomAttributes(typeof(ORM_TableAttribute),
|
false);
|
if (attrClass != null && attrClass.Length == 0)
|
throw new Exception("ORM_ObjectClassAttribute未定义!");
|
classAttribute = attrClass[0] as ORM_TableAttribute;
|
|
//查找ORM控制并发的属性定义
|
ORM_ConcurrentAttribute concurrentAttribute = null;
|
attrClass =
|
ORM_Model.GetCustomAttributes(typeof(ORM_ConcurrentAttribute),
|
false);
|
if (attrClass != null && attrClass.Length > 0 &&
|
classAttribute.IsSummaryTable) //仅主表控制并发
|
{
|
concurrentAttribute = attrClass[0] as ORM_ConcurrentAttribute;
|
_ConcurrentAttribute = concurrentAttribute;
|
}
|
|
//是否主表属性
|
_IsSummary = classAttribute.IsSummaryTable;
|
_PrimaryFieldName =
|
classAttribute.PrimaryKey; //主键，复合主键盘用";"分开
|
|
//生成一个新的对象
|
var obj = ORM_Model.Assembly.CreateInstance(ORM_Model.FullName);
|
|
//获取类中的所有属性
|
var infosSelf = ORM_Model.GetProperties();
|
var infosBase = ORM_Model.BaseType.GetProperties();
|
|
PropertyInfo[] infos = null;
|
if (infosBase.Length == 0)
|
{
|
infos = infosSelf;
|
}
|
else
|
{
|
var iLength = infosBase.Length;
|
Array.Resize<PropertyInfo>(ref infosBase,
|
infosBase.Length + infosSelf.Length); //相加两数组
|
infosSelf.CopyTo(infosBase, iLength);
|
infos = infosBase;
|
}
|
|
var fieldArr = new ArrayList();
|
|
_cmdInsert = _Factory.CreateCommand();
|
_cmdUpdate = _Factory.CreateCommand();
|
_cmdDelete = _Factory.CreateCommand();
|
|
var paramSymbol = _Factory.ParamSymboName;
|
DbParameter p;
|
|
foreach (var info in infos)
|
{
|
//取字段属性定义
|
var attrField =
|
info.GetCustomAttributes(typeof(ORM_FieldAttribute), false);
|
if (attrField == null || attrField.Length == 0) continue;
|
|
var fieldName = info.Name;
|
var fieldAttr = attrField[0] as ORM_FieldAttribute;
|
if (ORM_Table.Columns[fieldName] == null) continue;
|
|
//构造SQL命令带参数的SQL语句
|
if (fieldAttr.IsAddOrUpdate)
|
{
|
//构造带参数的Insert命令的SQL语句
|
if (!_cmdInsert.Parameters.Contains(paramSymbol +
|
fieldName))
|
{
|
p = _Factory.CreateParameter(paramSymbol + fieldName,
|
fieldAttr.Type, fieldAttr.Size, fieldName);
|
_cmdInsert.Parameters.Add(p);
|
}
|
|
//构造带参数的Update命令的SQL语句
|
if (!_cmdUpdate.Parameters.Contains(paramSymbol +
|
fieldName))
|
{
|
p = _Factory.CreateParameter(paramSymbol + fieldName,
|
fieldAttr.Type, fieldAttr.Size, fieldName);
|
_cmdUpdate.Parameters.Add(p);
|
}
|
|
var colProper = new ColumnProperty(fieldName,
|
fieldAttr.IsPrimaryKey ? true : false);
|
fieldArr.Add(colProper);
|
}
|
|
//生成主键的参数
|
if (fieldAttr.IsPrimaryKey)
|
{
|
if (!_cmdUpdate.Parameters.Contains(paramSymbol +
|
fieldName))
|
{
|
p = _Factory.CreateParameter(paramSymbol + fieldName,
|
fieldAttr.Type, fieldAttr.Size, fieldName);
|
_cmdUpdate.Parameters.Add(p);
|
}
|
|
if (!_cmdDelete.Parameters.Contains(paramSymbol +
|
fieldName))
|
{
|
p = _Factory.CreateParameter(paramSymbol + fieldName,
|
fieldAttr.Type, fieldAttr.Size, fieldName);
|
_cmdDelete.Parameters.Add(p);
|
}
|
}
|
|
//控制并发的字段名
|
if (concurrentAttribute != null &&
|
concurrentAttribute.TimestampFieldName == fieldName)
|
if (!_cmdUpdate.Parameters.Contains(paramSymbol +
|
fieldName))
|
{
|
p = _Factory.CreateParameter(paramSymbol + fieldName,
|
fieldAttr.Type, fieldAttr.Size, fieldName);
|
_cmdUpdate.Parameters.Add(p);
|
}
|
|
|
//流水号字段名
|
if (fieldAttr.IsDocFieldName) _DocNoFieldName = fieldName;
|
|
//外键字段名
|
if (fieldAttr.IsForeignKey)
|
_ForeignFieldName =
|
(string.IsNullOrEmpty(_ForeignFieldName)
|
? ""
|
: _ForeignFieldName + ";") + fieldName; //组合外键
|
}
|
|
_sqlInsert = GenerateInsertSql(classAttribute.TableName,
|
classAttribute.PrimaryKey, fieldArr); //新增的SQL
|
_sqlUpdate = GenerateUpdateSql(classAttribute.TableName,
|
classAttribute.PrimaryKey, fieldArr); //修改的SQL
|
_sqlDelete = GenerateDeleteSql(classAttribute.TableName,
|
classAttribute.PrimaryKey); //删除的SQL
|
}
|
}
|
}
|
