namespace IStation
|
{
|
internal 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>
|
/// Analysis SQLite连接配置
|
/// </summary>
|
internal static ConnectionConfig AnalysisConnectionConfig
|
{
|
get
|
{
|
//SnowFlakeSingle.WorkId = Settings.SqlSugar.SnowFlakeWorkId; 不同机器配置的唯一数字; // 单服务器不需要指定
|
return new ConnectionConfig()
|
{
|
DbType = SqlSugar.DbType.Sqlite,//数据库类型
|
ConnectionString = 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);
|
}
|
}
|
};
|
}
|
}
|
|
/// <summary>
|
/// Schedule SQLite连接配置
|
/// </summary>
|
internal static ConnectionConfig ScheduleConnectionConfig
|
{
|
get
|
{
|
//SnowFlakeSingle.WorkId = Settings.SqlSugar.SnowFlakeWorkId; 不同机器配置的唯一数字; // 单服务器不需要指定
|
return new ConnectionConfig()
|
{
|
DbType = SqlSugar.DbType.Sqlite,//数据库类型
|
ConnectionString = 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);
|
}
|
}
|
};
|
}
|
}
|
|
#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
|
|
|
}
|
}
|
