欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

.NET Core实现分表分库、读写分离的通用 Repository功能

程序员文章站 2023-12-12 08:14:40
首先声明这篇文章不是标题党,我说的这个类库是 freesql.repository,它作为扩展库现实了通用仓储层功能,接口规范参考 abp vnext 定义,实现了基础的仓...

首先声明这篇文章不是标题党,我说的这个类库是 freesql.repository,它作为扩展库现实了通用仓储层功能,接口规范参考 abp vnext 定义,实现了基础的仓储层(curd)。

安装

dotnet add package freesql.repository

可用于:.net framework 4.6+、.net core 2.1+

定义
var fsql = new freesql.freesqlbuilder()
 .useconnectionstring(freesql.datatype.sqlite, @"data source=|datadirectory|\document.db;pooling=true;max pool size=10")
 .uselogger(loggerfactory.createlogger<ifreesql>())
 .useautosyncstructure(true) //自动迁移实体的结构到数据库
 .build();

过滤与验证

假设我们有user(用户)、topic(主题)两个实体,在某领域类中定义了两个仓储:

var userrepository = fsql.getguidrepository<user>();
var topicrepository = fsql.getguidrepository<topic>();

开发过程中,我总会担心 topicrepository 的数据安全问题,即有可能查询或操作到其他用户的主题。因此在v0.0.7版本进行了改进,增加了 filter lambad 表达式参数。

var userrepository = fsql.getguidrepository<user>(a => a.id == 1);
var topicrepository = fsql.getguidrepository<topic>(a => a.userid == 1);
  • 在查询/修改/删除时附加此条件,从而达到不会修改其他用户的数据;
  • 在添加时,使用表达式验证数据的合法性,若不合法则抛出异常;

有朋友说这个功能像 abp 的租户,但这是更小单位的过滤+验证,确保数据安全。
有朋友说这个功能省事,但我觉得是省心。

分表与分库

guidrepository 作为分存式仓储将实现了分表与分库(不支持跨服务器分库)的封装类。

var logrepository = fsql.getguidrepository<log>(null, oldname => $"{oldname}_{datetime.now.tostring("yyyymm")}");

上面我们得到一个日志仓储实例按年月分表,使用它 curd 最终会操作 log_201903 表。

注意:虽然 freesql 支持 codefirst 迁移,但不提供迁移分表,开发环境中仍然可以迁移 log 表。

读写分离

freesql 支持数据库读写分离,本功能是客户端的读写分离行为,数据库服务器该怎么配置仍然那样配置,不受本功能影响,为了方便描术后面讲到的【读写分离】都是指客户端的功能支持。

各种数据库的读写方案不一,数据库端开启读写分离功能后,读写分离的实现大致分为以下几种:

1、nginx代理,配置繁琐且容易出错;

2、中件间,如mysql可以使用mycat,但是其他数据库怎么办?

3、在client端支持;

freesql 实现了第3种方案,支持一个【主库】多个【从库】,【从库】的查询策略为随机方式。

若某【从库】发生故障,将切换到其他可用【从库】,若已全部不可用则使用【主库】查询。

出现故障【从库】被隔离起来间隔性的检查可用状态,以待恢复。以 mysql 为例:

var connstr = "data source=127.0.0.1;port=3306;user id=root;password=root;" + 
 "initial catalog=cccddd;charset=utf8;sslmode=none;max pool size=10";

ifreesql fsql = new freesql.freesqlbuilder()
 .useconnectionstring(freesql.datatype.mysql, connstr)
 .useslave("connectionstring1", "connectionstring2") //使用从数据库,支持多个
 .build();

select.where(a => a.id == 1).toone(); //读【从库】(默认)
select.master().whereid(a => a.id == 1).toone(); //强制读【主库】
其他特性
  • [x] 支持 codefirst 迁移;
  • [x] 支持 dbfirst 从数据库导入实体类,支持三种模板生成器;
  • [x] 采用 expressiontree 高性能读取数据;
  • [x] 支持深入的类型映射,比如pgsql的数组类型;
  • [x] 支持丰富的表达式函数;
  • [x] 支持导航属性查询,和延时加载;
  • [x] 支持同步/异步数据库操作方法,丰富多彩的链式查询方法;
  • [x] 支持读写分离、分表分库;
  • [x] 支持多种数据库,mysql/sqlserver/postgresql/oracle/sqlite;
结束语

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对的支持。

上一篇:

下一篇: