Day 3 - 事务与批量写入
建议用时：150-210 分钟
你将学会什么
- 使用事务
- 复用参数和命令
- 控制批次大小和提交周期
逐条提交会很慢。事务把一批采样作为一个原子操作，失败时整体回滚。 今天的 3 个例子都要亲手敲，不能只复制，也不能只看运行结果。
标为 Program.cs 的最小例子可以放进控制台练习项目；标为 Service、ViewModel、XAML 或 SQL 文件的例子，要在本周项目中按前一天已经建立的模型继续敲。文件名和上下文不同，不要把所有片段塞进同一个 Program.cs。
学习衔接
这是 Week 18 的第 3 天。先使用前面已经掌握的 C#、异步、异常、接口和 MVVM，只增加今天这一层上位机能力。
今天的最低通过线
| 顺序 | 必须掌握 | 怎么证明 |
|---|---|---|
| 1 | 使用事务 | 能用自己的话解释并完成对应例子 |
| 2 | 复用参数和命令 | 能用自己的话解释并完成对应例子 |
| 3 | 控制批次大小和提交周期 | 能用自己的话解释并完成对应例子 |
先用大白话理解
逐条提交会很慢。事务把一批采样作为一个原子操作，失败时整体回滚。
学习时固定按这个顺序：
先看数据是什么
-> 再看最小代码
-> 对照运行结果
-> 修改一个参数
-> 故意制造错误
-> 最后组合进上位机项目例子 1：开始并提交事务
文件：Program.cs
await using var transaction = await connection.BeginTransactionAsync();
try
{
await InsertBatchAsync(connection, transaction, samples, token);
await transaction.CommitAsync(token);
}
catch
{
await transaction.RollbackAsync(token);
throw;
}运行结果或界面效果：
整批成功提交，失败回滚必须改一次： 故意制造一条错误数据验证回滚。
例子 2：复用命令参数
文件：Program.cs
command.Parameters.Add("$tag", SqliteType.Text);
command.Parameters.Add("$value", SqliteType.Real);
foreach (TagSample item in batch)
{
command.Parameters["$tag"].Value = item.TagId;
command.Parameters["$value"].Value = item.Value;
await command.ExecuteNonQueryAsync(token);
}运行结果或界面效果：
一个命令写入整批数据必须改一次： 比较 1 条提交和 500 条事务提交耗时。
例子 3：按大小或时间提交
文件：Program.cs
bool shouldFlush = batch.Count >= 500 || stopwatch.Elapsed >= TimeSpan.FromSeconds(1);
if (shouldFlush)
{
await repository.InsertBatchAsync(batch, token);
batch.Clear();
stopwatch.Restart();
}运行结果或界面效果：
最多 500 条或 1 秒提交一次必须改一次： 停止服务前强制提交剩余数据。
常见错误和修法
- 每条采样单独打开连接和提交
- 事务失败后仍清空内存批次
- 停止时遗漏最后不足一批的数据
修错顺序固定为：先看第一条异常和行号，再看输入数据，再看原始字节或状态，最后才怀疑框架。
小白重复敲写训练
- 不看上面的代码，重新敲“开始并提交事务”。
- 不看上面的代码，重新敲“复用命令参数”。
- 不看上面的代码，重新敲“按大小或时间提交”。
- 完成改动任务：故意制造一条错误数据验证回滚。
- 完成改动任务：比较 1 条提交和 500 条事务提交耗时。
- 完成改动任务：停止服务前强制提交剩余数据。
每日小测
- 今天的知识在上位机里解决什么问题？
- 三个例子分别输入了什么，输出了什么？
- 如果运行结果不对，你第一步检查什么？
- 哪一段代码负责停止、超时或错误处理？
小测答案
答案不能只背一句话。回到三个例子，用代码中的变量、方法和输出逐项说明。能脱离页面说清楚，才算真的理解。
今日作业
- 新建空项目，不复制地重做三个例子。
- 每个例子都完成“必须改一次”。
- 故意制造一个错误，记录错误文字和修复办法。
- 把今天代码提交到自己的练习仓库。
作业验收
- 三个例子都能运行或显示预期界面。
- 能解释关键数据从哪里来、经过什么处理、最后去哪里。
- 失败时不会让程序无提示崩溃。
- 能说出今天内容如何进入“采集历史数据库与查询页面”。