From 626bbb0f4cb607144a252adadf3fe4c4c1e60d28 Mon Sep 17 00:00:00 2001
From: xuejiaming <326308290@qq.com>
Date: Fri, 24 Nov 2023 08:18:05 +0800
Subject: [PATCH] 7.x.1.19-preview1 [#252]
---
ShardingCore.sln | 7 +
nuget-publish.bat | 12 +-
.../Sample.SqlServer/Sample.SqlServer.csproj | 2 +-
src/ShardingCore.Test7x/Common/SnowflakeId.cs | 196 ++
.../Domain/Entities/LogDay.cs | 12 +
.../Domain/Entities/LogDayLong.cs | 16 +
.../Domain/Entities/LogMonthLong.cs | 15 +
.../Domain/Entities/LogNoSharding.cs | 15 +
.../Domain/Entities/LogWeekDateTime.cs | 12 +
.../Domain/Entities/LogWeekTimeLong.cs | 16 +
.../Domain/Entities/LogYearDateTime.cs | 15 +
.../Domain/Entities/LogYearLong.cs | 15 +
.../Domain/Entities/MultiShardingOrder.cs | 11 +
.../Domain/Entities/Order.cs | 13 +
.../Domain/Entities/SysUserMod.cs | 32 +
.../Domain/Entities/SysUserModInt.cs | 25 +
.../Domain/Entities/SysUserSalary.cs | 39 +
.../Domain/Maps/LogDayLongMap.cs | 22 +
.../Domain/Maps/LogDayMap.cs | 17 +
.../Domain/Maps/LogMonthLongMap.cs | 23 +
.../Domain/Maps/LogNoShardingMap.cs | 22 +
.../Domain/Maps/LogWeekDateTimeMap.cs | 17 +
.../Domain/Maps/LogWeekTimeLongMap.cs | 22 +
.../Domain/Maps/LogYearDateTimeMap.cs | 22 +
.../Domain/Maps/LogYearLongMap.cs | 23 +
.../Domain/Maps/MultiShardingOrderMap.cs | 22 +
.../Domain/Maps/OrderMap.cs | 16 +
.../Domain/Maps/SysUserModIntMap.cs | 23 +
.../Domain/Maps/SysUserModMap.cs | 23 +
.../Domain/Maps/SysUserSalaryMap.cs | 23 +
.../ShardingCore.Test7x.csproj | 28 +
.../ShardingDefaultDbContext.cs | 48 +
src/ShardingCore.Test7x/ShardingTest.cs | 1792 +++++++++++++++++
src/ShardingCore.Test7x/ShardingTestSync.cs | 1541 ++++++++++++++
.../Shardings/LogDayLongVirtualRoute.cs | 53 +
.../Shardings/LogDayVirtualTableRoute.cs | 57 +
.../Shardings/LogMonthLongvirtualRoute.cs | 33 +
.../LogWeekDateTimeVirtualTableRoute.cs | 28 +
.../LogWeekTimeLongVirtualTableRoute.cs | 32 +
.../Shardings/LogYearDateTimeVirtualRoute.cs | 31 +
.../Shardings/LogYearLongVirtualRoute.cs | 32 +
.../MultiShardingOrderVirtualTableRoute.cs | 79 +
...OrderAreaShardingVirtualDataSourceRoute.cs | 59 +
.../OrderCreateTimeVirtualTableRoute.cs | 65 +
.../LogDayPaginationConfiguration.cs | 15 +
.../Shardings/SysUserModIntVirtualRoute.cs | 26 +
.../Shardings/SysUserModVirtualTableRoute.cs | 28 +
.../SysUserSalaryVirtualTableRoute.cs | 77 +
src/ShardingCore.Test7x/Startup.cs | 383 ++++
.../ShardingCore.CommonTest.csproj | 4 +-
.../ShardingCore.Test.csproj | 6 +-
test/ShardingCore.Test/Startup.cs | 4 +-
52 files changed, 5135 insertions(+), 14 deletions(-)
create mode 100644 src/ShardingCore.Test7x/Common/SnowflakeId.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/LogDay.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/LogDayLong.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/LogMonthLong.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/LogNoSharding.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/LogWeekDateTime.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/LogWeekTimeLong.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/LogYearDateTime.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/LogYearLong.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/MultiShardingOrder.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/Order.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/SysUserMod.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/SysUserModInt.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Entities/SysUserSalary.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/LogDayLongMap.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/LogDayMap.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/LogMonthLongMap.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/LogNoShardingMap.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/LogWeekDateTimeMap.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/LogWeekTimeLongMap.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/LogYearDateTimeMap.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/LogYearLongMap.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/MultiShardingOrderMap.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/OrderMap.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/SysUserModIntMap.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/SysUserModMap.cs
create mode 100644 src/ShardingCore.Test7x/Domain/Maps/SysUserSalaryMap.cs
create mode 100644 src/ShardingCore.Test7x/ShardingCore.Test7x.csproj
create mode 100644 src/ShardingCore.Test7x/ShardingDefaultDbContext.cs
create mode 100644 src/ShardingCore.Test7x/ShardingTest.cs
create mode 100644 src/ShardingCore.Test7x/ShardingTestSync.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/LogDayLongVirtualRoute.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/LogDayVirtualTableRoute.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/LogMonthLongvirtualRoute.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/LogWeekDateTimeVirtualTableRoute.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/LogWeekTimeLongVirtualTableRoute.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/LogYearDateTimeVirtualRoute.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/LogYearLongVirtualRoute.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/MultiShardingOrderVirtualTableRoute.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/OrderAreaShardingVirtualDataSourceRoute.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/OrderCreateTimeVirtualTableRoute.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/PaginationConfigs/LogDayPaginationConfiguration.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/SysUserModIntVirtualRoute.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/SysUserModVirtualTableRoute.cs
create mode 100644 src/ShardingCore.Test7x/Shardings/SysUserSalaryVirtualTableRoute.cs
create mode 100644 src/ShardingCore.Test7x/Startup.cs
diff --git a/ShardingCore.sln b/ShardingCore.sln
index ebedb93f..86c27b97 100644
--- a/ShardingCore.sln
+++ b/ShardingCore.sln
@@ -79,6 +79,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ShardingCore7", "src7\Shard
EndProject
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src7", "src7", "{A5321A3E-8539-4E2A-889C-8E91989EECBD}"
EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ShardingCore.Test7x", "src\ShardingCore.Test7x\ShardingCore.Test7x.csproj", "{FC6C1017-69D5-44E0-8C4C-99B6F476FB55}"
+EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
@@ -201,6 +203,10 @@ Global
{A308D253-A072-40EC-AA97-15EE82BB8AAD}.Debug|Any CPU.Build.0 = Debug|Any CPU
{A308D253-A072-40EC-AA97-15EE82BB8AAD}.Release|Any CPU.ActiveCfg = Release|Any CPU
{A308D253-A072-40EC-AA97-15EE82BB8AAD}.Release|Any CPU.Build.0 = Release|Any CPU
+ {FC6C1017-69D5-44E0-8C4C-99B6F476FB55}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {FC6C1017-69D5-44E0-8C4C-99B6F476FB55}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {FC6C1017-69D5-44E0-8C4C-99B6F476FB55}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {FC6C1017-69D5-44E0-8C4C-99B6F476FB55}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection
GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE
@@ -235,6 +241,7 @@ Global
{F0393C32-2285-4F47-AC61-C1BA1CAC269D} = {B11D7DF7-A907-407E-8BF1-35B430413557}
{3B5A4B03-5190-41A8-8E4B-F95A79A5C018} = {EDF8869A-C1E1-491B-BC9F-4A33F4DE1C73}
{A308D253-A072-40EC-AA97-15EE82BB8AAD} = {A5321A3E-8539-4E2A-889C-8E91989EECBD}
+ {FC6C1017-69D5-44E0-8C4C-99B6F476FB55} = {CC2C88C0-65F2-445D-BE78-973B840FE281}
EndGlobalSection
GlobalSection(ExtensibilityGlobals) = postSolution
SolutionGuid = {8C07A667-E8B4-43C7-8053-721584BAD291}
diff --git a/nuget-publish.bat b/nuget-publish.bat
index 2da1f2af..55e69b01 100644
--- a/nuget-publish.bat
+++ b/nuget-publish.bat
@@ -1,11 +1,11 @@
:start
::定义版本
-set EFCORE8=7.8.1.19
-set EFCORE7=7.7.1.19
-set EFCORE6=7.6.1.19
-set EFCORE5=7.5.1.19
-set EFCORE3=7.3.1.19
-set EFCORE2=7.2.1.19
+set EFCORE8=7.8.1.19-preview1
+set EFCORE7=7.7.1.19-preview1
+set EFCORE6=7.6.1.19-preview1
+set EFCORE5=7.5.1.19-preview1
+set EFCORE3=7.3.1.19-preview1
+set EFCORE2=7.2.1.19-preview1
::删除所有bin与obj下的文件
@echo off
diff --git a/samples/Sample.SqlServer/Sample.SqlServer.csproj b/samples/Sample.SqlServer/Sample.SqlServer.csproj
index 8cdf1b55..06f2338d 100644
--- a/samples/Sample.SqlServer/Sample.SqlServer.csproj
+++ b/samples/Sample.SqlServer/Sample.SqlServer.csproj
@@ -16,7 +16,7 @@
-
+
diff --git a/src/ShardingCore.Test7x/Common/SnowflakeId.cs b/src/ShardingCore.Test7x/Common/SnowflakeId.cs
new file mode 100644
index 00000000..b8d6337d
--- /dev/null
+++ b/src/ShardingCore.Test7x/Common/SnowflakeId.cs
@@ -0,0 +1,196 @@
+using System;
+using System.Text;
+
+namespace ShardingCore.Test.Common
+{///
+ /// 雪花ID
+ /// Twitter_Snowflake
+ /// SnowFlake的结构如下(每部分用-分开)
+ /// 0 - 0000000000 0000000000 0000000000 0000000000 0 - 00000 - 00000 - 000000000000
+ /// 1位标识,由于long基本类型在Java中是带符号的,最高位是符号位,正数是0,负数是1,所以id一般是正数,最高位是0
+ /// 41位时间截(毫秒级),注意,41位时间截不是存储当前时间的时间截,而是存储时间截的差值(当前时间截 - 开始时间截)得到的值),
+ /// 41位的时间截,可以使用69年,年T = (1L << 41) / (1000L * 60 * 60 * 24 * 365) = 69
+ /// 这里的的开始时间截,一般是我们的id生成器开始使用的时间,由我们程序来指定的(如下下面程序IdWorker类的startTime属性)。
+ /// 10位的数据机器位,可以部署在1024个节点,包括5位datacenterId和5位workerId
+ /// 12位序列,毫秒内的计数,12位的计数顺序号支持每个节点每毫秒(同一机器,同一时间截)产生4096个ID序号
+ /// 总共加起来刚好64位,为一个Long型。
+ /// SnowFlake的优点是,整体上按照时间自增排序,并且整个分布式系统内不会产生ID碰撞(由数据中心ID和机器ID作区分),
+ /// 并且效率较高,经测试,SnowFlake单机每秒都能够产生出极限4,096,000个ID来
+ ///
+ public class SnowflakeId
+ {
+
+ // 开始时间截 (new DateTime(2020, 1, 1).ToUniversalTime() - Jan1st1970).TotalMilliseconds
+ private const long twepoch = 1577808000000L;
+
+ // 机器id所占的位数
+ private const int workerIdBits = 5;
+
+ // 数据标识id所占的位数
+ private const int datacenterIdBits = 5;
+
+ // 支持的最大机器id,结果是31 (这个移位算法可以很快的计算出几位二进制数所能表示的最大十进制数)
+ private const long maxWorkerId = -1L ^ (-1L << workerIdBits);
+
+ // 支持的最大数据标识id,结果是31
+ private const long maxDatacenterId = -1L ^ (-1L << datacenterIdBits);
+
+ // 序列在id中占的位数
+ private const int sequenceBits = 12;
+
+ // 数据标识id向左移17位(12+5)
+ private const int datacenterIdShift = sequenceBits + workerIdBits;
+
+ // 机器ID向左移12位
+ private const int workerIdShift = sequenceBits;
+
+
+ // 时间截向左移22位(5+5+12)
+ private const int timestampLeftShift = sequenceBits + workerIdBits + datacenterIdBits;
+
+ // 生成序列的掩码,这里为4095 (0b111111111111=0xfff=4095)
+ private const long sequenceMask = -1L ^ (-1L << sequenceBits);
+
+ // 数据中心ID(0~31)
+ public long datacenterId { get; private set; }
+
+ // 工作机器ID(0~31)
+ public long workerId { get; private set; }
+
+ // 毫秒内序列(0~4095)
+ public long sequence { get; private set; }
+
+ // 上次生成ID的时间截
+ public long lastTimestamp { get; private set; }
+
+
+ ///
+ /// 雪花ID
+ ///
+ /// 数据中心ID
+ /// 工作机器ID
+ public SnowflakeId(long datacenterId, long workerId)
+ {
+ if (datacenterId > maxDatacenterId || datacenterId < 0)
+ {
+ throw new Exception(string.Format("datacenter Id can't be greater than {0} or less than 0", maxDatacenterId));
+ }
+ if (workerId > maxWorkerId || workerId < 0)
+ {
+ throw new Exception(string.Format("worker Id can't be greater than {0} or less than 0", maxWorkerId));
+ }
+ this.workerId = workerId;
+ this.datacenterId = datacenterId;
+ this.sequence = 0L;
+ this.lastTimestamp = -1L;
+ }
+
+ ///
+ /// 获得下一个ID
+ ///
+ ///
+ public long NextId()
+ {
+ lock (this)
+ {
+ long timestamp = GetCurrentTimestamp();
+ if (timestamp > lastTimestamp) //时间戳改变,毫秒内序列重置
+ {
+ sequence = 0L;
+ }
+ else if (timestamp == lastTimestamp) //如果是同一时间生成的,则进行毫秒内序列
+ {
+ sequence = (sequence + 1) & sequenceMask;
+ if (sequence == 0) //毫秒内序列溢出
+ {
+ timestamp = GetNextTimestamp(lastTimestamp); //阻塞到下一个毫秒,获得新的时间戳
+ }
+ }
+ else //当前时间小于上一次ID生成的时间戳,证明系统时钟被回拨,此时需要做回拨处理
+ {
+ sequence = (sequence + 1) & sequenceMask;
+ if (sequence > 0)
+ {
+ timestamp = lastTimestamp; //停留在最后一次时间戳上,等待系统时间追上后即完全度过了时钟回拨问题。
+ }
+ else //毫秒内序列溢出
+ {
+ timestamp = lastTimestamp + 1; //直接进位到下一个毫秒
+ }
+ //throw new Exception(string.Format("Clock moved backwards. Refusing to generate id for {0} milliseconds", lastTimestamp - timestamp));
+ }
+
+ lastTimestamp = timestamp; //上次生成ID的时间截
+
+ //移位并通过或运算拼到一起组成64位的ID
+ var id = ((timestamp - twepoch) << timestampLeftShift)
+ | (datacenterId << datacenterIdShift)
+ | (workerId << workerIdShift)
+ | sequence;
+ return id;
+ }
+ }
+
+ ///
+ /// 解析雪花ID
+ ///
+ ///
+ public static DateTime AnalyzeIdToDateTime(long Id)
+ {
+
+ var timestamp = (Id >> timestampLeftShift);
+ var time = Jan1st1970.AddMilliseconds(timestamp + twepoch);
+ return time.ToLocalTime();
+ }
+
+ ///
+ /// 解析雪花ID
+ ///
+ ///
+ public static string AnalyzeId(long Id)
+ {
+ StringBuilder sb = new StringBuilder();
+
+ var timestamp = (Id >> timestampLeftShift);
+ var time = Jan1st1970.AddMilliseconds(timestamp + twepoch);
+ sb.Append(time.ToLocalTime().ToString("yyyy-MM-dd HH:mm:ss:fff"));
+
+ var datacenterId = (Id ^ (timestamp << timestampLeftShift)) >> datacenterIdShift;
+ sb.Append("_" + datacenterId);
+
+ var workerId = (Id ^ ((timestamp << timestampLeftShift) | (datacenterId << datacenterIdShift))) >> workerIdShift;
+ sb.Append("_" + workerId);
+
+ var sequence = Id & sequenceMask;
+ sb.Append("_" + sequence);
+
+ return sb.ToString();
+ }
+
+ ///
+ /// 阻塞到下一个毫秒,直到获得新的时间戳
+ ///
+ /// 上次生成ID的时间截
+ /// 当前时间戳
+ private static long GetNextTimestamp(long lastTimestamp)
+ {
+ long timestamp = GetCurrentTimestamp();
+ while (timestamp <= lastTimestamp)
+ {
+ timestamp = GetCurrentTimestamp();
+ }
+ return timestamp;
+ }
+
+ ///
+ /// 获取当前时间戳
+ ///
+ ///
+ private static long GetCurrentTimestamp()
+ {
+ return (long)(DateTime.UtcNow - Jan1st1970).TotalMilliseconds;
+ }
+
+ private static readonly DateTime Jan1st1970 = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Entities/LogDay.cs b/src/ShardingCore.Test7x/Domain/Entities/LogDay.cs
new file mode 100644
index 00000000..cec94311
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/LogDay.cs
@@ -0,0 +1,12 @@
+using System;
+
+namespace ShardingCore.Test.Domain.Entities
+{
+ public class LogDay
+ {
+ public Guid Id { get; set; }
+ public string LogLevel { get; set; }
+ public string LogBody { get; set; }
+ public DateTime LogTime { get; set; }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Entities/LogDayLong.cs b/src/ShardingCore.Test7x/Domain/Entities/LogDayLong.cs
new file mode 100644
index 00000000..dcd5e588
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/LogDayLong.cs
@@ -0,0 +1,16 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ShardingCore.Test.Domain.Entities
+{
+ public class LogDayLong
+ {
+ public Guid Id { get; set; }
+ public string LogLevel { get; set; }
+ public string LogBody { get; set; }
+ public long LogTime { get; set; }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Entities/LogMonthLong.cs b/src/ShardingCore.Test7x/Domain/Entities/LogMonthLong.cs
new file mode 100644
index 00000000..043ad7e2
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/LogMonthLong.cs
@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ShardingCore.Test.Domain.Entities
+{
+ public class LogMonthLong
+ {
+ public string Id { get; set; }
+ public string Body { get; set; }
+ public long LogTime { get; set; }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Entities/LogNoSharding.cs b/src/ShardingCore.Test7x/Domain/Entities/LogNoSharding.cs
new file mode 100644
index 00000000..56cf6fd9
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/LogNoSharding.cs
@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ShardingCore.Test.Domain.Entities
+{
+ public class LogNoSharding
+ {
+ public string Id { get; set; }
+ public string Body { get; set; }
+ public DateTime CreationTime { get; set; }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Entities/LogWeekDateTime.cs b/src/ShardingCore.Test7x/Domain/Entities/LogWeekDateTime.cs
new file mode 100644
index 00000000..34c3b140
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/LogWeekDateTime.cs
@@ -0,0 +1,12 @@
+using System;
+
+namespace ShardingCore.Test.Domain.Entities
+{
+ public class LogWeekDateTime
+ {
+
+ public string Id { get; set; }
+ public string Body { get; set; }
+ public DateTime LogTime { get; set; }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Entities/LogWeekTimeLong.cs b/src/ShardingCore.Test7x/Domain/Entities/LogWeekTimeLong.cs
new file mode 100644
index 00000000..014f0886
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/LogWeekTimeLong.cs
@@ -0,0 +1,16 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ShardingCore.Test.Domain.Entities
+{
+ public class LogWeekTimeLong
+ {
+
+ public string Id { get; set; }
+ public string Body { get; set; }
+ public long LogTime { get; set; }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Entities/LogYearDateTime.cs b/src/ShardingCore.Test7x/Domain/Entities/LogYearDateTime.cs
new file mode 100644
index 00000000..4d420d9f
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/LogYearDateTime.cs
@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ShardingCore.Test.Domain.Entities
+{
+ public class LogYearDateTime
+ {
+ public Guid Id { get; set; }
+ public string LogBody { get; set; }
+ public DateTime LogTime { get; set; }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Entities/LogYearLong.cs b/src/ShardingCore.Test7x/Domain/Entities/LogYearLong.cs
new file mode 100644
index 00000000..78a17aaa
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/LogYearLong.cs
@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ShardingCore.Test.Domain.Entities
+{
+ public class LogYearLong
+ {
+ public string Id { get; set; }
+ public string LogBody { get; set; }
+ public long LogTime { get; set; }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Entities/MultiShardingOrder.cs b/src/ShardingCore.Test7x/Domain/Entities/MultiShardingOrder.cs
new file mode 100644
index 00000000..2d2e124d
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/MultiShardingOrder.cs
@@ -0,0 +1,11 @@
+using System;
+
+namespace ShardingCore.Test.Domain.Entities
+{
+ public class MultiShardingOrder
+ {
+ public long Id { get; set; }
+ public string Name { get; set; }
+ public DateTime CreateTime { get; set; }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Entities/Order.cs b/src/ShardingCore.Test7x/Domain/Entities/Order.cs
new file mode 100644
index 00000000..a471c4ee
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/Order.cs
@@ -0,0 +1,13 @@
+using System;
+using ShardingCore.Core;
+
+namespace ShardingCore.Test.Domain.Entities
+{
+ public class Order
+ {
+ public Guid Id { get; set; }
+ public string Area { get; set; }
+ public long Money { get; set; }
+ public DateTime CreateTime { get; set; }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Entities/SysUserMod.cs b/src/ShardingCore.Test7x/Domain/Entities/SysUserMod.cs
new file mode 100644
index 00000000..1eefd3bb
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/SysUserMod.cs
@@ -0,0 +1,32 @@
+namespace ShardingCore.Test.Domain.Entities
+{
+/*
+* @Author: xjm
+* @Description:
+* @Date: Thursday, 14 January 2021 15:36:43
+* @Email: 326308290@qq.com
+*/
+ public class SysUserMod: IId
+ {
+ ///
+ /// 用户Id用于分表
+ ///
+ public string Id { get; set; }
+ ///
+ /// 用户名称
+ ///
+ public string Name { get; set; }
+ ///
+ /// 用户姓名
+ ///
+ public int Age { get; set; }
+ public int AgeGroup { get; set; }
+
+ }
+
+ public interface IId
+ {
+ string Id { get; set; }
+ }
+
+}
\ No newline at end of file
diff --git a/src/ShardingCore.Test7x/Domain/Entities/SysUserModInt.cs b/src/ShardingCore.Test7x/Domain/Entities/SysUserModInt.cs
new file mode 100644
index 00000000..a77b9d4c
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/SysUserModInt.cs
@@ -0,0 +1,25 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ShardingCore.Test.Domain.Entities
+{
+ public class SysUserModInt
+ {
+ ///
+ /// 用户Id用于分表
+ ///
+ public int Id { get; set; }
+ ///
+ /// 用户名称
+ ///
+ public string Name { get; set; }
+ ///
+ /// 用户姓名
+ ///
+ public int Age { get; set; }
+ public int AgeGroup { get; set; }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Entities/SysUserSalary.cs b/src/ShardingCore.Test7x/Domain/Entities/SysUserSalary.cs
new file mode 100644
index 00000000..33797926
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Entities/SysUserSalary.cs
@@ -0,0 +1,39 @@
+namespace ShardingCore.Test.Domain.Entities
+{
+/*
+* @Author: xjm
+* @Description:
+* @Date: Monday, 01 February 2021 15:43:22
+* @Email: 326308290@qq.com
+*/
+ public class SysUserSalary
+ {
+ public string Id { get; set; }
+ public string UserId { get; set; }
+ ///
+ /// 每月的金额
+ ///
+ public int DateOfMonth { get; set; }
+ ///
+ /// 工资
+ ///
+ public int Salary { get; set; }
+ ///
+ /// 工资
+ ///
+ public long SalaryLong { get; set; }
+
+ ///
+ /// 工资
+ ///
+ public decimal SalaryDecimal { get; set; }
+ ///
+ /// 工资
+ ///
+ public double SalaryDouble { get; set; }
+ ///
+ /// 工资
+ ///
+ public float SalaryFloat { get; set; }
+ }
+}
\ No newline at end of file
diff --git a/src/ShardingCore.Test7x/Domain/Maps/LogDayLongMap.cs b/src/ShardingCore.Test7x/Domain/Maps/LogDayLongMap.cs
new file mode 100644
index 00000000..06b0e628
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/LogDayLongMap.cs
@@ -0,0 +1,22 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+ public class LogDayLongMap:IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.LogLevel).IsRequired().IsUnicode(false).HasMaxLength(32);
+ builder.Property(o => o.LogBody).IsRequired().HasMaxLength(256);
+ builder.ToTable(nameof(LogDayLong));
+ }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Maps/LogDayMap.cs b/src/ShardingCore.Test7x/Domain/Maps/LogDayMap.cs
new file mode 100644
index 00000000..91e3070d
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/LogDayMap.cs
@@ -0,0 +1,17 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+ public class LogDayMap:IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.LogLevel).IsRequired().IsUnicode(false).HasMaxLength(32);
+ builder.Property(o => o.LogBody).IsRequired().HasMaxLength(256);
+ builder.ToTable(nameof(LogDay));
+ }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Maps/LogMonthLongMap.cs b/src/ShardingCore.Test7x/Domain/Maps/LogMonthLongMap.cs
new file mode 100644
index 00000000..40c20d46
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/LogMonthLongMap.cs
@@ -0,0 +1,23 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+ public class LogMonthLongMap:IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.Id).IsRequired().IsUnicode(false).HasMaxLength(50);
+ builder.Property(o => o.Body).HasMaxLength(128);
+ builder.ToTable(nameof(LogMonthLong));
+ }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Maps/LogNoShardingMap.cs b/src/ShardingCore.Test7x/Domain/Maps/LogNoShardingMap.cs
new file mode 100644
index 00000000..691d9db4
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/LogNoShardingMap.cs
@@ -0,0 +1,22 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+ public class LogNoShardingMap:IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.Id).IsRequired().HasMaxLength(50);
+ builder.Property(o => o.Body).HasMaxLength(256);
+ builder.ToTable(nameof(LogNoSharding));
+ }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Maps/LogWeekDateTimeMap.cs b/src/ShardingCore.Test7x/Domain/Maps/LogWeekDateTimeMap.cs
new file mode 100644
index 00000000..452d9215
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/LogWeekDateTimeMap.cs
@@ -0,0 +1,17 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+ public class LogWeekDateTimeMap:IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.Id).IsRequired().IsUnicode(false).HasMaxLength(50);
+ builder.Property(o => o.Body).HasMaxLength(128);
+ builder.ToTable(nameof(LogWeekDateTime));
+ }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Maps/LogWeekTimeLongMap.cs b/src/ShardingCore.Test7x/Domain/Maps/LogWeekTimeLongMap.cs
new file mode 100644
index 00000000..b04b108a
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/LogWeekTimeLongMap.cs
@@ -0,0 +1,22 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+ public class LogWeekTimeLongMap : IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.Id).IsRequired().IsUnicode(false).HasMaxLength(50);
+ builder.Property(o => o.Body).HasMaxLength(128);
+ builder.ToTable(nameof(LogWeekTimeLong));
+ }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Maps/LogYearDateTimeMap.cs b/src/ShardingCore.Test7x/Domain/Maps/LogYearDateTimeMap.cs
new file mode 100644
index 00000000..5a1283b7
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/LogYearDateTimeMap.cs
@@ -0,0 +1,22 @@
+
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+ public class LogYearDateTimeMap : IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.LogBody).IsRequired().HasMaxLength(256);
+ builder.ToTable(nameof(LogYearDateTime));
+ }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Maps/LogYearLongMap.cs b/src/ShardingCore.Test7x/Domain/Maps/LogYearLongMap.cs
new file mode 100644
index 00000000..f091ccb0
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/LogYearLongMap.cs
@@ -0,0 +1,23 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+ public class LogYearLongMap:IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.Id).IsRequired().IsUnicode(false).HasMaxLength(50);
+ builder.Property(o => o.LogBody).HasMaxLength(128);
+ builder.ToTable(nameof(LogYearLong));
+ }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Maps/MultiShardingOrderMap.cs b/src/ShardingCore.Test7x/Domain/Maps/MultiShardingOrderMap.cs
new file mode 100644
index 00000000..855d910a
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/MultiShardingOrderMap.cs
@@ -0,0 +1,22 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+ public class MultiShardingOrderMap:IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.Id).ValueGeneratedNever();
+ builder.Property(o => o.Name).IsRequired().IsUnicode(false).HasMaxLength(50);
+ builder.ToTable(nameof(MultiShardingOrder));
+ }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Maps/OrderMap.cs b/src/ShardingCore.Test7x/Domain/Maps/OrderMap.cs
new file mode 100644
index 00000000..97dcdad4
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/OrderMap.cs
@@ -0,0 +1,16 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+ public class OrderMap:IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.Area).IsRequired().IsUnicode(false).HasMaxLength(20);
+ builder.ToTable(nameof(Order));
+ }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Maps/SysUserModIntMap.cs b/src/ShardingCore.Test7x/Domain/Maps/SysUserModIntMap.cs
new file mode 100644
index 00000000..79da8daf
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/SysUserModIntMap.cs
@@ -0,0 +1,23 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+ public class SysUserModIntMap:IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.Id).ValueGeneratedNever();
+ builder.Property(o => o.Name).HasMaxLength(128);
+ builder.ToTable(nameof(SysUserModInt));
+ }
+ }
+}
diff --git a/src/ShardingCore.Test7x/Domain/Maps/SysUserModMap.cs b/src/ShardingCore.Test7x/Domain/Maps/SysUserModMap.cs
new file mode 100644
index 00000000..ae495948
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/SysUserModMap.cs
@@ -0,0 +1,23 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+/*
+* @Author: xjm
+* @Description:
+* @Date: Thursday, 14 January 2021 15:37:33
+* @Email: 326308290@qq.com
+*/
+ public class SysUserModMap:IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.Id).IsRequired().HasMaxLength(128);
+ builder.Property(o => o.Name).HasMaxLength(128);
+ builder.ToTable(nameof(SysUserMod));
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/ShardingCore.Test7x/Domain/Maps/SysUserSalaryMap.cs b/src/ShardingCore.Test7x/Domain/Maps/SysUserSalaryMap.cs
new file mode 100644
index 00000000..654d4ae6
--- /dev/null
+++ b/src/ShardingCore.Test7x/Domain/Maps/SysUserSalaryMap.cs
@@ -0,0 +1,23 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using ShardingCore.Test.Domain.Entities;
+
+namespace ShardingCore.Test.Domain.Maps
+{
+/*
+* @Author: xjm
+* @Description:
+* @Date: Monday, 01 February 2021 15:42:35
+* @Email: 326308290@qq.com
+*/
+ public class SysUserSalaryMap:IEntityTypeConfiguration
+ {
+ public void Configure(EntityTypeBuilder builder)
+ {
+ builder.HasKey(o => o.Id);
+ builder.Property(o => o.Id).IsRequired().HasMaxLength(128);
+ builder.Property(o => o.UserId).IsRequired().HasMaxLength(128);
+ builder.ToTable(nameof(SysUserSalary));
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/ShardingCore.Test7x/ShardingCore.Test7x.csproj b/src/ShardingCore.Test7x/ShardingCore.Test7x.csproj
new file mode 100644
index 00000000..bebad4ad
--- /dev/null
+++ b/src/ShardingCore.Test7x/ShardingCore.Test7x.csproj
@@ -0,0 +1,28 @@
+
+
+
+ net6.0
+ TRACE;DEBUG;EFCORE7Test;
+ ShardingCore.Test
+ latest
+
+
+
+
+
+
+
+
+
+
+ all
+ runtime; build; native; contentfiles; analyzers; buildtransitive
+
+
+
+
+
+
+
+
+
diff --git a/src/ShardingCore.Test7x/ShardingDefaultDbContext.cs b/src/ShardingCore.Test7x/ShardingDefaultDbContext.cs
new file mode 100644
index 00000000..a8a33a93
--- /dev/null
+++ b/src/ShardingCore.Test7x/ShardingDefaultDbContext.cs
@@ -0,0 +1,48 @@
+using Microsoft.EntityFrameworkCore;
+using ShardingCore.Core.VirtualRoutes.TableRoutes.RouteTails.Abstractions;
+using ShardingCore.Sharding;
+using ShardingCore.Sharding.Abstractions;
+using ShardingCore.Test.Domain.Maps;
+
+namespace ShardingCore.Test
+{
+ /*
+ * @Author: xjm
+ * @Description:
+ * @Date: 2021/8/15 10:21:03
+ * @Ver: 1.0
+ * @Email: 326308290@qq.com
+ */
+ public class ShardingDefaultDbContext:AbstractShardingDbContext, IShardingTableDbContext
+ {
+ public ShardingDefaultDbContext(DbContextOptions options) : base(options)
+ {
+ }
+
+ //protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ //{
+ // base.OnConfiguring(optionsBuilder);
+ // optionsBuilder.UseLazyLoadingProxies();
+ //}
+
+ protected override void OnModelCreating(ModelBuilder modelBuilder)
+ {
+ base.OnModelCreating(modelBuilder);
+ modelBuilder.ApplyConfiguration(new SysUserModMap());
+ modelBuilder.ApplyConfiguration(new SysUserSalaryMap());
+ modelBuilder.ApplyConfiguration(new OrderMap());
+ modelBuilder.ApplyConfiguration(new LogDayMap());
+ modelBuilder.ApplyConfiguration(new LogWeekDateTimeMap());
+ modelBuilder.ApplyConfiguration(new LogWeekTimeLongMap());
+ modelBuilder.ApplyConfiguration(new LogYearDateTimeMap());
+ modelBuilder.ApplyConfiguration(new LogNoShardingMap());
+ modelBuilder.ApplyConfiguration(new LogMonthLongMap());
+ modelBuilder.ApplyConfiguration(new LogYearLongMap());
+ modelBuilder.ApplyConfiguration(new SysUserModIntMap());
+ modelBuilder.ApplyConfiguration(new LogDayLongMap());
+ modelBuilder.ApplyConfiguration(new MultiShardingOrderMap());
+ }
+
+ public IRouteTail RouteTail { get; set; }
+ }
+}
diff --git a/src/ShardingCore.Test7x/ShardingTest.cs b/src/ShardingCore.Test7x/ShardingTest.cs
new file mode 100644
index 00000000..9b545234
--- /dev/null
+++ b/src/ShardingCore.Test7x/ShardingTest.cs
@@ -0,0 +1,1792 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Reflection;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Configuration;
+using ShardingCore.Core.EntityMetadatas;
+using ShardingCore.Core.QueryRouteManagers.Abstractions;
+using ShardingCore.Core.RuntimeContexts;
+using ShardingCore.Core.VirtualDatabase.VirtualDataSources;
+using ShardingCore.Core.VirtualDatabase.VirtualDataSources.PhysicDataSources;
+using ShardingCore.Core.VirtualRoutes.Abstractions;
+using ShardingCore.Core.VirtualRoutes.DataSourceRoutes.RouteRuleEngine;
+using ShardingCore.Core.VirtualRoutes.TableRoutes.RouteTails;
+using ShardingCore.Core.VirtualRoutes.TableRoutes.RouteTails.Abstractions;
+using ShardingCore.Core.VirtualRoutes.TableRoutes.RoutingRuleEngine;
+using ShardingCore.Exceptions;
+using ShardingCore.Extensions;
+using ShardingCore.Extensions.ShardingPageExtensions;
+using ShardingCore.Extensions.ShardingQueryableExtensions;
+using ShardingCore.Helpers;
+using ShardingCore.Sharding;
+using ShardingCore.Sharding.ParallelTables;
+using ShardingCore.Sharding.ReadWriteConfigurations;
+using ShardingCore.Sharding.ReadWriteConfigurations.Abstractions;
+using ShardingCore.Sharding.ShardingComparision.Abstractions;
+using ShardingCore.Sharding.ShardingDbContextExecutors;
+using ShardingCore.Sharding.StreamMergeEngines;
+using ShardingCore.TableCreator;
+using ShardingCore.Test.Domain.Entities;
+using ShardingCore.Utils;
+using Xunit;
+
+namespace ShardingCore.Test
+{
+
+ public class ShardingTest
+ {
+ private readonly ShardingDefaultDbContext _virtualDbContext;
+ private readonly IShardingRouteManager _shardingRouteManager;
+ private readonly ActualConnectionStringManager _connectionStringManager;
+ private readonly IConfiguration _configuration;
+ private readonly IEntityMetadataManager _entityMetadataManager;
+ private readonly IVirtualDataSource _virtualDataSource;
+ private readonly ITableRouteManager _tableRouteManager;
+ private readonly IShardingTableCreator _shardingTableCreator;
+ private readonly IShardingReadWriteManager _shardingReadWriteManager;
+ private readonly IRouteTailFactory _routeTailFactory;
+ private readonly IReadWriteConnectorFactory _readWriteConnectorFactory;
+ private readonly IShardingConnectionStringResolver _shardingConnectionStringResolver;
+ private readonly ITableRouteRuleEngineFactory _tableRouteRuleEngineFactory;
+ private readonly IShardingComparer _shardingComparer;
+
+ public ShardingTest(ShardingDefaultDbContext virtualDbContext, IShardingRuntimeContext shardingRuntimeContext, IConfiguration configuration)
+ {
+ _virtualDbContext = virtualDbContext;
+ _shardingRouteManager = shardingRuntimeContext.GetShardingRouteManager();
+ _shardingReadWriteManager = shardingRuntimeContext.GetShardingReadWriteManager();
+ _virtualDataSource = shardingRuntimeContext.GetVirtualDataSource();
+ _connectionStringManager = new ActualConnectionStringManager(_shardingReadWriteManager, _virtualDataSource,virtualDbContext);
+ _configuration = configuration;
+ _entityMetadataManager = shardingRuntimeContext.GetEntityMetadataManager();
+ _tableRouteManager = shardingRuntimeContext.GetTableRouteManager();
+ _shardingTableCreator = shardingRuntimeContext.GetShardingTableCreator();
+ _routeTailFactory = shardingRuntimeContext.GetRouteTailFactory();
+ _shardingComparer = shardingRuntimeContext.GetShardingComparer();
+ _readWriteConnectorFactory = shardingRuntimeContext.GetReadWriteConnectorFactory();
+ _tableRouteRuleEngineFactory = shardingRuntimeContext.GetService();
+ var readWriteConnectors = _virtualDataSource.ConfigurationParams.ReadWriteNodeSeparationConfigs.Select(o => _readWriteConnectorFactory.CreateConnector(_virtualDataSource.ConfigurationParams.ReadStrategy.GetValueOrDefault(), o.Key, o.Value));
+ _shardingConnectionStringResolver = new ReadWriteShardingConnectionStringResolver(readWriteConnectors, _virtualDataSource.ConfigurationParams.ReadStrategy.GetValueOrDefault(), _readWriteConnectorFactory);
+ }
+ // [Fact]
+ // public void RouteParseCompileCacheTest()
+ // {
+ // var expressionEqualityComparer = new RouteParseExpressionEqualityComparer();
+ // var virtualTable = _virtualTableManager.GetVirtualTable();
+ // var virtualTableRoute = (AbstractShardingOperatorVirtualTableRoute)virtualTable.GetVirtualRoute();
+ // var xxxx = "202102";
+ // var queryable1 = _virtualDbContext.Set().Where(o => o.DateOfMonth >= 202102);
+ // var routeParseExpression1 = ShardingUtil.GetRouteParseExpression(queryable1, virtualTableRoute.EntityMetadata,
+ // (i, op, propertyName) => virtualTableRoute.GetRouteFilter(i, op, propertyName), true);
+ // var queryable2 = _virtualDbContext.Set().Where(ox => ox.DateOfMonth >= 202102);
+ // var routeParseExpression2 = ShardingUtil.GetRouteParseExpression(queryable2, virtualTableRoute.EntityMetadata,
+ // (i, op, propertyName) => virtualTableRoute.GetRouteFilter(i, op, propertyName), true);
+ // var xxxx1 = 202102;
+ // var queryable3 = _virtualDbContext.Set().Where(ox => ox.DateOfMonth >= xxxx1);
+ // var routeParseExpression3 = ShardingUtil.GetRouteParseExpression(queryable3, virtualTableRoute.EntityMetadata,
+ // (i, op, propertyName) => virtualTableRoute.GetRouteFilter(i, op, propertyName), true);
+ // var queryable4 = _virtualDbContext.Set().Where(o => o.DateOfMonth >= 202101);
+ // var routeParseExpression4 = ShardingUtil.GetRouteParseExpression(queryable4, virtualTableRoute.EntityMetadata,
+ // (i, op, propertyName) => virtualTableRoute.GetRouteFilter(i, op, propertyName), true);
+ // var queryable5 = _virtualDbContext.Set().Where(o => o.DateOfMonth > 202101);
+ // var routeParseExpression5 = ShardingUtil.GetRouteParseExpression(queryable5, virtualTableRoute.EntityMetadata,
+ // (i, op, propertyName) => virtualTableRoute.GetRouteFilter(i, op, propertyName), true);
+ // var queryable6 = _virtualDbContext.Set().Where(o => o.DateOfMonth == 202101);
+ // var routeParseExpression6 = ShardingUtil.GetRouteParseExpression(queryable6, virtualTableRoute.EntityMetadata,
+ // (i, op, propertyName) => virtualTableRoute.GetRouteFilter(i, op, propertyName), true);
+ // var queryable7 = _virtualDbContext.Set().Where(o => 202101 <= o.DateOfMonth);
+ // var routeParseExpression7 = ShardingUtil.GetRouteParseExpression(queryable7, virtualTableRoute.EntityMetadata,
+ // (i, op, propertyName) => virtualTableRoute.GetRouteFilter(i, op, propertyName), true);
+ // var queryable8 = _virtualDbContext.Set().Where(o => 202101 == o.DateOfMonth);
+ // var routeParseExpression8 = ShardingUtil.GetRouteParseExpression(queryable8, virtualTableRoute.EntityMetadata,
+ // (i, op, propertyName) => virtualTableRoute.GetRouteFilter(i, op, propertyName), true);
+ // Assert.Equal(expressionEqualityComparer.GetHashCode(routeParseExpression1), expressionEqualityComparer.GetHashCode(routeParseExpression2));
+ // Assert.Equal(expressionEqualityComparer.GetHashCode(routeParseExpression1), expressionEqualityComparer.GetHashCode(routeParseExpression3));
+ // Assert.NotEqual(expressionEqualityComparer.GetHashCode(routeParseExpression1), expressionEqualityComparer.GetHashCode(routeParseExpression4));
+ // Assert.Equal(expressionEqualityComparer.GetHashCode(routeParseExpression4), expressionEqualityComparer.GetHashCode(routeParseExpression5));
+ // Assert.NotEqual(expressionEqualityComparer.GetHashCode(routeParseExpression5), expressionEqualityComparer.GetHashCode(routeParseExpression6));
+ // Assert.Equal(expressionEqualityComparer.GetHashCode(routeParseExpression4), expressionEqualityComparer.GetHashCode(routeParseExpression7));
+ // Assert.Equal(expressionEqualityComparer.GetHashCode(routeParseExpression6), expressionEqualityComparer.GetHashCode(routeParseExpression8));
+ //
+ // }
+
+ [Fact]
+ public async Task GenericTest()
+ {
+ var a = new DefaultPhysicDataSource("aaa", "aaa", true);
+ var b = new DefaultPhysicDataSource("aaa", "aaa1", false);
+ Assert.Equal(a, b);
+ var x = new EntityMetadata(typeof(LogDay));
+ var y = new EntityMetadata(typeof(LogDay));
+ Assert.Equal(x, y);
+ var dateTime = new DateTime(2021, 1, 1);
+ var logDays = Enumerable.Range(0, 100).Select(o => new LogDay() { Id = Guid.NewGuid(), LogLevel = "info", LogBody = o.ToString(), LogTime = dateTime.AddDays(o) }).ToList();
+
+ var bulkShardingTableEnumerable = _virtualDbContext.BulkShardingTableEnumerable(logDays);
+
+ Assert.Equal(100, bulkShardingTableEnumerable.Count);
+ var bulkShardingEnumerable = _virtualDbContext.BulkShardingEnumerable(logDays);
+ Assert.Equal(1, bulkShardingEnumerable.Count);
+ foreach (var (key, value) in bulkShardingEnumerable)
+ {
+ Assert.Equal(100, value.Count);
+ }
+
+ _virtualDbContext.Set().Where(o => o.Id == "300").ShardingPrint();
+ var contains = await _virtualDbContext.Set().Where(o => o.Id == "300").Select(o => o.Id).ContainsAsync("300");
+ Assert.True(contains);
+
+ try
+ {
+ var x1 = _virtualDataSource.GetPhysicDataSource("abc");
+ }
+ catch (Exception e)
+ {
+ Assert.Equal(typeof(ShardingCoreNotFoundException), e.GetType());
+ }
+
+ var queryable = new List().Select(o => new SequenceClass { Id = "123", T = o }).AsQueryable();
+ var sourceType = queryable.GetType().GetSequenceType();
+ Assert.Equal(typeof(SequenceClass), sourceType);
+ try
+ {
+ _shardingTableCreator.CreateTable("A", "202105");
+ }
+ catch (Exception e)
+ {
+ Assert.Equal(typeof(ShardingCoreException), e.GetType());
+ }
+
+ var orderMetadata = _entityMetadataManager.TryGet();
+ Assert.NotNull(orderMetadata);
+ var isKey1 = orderMetadata.ShardingDataSourceFieldIsKey();
+ Assert.False(isKey1);
+ var isKey2 = orderMetadata.ShardingTableFieldIsKey();
+ Assert.False(isKey2);
+ var userModMetadata = _entityMetadataManager.TryGet();
+ Assert.NotNull(userModMetadata);
+ var isKey3 = userModMetadata.ShardingDataSourceFieldIsKey();
+ Assert.False(isKey3);
+ var isKey4 = userModMetadata.ShardingTableFieldIsKey();
+ Assert.True(isKey4);
+
+ await _virtualDbContext.AddRangeAsync(logDays);
+ var bulkShardingExpression = _virtualDbContext.BulkShardingExpression(o => new[] { "A", "B" }.Contains(o.Area));
+
+ Assert.Equal(2, bulkShardingExpression.Count);
+ Assert.True(bulkShardingExpression.ContainsKey("A"));
+ Assert.True(bulkShardingExpression.ContainsKey("B"));
+
+ var bulkShardingTableExpression = _virtualDbContext.BulkShardingTableExpression(o => o.Id == Guid.NewGuid().ToString());
+ Assert.Equal(1, bulkShardingTableExpression.Count());
+
+ var noShardingExpression = _virtualDbContext.BulkShardingExpression(o => o.Id == "123");
+ Assert.Equal(1, noShardingExpression.Count());
+
+ var isShardingDbContext = _virtualDbContext.IsShardingDbContext();
+ Assert.True(isShardingDbContext);
+ var isShardingTableDbContext = _virtualDbContext.IsShardingTableDbContext();
+ Assert.True(isShardingTableDbContext);
+ var shardingDbContext = _virtualDbContext.GetType().IsShardingDbContext();
+ Assert.True(shardingDbContext);
+ var shardingTableDbContext = _virtualDbContext.GetType().IsShardingTableDbContext();
+ Assert.True(shardingTableDbContext);
+ var emptyTailIdentity = new SingleQueryRouteTail(string.Empty).GetRouteTailIdentity();
+ var aTailIdentity = new SingleQueryRouteTail("a").GetRouteTailIdentity();
+ var bTailIdentity = new SingleQueryRouteTail("b").GetRouteTailIdentity();
+ var dics = new SortedDictionary(new NoShardingFirstComparer());
+ var dicTails = new List() { emptyTailIdentity, aTailIdentity, bTailIdentity };
+ for (int i = 0; i < 10; i++)
+ {
+ dics.Clear();
+ var reOrderList = dicTails.OrderBy(o => Guid.NewGuid()).ToList();
+ foreach (var tail in reOrderList)
+ {
+ dics.Add(tail, null);
+ }
+ Assert.Equal($"{emptyTailIdentity},{aTailIdentity},{bTailIdentity}", string.Join(",", dics.Keys));
+ }
+
+ var x1x1 = new ParallelTableGroupNode(new HashSet()
+ { new ParallelTableComparerType(typeof(SysUserMod)), new ParallelTableComparerType(typeof(SysUserSalary)) });
+ var x2x2 = new ParallelTableGroupNode(new HashSet()
+ { new ParallelTableComparerType(typeof(SysUserSalary)),new ParallelTableComparerType(typeof(SysUserMod)), });
+ Assert.Equal(x1x1, x2x2);
+ Assert.Equal(x1x1.GetHashCode(), x2x2.GetHashCode());
+ var succeedAddConnectionString = _shardingConnectionStringResolver.AddConnectionString("X", "Data Source=localhost;Initial Catalog=ShardingCoreDBC;Integrated Security=True;", null);
+ Assert.True(succeedAddConnectionString);
+ var connectionString = _shardingConnectionStringResolver.GetConnectionString("X", null);
+ Assert.Equal("Data Source=localhost;Initial Catalog=ShardingCoreDBC;Integrated Security=True;", connectionString);
+ }
+
+ public class SequenceClass
+ {
+ public string Id { get; set; }
+ public string T { get; set; }
+ }
+
+ [Fact]
+ public async Task TestMultiShardingProperty()
+ {
+
+ var multiOrder = await _virtualDbContext.Set().Where(o => o.Id == 232398109278351360).FirstOrDefaultAsync();
+ Assert.NotNull(multiOrder);
+ var allMultiOrders = await _virtualDbContext.Set().ToListAsync();
+ Assert.Equal(8, allMultiOrders.Count);
+ var longs = new[] { 232398109278351360, 255197859283087360 };
+ var multiOrders = await _virtualDbContext.Set().Where(o => longs.Contains(o.Id)).ToListAsync();
+ Assert.Equal(2, multiOrders.Count);
+ var multinNotOrders = await _virtualDbContext.Set().Where(o => !longs.Contains(o.Id)).ToListAsync();
+ Assert.Equal(6, multinNotOrders.Count);
+ var dateTime = new DateTime(2021, 11, 1);
+ var multiOrder404 = await _virtualDbContext.Set().Where(o => o.Id == 250345338962063360 && o.CreateTime < dateTime).FirstOrDefaultAsync();
+ Assert.Null(multiOrder404);
+ }
+ [Fact]
+ public void TestEntityMetadataManager()
+ {
+ var objMetadata0 = _entityMetadataManager.TryGet(typeof(object));
+ Assert.Null(objMetadata0);
+ var objMetadata1 = _entityMetadataManager.TryGet