track bug 跨库也支持track

Author: xuejmnet

src/ShardingCore/Sharding/ShardingExecutors/DefaultShardingTrackQueryExecutor.cs

@@ -62,8 +62,7 @@ public TResult Execute<TResult>(IQueryCompilerContext queryCompilerContext)
             {
                 if (queryCompilerContext is IMergeQueryCompilerContext mergeQueryCompilerContext)
                 {
-                    var mergeResult = _shardingQueryExecutor.Execute<TResult>(mergeQueryCompilerContext);
-                    return ResultTrackExecute(mergeResult, queryCompilerContext, TrackEnumerable, Track);
+                    return _shardingQueryExecutor.Execute<TResult>(mergeQueryCompilerContext);
                 }
                 throw new ShardingCoreNotFoundException(queryCompilerContext.GetQueryExpression().ShardingPrint());
             }
@@ -120,8 +119,7 @@ public TResult ExecuteAsync<TResult>(IQueryCompilerContext queryCompilerContext,
             {
                 if (queryCompilerContext is IMergeQueryCompilerContext mergeQueryCompilerContext)
                 {
-                    var mergeResult = _shardingQueryExecutor.ExecuteAsync<TResult>(mergeQueryCompilerContext);
-                    return ResultTrackExecute(mergeResult, queryCompilerContext, TrackAsyncEnumerable, TrackAsync);
+                    return _shardingQueryExecutor.ExecuteAsync<TResult>(mergeQueryCompilerContext);
                 }
                 throw new ShardingCoreNotFoundException(queryCompilerContext.GetQueryExpression().ShardingPrint());
             }
@@ -143,8 +141,7 @@ public IAsyncEnumerable<TResult> ExecuteAsync<TResult>(IQueryCompilerContext que
             {
                 if (queryCompilerContext is IMergeQueryCompilerContext mergeQueryCompilerContext)
                 {
-                    var mergeResult= _shardingQueryExecutor.ExecuteAsync<IAsyncEnumerable<TResult>>(mergeQueryCompilerContext);
-                    return ResultTrackExecute(mergeResult, queryCompilerContext, TrackEnumerable, Track);
+                    return _shardingQueryExecutor.ExecuteAsync<IAsyncEnumerable<TResult>>(mergeQueryCompilerContext);
                 }
                 throw new ShardingCoreNotFoundException(queryCompilerContext.GetQueryExpression().ShardingPrint());
             }
@@ -162,8 +159,7 @@ public Task<TResult> ExecuteAsync<TResult>(IQueryCompilerContext queryCompilerCo
             {
                 if (queryCompilerContext is IMergeQueryCompilerContext mergeQueryCompilerContext)
                 {
-                    var mergeResult= _shardingQueryExecutor.ExecuteAsync<Task<TResult>>(mergeQueryCompilerContext);
-                    return ResultTrackExecute(mergeResult, queryCompilerContext, TrackEnumerable, TrackAsync);
+                    return _shardingQueryExecutor.ExecuteAsync<Task<TResult>>(mergeQueryCompilerContext);
                 }
                 throw new ShardingCoreNotFoundException(queryCompilerContext.GetQueryExpression().ShardingPrint());
             }

src/ShardingCore/Sharding/ShardingExecutors/MergeQueryCompilerContext.cs

@@ -246,7 +246,7 @@ public string GetQueryMethodName()
         /// <returns></returns>
         public bool IsParallelQuery()
         {
-            return _isCrossTable || _existCrossTableTails|| _queryCompilerContext.IsParallelQuery();
+            return _isCrossTable || _existCrossTableTails || _queryCompilerContext.IsParallelQuery();
         }
 
         public int? GetFixedTake()

src/ShardingCore/Sharding/StreamMergeContext.cs

@@ -278,7 +278,13 @@ public bool IsParallelQuery()
         public bool IsUseShardingTrack(Type entityType)
         {
             if (!IsParallelQuery())
+            {
+                if (IsCrossDataSource)
+                {
+                    return true;
+                }
                 return false;
+            }
             return QueryTrack() && _trackerManager.EntityUseTrack(entityType);
         }