Access大数据表提取首/末次记录并写入新表的C#问题

我来帮你拆解下你遇到的两个核心问题：大数据量下SQL查询慢，以及DataAdapter.Update()返回0行生效的问题。下面分别给出解决方案，还有整体的高效处理思路：

Access处理25万行数据完全没问题，但必须给查询用到的字段建合适的索引，否则全表扫描肯定慢到无法接受。

1. 先创建复合索引 #

给原表建一个包含name、date、time的复合索引，让Access能快速定位每个name对应的记录，不用扫整个表：

CREATE INDEX idx_name_datetime ON YourTable (name, date, time);

2. 用高效的SQL提取首/末记录 #

基于上面的索引，用子查询的方式提取每个name的最早/最晚记录，比分组后关联的写法更高效：

-- 提取每个name的第一条（最早）记录
SELECT t.name, t.date, t.time
FROM YourTable t
WHERE (t.date + t.time) = (
    SELECT MIN(date + time)
    FROM YourTable
    WHERE name = t.name
)

如果要提取最后一条（最晚）记录，把MIN换成MAX即可。这里用date + time是Access合并日期和时间字段的原生方式，能完美利用我们建的复合索引，比字符串拼接快很多。

这个问题几乎都是因为DataTable里的行状态不对，你提到调用了AcceptChanges()，这就是核心原因！

AcceptChanges()会把DataTable中所有行的状态改成Unchanged，而DataAdapter.Update()只会处理状态为Added、Modified或Deleted的行。所以过滤完数据后，千万别先调用这个方法！

修正后的C#代码示例 #

// 1. 自动获取目标新表的结构，避免手动写列名出错
DataTable targetTable = new DataTable();
using (OleDbConnection conn = new OleDbConnection("你的Access连接字符串"))
{
    string getSchemaSql = "SELECT TOP 0 name, date, time FROM NewTable";
    OleDbDataAdapter adapter = new OleDbDataAdapter(getSchemaSql, conn);
    adapter.FillSchema(targetTable, SchemaType.Source);
}

// 2. 假设你已经从原表过滤得到了每个name的首/末记录列表（比如filteredRows）
foreach (DataRow originalRow in filteredRows)
{
    DataRow newRow = targetTable.NewRow();
    // 复制字段值
    newRow["name"] = originalRow["name"];
    newRow["date"] = originalRow["date"];
    newRow["time"] = originalRow["time"];
    targetTable.Rows.Add(newRow); // 此行状态会被标记为Added
}

// 3. 插入到数据库
using (OleDbConnection conn = new OleDbConnection("你的Access连接字符串"))
{
    string insertSql = "INSERT INTO NewTable (name, date, time) VALUES (?, ?, ?)";
    OleDbDataAdapter adapter = new OleDbDataAdapter();
    // 用参数化查询，避免注入同时提升效率
    adapter.InsertCommand = new OleDbCommand(insertSql, conn);
    adapter.InsertCommand.Parameters.Add("name", OleDbType.VarChar, 255, "name");
    adapter.InsertCommand.Parameters.Add("date", OleDbType.Date, 0, "date");
    adapter.InsertCommand.Parameters.Add("time", OleDbType.DBTime, 0, "time");

    int rowsAffected = adapter.Update(targetTable);
    Console.WriteLine($"成功插入 {rowsAffected} 行数据");
}

如果已经不小心调用了AcceptChanges()，可以手动把行状态改回来：

foreach (DataRow row in targetTable.Rows)
{
    row.SetAdded();
}

优先选择带索引的SQL方案，因为数据库引擎是专门为数据聚合优化的，比把25万行数据全读到内存里处理要快得多。

如果SQL方案还是有性能瓶颈（比如Access的子查询优化有限），可以试试分批处理：

• 先把原表的name去重，分成若干批次（比如按首字母，或每1000个name一批）
• 每批次查询对应name的首/末记录，再插入新表
• 这样每次处理的数据量小，内存压力也小

另外，插入新表时可以先关闭索引，插入完成后再重建，能大幅提升插入速度：

-- 插入前删除索引
DROP INDEX idx_newtable_name ON NewTable;
-- 执行所有插入操作
-- 插入完成后重建索引
CREATE INDEX idx_newtable_name ON NewTable (name);

内容的提问来源于stack exchange，提问作者Stana Macala