From 6e2bf99186739a554f20c48dd01affd55d4cb6b1 Mon Sep 17 00:00:00 2001 From: xuejiaming <326308290@qq.com> Date: Fri, 12 Nov 2021 17:32:17 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=B1=BB=E7=9B=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ...=> AppendOrderSequenceEnumeratorAsyncStreamMergeEngine.cs} | 4 ++-- .../EnumeratorStreamMergeEngineFactory.cs | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) rename src/ShardingCore/Sharding/MergeEngines/EnumeratorStreamMergeEngines/EnumeratorAsync/{AppenOrderSequenceEnumeratorAsyncStreamMergeEngine.cs => AppendOrderSequenceEnumeratorAsyncStreamMergeEngine.cs} (93%) diff --git a/src/ShardingCore/Sharding/MergeEngines/EnumeratorStreamMergeEngines/EnumeratorAsync/AppenOrderSequenceEnumeratorAsyncStreamMergeEngine.cs b/src/ShardingCore/Sharding/MergeEngines/EnumeratorStreamMergeEngines/EnumeratorAsync/AppendOrderSequenceEnumeratorAsyncStreamMergeEngine.cs similarity index 93% rename from src/ShardingCore/Sharding/MergeEngines/EnumeratorStreamMergeEngines/EnumeratorAsync/AppenOrderSequenceEnumeratorAsyncStreamMergeEngine.cs rename to src/ShardingCore/Sharding/MergeEngines/EnumeratorStreamMergeEngines/EnumeratorAsync/AppendOrderSequenceEnumeratorAsyncStreamMergeEngine.cs index 08772b53..ce570843 100644 --- a/src/ShardingCore/Sharding/MergeEngines/EnumeratorStreamMergeEngines/EnumeratorAsync/AppenOrderSequenceEnumeratorAsyncStreamMergeEngine.cs +++ b/src/ShardingCore/Sharding/MergeEngines/EnumeratorStreamMergeEngines/EnumeratorAsync/AppendOrderSequenceEnumeratorAsyncStreamMergeEngine.cs @@ -24,13 +24,13 @@ namespace ShardingCore.Sharding.StreamMergeEngines.EnumeratorStreamMergeEngines. * @Ver: 1.0 * @Email: 326308290@qq.com */ - internal class AppenOrderSequenceEnumeratorAsyncStreamMergeEngine : AbstractEnumeratorStreamMergeEngine + internal class AppendOrderSequenceEnumeratorAsyncStreamMergeEngine : AbstractEnumeratorStreamMergeEngine where TShardingDbContext : DbContext, IShardingDbContext { private readonly PaginationSequenceConfig _dataSourceSequenceOrderConfig; private readonly PaginationSequenceConfig _tableSequenceOrderConfig; private readonly ICollection> _routeQueryResults; - public AppenOrderSequenceEnumeratorAsyncStreamMergeEngine(StreamMergeContext streamMergeContext, PaginationSequenceConfig dataSourceSequenceOrderConfig, PaginationSequenceConfig tableSequenceOrderConfig, ICollection> routeQueryResults) : base(streamMergeContext) + public AppendOrderSequenceEnumeratorAsyncStreamMergeEngine(StreamMergeContext streamMergeContext, PaginationSequenceConfig dataSourceSequenceOrderConfig, PaginationSequenceConfig tableSequenceOrderConfig, ICollection> routeQueryResults) : base(streamMergeContext) { _dataSourceSequenceOrderConfig = dataSourceSequenceOrderConfig; _tableSequenceOrderConfig = tableSequenceOrderConfig; diff --git a/src/ShardingCore/Sharding/MergeEngines/EnumeratorStreamMergeEngines/EnumeratorStreamMergeEngineFactory.cs b/src/ShardingCore/Sharding/MergeEngines/EnumeratorStreamMergeEngines/EnumeratorStreamMergeEngineFactory.cs index c917a4e9..d05c98d9 100644 --- a/src/ShardingCore/Sharding/MergeEngines/EnumeratorStreamMergeEngines/EnumeratorStreamMergeEngineFactory.cs +++ b/src/ShardingCore/Sharding/MergeEngines/EnumeratorStreamMergeEngines/EnumeratorStreamMergeEngineFactory.cs @@ -115,7 +115,7 @@ namespace ShardingCore.Sharding.MergeEngines.EnumeratorStreamMergeEngines } if (dataSourceSequenceOrderConfig != null || tableSequenceOrderConfig != null) { - return new AppenOrderSequenceEnumeratorAsyncStreamMergeEngine(_streamMergeContext, dataSourceSequenceOrderConfig, tableSequenceOrderConfig, _shardingPageManager.Current.RouteQueryResults); + return new AppendOrderSequenceEnumeratorAsyncStreamMergeEngine(_streamMergeContext, dataSourceSequenceOrderConfig, tableSequenceOrderConfig, _shardingPageManager.Current.RouteQueryResults); } return null;