您的位置:首页 > 教育 > 培训 > .net SqlSugarHelper

.net SqlSugarHelper

2025/2/24 8:03:01 来源:https://blog.csdn.net/djk8888/article/details/141059806  浏览:    关键词:.net SqlSugarHelper

NuGet安装: SqlSugarCore

using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;namespace Namespace 
{public class SqlSugarHelper{public string _connectionString = CustomConfigManager.GetConfig("MySql");//MySql连接字符串public SqlSugarClient _db = null;/// <summary>/// 构造函数(初始化)/// 调用方法:/// SqlSugarHelper sugar = new SqlSugarHelper();/// var db = sugar.SqlClient();/// var user = db.Queryable<Userinfo>().Where(a => a.Name.Equals(uid) && a.PWD.Equals(pwd)).ToList().FirstOrDefault();/// </summary>public SqlSugarClient SqlClient(){if (string.IsNullOrEmpty(_connectionString))throw new ArgumentNullException("数据库连接字符串为空");_db = new SqlSugarClient(new ConnectionConfig(){ConnectionString = _connectionString,//数据库连接字符串,见UI的appsettings.json内配置DbType = DbType.MySql,//数据库类型IsAutoCloseConnection = true,//自动断开连接MoreSettings = new ConnMoreSettings(){IsWithNoLockQuery = true,//为true表式查询的时候默认会加上.With(SqlWith.NoLock),IsAutoRemoveDataCache = true//为true自动清除缓存}});//输入最终SQL语句..._db.Aop.OnLogExecuting = (sql, pars) =>{var s1 = sql;//断点打在这里看内部生成的sql语句...};return _db;}}
}

config文件:

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

调用举例:

    //查询public static List<tb_equip> Get_EquipList(){SqlSugarHelper sugar = new SqlSugarHelper();var db = sugar.SqlClient();try{var gsList = db.Queryable<tb_equip>().Where(a => a.IsUsing == true)//使用中.WhereIF(!string.IsNullOrWhiteSpace(PowerStation), a => a.PowerStation.Equals(PowerStation))//可选条件.ToList();return gsList;}catch (Exception ex){Console.WriteLine("Get_TH70M_EquipList() " + ex.Message);//打印结果return null;}}//添加public static bool tb_tcp_log_add(Socket send, decimal wd_dec, decimal sd_dec, tb_equip equip, string packet, TcpType tcpType){SqlSugarHelper sugar = new SqlSugarHelper();var db = sugar.SqlClient();tb_tcp_log log = new tb_tcp_log();log.TCP_IP_STR = send.RemoteEndPoint.ToString();//IP原文log.TCP_IP = Tools.SocketFormat(send.RemoteEndPoint.ToString());//IP格式化log.UUID = Guid.NewGuid().ToString();//主键(必须)log.Type = tcpType.ToString(); //类型int cc = db.Insertable(log).ExecuteCommand();//添加到数据库Console.WriteLine($"添加到数据库,成功添加{cc}条...");//打印结果if (cc > 0){WriteLineAndLog("已添加");}return cc > 0;}

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com