using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using Ant.Frame;
using Ant.Data;
using System.Reflection;
using Ant.Descriptors;
using Ant.Common;
namespace Ant.ORM
{
class MySqlQueryCommandBuilder : QueryCommandBuilder
{
public override QueryCommand GetQueryCommand()
{
QueryCommand cmd = null;
EntityPersistType strtype = (!object.Equals(PersistType, null)) ? PersistType : Md.PersistType;
switch (strtype)
{
case EntityPersistType.Save:
cmd = ParserInsertCommand();
break;
case EntityPersistType.Update:
cmd = ParserUpdateCommand();
break;
case EntityPersistType.Delete:
cmd = ParserDeleteCommand();
break;
case EntityPersistType.Query:
cmd = ParserSelectCommand();
break;
case EntityPersistType.Sum:
cmd = ParserSumCommand();
break;
case EntityPersistType.QueryPage://查询分页
cmd = ParserQueryPageCommand();
break;
}
return cmd;
}
///
/// 解析Insert SQL
///
///
private QueryCommand ParserInsertCommand()
{
QueryCommand qc = new QueryCommand(); bool IsAutoincrement = false;
List columnlist = new List();
List paramlist = new List();
List valuelist = new List();
var typedesc = Md.FiledMeta.MemberColumnMap;
foreach (var kv in typedesc)
{
MemberInfo member = kv.Key;
MappingMemberDescriptor memberDescriptor = MetaDataManager.TryGetMappingMemberDescriptor(kv.Key, Md.FiledMeta);
var val = memberDescriptor.Column.Value;
if (!MetaDataManager.IsAutoIncrement(memberDescriptor, Md))
{
columnlist.Add(string.Format("[{0}]", memberDescriptor.Column.Name));
paramlist.Add("@" + memberDescriptor.Column.Name);
QueryParameter parameter = new QueryParameter();
parameter.ParameterName = "@" + memberDescriptor.Column.Name;
parameter.DbType = (DbType)AntUtils.TryGetDbType(memberDescriptor.Column.Type);
parameter.Direction = ParameterDirection.Input;
if (val.IsNull())
val = SetDefaultValue(parameter.DbType);
parameter.Value = val;
valuelist.Add("'" + val + "'");
qc.Parameters.Add(parameter);
}
}
string sqlstr = string.Format(ConstSql.SQL_INSERT_TABLE, Md.FiledMeta.Table.Name, columnlist.AppendStrings(), paramlist.AppendStrings(),
IsAutoincrement ? "select @@IDENTITY;" : string.Empty);
qc.CommandText = sqlstr;
qc.SqlString = string.Format(ConstSql.SQL_INSERT_TABLE, Md.FiledMeta.Table.Name, columnlist.AppendStrings(),
valuelist.AppendStrings(), IsAutoincrement ? "select @@IDENTITY;" : string.Empty);
return qc;
}
private QueryCommand ParserUpdateCommand()
{
//string strsql = string.Format(" UPDATE {0} SET {1} WHERE {2} ", Md.TableName, "", "");
QueryCommand qc = new QueryCommand(); string strwhere = string.Empty;
StringBuilder sql = new StringBuilder();//SQL语句
StringBuilder sqlstr = new StringBuilder();
List updateColumns = new List();//更新列
List StrupdateColumns = new List();
List WhereColumn = new List();//条件列
List StrWhereColumn = new List();//条件列
sql.AppendFormat("UPDATE [{0}] SET ", Md.FiledMeta.Table.Name);
List condition = new List();
#region 更新字段
if (Md.UpdateColumns.IsNull())
{
var typedesc = Md.FiledMeta.MemberColumnMap;
foreach (var kv in typedesc)
{
MemberInfo member = kv.Key;
MappingMemberDescriptor memberDescriptor = MetaDataManager.TryGetMappingMemberDescriptor(member, Md.FiledMeta);
if (!MetaDataManager.IsAutoIncrement(memberDescriptor, Md))
{
var column = memberDescriptor.Column;
updateColumns.Add(string.Format("[{0}]=:{0}", column.Name));
qc.Parameters.Add(":" + column.Name, (DbType)AntUtils.TryGetDbType(column.Type), column.Value);
StrupdateColumns.Add(string.Format("[{0}]='{1}'", column.Name, column.Value));
}
}
}
else
{
foreach (var column in Md.UpdateColumns)
{
if (column.Value.Value.IfNotNull())
{
updateColumns.Add(string.Format("[{0}]=:{0}", column.Key));
qc.Parameters.Add(":" + column.Key, (DbType)AntUtils.TryGetDbType(column.Value.Type), column.Value.Value);
StrupdateColumns.Add(string.Format("[{0}]='{1}'", column.Key, column.Value.Value));
}
}
}
#endregion
if (Md.FiledMeta.PrimaryKey.Column.Value.IfNotNull())//通过主键作用查询条件
{
WhereColumn.Add(string.Format("[{0}]=:{0}", Md.FiledMeta.PrimaryKey.MemberInfo.Name));
qc.Parameters.Add(":" + Md.FiledMeta.PrimaryKey.Column.Name, (DbType)AntUtils.TryGetDbType(Md.FiledMeta.PrimaryKey.Column.Type), Md.FiledMeta.PrimaryKey.Column.Value);
StrWhereColumn.Add(string.Format("[{0}]='{1}'", Md.FiledMeta.PrimaryKey.Column.Name, Md.FiledMeta.PrimaryKey.Column.Value));
}
else
{//通过查询实体进行查询
#region 给实体赋值的查询条件更新
foreach (var key in Md.WhereColumns.Values)
{
WhereColumn.Add(string.Format("[{0}]=:{0}", key.Name));
qc.Parameters.Add(":" + key.Name, (DbType)AntUtils.TryGetDbType(key.Type), key.Value);
StrWhereColumn.Add(string.Format("[{0}]={1}", key.Name, key.Value));
}
#endregion
}
if (updateColumns.Count > 0)//更新字段
{
#region 带时间戳
if (Md.FieldsColumns.ContainsKey("Version"))
{
//WhereColumn.Add(string.Format(" {0}+0=@{0}", Md.FieldMeteDatas["Version"].ColumnName));
WhereColumn.Add(string.Format(" CONVERT(bigint,{0})=:{0}", Md.FieldsColumns["Version"].Name));
qc.Parameters.Add(":" + Md.FieldsColumns["Version"].Name, (DbType)AntUtils.TryGetDbType(Md.FieldsColumns["Version"].Type), Md.FieldsColumns["Version"].Value);
StrWhereColumn.Add(string.Format(" CONVERT(bigint,{0})='{1}'", Md.FieldsColumns["Version"].Name, Md.FieldsColumns["Version"].Value));
}
#endregion
sql.Append(string.Join(",", updateColumns.ToArray())).Append(" WHERE ").Append(string.Join(" AND ", WhereColumn.ToArray()));
if (!string.IsNullOrEmpty(Md.WhereSql))
{//有自定义查询条件的时候
if (Md.WhereSql.Trim().Length > 0) WhereColumn.Add(Md.WhereSql);
}
if (Predicate.IfNotNull())
{
var FlieldWhere = new FieldValueCollection();
strwhere = Predicate.GetSql(FlieldWhere, qc);//拼接SQL语句
if (!strwhere.IsEmpty())
{
sql.AppendFormat(" and {0} ", strwhere);
foreach (string key in FlieldWhere.Keys)
{
strwhere = strwhere.Replace(key.ToString(), "'" + FlieldWhere[key].ToString() + "'");
}
sqlstr.AppendFormat(" and {0} ", strwhere);
}
}
qc.CommandText = sql.ToString();
qc.SqlString = string.Format(ConstSql.SQL_UPDATE_TABLE, Md.FiledMeta.Table.Name, string.Join(",", StrupdateColumns.ToArray()), string.Join(" AND ", StrWhereColumn.ToArray()) + (strwhere.IsEmpty() ? strwhere : " and " + strwhere));
}
return qc;
}
private QueryCommand ParserDeleteCommand()
{
QueryCommand qc = new QueryCommand();
StringBuilder sql = new StringBuilder();
StringBuilder sqlstr = new StringBuilder();
List WhereColumn = new List();//条件列集合
List WhereColumnStr = new List();
if (!Md.FieldsColumns.IsNull())
{
foreach (string key in Md.FieldsColumns.Keys)//查询条件
{
//if (!Object.Equals(Md.Fields[key], null) || !Object.Equals(Md.Fields[key], DBNull.Value))
if (!(Md.FieldsColumns[key].IsNull()))
{
if (!Md.FieldsColumns[key].Value.ToString().IsEmpty())
{
WhereColumn.Add(string.Format(" [{0}].{1}=:{2} ", Md.FiledMeta.Table.Name, Md.FieldsColumns[key].Name, Md.FieldsColumns[key].Name));
qc.Parameters.Add(":" + Md.FieldsColumns[key].Name, (DbType)AntUtils.TryGetDbType(Md.FieldsColumns[key].Type), Md.FieldsColumns[key].Value);
WhereColumnStr.Add(string.Format(" [{0}].{1}={2} ", Md.FiledMeta.Table.Name, Md.FieldsColumns[key].Name, Md.FieldsColumns[key].Value));
}
}
}
}
if (!Md.WhereSql.IsNull())
{
if (Md.WhereSql.Trim().Length > 0)
{
string sqlwherestr = (Md.WhereSql.StartsWith("(") && Md.WhereSql.EndsWith(")")) ? Md.WhereSql : " (" + Md.WhereSql + ") ";
WhereColumn.Add(sqlwherestr);
WhereColumnStr.Add(sqlwherestr);
}
}
sql.AppendFormat(ConstSql.SQL_DELETE_DATA, Md.FiledMeta.Table.Name, (WhereColumn.Count > 0) ? string.Format(" and {0}", string.Join(" AND ", WhereColumn.ToArray())) : string.Empty);
sqlstr.AppendFormat(ConstSql.SQL_DELETE_DATA, Md.FiledMeta.Table.Name, (WhereColumnStr.Count > 0) ? string.Format(" and {0}", string.Join(" AND ", WhereColumnStr.ToArray())) : string.Empty);
if (Predicate.IfNotNull())
{
var FlieldWhere = new FieldValueCollection();
string strwhere = Predicate.GetSql(FlieldWhere, qc);//拼接SQL语句
if (!strwhere.IsEmpty())
{
sql.AppendFormat(" and {0} ", strwhere);
foreach (string key in FlieldWhere.Keys)
{
strwhere = strwhere.Replace(key.ToString(), "'" + FlieldWhere[key].ToString() + "'");
}
sqlstr.AppendFormat(" and {0} ", strwhere);
}
}
qc.CommandText = sql.ToString();
qc.SqlString = sqlstr.ToString();
return qc;
//QueryCommand qc = new QueryCommand();
//StringBuilder sql = new StringBuilder(); List WhereColumn = new List();
//sql.AppendFormat("DELETE FROM {0}", Md.FiledMeta.TableName);
//foreach (string key in Md.Fields.Keys)
//{
// if (!Object.Equals(Md.Fields[key], null) && !Object.Equals(Md.Fields[key], DBNull.Value))
// {
// if (Convert.ToString(Md.Fields[key]) != "")
// {
// WhereColumn.Add(string.Format(" {0}=:{0}", Md.FiledMeta.FieldMeteDatas[key].ColumnName));
// qc.Parameters.Add(":" + Md.FiledMeta.FieldMeteDatas[key].ColumnName, Md.FiledMeta.FieldMeteDatas[key].ColumnType, Md.Fields[key]);
// }
// }
//}
//if (!string.IsNullOrEmpty(Md.WhereSql))
//{
// WhereColumn.Add(Md.WhereSql);
//}
//sql.AppendFormat(" WHERE {0}", string.Join(" AND ", WhereColumn.ToArray()));
//qc.CommandText = sql.ToString();
//return qc;
}
#region 解析 Select SQL语句
///
/// 解析 Select SQL语句
///
///
private QueryCommand ParserSelectCommand()
{
QueryCommand qc = new QueryCommand() { DbParmChar = DbParmChar };
StringBuilder sql = new StringBuilder();
StringBuilder sqlstr = new StringBuilder();
switch (SqlType)
{
case SqlEnum.MainSql:
{
string topnum = Top.IsEmpty() ? string.Empty : " limit " + Top;
sql.AppendFormat(ConstSql.MYSQL_GET_VALUE, topnum, FieldColumn(), Md.FiledMeta.Table.Name);//显示自定义的字段
List WhereColumn = new List();//条件列集合
List WhereColumnStr = new List();//条件列集合
if (Md.FieldsColumns.IfNotNull())//查询条件
{
foreach (string key in Md.FieldsColumns.Keys)
{
var field = Md.FieldsColumns[key];
if (!(field.Value.IsNull()))
{
if (!field.Value.ToString().IsEmpty())
{
WhereColumn.Add(string.Format(" [{0}].{1}=:{2} ", Md.FiledMeta.Table.Name, field.Name,
field.Name));
qc.Parameters.Add(":" + field.Name, (DbType)AntUtils.TryGetDbType(field.Type), field.Value);
WhereColumnStr.Add(string.Format(" [{0}].{1}='{2}' ", Md.FiledMeta.Table.Name, field.Name, field.Value));
}
}
}
}
else
{
if (!Md.WhereSql.IsEmpty()) sql.AppendFormat(" and {0} ", Md.WhereSql);
}
sqlstr.Append(sql.ToString());
if (WhereColumn.Count > 0) sql.AppendFormat(" and {0} ", string.Join(" AND ", WhereColumn.ToArray()));
if (WhereColumnStr.Count > 0) sqlstr.AppendFormat(" and {0} ", string.Join(" AND ", WhereColumnStr.ToArray()));
if (Predicate.IfNotNull())
{
var FlieldWhere = new FieldValueCollection();
string strwhere = Predicate.GetSql(FlieldWhere, qc);//拼接SQL语句
if (!strwhere.IsEmpty())
{
sql.AppendFormat(" and {0} ", strwhere);
foreach (string key in FlieldWhere.Keys)
{
strwhere = strwhere.Replace(key.ToString(), "'" + FlieldWhere[key].ToString() + "'");
}
sqlstr.AppendFormat(" and {0} ", strwhere);
}
}
string orderstr = GetOrderBy();
sql.Append(orderstr);
sqlstr.Append(orderstr);
WhereColumn = null; WhereColumnStr = null;
}
break;
}
qc.CommandText = sql.ToString();
qc.SqlString = sqlstr.ToString();
sqlstr = null; sql = null;
return qc;
//QueryCommand qc = new QueryCommand();
//StringBuilder sql = new StringBuilder();
//List columns = new List(); List WhereColumn = new List();
//switch (SqlType)
//{
// case SqlEnum.MainSql:
// {
// sql.AppendFormat("SELECT ");
// if (!string.IsNullOrEmpty(Top))
// {
// sql.AppendFormat(" top " + Top);
// }
// foreach (DataFieldMetaData df in Md.FiledMeta.FieldMeteDatas.Values)//显示字段
// {
// columns.Add(string.Format("{0}", df.ColumnName));
// }
// sql.AppendFormat(" {0} FROM {1}", string.Join(",", columns.ToArray()), Md.FiledMeta.TableName);
// if (!Object.Equals(Md.Fields, null) && !Object.Equals(Fields, DBNull.Value))
// {
// foreach (string key in Md.Fields.Keys)//查询条件
// {
// //if (!object.Equals(Md.Fields[key], null))
// if (!Object.Equals(Md.Fields[key], null) || !Object.Equals(Md.Fields[key], DBNull.Value))
// {
// if (Convert.ToString(Md.Fields[key]) != "")
// {
// WhereColumn.Add(string.Format(" {0}=:{0}", Md.FiledMeta.FieldMeteDatas[key].ColumnName));
// qc.Parameters.Add(":" + Md.FiledMeta.FieldMeteDatas[key].ColumnName, Md.FiledMeta.FieldMeteDatas[key].ColumnType, Md.Fields[key]);
// }
// }
// }
// }
// }
// break;
// case SqlEnum.ReferenceSql:
// {
// foreach (ReferenceMataData refermod in Md.FiledMeta.ReferenceObjects.Values)
// {
// sql.AppendFormat("SELECT ");
// if (!string.IsNullOrEmpty(Top))
// {
// sql.AppendFormat(" top " + Top);
// }
// columns.Add(string.Format("{0}", refermod.ShowField));
// sql.AppendFormat(" {0} FROM {1}", string.Join(",", columns.ToArray()), refermod.ForeignTable);
// WhereColumn.Add(string.Format("{0}=:{1}", refermod.MainKey[0], refermod.ForeignKey[0]));
// foreach (string key in Md.Fields.Keys)
// {
// if (key == refermod.ForeignKey[0] && Convert.ToString(Md.Fields[key]) != "")
// qc.Parameters.Add(":" + refermod.ForeignKey[0], refermod.DataType[0], Md.Fields[key]);
// }
// }
// }
// break;
// case SqlEnum.ChildSql:
// {
// foreach (ChildMataData refermod in Md.FiledMeta.ChildObjects.Values)
// {
// sql.AppendFormat("SELECT ");
// if (!string.IsNullOrEmpty(Top))
// {
// sql.AppendFormat(" top " + Top);
// }
// foreach (DataFieldMetaData df in Md.FiledMeta.FieldMeteDatas.Values)//显示字段
// {
// columns.Add(string.Format("{0}", df.ColumnName));
// }
// sql.AppendFormat(" {0} FROM {1}", string.Join(",", columns.ToArray()), refermod.ChildTable);
// WhereColumn.Add(string.Format("{0}=:{1}", refermod.ParentTableFields[0], refermod.ChildTableFields[0]));
// foreach (string key in Md.Fields.Keys)//查询条件
// {
// if (key == refermod.ChildTableFields[0] && Convert.ToString(Md.Fields[key]) != "")
// qc.Parameters.Add(":" + refermod.ChildTableFields[0], refermod.DataType[0], Md.Fields[key]);
// }
// }
// } break;
//}
//if (Md.WhereSql != null)
//{
// if (Md.WhereSql.Trim().Length > 0)
// {
// string sqlwherestr = "";
// if (Md.WhereSql.StartsWith("(") && Md.WhereSql.EndsWith(")"))
// {
// sqlwherestr = "(" + Md.WhereSql + ")";
// }
// else
// {
// sqlwherestr = Md.WhereSql;
// }
// WhereColumn.Add(sqlwherestr);
// }
//}
//if (WhereColumn.Count > 0)
// sql.AppendFormat(" WHERE {0}", string.Join(" AND ", WhereColumn.ToArray()));
//if (!string.IsNullOrEmpty(Md.OrderBy))
//{
// if (Md.OrderBy.Trim().Length > 0)
// {
// sql.AppendFormat(Md.OrderBy);
// }
//}
//qc.CommandText = sql.ToString();
//qc.MaxRecords = PageSize;
//qc.StartRecord = PageSize * PageNo;
return qc;
}
///
/// 获取排序
///
///
public string GetOrderBy()
{
string orderbystr = string.Empty;
if (Sort.IsNull())
{
orderbystr = (orderbystr.Trim().IndexOf("order by", StringComparison.InvariantCultureIgnoreCase) != -1) ? string.Format(" {0} ", Md.FiledMeta.PrimaryKey.MemberInfo.Name) : string.Format(" order by {0}", Md.FiledMeta.PrimaryKey.MemberInfo.Name);
}
else
{
string orderby = string.Empty;
foreach (ISort sort in Sort)
{
if (orderby.IsEmpty())
{
orderby = sort.PropertyName + (sort.Ascending ? " ASC" : " DESC");
}
else
{
orderby += " ," + sort.PropertyName + (sort.Ascending ? " ASC" : " DESC");
}
}
orderbystr = string.Format(" ORDER BY {0} ", orderby);
}
return orderbystr;
}
#endregion
#region 解析 查询分页 SQL语句
///
/// 解析 Select SQL语句
///
///
private QueryCommand ParserQueryPageCommand()
{
List WhereColumn = new List();
List WhereColumnStr = new List();//条件列集合
QueryCommand qc = new QueryCommand() { DbParmChar = DbParmChar };
StringBuilder sql = new StringBuilder();
if (Md.FieldsColumns.IfNotNull())//查询条件
{
foreach (string key in Md.FieldsColumns.Keys)
{
var field = Md.FieldsColumns[key];
if (!(field.Value.IsNull()))
{
if (!field.Value.ToString().IsEmpty())
{
string parmname = string.Format("@{0}_{1}", field.Name, qc.Parameters.Count);
WhereColumn.Add(string.Format(" [{0}].{1}=:{2} ", Md.FiledMeta.Table.Name, field.Name,
parmname));
qc.Parameters.Add(":" + parmname, (DbType)AntUtils.TryGetDbType(field.Type), field.Value);
WhereColumnStr.Add(string.Format(" [{0}].{1}='{2}' ", Md.FiledMeta.Table.Name, field.Name, field.Value));
}
}
}
}
string strsqlwhere = string.Join(" AND ", WhereColumn.ToArray());
if (Md.WhereSql.Length > 0) strsqlwhere = strsqlwhere + " and " + Md.WhereSql;
if (Predicate.IfNotNull())
{
var FlieldWhere = new FieldValueCollection();
string strwhere = Predicate.GetSql(FlieldWhere, qc);//拼接SQL语句
if (!strwhere.IsEmpty())
{
strsqlwhere = strsqlwhere + " and " + strwhere;
}
}
sql.AppendFormat(ConstSql.MYSQL_PAGE_VALUE, FieldColumn(), Md.FiledMeta.Table.Name, strsqlwhere, GetOrderBy(), (((PageNo - 1) * PageSize) + 1), (PageNo * PageSize));
if (!qc.SqlNotes.IsNull())
qc.CommandText = sql.ToString();
else
qc.CommandText = sql.ToString();
string sqlstr = sql.ToString();
qc.SqlString = sqlstr;
return qc;
}
#endregion
///
/// 获取显示字段列
///
///
private string FieldColumn()
{
List columns = new List();
string fieldcolumn = string.Empty;
if (!ShowField.IsEmpty())
{
fieldcolumn = ShowField;
}
else
{
foreach (MemberInfo df in Md.FiledMeta.MemberColumnMap.Keys)//显示字段
{
columns.Add(string.Format("{0}", "[" + Md.FiledMeta.Table.Name + "]." + df.Name));
}
fieldcolumn = string.Join(",", columns.ToArray());
}
fieldcolumn = fieldcolumn.IsEmpty() ? " * " : fieldcolumn;
return fieldcolumn;
}
///
/// 通配符转换
///
///
///
protected static string GetEscape(string str)
{
return str.Replace("!", "!!").Replace("%", "!%").Replace("_", "!_");
}
///
/// 获取默认值
///
///
///
private object SetDefaultValue(DbType ColumnType)
{
object value = null;
switch (ColumnType)
{
case DbType.String:
{
value = "";
}
break;
case DbType.Boolean:
{
value = false;
}
break;
case DbType.Decimal:
case DbType.Double:
case DbType.Int32:
case DbType.Int16:
case DbType.Int64:
{
value = 0;
}
break;
case DbType.DateTime:
{
value = DateTime.Now;
}
break;
}
return value;
}
private QueryCommand ParserSumCommand()
{
QueryCommand qc = new QueryCommand();
StringBuilder sql = new StringBuilder();
sql.AppendFormat("SELECT COUNT(*) FROM {0}", Md.FiledMeta.Table.Name);
if (!string.IsNullOrEmpty(Md.WhereSql))
{
sql.AppendFormat(" WHERE {0}", Md.WhereSql);
}
qc.CommandText = sql.ToString();
return qc;
}
///
///
///
///
public string L()
{
return "`";
}
///
///
///
///
public string R()
{
return "`";
}
}
}