.net SqlSugarHelper

NuGet安装： SqlSugarCore

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 Namespace
9. {
10.     public class SqlSugarHelper
11.     {
12.         public string _connectionString = CustomConfigManager.GetConfig("MySql");//MySql连接字符串
13.         public SqlSugarClient _db = null;
15.         /// <summary>
16.         /// 构造函数(初始化)
17.         /// 调用方法:
18.         /// SqlSugarHelper sugar = new SqlSugarHelper();
19.         /// var db = sugar.SqlClient();
20.         /// var user = db.Queryable<Userinfo>().Where(a => a.Name.Equals(uid) && a.PWD.Equals(pwd)).ToList().FirstOrDefault();
21.         /// </summary>
22.         public SqlSugarClient SqlClient()
23.         {
24.             if (string.IsNullOrEmpty(_connectionString))
25.                 throw new ArgumentNullException("数据库连接字符串为空");
27.             _db = new SqlSugarClient(new ConnectionConfig()
28.             {
29.                 ConnectionString = _connectionString,//数据库连接字符串,见UI的appsettings.json内配置
30.                 DbType = DbType.MySql,//数据库类型
31.                 IsAutoCloseConnection = true,//自动断开连接
32.                 MoreSettings = new ConnMoreSettings()
33.                 {
34.                     IsWithNoLockQuery = true,//为true表式查询的时候默认会加上.With(SqlWith.NoLock)，
35.                     IsAutoRemoveDataCache = true//为true自动清除缓存
36.                 }
37.             });
38.             //输入最终SQL语句...
39.             _db.Aop.OnLogExecuting = (sql, pars) =>
40.             {
41.                 var s1 = sql;//断点打在这里看内部生成的sql语句...
42.             };
44.             return _db;
45.         }
47.     }
48. }

复制代码

---

config文件：

1. {
2.   //MySql连接字符串
3.   "MySql": "Server=127.0.0.1;Database=db_test;User ID=root;Password=123456;SslMode=None;allowPublicKeyRetrieval=true;"//开发环境
4. }

复制代码

---

调用举例：

1.     //查询
2.     public static List<tb_equip> Get_EquipList()
3.     {
4.             SqlSugarHelper sugar = new SqlSugarHelper();
5.             var db = sugar.SqlClient();
6.             try
7.             {
8.                 var gsList = db.Queryable<tb_equip>()
9.                    .Where(a => a.IsUsing == true)//使用中
10.                    .WhereIF(!string.IsNullOrWhiteSpace(PowerStation), a => a.PowerStation.Equals(PowerStation))//可选条件
11.                    .ToList();
13.                 return gsList;
14.             }
15.             catch (Exception ex)
16.             {
17.                 Console.WriteLine("Get_TH70M_EquipList() " + ex.Message);//打印结果
18.                 return null;
19.             }
20.     }
23.     //添加
24.     public static bool tb_tcp_log_add(Socket send, decimal wd_dec, decimal sd_dec, tb_equip equip, string packet, TcpType tcpType)
25.     {
26.         SqlSugarHelper sugar = new SqlSugarHelper();
27.         var db = sugar.SqlClient();
28.         tb_tcp_log log = new tb_tcp_log();
29.         log.TCP_IP_STR = send.RemoteEndPoint.ToString();//IP原文
30.         log.TCP_IP = Tools.SocketFormat(send.RemoteEndPoint.ToString());//IP格式化
31.         log.UUID = Guid.NewGuid().ToString();//主键(必须)
32.         log.Type = tcpType.ToString(); //类型
34.         int cc = db.Insertable(log).ExecuteCommand();//添加到数据库
35.         Console.WriteLine($"添加到数据库，成功添加{cc}条...");//打印结果
36.         if (cc > 0)
37.         {
38.             WriteLineAndLog("已添加");
39.         }
41.         return cc > 0;
42.     }

复制代码

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