SqlSugar简单使用之Nuget包封装-Easy.SqlSugar.Core

ops/2025/2/10 23:14:43/

在这里插入图片描述

SqlSugar官方文档
Nuget包开源地址

Nuget包是为了简化SqlSugar的使用步骤,增加一些基础的使用封装

引入分为两个版本，一个Ioc模式，另一个是注入模式，如果不想影响原本的仓储代码推荐使用Ioc模式，两者区别不大，方法通用

线上nuget引入 版本号随时更新

<PackageReference Include="Easy.SqlSugar.Core" Version="2025.02.06.6" />

3.1.1 SqlSugar配置文件

/*对应下边的 DBTypeMySql = 0,SqlServer = 1,Sqlite = 2,Oracle = 3,PostgreSQL = 4,Dm = 5,//达梦Kdbndp = 6,//人大金仓*/"DBS": [{"ConfigId": "journal","DBType": 0,"IsAutoCloseConnection": true,"ConnectionString": "server=localhost;Database=journal;Uid=root;Pwd=123456;allowPublicKeyRetrieval=true;"}]

3.1.2 或者使用自定义的配置只要转换为对应的List配置集合就行,Ioc需要转换为List,普通模式需要转换为List

根据字符串获取DbType
DataBaseTypeExtensions.GetDatabaseType("sql连接字符串")
自定义的配置文件示例
    public static class SqlSugarSetup{public static void AddSqlSugarSetup(this IServiceCollection services, IConfiguration configuration){var dblist = new List<IocConfig>();var conn = configuration.GetConnectionString("连接字符串");if (string.IsNullOrWhiteSpace(conn)){continue;}dblist.Add(new IocConfig(){ConfigId = "TestConfig",ConnectionString = conn,DbType = DataBaseTypeExtensions.GetDatabaseType(conn),IsAutoCloseConnection = true});bool aopLogging = false;Action<SqlSugarClient> aopConfigAction = null;//开发环境打印实际sql语句
#if DEBUGaopLogging = true;aopConfigAction = sqlSugarClient =>{foreach (var config in dblist){sqlSugarClient.GetConnection(config.ConfigId).Aop.OnLogExecuting = (Action<string, SugarParameter[]>)((sql, p) =>{Console.WriteLine($"----------------{Environment.NewLine}{DateTime.Now},ConfigId:{config.ConfigId},Sql:{Environment.NewLine}{UtilMethods.GetSqlString((SqlSugar.DbType)config.DbType, sql, p)}{Environment.NewLine}----------------");});}};
#endifservices.AddSqlSugarIocSetup(dblist, aopLogging, aopConfigAction);}}

3.2 SqlSugar配置

3.2.1 使用Ioc模式的配置
//使用SqlSugar
//参数含义
//1.配置文件
//2.是否启用AOP日志
//3.ConfigurationSugar自定义配置
builder.Services.AddSqlSugarIocSetup(configuration.GetSection("DBS").Get<List<IocConfig>>(), true, config =>
{config.Aop.OnLogExecuting = (sql, pars) =>{Console.WriteLine("这是自定义事件{0}", sql);};
});
3.2.2 使用普通模式的配置
//使用SqlSugar
var list = configuration.GetSection("DBS").Get<List<ConnectionConfig>>();
foreach (var item in list)
{//调试模式日志输出
#if DEBUGitem.AopEvents = new AopEvents(){OnLogExecuting = (sql, pars) =>{Console.WriteLine($"{DateTime.Now},ConfigId:{item.ConfigId},Sql:{UtilMethods.GetSqlString(DbType.MySql, sql, pars)}");}};
#endif
}
builder.Services.AddSqlSugarSetup(list);//注入3.2.1.1中的仓储(如果使用其他方式注入，可以忽略这里)
builder.Services.AddSingleton<IUserRepository, UserRepository>();

3.3 实体类、仓储

    /// <summary>/// 用户表///</summary>[SugarTable("J_User")]//表别名[Tenant("journal")]//数据库标识 需要与配置文件中的ConfigId对应public class User{/// <summary>///用户id///</summary>[Key][SugarColumn(ColumnName = "ID", IsPrimaryKey = true, IsIdentity = true)]public int Id { get; set; }}//可以直接不使用接口模式,直接使用仓储(如果名称Service、Repository、Dao结尾的类,ISingletony也可以省略,前提是必须使用autofac包)public class UserRepository : BaseSqlSugarIocRepository<User>, ISingleton{//在这里直接用base.  也可以直接调用仓储的方法}public class UserRepository : BaseSqlSugarRepository<User>, ISingleton{public UserRepository(ISqlSugarClient db) : base(db){}}/// <summary>/// 用户仓储(使用SqlsugarIoc模式)/// </summary>public class UserRepository : BaseSqlSugarIocRepository<User>, IUserRepository{//在这里直接用base.  也可以直接调用仓储的方法}/// <summary>/// 用户仓储接口层(使用SqlsugarIoc模式)/// </summary>public interface IUserRepository : IBaseRepository<User>, ISingleton{}//另一个仓储需要注入dbpublic class UserRepository : BaseSqlSugarRepository<User>, ISingleton{public UserRepository(ISqlSugarClient db) : base(db){}}/// <summary>/// 用户仓储接口层(使用SqlsugarIoc模式)/// </summary>public interface IUserRepository : IBaseRepository<User>, ISingleton{}//注入private readonly IUserRepository _userRepository;public SqlSugarController(IUserRepository userRepository){_userRepository = userRepository;}//方法中使用public object Get(){var user = _userRepository.GetSingle(p => p.Id == 1);return user;}

3.4 使用示例

//所有操作都有异步方法，增加Async即可//直接使用DbContext上下文
_userRepository.SqlSugarDbContext
//使用上下文Ado
_userRepository.SqlSugarDbContextAdo

3.4.1 Ioc仓储模式

//查询单个
var obj = _userRepository.GetSingle(p => p.Id == 1);
//查询列表
var list = _userRepository.GetList(p => p.Id > 0);
//分页查询 (条件,排序,页码,每页条数)
var page = _userRepository.QueryPage(p => p.Id > 0, "", 1, 10);
//分页查询 (条件,排序,排序方式,页码,每页条数)
var page2 = _userRepository.QueryPage(p => p.Id > 0, o => o.Id, SqlSugar.OrderByType.Desc, 1, 10);
//分页排序
// 设置排序参数
// Dictionary<string, QueryOrderBy> orderBy = new Dictionary<string, QueryOrderBy>
// {
//     { "CreateTime", QueryOrderBy.Desc }, // 按 CreateTime 降序排序
//     { "Name", QueryOrderBy.Asc } // 按 Name 升序排序
// };
// var page3 = _userRepository.IQueryablePage(p => p.Id > 0, 1, out int rowcount,  orderBy, true);
//判断数据是否存在
var isAny = _userRepository.Exists(p => p.Id == 1);
//获取数据总数
var count = _userRepository.GetCount(p => p.Id > 0);
//添加
var userId = _userRepository.Insert(new User() { Id = 1 });
//添加指定列
var userId2 = _userRepository.Insert(new User() { Id = 1 }, p => new { p.Id });
//批量添加
var userIds = _userRepository.Insert(new List<User>() { new User() { Id = 1 }, new User() { Id = 2 } });//修改
var isUpdate = _userRepository.Update(obj);
//修改指定列
var isUpdate7 = _userRepository.Update(obj, x => new { x.Name });
//修改指定条件数据
var isUpdate2 = _userRepository.Update(p => new User() { Name = "2" }, p => new { p.Id });
//根据条件更新 (实体,要修改的列,条件)
var isUpdate3 = _userRepository.Update(obj, x => new { x.Name }, x => new { x.Id });
//批量修改
var isUpdate4 = _userRepository.Update(new List<User>() { new User() { Id = 1 }, new User() { Id = 2 } });
//无实体更新
Dictionary<string, object> updateColumns = new Dictionary<string, object>
{{ "name", "2" }
};
var isUpdate5 = _userRepository.Update(updateColumns, x => new { x.Id });
//无实体更新2,先将值放在实体中,只更新要更新的值(实体内字段如果全部更新就不要带where条件,避免误传导致数值问题,有where必须由更新字段指定)
var user = new User() { Name = "2" };
var isUpdate6 = _userRepository.Update(user, x => new { x.Name }, x => new { x.Id });//添加或更新 单条或list集合
//根据主键添加或更新
var inserOrUpdate = _userRepository.InsertOrUpdate(new User() { Id = 1, Name ="admin" });
//根据条件添加或更新
var inserOrUpdate2 = _userRepository.InsertOrUpdate(new User() { Id = 1, Name= "admin" }, x => new { x.Id, x.Name });
//根据条件添加并更新指定列
var isInsertOrUpdate = _userRepository.InsertOrUpdate(user, x => new { xName }, x => new { x.Id, x.Name });//删除
var isDelete = _userRepository.Delete(obj);
//批量删除  有问题
var isDelete2 = _userRepository.Delete(new List<User>() { new User() { Id = 1 }, new User() { Id = 2 } });
//根据主键删除
var isDelete3 = _userRepository.DeleteByIds([1, 2]);//执行自定义sql
//查询
var list2 = _userRepository.SqlQuery("select * from test_user", null);
//查询到指定实体
var list3 = _userRepository.SqlQuery<User>("select * from test_user", null);
//执行增删改
var count2 = _userRepository.ExecuteSql("update test_user set name='a' where id=1", null);
//查询分页到指定实体
var page4 = _userRepository.SqlPageQuery<User>("select * from test_user", null, 1, 1);
var page4Count = page4.TotalCount;//执行事务 return true表示提交,return false表示回滚
var BeginTranRes = _userRepository.DbContextBeginTransaction(() =>
{_userRepository.Insert(new User() { Id = 1 });_userRepository.Insert(new User() { Id = 2 });return true;
});
3.4.2 原生使用方法

//也可以用原生方法var list = _userRepository.GetList(p => p.Id > 0);
//分页查询 (条件,排序,页码,每页条数)
int pgae = 1;
int pageSize = 10;
int totalCount = 0;
var page = _userRepository.AsQueryable().Where(p => p.Id > 0).OrderBy(o => o.d).ToPageList(pgae, pageSize, ref totalCount);
//分页查询 (条件,排序,排序方式,页码,每页条数)
var page2 = _userRepository.AsQueryable().Where(p => p.Id > 0).OrderBy(o => o.d, SqlSugar.OrderByType.Desc).ToPageList(pgae, pageSize, ref totalCount);
//分页排序
// 设置排序参数
List<OrderByModel> orderByModels = new List<OrderByModel>
{new OrderByModel() { FieldName = "CreateTime", OrderByType = OrderByType.Desc }, // 按 CreateTime 降序排序new OrderByModel() { FieldName = "Name", OrderByType = OrderByType.Asc } // 按 Name 升序排序
};
var page3 = _userRepository.AsQueryable().Where(p => p.Id > 0).OrderByorderByModels).ToPageList(pgae, pageSize, ref totalCount);
//判断数据是否存在
var isAny = _userRepository.AsQueryable().Any(p => p.Id == 1);
//获取数据总数
var count = _userRepository.AsQueryable().Count(p => p.Id > 0);
//添加
var user = new User() { Id = 1 };
var userId = _userRepository.InsertReturnIdentity(user);
//添加指定列
var userId2 = _userRepository.AsInsertable(user).InsertColumns(p => new { p.d }).ExecuteReturnIdentity();
//批量添加
_userRepository.AsInsertable(new List<User>() { new() { Id = 1 }, new() { Id =  } });
//修改
var isUpdate = _userRepository.Update(user);
//修改指定列
var isUpdate2 = _userRepository.AsUpdateable(user).UpdateColumns(p => new User) { Name = "2" }).Where(p => p.Name == "test").ExecuteCommand();
//根据条件更新 (实体,要修改的列,条件)
var isUpdate3 = _userRepository.AsUpdateable(user).UpdateColumns(p => new User) { Name = "2" }).Where(p => p.Id == 1).ExecuteCommand();
//批量修改
_userRepository.AsUpdateable(new List<User>() { new() { Id = 1 }, new() { Id =  } });
//删除
var isDelete = _userRepository.Delete(user);
//批量删除
_userRepository.Delete(new List<User>() { new() { Id = 1 }, new() { Id =  } });
//根据主键删除
_userRepository.DeleteByIds(new dynamic[] { 1, 2 });
//执行自定义sql
//查询
var list2 = _userRepository.SqlSugarDbContext.SqlQueryable<User>("select * rom test_user");
//查询到指定实体
var list3 = _userRepository.SqlSugarDbContext.SqlQueryable<User>("select * rom test_user").ToList();
//执行增删改
var count2 = _userRepository.SqlSugarDbContextAdo.ExecuteCommand("update est_user set name='a' where id=1");
//事务
var tran = _userRepository.SqlSugarDbContext.AsTenant();
tran.BeginTran();
try
{_userRepository.Insert(new User() { Id = 1 });_userRepository.Insert(new User() { Id = 2 });tran.CommitTran();
}
catch (Exception)
{tran.RollbackTran();
}

http://www.ppmy.cn/ops/157381.html

相关文章

C++开发（软件开发）常见面试题

C++开发（软件开发）常见面试题

目录 1、C里指针和数组的区别 2、C中空指针请使用nullptr不要使用NULL 3、http/https区别和头部结构&#xff1f; 4、有了mac地址为什么还要ip地址&#xff1f;ip地址的作用 5、有了路由器为什么还要交换机&#xff1f; 6、面向对象三大特性 7、友元函数 8、大端小端 …
阅读更多...
Day.23

Day.23

leetcode 413.等差数列划分 问题&#xff1a;如果一个数列 至少有三个元素 &#xff0c;并且任意两个相邻元素之差相同&#xff0c;则称该数列为等差数列。给你一个整数数组 nums &#xff0c;返回数组 nums 中所有为等差数组的 子数组 个数。 子数组 是数组中的一个连续序列…
阅读更多...
Spring Boot 条件注解：@ConditionalOnProperty 完全解析

Spring Boot 条件注解：@ConditionalOnProperty 完全解析

在 Spring Boot 项目中&#xff0c;有时候我们希望根据配置文件中的某个属性值来决定是否启用某个功能或加载某个组件。此时&#xff0c;ConditionalOnProperty 注解就可以发挥作用。它通过配置文件的属性值控制 Bean 或配置类的加载&#xff0c;使得我们的程序更具灵活性。 本…
阅读更多...
MySQL第五次作业

MySQL第五次作业

根据图片内容完成作业 1.建表 &#xff08;1&#xff09;建立两个表:goods(商品表)、orders(订单表) mysql> create table goods( -> gid char(8) primary key, -> name varchar(10), -> price decimal(8,2), -> num int); mysql> create t…
阅读更多...
Apache SeaTunnel 整体架构运行原理

Apache SeaTunnel 整体架构运行原理

概述 SeaTunnel 缘起 数据集成在现代企业的数据治理和决策支持中扮演着至关重要的角色。随着数据源的多样化和数据量的迅速增长及业务需求的快速变化&#xff0c;企业需要具备强大的数据集成能力来高效地处理数据。SeaTunnel通过其高度可扩展和灵活的架构&#xff0c;帮助企业…
阅读更多...
机器学习数学基础：18.向量组及其线性组合

机器学习数学基础：18.向量组及其线性组合

向量组与线性表示&#xff1a;案例与教程详解 一、基础概念 &#xff08;一&#xff09;向量组 向量组是若干同位数列向量组成的集合。比如在平面直角坐标系中&#xff0c;向量组 { α ⃗ 1 [ 1 0 ] , α ⃗ 2 [ 0 1 ] } \{\vec{\alpha}_1 \ \begin{bmatrix}1\\0\end{bma…
阅读更多...
十三. Redis 应用问题和解决方案思想

十三. Redis 应用问题和解决方案思想

十三. Redis 应用问题和解决方案思想 文章目录 十三. Redis 应用问题和解决方案思想1. 缓存穿透2. 缓存击穿3. 缓存雪崩4. 分布式锁4.1 分布式锁主流实现方案&#xff1a;4.2 Redis 实现分布式锁-基本实现4.3 Redis 实现分布式锁-Java代码实现4.4 实例&#xff1a;优化-设置锁的…
阅读更多...
AI软件外包需要注意什么 外包开发AI软件的关键因素是什么 如何选择AI外包开发语言

AI软件外包需要注意什么 外包开发AI软件的关键因素是什么 如何选择AI外包开发语言

1. 定义目标与需求 首先&#xff0c;要明确你希望AI智能体做什么。是自动化任务、数据分析、自然语言处理&#xff0c;还是其他功能&#xff1f;明确目标可以帮助你选择合适的技术和方法。 2. 选择开发平台与工具 开发AI智能体的软件时&#xff0c;你需要选择适合的编程语言、…
阅读更多...
最新文章

Copyright @ 2022~2023