Synchronization code

This commit is contained in:
sunkaixuan 2023-08-15 11:28:38 +08:00
parent 086067e848
commit f6cdb598c8
2 changed files with 6 additions and 5 deletions

View File

@ -41,9 +41,10 @@ namespace SqlSugar
public virtual async Task CreateTempAsync<T>(DataTable dt) where T : class, new() public virtual async Task CreateTempAsync<T>(DataTable dt) where T : class, new()
{ {
var sqlbuilder = this.Context.Queryable<object>().SqlBuilder;
await this.Context.UnionAll( await this.Context.UnionAll(
this.Context.Queryable<T>().Filter(null,true).Select("*").Where(it => false).AS(dt.TableName), this.Context.Queryable<T>().Filter(null,true).Select(string.Join(",", dt.Columns.Cast<DataColumn>().Select(it => sqlbuilder.GetTranslationColumnName(it.ColumnName)))).Where(it => false).AS(dt.TableName),
this.Context.Queryable<T>().Filter(null, true).Select("*").Where(it => false).AS(dt.TableName)).Select("top 1 * into #temp").ToListAsync(); this.Context.Queryable<T>().Filter(null, true).Select(string.Join(",", dt.Columns.Cast<DataColumn>().Select(it => sqlbuilder.GetTranslationColumnName(it.ColumnName)))).Where(it => false).AS(dt.TableName)).Select("top 1 * into #temp").ToListAsync();
dt.TableName = "#temp"; dt.TableName = "#temp";
} }
} }

View File

@ -336,7 +336,7 @@ namespace SqlSugar
{ {
if (tableName!=null&&tableName.Contains(".") && tableName.Contains(SqlBuilder.SqlTranslationLeft)) if (tableName!=null&&tableName.Contains(".") && tableName.Contains(SqlBuilder.SqlTranslationLeft))
{ {
tableName =string.Join(".", tableName.Split(".").Select(it => SqlBuilder.GetNoTranslationColumnName(it))); tableName =string.Join(".", tableName.Split('.').Select(it => SqlBuilder.GetNoTranslationColumnName(it)));
} }
if (IsAnySchemaTable(tableName)) if (IsAnySchemaTable(tableName))
{ {
@ -353,7 +353,7 @@ namespace SqlSugar
{ {
if (tableName != null&&tableName.Contains(".") && tableName.Contains(SqlBuilder.SqlTranslationLeft)) if (tableName != null&&tableName.Contains(".") && tableName.Contains(SqlBuilder.SqlTranslationLeft))
{ {
tableName = string.Join(".", tableName.Split(".").Select(it => SqlBuilder.GetNoTranslationColumnName(it))); tableName = string.Join(".", tableName.Split('.').Select(it => SqlBuilder.GetNoTranslationColumnName(it)));
} }
if (IsAnySchemaTable(tableName)) if (IsAnySchemaTable(tableName))
{ {
@ -370,7 +370,7 @@ namespace SqlSugar
{ {
if (tableName != null&&tableName.Contains(".") && tableName.Contains(SqlBuilder.SqlTranslationLeft)) if (tableName != null&&tableName.Contains(".") && tableName.Contains(SqlBuilder.SqlTranslationLeft))
{ {
tableName = string.Join(".", tableName.Split(".").Select(it => SqlBuilder.GetNoTranslationColumnName(it))); tableName = string.Join(".", tableName.Split('.').Select(it => SqlBuilder.GetNoTranslationColumnName(it)));
} }
if (IsAnySchemaTable(tableName)) if (IsAnySchemaTable(tableName))
{ {