可分片数据持久层ShardingPL使用说明

ShardingPL是在轻量级数据持久层Seaking.PL基础上开发的,从框架级别上提供数据分片支持的持久层。

ShardingPL采用按ID分段与按时间分段相结合的分片策略,使用分段字典为策略提供数据支持。适用于随着时间的延续,数据量呈线性或接近于线性增长的场景,如MIS软件中的业务数据。借助ShardingPL,可实现“年度数据库”或类似的数据分片存储。

使用ShardingPL时,不必也不能在系统启用时即建立足够的数据分片,而是随着时间的延续,在现有数据分片的数据规模达到应当进行分片时,再利用ShardingPL提供的辅助工具建立起新的数据分片。

ShardingPL在处理分片数据时,假定“最新的数据会更频繁的被使用”,因此,访问新增加的数据的性能会优于访问旧数据的性能。

ShardingPL提供了与Seaking.PL近似的类库与方法,ShardingPL提供的所有类都会在Seaking.PL中找到对应类,如ShardingDataProvider对应于DataProvider,ShardingSession对应于Session,ShardingCriteria对应于Criteria。类中所提供的方法与Seaking.PL提供的方法相同或基本相同,但对部分Seaking.PL中提供的API不支持,包括:暂不支持OleDb、不支持Session中的Execute系列方法、不支持Query、不支持EntityList及EntityDataTable、不支持Criteria类中的AddOrder等。

ShardingPL支持事务,提供了与Seaking.PL一致的BeginTransaction、TransactionCommit、TransactionRollback方法。

使用步骤:

1、声明并实例化ShardingDataProvider,示例代码:

string connectionString = @"server=server;uid=sa;pwd=123456;database=DatabaseSharding2010;";
ShardingDataProvider dp = new ShardingDataProvider(connectionString);

2、声明并用ShardingDataProvider 产生ShardingSession。

var session = dp.NewSession();

3、单实体数据操作:使用ShardingSession完成Insert、Update、Delete、Retrieve、IsExist等操作。使用与Seaking.PL一致,具体可参考轻量级数据持久层 Seaking.PL 2.1 使用说明 (二)

单实体数据操作时,ShardingPL会根据分片策略快速确定数据所在分片,当单个分片的数据规模适当时,性能可以得到有效保障。

4、按标准数据操作:如果需要按标准操作数据,需要使用ShardingSession提供的方法建立操作标准。

 var criteria = session.CreateCriteria<Invoice>(ShardingCriteriaTimeRange.CurrentMonth);

与Seaking.PL不同的是,建立标准时,需要为标准指定一个时间范围,可以使用ShardingCriteriaTimeRange枚举或指定一个明确的开始时间。需注意的是,该时间范围只会为ShardingPL选择要操作的数据分片提供依据,并不会成为业务数据的查询条件,如果需要按时间对业务数据进行筛选,应为标准添加相应的条件(见第5条)。如以上代码中,按ShardingCriteriaTimeRange.CurrentMonth建立标准获取出来的数据并不一定是当月的。

按标准数据操作时,ShardingPL可能需要操作一个或几个数据分片,并对操作结果进行合并。为了提高性能,应当在满足要求的前提下为标准指定尽可能短的时间范围。

5、为标准添加条件。ShardingCriteria提供了与Seaking.PL一致的添加条件的方法,但不支持条件组。ShardingCriteria同样支持“连写”方式。如:

criteria.AddGreaterThan(Invoice.ID, 100).AddEqualTo(Invoice.CODE, "001");


6、执行按标准操作,包括Retrive、RetrieveGeneralList、Update、Delete、Count、Exists。

var invoices = criteria.RetrieveGeneralList();
原文地址:https://www.cnblogs.com/chinadhf/p/1713250.html