1.列表时间范围查询，先过滤表，再去过滤数据，提高效率。2.启动时创建表完成的回调。只有表创建完成，才可读写数据表，否则崩溃

src/EFCore.Sharding/DependencyInjection/IShardingBuilder.cs

@@ -43,6 +43,13 @@ public interface IShardingBuilder
         /// <returns></returns>
         IShardingBuilder CreateShardingTableOnStarting(bool enable);
 
+        /// <summary>
+        /// 启动时创建表完成
+        /// </summary>
+        /// <param name="callback"></param>
+        /// <returns></returns>
+        IShardingBuilder CreateShardingTableOnStartingFinish(Action callback);
+
         /// <summary>
         /// 是否启用分表数据库迁移,默认false
         /// </summary>

src/EFCore.Sharding/DependencyInjection/IShardingConfig.cs

@@ -1,4 +1,5 @@
-using System.Collections.Generic;
+using System;
+using System.Collections.Generic;
 using System.Linq;
 
 namespace EFCore.Sharding
@@ -7,6 +8,7 @@ internal interface IShardingConfig
     {
         DatabaseType FindADbType();
         List<(string suffix, string conString, DatabaseType dbType)> GetReadTables<T>(IQueryable<T> source);
+        List<(string suffix, string conString, DatabaseType dbType)> GetReadTables<T>(IQueryable<T> source, DateTime s, DateTime e);
         List<(string suffix, string conString, DatabaseType dbType)> GetWriteTables<T>(IQueryable<T> source = null);
         (string suffix, string conString, DatabaseType dbType) GetTheWriteTable<T>(T obj);
     }

src/EFCore.Sharding/DependencyInjection/ShardingContainer.cs

@@ -13,6 +13,7 @@ internal class ShardingContainer : IShardingConfig, IShardingBuilder
         #region 构造函数
 
         private readonly IServiceCollection _services;
+        private Action _createShardingTableOnStartingFinishFun = null;
         public ShardingContainer(IServiceCollection services)
         {
             _services = services;
@@ -145,6 +146,16 @@ private void AddShardingTable(string absTableName, string fullTableName)
 
             return FilterTable(allTables, source);
         }
+        public List<(string suffix, string conString, DatabaseType dbType)> GetReadTables<T>(IQueryable<T> source, DateTime s, DateTime e)
+        {
+            var allTables = GetTargetTables<T>(ReadWriteType.Read);
+            var ret = FilterTable(allTables, source);
+            var entityType = typeof(T);
+            var rule = _shardingRules.Where(x => x.EntityType == entityType).FirstOrDefault();
+            var sT = rule.GetTableSuffixByField(s);
+            var eT = rule.GetTableSuffixByField(e);
+            return ret.Where(t => t.suffix.CompareTo(sT) >= 0 && t.suffix.CompareTo(eT) <= 0).ToList();
+        }
         public DatabaseType FindADbType()
         {
             return _dataSources.FirstOrDefault().DbType;
@@ -381,7 +392,10 @@ public IShardingBuilder SetDateSharding<TEntity>(string shardingField, ExpandByD
 
                     theTime = paramter.nextTime(theTime);
                 }
-
+                if (sharingOption.CreateShardingTableOnStarting)
+                {
+                    _createShardingTableOnStartingFinishFun?.Invoke();
+                }
                 //定时自动建表
                 JobHelper.SetCronJob(() =>
                 {
@@ -448,6 +462,12 @@ public IShardingBuilder SetHashModSharding<TEntity>(string shardingField, int mo
             return this;
         }
 
+        public IShardingBuilder CreateShardingTableOnStartingFinish(Action callback)
+        {
+            _createShardingTableOnStartingFinishFun = callback;
+            return this;
+        }
+
         #endregion
     }
 }

src/EFCore.Sharding/Sharding/IShardingQueryable.T.cs

@@ -86,7 +86,7 @@ public interface IShardingQueryable<T> where T : class
         /// 异步获取列表
         /// </summary>
         /// <returns></returns>
-        Task<List<T>> ToListAsync();
+        Task<List<T>> ToListAsync((DateTime s, DateTime e)? range = null);
 
         /// <summary>
         /// 获取第一个,若不存在则返回默认值

src/EFCore.Sharding/Sharding/ShardingIQueryable.T.cs

@@ -152,7 +152,7 @@ public List<T> ToList()
         {
             return AsyncHelper.RunSync(() => ToListAsync());
         }
-        public async Task<List<T>> ToListAsync()
+        public async Task<List<T>> ToListAsync((DateTime s, DateTime e)? range = null)
         {
             //去除分页,获取前Take+Skip数量
             int? take = _source.GetTakeCount();
@@ -164,7 +164,9 @@ public async Task<List<T>> ToListAsync()
                 noPaginSource = noPaginSource.Take(take.Value + skip.Value);
 
             //从各个分表获取数据
-            var tables = _shardingConfig.GetReadTables(_source);
+            var tables = range == null ? _shardingConfig.GetReadTables(_source)
+            : _shardingConfig.GetReadTables(_source, range.Value.s, range.Value.e)
+            ;
             SynchronizedCollection<IDbAccessor> dbs = new SynchronizedCollection<IDbAccessor>();
             List<Task<List<T>>> tasks = tables.Select(aTable =>
             {