namespace IStation { internal class ConfigHelper { #region PostgreSql-ConnectionConfig /// /// 默认连接配置 /// 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); } } }; } } /// /// PostgreSql连接配置 /// 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 /// /// Analysis SQLite连接配置 /// 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); } } }; } } /// /// Schedule SQLite连接配置 /// 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 ///// ///// AnalysisCombine 表名前缀 ///// //internal static string AnalysisCombinePrefix = "AnalysisCombine_Cb_"; ///// ///// AnalysisConclusion 表名前缀 ///// //internal static string AnalysisConclusionPrefix = "AnalysisConclusion_Cl_"; ///// ///// 获取 AnalysisCombine建表 SQL ///// ///// 表名 ///// //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; //} ///// ///// 获取 AnalysisConclusion建表 SQL ///// ///// 表名 ///// //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; //} /// /// 获取 判断表是否存在 SQL /// /// 表名 /// internal static string GetExistTableSql(string tableName) { var sql = $"select count(*) from sqlite_master where type = 'table' and name = '{tableName}';"; return sql; } #endregion } }