diff --git a/Src/Asp.NetCore2/SqlSugar.TDengineCore/TDengine/SqlBuilder/TDengineUpdateBuilder.cs b/Src/Asp.NetCore2/SqlSugar.TDengineCore/TDengine/SqlBuilder/TDengineUpdateBuilder.cs index a6d2bfbc8..d8d8b98cc 100644 --- a/Src/Asp.NetCore2/SqlSugar.TDengineCore/TDengine/SqlBuilder/TDengineUpdateBuilder.cs +++ b/Src/Asp.NetCore2/SqlSugar.TDengineCore/TDengine/SqlBuilder/TDengineUpdateBuilder.cs @@ -6,244 +6,16 @@ using System.Text; namespace SqlSugar.TDengine { public class TDengineUpdateBuilder : UpdateBuilder - { - public override string SqlTemplateBatch + { + public override string ToSqlString() { - get - { - return @"UPDATE {1} {2} SET {0} FROM ${{0}} "; - } + throw new NotSupportedException("TDengine库不支持更新操作"); } - public override string SqlTemplateJoin - { - get - { - return @" (VALUES - {0} - - ) AS T ({2}) WHERE {1} - "; - } - } - - public override string SqlTemplateBatchUnion - { - get - { - return ","; - } - } - - public object FormatValue(object value,string name,int i,DbColumnInfo columnInfo) - { - if (value == null) - { - return "NULL"; - } - else - { - var type =UtilMethods.GetUnderType(value.GetType()); - if (type == UtilConstants.DateType||columnInfo.IsArray||columnInfo.IsJson) - { - var parameterName = this.Builder.SqlParameterKeyWord + name + i; - var paramter = new SugarParameter(parameterName, value); - if (columnInfo.IsJson) - { - paramter.IsJson = true; - } - if (columnInfo.IsArray) - { - paramter.IsArray = true; - } - this.Parameters.Add(paramter); - return parameterName; - } - else if (type == UtilConstants.DateTimeOffsetType) - { - return FormatDateTimeOffset(value); - } - else if (type == UtilConstants.ByteArrayType) - { - string bytesString = "0x" + BitConverter.ToString((byte[])value); - return bytesString; - } - else if (type.IsEnum()) - { - if (this.Context.CurrentConnectionConfig.MoreSettings?.TableEnumIsString == true) - { - return value.ToSqlValue(); - } - else - { - return Convert.ToInt64(value); - } - } - else if (type == UtilConstants.BoolType) - { - return value.ObjToBool() ? "1" : "0"; - } - else if (type == UtilConstants.StringType || type == UtilConstants.ObjType) - { - return "'" + value.ToString().ToSqlFilter() + "'"; - } - else - { - return "'" + value.ToString() + "'"; - } - } - } - protected override string TomultipleSqlString(List> groupList) { - Check.Exception(PrimaryKeys == null || PrimaryKeys.Count == 0, " Update List need Primary key"); - int pageSize = 200; - int pageIndex = 1; - int totalRecord = groupList.Count; - int pageCount = (totalRecord + pageSize - 1) / pageSize; - StringBuilder batchUpdateSql = new StringBuilder(); - while (pageCount >= pageIndex) - { - StringBuilder updateTable = new StringBuilder(); - string setValues = string.Join(",", groupList.First().Where(it => it.IsPrimarykey == false && (it.IsIdentity == false || (IsOffIdentity && it.IsIdentity))).Select(it => - { - if (SetValues.IsValuable()) - { - var setValue = SetValues.Where(sv => sv.Key == Builder.GetTranslationColumnName(it.DbColumnName)); - if (setValue != null && setValue.Any()) - { - return setValue.First().Value; - } - } - var result = string.Format("{0}=T.{0}", Builder.GetTranslationColumnName(it.DbColumnName)); - return result; - })); - string tempColumnValue = string.Join(",", groupList.First().Select(it => - { - if (SetValues.IsValuable()) - { - var setValue = SetValues.Where(sv => sv.Key == Builder.GetTranslationColumnName(it.DbColumnName)); - if (setValue != null && setValue.Any()) - { - return setValue.First().Value; - } - } - var result = Builder.GetTranslationColumnName(it.DbColumnName); - return result; - })); - batchUpdateSql.AppendFormat(SqlTemplateBatch.ToString(), setValues, GetTableNameStringNoWith, TableWithString); - int i = 0; - var tableColumnList = this.Context.DbMaintenance.GetColumnInfosByTableName(GetTableNameStringNoWith); - - foreach (var columns in groupList.Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList()) - { - var isFirst = i == 0; - if (!isFirst) - { - updateTable.Append(SqlTemplateBatchUnion); - } - updateTable.Append("\r\n (" + string.Join(",", columns.Select(it => - { - var columnInfo = tableColumnList.FirstOrDefault(x => x.DbColumnName.Equals(it.DbColumnName, StringComparison.OrdinalIgnoreCase)); - var dbType = columnInfo?.DataType; - if (dbType == null) { - var typeName = it.PropertyType.Name.ToLower(); - if (columnInfo==null&&it.PropertyType.IsEnum) - { - if (this.Context.CurrentConnectionConfig?.MoreSettings?.TableEnumIsString!=true) - { - typeName = "int"; - } - } - if (typeName == "int32") - typeName = "int"; - if (typeName == "int64") - typeName = "long"; - if (typeName == "int16") - typeName = "short"; - if (typeName == "boolean") - typeName = "bool"; - - var isAnyType = TDengineDbBind.MappingTypesConst.Where(x => x.Value.ToString().ToLower() == typeName).Any(); - if (isAnyType) - { - dbType = TDengineDbBind.MappingTypesConst.Where(x => x.Value.ToString().ToLower() == typeName).FirstOrDefault().Key; - } - else { - dbType = "varchar"; - } - } - return string.Format("CAST({0} AS {1})", base.GetDbColumn(it,FormatValue(it.Value,it.DbColumnName,i,it)), dbType); - - })) + ")"); - ++i; - } - pageIndex++; - updateTable.Append("\r\n"); - string whereString = null; - if (this.WhereValues.HasValue()) - { - foreach (var item in WhereValues) - { - var isFirst = whereString == null; - whereString += (isFirst ? null : " AND "); - whereString += item; - } - } - else if (PrimaryKeys.HasValue()) - { - foreach (var item in PrimaryKeys) - { - var isFirst = whereString == null; - whereString += (isFirst ? null : " AND "); - whereString += string.Format("{0}.{1}=T.{1}", GetTableNameStringNoWith, Builder.GetTranslationColumnName(item)); - } - } - var format = string.Format(SqlTemplateJoin, updateTable, whereString, tempColumnValue); - batchUpdateSql.Replace("${0}", format); - batchUpdateSql.Append(";"); - } - batchUpdateSql = GetBatchUpdateSql(batchUpdateSql); - return batchUpdateSql.ToString(); + throw new NotSupportedException("TDengine库不支持更新操作"); } - private StringBuilder GetBatchUpdateSql(StringBuilder batchUpdateSql) - { - if (ReSetValueBySqlExpListType == null && ReSetValueBySqlExpList != null) - { - var result = batchUpdateSql.ToString(); - foreach (var item in ReSetValueBySqlExpList) - { - var dbColumnName = item.Value.DbColumnName; - if (item.Value.Type == ReSetValueBySqlExpListModelType.List) - { - result = result.Replace($"{dbColumnName}=T.{dbColumnName}", $"{dbColumnName}={GetTableNameString}.{dbColumnName}{item.Value.Sql}T.{dbColumnName}"); - } - else - { - result = result.Replace($"{dbColumnName}=T.{dbColumnName}", $"{dbColumnName}={item.Value.Sql.Replace(dbColumnName, $"{Builder.GetTranslationColumnName(this.TableName)}.{dbColumnName}")}"); - } - batchUpdateSql = new StringBuilder(result); - } - } - - return batchUpdateSql; - } - protected override string GetJoinUpdate(string columnsString, ref string whereString) - { - var formString = $" {Builder.GetTranslationColumnName(this.TableName)} AS {Builder.GetTranslationColumnName(this.ShortName)} "; - var joinString = ""; - foreach (var item in this.JoinInfos) - { - whereString += " AND "+item.JoinWhere; - joinString += $"\r\n FROM {Builder.GetTranslationColumnName(item.TableName)} {Builder.GetTranslationColumnName(item.ShortName)} "; - } - var tableName = formString + "\r\n "; - columnsString = columnsString.Replace(Builder.GetTranslationColumnName(this.ShortName)+".","")+joinString; - return string.Format(SqlTemplate, tableName, columnsString, whereString); - } - public override string FormatDateTimeOffset(object value) - { - return "'" + ((DateTimeOffset)value).ToString("o") + "'"; - } + } } diff --git a/Src/Asp.NetCore2/TDengineTest/Demo/ORMTest.cs b/Src/Asp.NetCore2/TDengineTest/Demo/ORMTest.cs index 84d6dd3ec..936e24c5b 100644 --- a/Src/Asp.NetCore2/TDengineTest/Demo/ORMTest.cs +++ b/Src/Asp.NetCore2/TDengineTest/Demo/ORMTest.cs @@ -24,8 +24,7 @@ namespace OrmTest { OnLogExecuting = (sql, p) => { - Console.WriteLine(sql); - Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + Console.WriteLine(UtilMethods.GetNativeSql(sql,p)); } } });