如何用C#实现数据库的数据同步？双向同步怎么做？-C#.Net教程-PHP中文网

如何用C#实现数据库的数据同步？双向同步怎么做？

月夜之吻

发布： 2025-09-23 11:29:01

原创

632人浏览过

答案：实现C#数据库双向同步需解决冲突检测与变更追踪，核心方法是添加SyncVersion、SyncSource字段并结合时间戳，通过轮询拉取对方新增或修改的数据，本地比对版本后应用变更，并推送本端未同步数据；推荐使用Dotmim.Sync等框架简化开发，避免手动处理复杂逻辑。

如何用c#实现数据库的数据同步？双向同步怎么做？

实现数据库数据同步，尤其是双向同步，在C#中通常涉及监听数据变更、对比差异并执行更新操作。核心思路是让两个或多个数据库保持一致状态，即使它们在不同时间点被修改。下面介绍一种实用的实现方式。

1. 单向同步基本实现

单向同步指从一个主数据库向另一个目标数据库同步数据。常见做法如下：

使用时间戳字段：在表中添加 LastModified 字段，记录每行最后修改时间。同步时只传输自上次同步以来更改的数据。
轮询变更：定期查询源库中 LastModified 大于上次同步时间的记录。
执行插入/更新：将变更应用到目标库，可用 MERGE 语句或先查后更。

示例代码片段（使用 SQL Server 和 ADO.NET）：

string lastSyncTime = GetLastSyncTime(); // 从本地配置或表中读取
string query = "SELECT Id, Name, Email, LastModified FROM Users WHERE LastModified > @lastTime";
using (var sourceConn = new SqlConnection(sourceConnectionString))
using (var destConn = new SqlConnection(destConnectionString))
{
    sourceConn.Open();
    destConn.Open();

    using (var cmd = new SqlCommand(query, sourceConn))
    {
        cmd.Parameters.AddWithValue("@lastTime", lastSyncTime);
        using (var reader = cmd.ExecuteReader())
        {
            while (reader.Read())
            {
                var id = reader["Id"];
                var name = reader["Name"];
                var email = reader["Email"];
                var lastMod = reader["LastModified"];

                // 向目标库插入或更新
                using (var updateCmd = new SqlCommand(@"
                    IF EXISTS (SELECT 1 FROM Users WHERE Id = @id)
                        UPDATE Users SET Name = @name, Email = @email, LastModified = @lastMod WHERE Id = @id
                    ELSE
                        INSERT INTO Users (Id, Name, Email, LastModified) VALUES (@id, @name, @email, @lastMod)", destConn))
                {
                    updateCmd.Parameters.AddWithValue("@id", id);
                    updateCmd.Parameters.AddWithValue("@name", name);
                    updateCmd.Parameters.AddWithValue("@email", email);
                    updateCmd.Parameters.AddWithValue("@lastMod", lastMod);
                    updateCmd.ExecuteNonQuery();
                }
            }
        }
    }
}
// 更新本次同步时间
SaveLastSyncTime(DateTime.Now);

登录后复制

2. 双向同步的关键挑战

双向同步意味着两个数据库都能被修改，需合并彼此的变更。主要难点包括：

阿里云-虚拟数字人

阿里云-虚拟数字人是什么？ ...

查看详情

冲突检测：同一记录在两边都被修改，需决定保留哪个版本。
变更追踪：必须知道每条数据是从哪边来的，以及是否已同步过。
同步顺序：避免死锁或重复同步。

3. 实现双向同步的建议方案

推荐使用“带版本和来源标记”的同步机制：

增加同步字段：为每张表添加 SyncVersion（递增）、SyncSource（如 'A' 或 'B'）、IsDeleted 等字段。
本地记录同步状态：维护一张 SyncLog 表，记录已同步的变更批次。
分步同步流程：
- 从对方库拉取自上次同步后、且 SyncSource ≠ 自身的所有新增/修改。
- 本地比对同 ID 记录是否存在及版本高低。
- 若本地有更新版本，跳过；否则应用变更。
- 将本端未同步的变更推送到对方库，并标记 SyncSource 为本端标识。
处理冲突：可采用策略如“最后写入优先”、“手动干预”或“时间戳+节点优先级”。

简化逻辑示例：

假设数据库 A 和 B 双向同步：

A 拉取 B 中 SyncSource = 'B' 且 SyncVersion > 上次同步最大版本的数据。
A 对每条记录检查本地是否有更高 SyncVersion。无则更新，有则根据策略处理。
A 将本地 SyncSource = 'A' 且未同步的记录发送给 B，并递增其 SyncVersion。
B 执行相同流程。

4. 使用现成框架简化开发

手动实现复杂且易出错，可考虑以下工具：

Microsoft Sync Framework：官方提供的离线/协作同步平台，支持数据库、文件等。支持双向同步、冲突处理、增量同步。
SQL Server Replication：如果使用 SQL Server，可配置事务复制或合并复制，无需编码。
第三方库：如 Dotmim.Sync（开源，支持 SQL Server、MySQL、SQLite 等），API 简洁，适合 .NET 应用。

Dotmim.Sync 示例：

var serverProvider = new SqlSyncProvider(serverConnectionString);
var clientProvider = new SqlSyncProvider(clientConnectionString);
var tables = new string[] { "Users", "Products" };
var agent = new SyncAgent(clientProvider, serverProvider, tables);

var result = await agent.SynchronizeAsync();
Console.WriteLine($"完成：{result.TotalChangesUploaded} 上传，{result.TotalChangesDownloaded} 下载");

登录后复制

基本上就这些。双向同步不复杂但容易忽略细节，关键是设计好版本控制和冲突策略。

以上就是如何用C#实现数据库的数据同步？双向同步怎么做？的详细内容，更多请关注php中文网其它相关文章！