SqlSugar:基于SQLSugar框架在 .Net情况中搭建PostgreSQL数据库访问、操作的 ...

SqlSugar 是一款 老牌 .NET开源ORM框架，由果糖大数据科技团队维护和更新 ，开箱即用最易上手的ORM 
优点 ：【生态丰富】【高性能】【超简朴】 【功能全面】 【多库兼容】【适合产物】 【SqlSugar视频教程】 
支持 ： .net framework  .net core3.1  .ne5 .net6 .net7 .net8 .net9 
特色 ： 拥有全球最活跃的ORM线上论坛，比EF还要活跃，交流群人数已超过万人 ，技术支持快，口碑好。
详情请看SqlSugar 官方教程SqlSugar .Net ORM 5.X 官网 、文档、教程 - SqlSugar 5x - .NET果糖网
概览

本文描述了在.Net情况中使用SQLSugar框架连接及访问PostgreSQL数据库的具体操作过程，主要包括四个步骤：1 下载SqlSugar包  2 创建初始化并连接数据库工具类 3 创建数据操作类 4调用操作类访问数据库。
1.下载SqlSugar包

1.1 下载

​​​在NuGet包管理器中搜索sqlsugar。注：.Net Framework框架选择SqlSugar，如果是.Net框架下则选择SqlSugarCore。

1.2引用

using SqlSugar

2.连接

创建数据库访问基类，代码中加密解密步骤可以根据实际需求省略或自设

2. using SqlSugar;
3. using System;
4. using System.Collections.Generic;
5. using System.Linq;
6. using System.Text;
7. using System.Threading.Tasks;
8. using System.Windows.Forms.Design;
10. namespace DemoSummaryZT.DatabaseOperation
11. {
12.     /// <summary>
13.     /// 数据库访问基类
14.     /// </summary>
15.     public  class PGSql
16.     {
17.         public static SqlSugarScope PG_db = null;
18.         /// <summary>
19.         /// 初始化数据库连接
20.         /// </summary>
21.         /// <param name="server">主机IP</param>
22.         /// <param name="port">端口</param>
23.         /// <param name="database">数据库名称</param>
24.         /// <param name="userId">用户名</param>
25.         /// <param name="passWord">密码</param>
26.         /// <param name="ifJiaMi">是否加密</param>
27.         public static void InitialPGSql(string server, string port, string database, string userId, string passWord, bool ifJiaMi)
28.         {
30.             if (ifJiaMi)
31.             {
32.                 passWord = Encryption.DecryptStringFromBytes_Aes(passWord, "PostgreSQLExample");//解密密码
33.             }
34.             PG_db = new SqlSugarScope(new ConnectionConfig
35.             {
36.                 ConnectionString = $"Server={server};Port={port};Database={database};User Id={userId};Password={passWord}",
37.                 DbType = DbType.PostgreSQL,
38.                 IsAutoCloseConnection = true,
39.             });  // 使用SqlSugarScope建立PostgreSQL数据库连接
42.         }
43.         /// <summary>
44.         /// 获取数据库Postgre当前时间
45.         /// </summary>
46.         /// <returns></returns>
47.         public DateTime GetPostgreDateTime()
48.         {
49.             return PG_db.Ado.GetDateTime("select now();");
50.         }
53.     }
54. }

复制代码

3.创建增编削查工具类

3.1创建数据库表

数据库表可以根据实际的情况创建，用SQL语句大概可视化开发工具，这里用的是DBeaver

3.2创建跟数据库表相对应的映射类

1. using SqlSugar;
2. using System;
3. using System.Collections.Generic;
4. using System.Linq;
5. using System.Text;
6. using System.Threading.Tasks;
8. namespace DemoSummaryZT.DataModel
9. {
10.     /// <summary>
11.     /// 用户信息
12.     /// </summary>
13.     [SugarTable("user_table")]
14.     public class UserTable
15.     {
16.         public string ID { get; set; }
17.         /// <summary>
18.         /// 年龄
19.         public int Age { get; set; }
20.         /// <summary>
21.         /// 姓名
22.         /// </summary>
23.         public string Name { get; set; }
24.       
26.     }
27. }

复制代码

3.3分别创建增编削查工具类

注意，这里的全部操作类都继承步骤2中的PGSql类
增

1. using DemoSummaryZT.DataModel;
2. using System;
3. using System.Collections.Generic;
4. using System.Linq;
5. using System.Text;
6. using System.Threading.Tasks;
8. namespace DemoSummaryZT.DatabaseOperation
9. {
10.     public  class AddUser :PGSql
11.     {
12.         /// <summary>
13.         /// 新增用户
14.         /// </summary>
15.         public static void AddNewUser(UserTable ut)
16.         {
17.             try
18.             {
19.                 var res = PG_db.Insertable(ut).ExecuteCommand();
20.                 if (res > 0)
21.                 {
22.                     return ;
23.                 }
24.                 else
25.                 {
26.                     return ;
27.                 }
28.             }
29.             catch (Exception ex)
30.             {
31.                 return;
32.             }
33.         }
35.     }
37.    
38. }

复制代码

删

1. using DemoSummaryZT.DataModel;
2. using System;
3. using System.Collections.Generic;
4. using System.Linq;
5. using System.Text;
6. using System.Threading.Tasks;
8. namespace DemoSummaryZT.DatabaseOperation
9. {
10.     public  class DeleteUser:PGSql
11.     {
12.         /// <summary>
13.         /// 删除用户
14.         /// </summary>
15.         public static void Delete(string id)
16.         {
17.             try
18.             {
20.                 var res = PG_db.Deleteable<UserTable>().In(it => it.ID , id).ExecuteCommand();
21.               //  var res = PG_db.Deleteable<UserTable>().In(100).ExecuteCommand();
22.               
23.                 if (res > 0)
24.                 {
25.                     return;
26.                 }
27.                 else
28.                 {
29.                     return;
30.                 }
31.             }
32.             catch (Exception ex)
33.             {
34.                 return;
35.             }
36.         }
38.     }
39. }

复制代码

改

1. using DemoSummaryZT.DataModel;
2. using System;
3. using System.Collections.Generic;
4. using System.Linq;
5. using System.Text;
6. using System.Threading.Tasks;
8. namespace DemoSummaryZT.DatabaseOperation
9. {
10.     public  class ModifyUser:PGSql
11.     {
14.         public static  void Modify(UserTable ut)
15.         {
16.             var result = PG_db.Updateable(ut).Where(a=>a.ID==ut.ID ).ExecuteCommand();
17.         }
19.     }
20. }

复制代码

查

1. using DemoSummaryZT.DataModel;
2. using SqlSugar;
3. using System;
4. using System.Collections.Generic;
5. using System.Linq;
6. using System.Text;
7. using System.Threading.Tasks;
10. namespace DemoSummaryZT.DatabaseOperation
11. {
13.     public  class QueryUser:PGSql
14.     {
16.         /// <summary>
17.        /// 查询所有的用户
18.         /// </summary>
19.         public static List<UserTable> QueryUserName()
20.         {
21.             List<UserTable>list = PG_db.Queryable<UserTable>().ToList();
22.             return list;
23.         }
24.     }
25. }

复制代码

4.调用操作类访问数据库

创建控制台步调，调用数据库访问工具类并运行

1. using DemoSummaryZT.DatabaseOperation;
2. using DemoSummaryZT.DataModel;
3. using System;
4. using System.Collections.Generic;
5. using System.Linq;
6. using System.Threading.Tasks;
7. using System.Windows.Forms;
9. namespace DemoSummaryZT
10. {
11.     internal static class Program
12.     {
13.         /// <summary>
14.         /// 应用程序的主入口点。
15.         /// </summary>
16.         [STAThread]
17.         static void Main()
18.         {
20.             //初始化数据库连接
21.             PGSql.InitialPGSql("localhost", "5432", "postgres", "postgres", "postgres", false);
22.             //查询数据
23.             Console.WriteLine("----新查询----");
24.             List<UserTable> userList = QueryUser.QueryUserName();
25.             foreach (var item in userList)
26.             {
27.                 Console.WriteLine("用户名:{0}\t\t ID:{1}\t年龄:{2}\t", item.Name, item.ID, item.Age);
28.             }
29.             //新增数据
30.             Console.WriteLine("----新增数据----");
31.             UserTable userTable = new UserTable();
32.             userTable.ID = "100";
33.             userTable.Name = "新增用户";
34.             userTable.Age = 47;
35.             AddUser.AddNewUser(userTable);
36.             Console.WriteLine("----新查询----");
37.             List<UserTable> userList1 = QueryUser.QueryUserName();
38.             foreach (var item in userList1)
39.             {
40.                 Console.WriteLine("用户名:{0}\t \t ID:{1}\t年龄:{2}\t", item.Name, item.ID, item.Age);
41.             }
42.             //修改数据
43.             Console.WriteLine("----修改数据----");
44.             UserTable userTable1 = new UserTable();
45.             userTable1.ID = "100";
46.             userTable1.Name = "新增用户名被修改";
47.             userTable1.Age = 47;
48.             ModifyUser.Modify(userTable1);
49.             Console.WriteLine("----新查询----");
50.             List<UserTable> userList2 = QueryUser.QueryUserName();
51.             foreach (var item in userList2)
52.             {
53.                 Console.WriteLine("用户名:{0}\t \t ID:{1}\t年龄:{2}\t", item.Name, item.ID, item.Age);
54.             }
55.             //删除数据
56.             Console.WriteLine("----删除数据-新增用户----");
57.             Console.WriteLine("----删除数据-新增用户----");
58.             DeleteUser.Delete("100");
59.             Console.WriteLine("----新查询----");
60.             List<UserTable> userList3 = QueryUser.QueryUserName();
61.             foreach (var item in userList3)
62.             {
63.                 Console.WriteLine("用户名:{0}\t \t ID:{1}\t年龄:{2}\t", item.Name, item.ID, item.Age);
64.             }
65.         }
66.     }
67. }

复制代码

检察运行结果

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。