namespace IStation
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public class ConfigHelper
|
{
|
|
#region PostgreSql-ConnectionConfig
|
|
/// <summary>
|
/// 默认连接配置
|
/// </summary>
|
internal static ConnectionConfig DefaultConnectionConfig
|
{
|
get
|
{
|
//SnowFlakeSingle.WorkId = Settings.SqlSugar.SnowFlakeWorkId; 不同机器配置的唯一数字; // 单服务器不需要指定
|
return new ConnectionConfig()
|
{
|
DbType = SqlSugar.DbType.PostgreSQL,//数据库类型
|
ConnectionString = Settings.ParasHelper.DataBase.PostgreSql.ConnectString,
|
IsAutoCloseConnection = true,//是否自动关闭
|
MoreSettings = new ConnMoreSettings()
|
{
|
//PgSqlIsAutoToLower = false //数据库存在大写字段的 ，需要把这个设为false ，并且实体和字段名称要一样
|
},
|
AopEvents = new AopEvents
|
{
|
OnLogExecuting = (sql, p) =>
|
{
|
// var sqlString = UtilMethods.GetNativeSql(sql, p);
|
//LogHelper.Debug(sqlString);
|
// Console.WriteLine(sql);
|
}
|
}
|
};
|
}
|
}
|
|
/// <summary>
|
/// PostgreSql连接配置
|
/// </summary>
|
internal static ConnectionConfig PostgreSqlConnectionConfig
|
{
|
get
|
{
|
//SnowFlakeSingle.WorkId = Settings.SqlSugar.SnowFlakeWorkId; 不同机器配置的唯一数字; // 单服务器不需要指定
|
return new ConnectionConfig()
|
{
|
DbType = SqlSugar.DbType.PostgreSQL,//数据库类型
|
ConnectionString = Settings.ParasHelper.DataBase.PostgreSql.ConnectString,
|
IsAutoCloseConnection = true,//是否自动关闭
|
MoreSettings = new ConnMoreSettings()
|
{
|
//PgSqlIsAutoToLower = false //数据库存在大写字段的 ，需要把这个设为false ，并且实体和字段名称要一样
|
},
|
AopEvents = new AopEvents
|
{
|
OnLogExecuting = (sql, p) =>
|
{
|
// var sqlString = UtilMethods.GetNativeSql(sql, p);
|
//LogHelper.Debug(sqlString);
|
// Console.WriteLine(sql);
|
}
|
}
|
};
|
}
|
}
|
#endregion
|
|
#region SQLite-ConnectionConfig
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="dbFile"></param>
|
/// <returns></returns>
|
private static string GetConnectionString(string dbFile)
|
{
|
var filePath = Settings.ParasHelper.LocalFile.DataFolderDirectory + "\\" + dbFile;
|
return $"DataSource={filePath}";
|
}
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="dbFile"></param>
|
/// <returns></returns>
|
public static string DeleteDataBase(string dbFile)
|
{
|
var filePath = Settings.ParasHelper.LocalFile.DataFolderDirectory + "\\" + dbFile;
|
if (File.Exists(filePath))
|
File.Delete(filePath);
|
return filePath;
|
}
|
|
|
|
|
/// <summary>
|
/// Analysis SQLite连接配置
|
/// </summary>
|
internal static ConnectionConfig AnalysisConnectionConfig
|
{
|
get
|
{
|
var config = new ConnectionConfig
|
{
|
DbType = SqlSugar.DbType.Sqlite,//数据库类型
|
ConnectionString = GetConnectionString(Settings.ParasHelper.DataBase.SQLite.AnalysisConnectString),
|
IsAutoCloseConnection = true,//是否自动关闭
|
MoreSettings = new ConnMoreSettings()
|
{
|
//PgSqlIsAutoToLower = false //数据库存在大写字段的 ，需要把这个设为false ，并且实体和字段名称要一样
|
},
|
AopEvents = new AopEvents
|
{
|
OnLogExecuting = (sql, p) =>
|
{
|
var sqlString = UtilMethods.GetNativeSql(sql, p);
|
//LogHelper.Debug(sqlString);
|
//Console.WriteLine(sql);
|
}
|
},
|
ConfigureExternalServices = new ConfigureExternalServices()
|
{
|
EntityService = (property, column) =>
|
{
|
//除主键外都可空
|
if (!column.IsPrimarykey)
|
{
|
column.IsNullable = true;
|
}
|
}
|
}
|
};
|
|
return config;
|
}
|
}
|
|
/// <summary>
|
/// Schedule SQLite连接配置
|
/// </summary>
|
internal static ConnectionConfig ScheduleConnectionConfig
|
{
|
get
|
{
|
var config = new ConnectionConfig
|
{
|
DbType = SqlSugar.DbType.Sqlite,//数据库类型
|
ConnectionString = GetConnectionString(Settings.ParasHelper.DataBase.SQLite.ScheduleConnectString),
|
IsAutoCloseConnection = true,//是否自动关闭
|
MoreSettings = new ConnMoreSettings()
|
{
|
//PgSqlIsAutoToLower = false //数据库存在大写字段的 ，需要把这个设为false ，并且实体和字段名称要一样
|
},
|
AopEvents = new AopEvents
|
{
|
OnLogExecuting = (sql, p) =>
|
{
|
var sqlString = UtilMethods.GetNativeSql(sql, p);
|
//LogHelper.Debug(sqlString);
|
//Console.WriteLine(sql);
|
}
|
},
|
ConfigureExternalServices = new ConfigureExternalServices()
|
{
|
EntityService = (property, column) =>
|
{
|
//除主键外都可空
|
if (!column.IsPrimarykey)
|
{
|
column.IsNullable = true;
|
}
|
|
//if (column.DbColumnName == "Config")
|
//{
|
// column.DataType = StaticConfig.CodeFirst_BigString;
|
//}
|
|
}
|
}
|
};
|
return config;
|
}
|
}
|
|
/// <summary>
|
/// Hydraulic SQLite连接配置
|
/// </summary>
|
internal static ConnectionConfig HydraulicConnectionConfig
|
{
|
get
|
{
|
var config = new ConnectionConfig
|
{
|
DbType = SqlSugar.DbType.Sqlite,//数据库类型
|
ConnectionString = GetConnectionString(Settings.ParasHelper.DataBase.SQLite.HydraulicConnectString),
|
IsAutoCloseConnection = true,//是否自动关闭
|
MoreSettings = new ConnMoreSettings()
|
{
|
//PgSqlIsAutoToLower = false //数据库存在大写字段的 ，需要把这个设为false ，并且实体和字段名称要一样
|
},
|
AopEvents = new AopEvents
|
{
|
OnLogExecuting = (sql, p) =>
|
{
|
var sqlString = UtilMethods.GetNativeSql(sql, p);
|
//LogHelper.Debug(sqlString);
|
//Console.WriteLine(sql);
|
}
|
},
|
ConfigureExternalServices = new ConfigureExternalServices()
|
{
|
EntityService = (property, column) =>
|
{
|
//除主键外都可空
|
if (!column.IsPrimarykey)
|
{
|
column.IsNullable = true;
|
}
|
|
//if (column.DbColumnName == "Config")
|
//{
|
// column.DataType = StaticConfig.CodeFirst_BigString;
|
//}
|
|
}
|
}
|
};
|
return config;
|
}
|
}
|
|
/// <summary>
|
/// 初始化 Analysis 数据库
|
/// </summary>
|
public static void InitAnalysisDB(bool backup = false)
|
{
|
DeleteDataBase(Settings.ParasHelper.DataBase.SQLite.AnalysisConnectString);
|
var sqlSugarClient = new SqlSugarClient(AnalysisConnectionConfig);
|
Type[] types = new Type[] {
|
typeof(Entity.AnalysisLog),
|
//typeof(Entity.AnalysisCombine),
|
//typeof(Entity.AnalysisConclusion),
|
};
|
sqlSugarClient.DbMaintenance.CreateDatabase();
|
if (backup)
|
{
|
sqlSugarClient.CodeFirst.BackupTable().InitTables(types);
|
}
|
else
|
{
|
sqlSugarClient.CodeFirst.InitTables(types);
|
}
|
}
|
|
/// <summary>
|
/// 初始化 Schedule 数据库
|
/// </summary>
|
public static void InitScheduleDB(bool backup = false)
|
{
|
var sqlSugarClient = new SqlSugarClient(ScheduleConnectionConfig);
|
Type[] types = new Type[] {
|
typeof(Entity.ScheduleRequest),
|
typeof(Entity.ScheduleScada),
|
typeof(Entity.ScheduleRule),
|
typeof(Entity.SchedulePump),
|
typeof(Entity.ScheduleConclusion),
|
};
|
sqlSugarClient.DbMaintenance.CreateDatabase();
|
if (backup)
|
{
|
sqlSugarClient.CodeFirst.BackupTable().InitTables(types);
|
}
|
else
|
{
|
sqlSugarClient.CodeFirst.InitTables(types);
|
}
|
}
|
|
/// <summary>
|
/// 初始化 Hydraulic 数据库
|
/// </summary>
|
public static void InitHydraulicDB(bool backup = false)
|
{
|
var sqlSugarClient = new SqlSugarClient(HydraulicConnectionConfig);
|
Type[] types = new Type[] {
|
typeof(Entity.HydraulicModelValidation),
|
typeof(Entity.HydraulicModelScada),
|
typeof(Entity.HydraulicModelRecord)
|
};
|
sqlSugarClient.DbMaintenance.CreateDatabase();
|
if (backup)
|
{
|
sqlSugarClient.CodeFirst.BackupTable().InitTables(types);
|
}
|
else
|
{
|
sqlSugarClient.CodeFirst.InitTables(types);
|
}
|
}
|
|
#endregion
|
|
#region SQLite-Sql
|
|
///// <summary>
|
///// AnalysisCombine 表名前缀
|
///// </summary>
|
//internal static string AnalysisCombinePrefix = "AnalysisCombine_Cb_";
|
|
///// <summary>
|
///// AnalysisConclusion 表名前缀
|
///// </summary>
|
//internal static string AnalysisConclusionPrefix = "AnalysisConclusion_Cl_";
|
|
///// <summary>
|
///// 获取 AnalysisCombine建表 SQL
|
///// </summary>
|
///// <param name="tableName">表名</param>
|
///// <returns></returns>
|
//internal static string GetAnalysisCombineCreateSql(string tableName)
|
//{
|
// var sql = $"CREATE TABLE {tableName} ( ID BIGINT NOT NULL PRIMARY KEY, RunCount INTEGER, Pump1 REAL, Pump2 REAL, CurveQH VARCHAR (255), CurveQP VARCHAR (255), MaxFlow REAL, MinFlow REAL, MaxHead REAL, MinHead REAL, AnaStatus BIT ); ";
|
// return sql;
|
//}
|
|
///// <summary>
|
///// 获取 AnalysisConclusion建表 SQL
|
///// </summary>
|
///// <param name="tableName">表名</param>
|
///// <returns></returns>
|
//internal static string GetAnalysisConclusionCreateSql(string tableName)
|
//{
|
// var sql = $"CREATE TABLE {tableName} ( ID BIGINT NOT NULL PRIMARY KEY, CombineID BIGINT, Pump1 REAL, Pump2 REAL, Head REAL, Flow REAL, Power REAL, WP REAL, UWP REAL ); ";
|
// return sql;
|
//}
|
|
/// <summary>
|
/// 获取 判断表是否存在 SQL
|
/// </summary>
|
/// <param name="tableName">表名</param>
|
/// <returns></returns>
|
internal static string GetExistTableSql(string tableName)
|
{
|
var sql = $"select count(*) from sqlite_master where type = 'table' and name = '{tableName}';";
|
return sql;
|
}
|
|
#endregion
|
|
|
}
|
}
|
