自动分表功能未开启AutoSyncStructure时无法读取跨月数据的问题

[cctczyg]

问题描述及重现代码：

系统按功能分了模块微服务，但是表都在同一个数据库，比如有三个表：设备表、设备状态表（自动跨月分表）、能耗表，一个设备微服务负责维护设备表和设备状态表，定时读取设备状态，并存入设备状态表；另一个能耗微服务负责维护设备能耗表，每天固定时间计算前一天的能耗，平时工作正常，但跨月时，却读不到设备状态表的数据，导致跨月1号的能耗为0

注意：两个微服务AutoSyncStructure都是false，平时有一个线程检测表的结构同步：
利用以下代码同步未分表的结构：
EntityHelper.FSql.CodeFirst.SyncStructure(typeof(DeviceInfo));
利用以下代码同步分表的结构：
var tabNameNext = EntityHelper.FSql.CodeFirst.GetTableByEntity(t)
.AsTableImpl.GetTableNameByColumnValue(monthNext, autoExpand: true);
EntityHelper.FSql.CodeFirst.SyncStructure(t, tabNameNext);

//设备表
public class DeviceInfo
{
    //xxx
}
//设备状态表
[Table(Name = "z_log_dev_{yyyy_MM}", AsTable = "Time=2026-02-01(1 month)")]
public class DeviceLog
{
    public DatetTime Time{get;set;}
    public fload Energy{get;set;}
    //xxx
}
//设备能耗表
public class DeviceEnergy
{
    public DateTime Day{get;set;}
    public float Energy{get;set;}
}

问题描述：
1、比如2026年5月两个微服务启动，程序运行正常，5月份的能耗计算都正常；
2、到2026年6月1号，表z_log_dev_2026_06已正常生成，且有数据，但6月1号的能耗计算逻辑里，查不到表z_log_dev_2026_06里的状态记录，导致能耗无法计算。
3、6月2号下午重启能耗计算微服务后，表z_log_dev_2026_06的数据可以正常读取，可以在6月3号正常计算6月2号的能耗。

数据库版本

mysql 5.6和sql server 2017都是这样的问题

安装的Nuget包

FreeSql.Provider.SqlServer 3.2.810
FreeSql.Provider.MySql 3.2.810

.net framework/. net core？ 及具体版本

.net5

[2881099]

用定义时间触发分表的内存状态，不然要等到有新记录 Insert Orm 才会创建内存状态。

主要问题是 Orm 没有内置定时任务功能。

[cctczyg]

如何触发内存状态？有专门的函数吗？

[cctczyg]

能耗微服务里只管读设备状态表的数据，不管写的，不会有Insert动作

[2881099]

var tableName = fsql.CodeFirst.GetTableByEntity(typeof(AsTableLog))
.AsTableImpl
.GetTableNameByColumnValue(DateTime.Parse("2023-7-1"), autoExpand: true);

//创建数据库表
if (fsql.DbFirst.ExistsTable(tableName) == false)
fsql.CodeFirst.SyncStructure(typeof(AsTableLog), tableName);

[cctczyg]

前几天忙，没来得及处理这个问题，今天专门研究了一下，发现问题不是表是否存在的问题。

我做了一个测试项目，里面有三个项目，1是实体层项目，项目代码是：

[Table(Name = "z_dev_his_{yyyy_MM}", AsTable = "FireTime=2026-05-01(1 month)")]
public class TransMonthHistory
{
///

/// 通信ID
///

[Column(StringLength = 30)]
public string Code { get; set; }
///

/// 发生时间
///

public DateTime FireTime { get; set; }
///

/// 是否发送，否则接收
///

public bool Send { get; set; }
///

/// 传输内容
///

[Column(StringLength = -1)]
public string Content { get; set; }
///

/// 连接标识
///

[Column(StringLength = 30)]
public string Conn { get; set; }
public static List Query(DateTime start, DateTime end)
{
var sql = EntityHelper.FSql.Select()
.Where(p => p.FireTime.Between(start, end))
.ToSql();
Console.WriteLine($"生成的sql：{sql}");
try
{
return EntityHelper.FSql.Select()
.Where(p => p.FireTime.Between(start, end))
.ToList();
}
catch(Exception ex)
{
Console.WriteLine($"执行出错：{ex.Message}");
return new List();
}
}
public bool Insert(out string message)
{
try
{
var sql = EntityHelper.FSql.Insert()
.AppendData(this).ToSql();
Console.WriteLine($"生成的sql：{sql}");
EntityHelper.FSql.Insert()
.AppendData(this).ExecuteAffrows();
message = string.Empty;
return true;
}
catch (Exception ex)
{
message = ex.Message;
return false;
}
}
public static void Sync(DateTime start)
{
var tabName = EntityHelper.FSql.CodeFirst.GetTableByEntity(typeof(TransMonthHistory))
.AsTableImpl.GetTableNameByColumnValue(start, autoExpand: true);
if (!EntityHelper.FSql.DbFirst.ExistsTable(tabName))
{
EntityHelper.FSql.CodeFirst.SyncStructure(typeof(TransMonthHistory), tabName);
}
}
}

2和3分别是引用实体层项目的webapi项目，里面都是一样的代码，分别是写入数据、查询数据、同步数据表接口，代码如下：

[ApiController]
[Route("[controller]/[action]")]
public class AppController : ControllerBase
{
[HttpPost]
public IActionResult InsertData([FromBody] JObject data)
{
var date = data.GetDateTime("date");
var item = new TransMonthHistory
{
Code = "1",
Conn = "1",
Content = "1",
FireTime = DateTime.Parse($"{date:yyyy-MM-dd} {DateTime.Now:HH:mm:ss}"),
Send = true,
};
item.Insert(out var message);
return Ok(message);
}
[HttpPost]
public IActionResult QueryData([FromBody] JObject data)
{
var date = data.GetDateTime("date");
var start = date.Date;
var end = start.AddDays(1).AddMilliseconds(-1);
var list = TransMonthHistory.Query(start, end);
return Ok(list);
}
[HttpPost]
public IActionResult SyncTable([FromBody] JObject data)
{
var date = data.GetDateTime("date");
TransMonthHistory.Sync(date);
return Ok(1);
}
}

现在同时启动项目2和3，在访问项目2和3的查询、写入、同步接口时，一切都表现正常，然后我又尝试了7月份的，出现了异常我没有注意。然后我传date参数是2026-08-10查询8月的数据时，我发现了问题，程序生成了以下sql：
SELECT a.[Code], a.[FireTime], a.[Send], a.[Content], a.[Conn]
FROM [z_dev_his_2026_07] a
WHERE (a.[FireTime] between '2026-08-10 00:00:00.000' and '2026-08-10 23:59:59.999')
CommitTimeoutTransaction: 0.0003ms
PrepareCommand: 2.557ms Total: 2.5624ms
Pool.Get: 0.0493ms Total: 2.6125ms
ExecuteReader: 0.4921ms Total: 3.1064ms
Pool.Return: 0.0155ms Total: 3.1225ms
从sql里面可以看出，程序并没有按参数FireTime查询对应的表名，反而查询的还是7月份的数据表，而此时我在调用写入接口时，生成的SQL：
INSERT INTO [z_dev_his_2026_08]([Code], [FireTime], [Send], [Content], [Conn]) VALUES(@Code_0, @FireTime_0, @Send_0, @Content_0, @Conn_0)
CommitTimeoutTransaction: 0.0005ms
Pool.Return: 0.0133ms Total: 2.156ms
这里使用的是8月份的表，程序正常报错：对象名 'z_dev_his_2026_08' 无效。
然后再回去调用查询接口，程序就能正常报错了：
SELECT a.[Code], a.[FireTime], a.[Send], a.[Content], a.[Conn]
FROM [z_dev_his_2026_08] a
WHERE (a.[FireTime] between '2026-08-10 00:00:00.000' and '2026-08-10 23:59:59.999')
CommitTimeoutTransaction: 0.0004ms
PrepareCommand: 1.0393ms Total: 1.0431ms
Pool.Get: 0.0527ms Total: 1.0967ms
Pool.Return: 0.7386ms Total: 1.8365ms
执行出错：对象名 'z_dev_his_2026_08' 无效。
这里显示确实是查询了8月份的数据了。

所以我的问题也就明确了，当时间跨月之后，查询语句用的虽然是新的条件，但生成的表还是上个月的表，此时程序既不会报错，也查不出数据。看看能否修复这个BUG？我这里先增加一个跨月就写一次表的防出错逻辑应付一下。

并不是我不采用你的建议，而是我想做到数据表的权限彻底隔离，某些应用只负责写某些表，其他应用就只读某些表。

[cctczyg]

刚测试了一下，仅调用EntityHelper.FSql.DbFirst.ExistsTable(tabName)函数，也能让程序生成正确的对应月份的查询语句了，我就不调用写入函数，就调用这个检测表是否存在的函数，这样逻辑干扰更小。

[2881099]

时间分表按时间线，你创建七月八月的，不符合现实情况。

如按定时任务走，顺着会触发7月再8月，而不是先触发7月，然后又去查询8月，触发7月不一定代表8月就会创建。