数据库连接

DAL/BaseService.cs

@@ -0,0 +1,51 @@
+using Model;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace DAL
+{
+    public class BaseService<T> where T : BaseEntity,  new()
+    {
+        public virtual async Task<int> InsertAsync(T model)
+        {
+            var runsql =  DB.SqlSugarClient.Insertable(model);
+            var rows = await runsql.ExecuteCommandAsync();
+            return rows;
+        }
+        public virtual async Task<bool> UpdateAsync(T model)
+        {
+            var runsql = DB.SqlSugarClient.Updateable(model);
+            var rows = await runsql.ExecuteCommandAsync();
+            return rows>0;
+        }
+
+        public virtual async Task<bool> DeleteAsync(T model)
+        {
+            var runsql = DB.SqlSugarClient.Deleteable(model);
+            var rows = await runsql.ExecuteCommandAsync();
+            return rows > 0;
+        }
+        
+        public virtual async Task<T> GetByOneAsync(Expression<Func<T,bool>> where)
+        {
+            var runsql = DB.SqlSugarClient.Queryable<T>().Where(where);
+            return await runsql.FirstAsync();
+        }
+
+        public virtual async Task<List<T>> GetListAsync(Expression<Func<T, bool>> where)
+        {
+            var runsql = DB.SqlSugarClient.Queryable<T>().Where(where);
+            return await runsql.ToListAsync();
+        }
+        public virtual async Task<bool> ExistAsync(Expression<Func<T, bool>> where)
+        {
+            return await DB.SqlSugarClient.Queryable<T>()
+                .Where(where)
+                .AnyAsync();
+        }
+    }
+}

DAL/DB.cs

@@ -0,0 +1,30 @@
+using Microsoft.Extensions.DependencyInjection;
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace DAL
+{
+    public static class DB
+    {
+        public static ISqlSugarClient SqlSugarClient { get; set; }
+        public static void AddSqlSugarSetup(this IServiceCollection services, SqlSugar.DbType dataType, string conn)
+        {
+            if (services == null) throw new ArgumentNullException(nameof(services));
+
+            services.AddSingleton<ISqlSugarClient>(s =>
+            {
+                SqlSugarClient = new SqlSugarScope(new ConnectionConfig()
+                {
+                    DbType = dataType,
+                    ConnectionString = conn,
+                    IsAutoCloseConnection = true
+                });
+                return SqlSugarClient;
+            });
+        }
+    }
+}

Scada/Page/PageTotalEquipmentControl.Designer.cs

@@ -85,7 +85,7 @@
             btn_DryRun.Text = null;
             btn_DryRun.TextAlignment = ContentAlignment.MiddleCenter;
             btn_DryRun.VariableName = "空运行";
-            btn_DryRun.ClickEvent += btn_DryRun_ClickEvent;
+            btn_DryRun.ClickEvent += this.btn_DryRun_ClickEvent;
             // 
             // btn_AlarmReset
             // 

Scada/Program.cs

@@ -1,10 +1,13 @@
 using System.Reflection;
+using DAL;
 using HZY.Framework.DependencyInjection;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
+using Model;
 using NLog;
 using NLog.Extensions.Logging;
+using SqlSugar;
 
 namespace Scada
 {
@@ -24,8 +27,14 @@ namespace Scada
 
             var serviceProvider = services.BuildServiceProvider();
             Globals.ServiceProvider = serviceProvider;
+
             var frmMain = serviceProvider.GetRequiredService<FormMain>();
-            
+
+            var db = serviceProvider.GetRequiredService<ISqlSugarClient>();
+
+            db.CodeFirst.SetStringDefaultLength(200)
+.InitTables(typeof(AuthEntity),typeof(DataEntity), typeof(RecipeEntity), typeof(UserEntity));
+
             Application.Run(frmMain);
         }
 
@@ -50,6 +59,11 @@ namespace Scada
                     loggerBuilder.AddNLog();
                 });
 
+            DbType dbType = Enum.Parse<DbType>(configuration["DbContexts:DbType"]);
+            string connnectString = configuration[$"DbContexts:{dbType}:ConnectionString"];
+
+            services.AddSqlSugarSetup(dbType, connnectString);
+
             //»ñÈ¡NLogÅäÖÃÐÅÏ¢
             var nlogConifg = configuration.GetSection("NLog");
 

Scada/appsettings.json

@@ -1,10 +1,10 @@
 {
-    "DbContexts": {
-        "DbType": "Sqlite",
-        "Sqlite": {
-            "ConnectionString": "Data Source=D://实战项目//Scada//Scada//bin//Debug//net8.0-windows"
-        }
-    },
+  "DbContexts": {
+    "DbType": "SqlServer",
+    "SqlServer": {
+      "ConnectionString": "Server=.;Database=scada;User ID=sa;Password=123456;Encrypt=True;TrustServerCertificate=True;"
+    }
+  },
     //相对路径  可以省略前面的东西
     // "ConnectionString": "Data Source=SprayData.db"
     "NLog": {