lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-08-24 07:22:57 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update HG

Browse Source
This commit is contained in:
sunkaixuan 2023-05-31 17:18:02 +08:00
parent 163260702c
commit 9a6a440d06
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
Src/Asp.NetCore2/SqlSugar.HG/HG/DbMaintenance/PostgreSQLDbMaintenance.cs
View File

@ -62,7 +62,7 @@ namespace SqlSugar.HG
pg_namespace n on n.oid = c.relnamespace and nspname='" + schema + @"' pg_namespace n on n.oid = c.relnamespace and nspname='" + schema + @"'
inner join inner join
pg_tables z on z.tablename=c.relname pg_tables z on z.tablename=c.relname
where relkind in('p', 'r') and relname not like 'pg_%' and relname not like 'sql_%' and schemaname='" + schema + "' order by relname"; where relkind in('p', 'r') and relname not like 'hg_%' and relname not like 'sql_%' and schemaname='" + schema + "' order by relname";
} }
} }
protected override string GetViewInfoListSql protected override string GetViewInfoListSql
@ -317,19 +317,21 @@ namespace SqlSugar.HG
FileHelper.CreateDirectory(databaseDirectory); FileHelper.CreateDirectory(databaseDirectory);
} }
} }
var oldDatabaseName = this.Context.Ado.Connection.Database; // var oldDatabaseName = this.Context.Ado.Connection.Database;
var connection = this.Context.CurrentConnectionConfig.ConnectionString; //var connection = this.Context.CurrentConnectionConfig.ConnectionString;
connection = connection.Replace(oldDatabaseName, "postgres"); //connection = connection.Replace(oldDatabaseName, "");
var newDb = new SqlSugarClient(new ConnectionConfig() if (this.Context.Ado.IsValidConnection())
{ {
DbType = this.Context.CurrentConnectionConfig.DbType, return true;
IsAutoCloseConnection = true, }
ConnectionString = connection var newDb = this.Context.CopyNew();
}); newDb.Ado.Connection.ChangeDatabase("highgo");
newDb.Open();
if (!GetDataBaseList(newDb).Any(it => it.Equals(databaseName, StringComparison.CurrentCultureIgnoreCase))) if (!GetDataBaseList(newDb).Any(it => it.Equals(databaseName, StringComparison.CurrentCultureIgnoreCase)))
{ {
newDb.Ado.ExecuteCommand(string.Format(CreateDataBaseSql, this.SqlBuilder.SqlTranslationLeft+databaseName+this.SqlBuilder.SqlTranslationRight, databaseDirectory)); newDb.Ado.ExecuteCommand(string.Format(CreateDataBaseSql, this.SqlBuilder.SqlTranslationLeft+databaseName+this.SqlBuilder.SqlTranslationRight, databaseDirectory));
} }
newDb.Close();
return true; return true;
} }
public override bool AddRemark(EntityInfo entity) public override bool AddRemark(EntityInfo entity)