VB.NET+XAMPP/MySQL多客户端并发编辑同数据库行的锁机制咨询

你的担心完全合理：多客户端同时编辑同一条数据库记录时，确实会出现数据覆盖或冲突报错的问题——比如两个用户同时读取旧数据、各自修改后提交，后提交的操作会直接覆盖先提交的修改，导致数据不一致。

下面针对你提到的事务（Transaction）和Session锁两种方案展开说明，对比优劣后给出适配不同场景的最优方案：

一、数据库事务+行级锁的实现 #

MySQL原生支持行级锁，结合事务可以实现“编辑时锁定目标行，防止其他用户修改”的效果，核心是用SELECT ... FOR UPDATE语句在查询时对目标行加排他锁，锁的生命周期和事务绑定。

1. MySQL层面注意事项 #

• 确保表使用InnoDB引擎（XAMPP默认MySQL的表引擎是InnoDB，无需额外修改），因为MyISAM不支持行级锁。
• 可以根据需求设置事务隔离级别：
  • 默认的REPEATABLE READ已能解决大部分并发问题；
  • 如果需要更严格的隔离（防止幻读），可以用SERIALIZABLE，但会降低并发性能。

2. VB.NET代码示例 #

' 替换为你的XAMPP MySQL连接字符串（格式：server=localhost;user=root;password=你的密码;database=你的数据库名）
Dim connStr As String = "server=localhost;user=root;password=;database=test_db"

Using conn As New MySqlConnection(connStr)
    conn.Open()
    ' 开启事务并设置隔离级别
    Dim tran As MySqlTransaction = conn.BeginTransaction(IsolationLevel.RepeatableRead)
    Try
        ' 1. 查询并锁定目标行（Row1的ID假设为1）
        Dim lockCmd As New MySqlCommand("SELECT * FROM Table1 WHERE ID = @RowID FOR UPDATE", conn, tran)
        lockCmd.Parameters.AddWithValue("@RowID", 1)
        Dim reader As MySqlDataReader = lockCmd.ExecuteReader()

        If reader.Read() Then
            ' 2. 获取当前数据（这里可以结合你的编辑逻辑处理）
            Dim originalValue As String = reader("TargetColumn").ToString()
            reader.Close()

            ' 3. 执行更新操作
            Dim updateCmd As New MySqlCommand("UPDATE Table1 SET TargetColumn = @NewValue WHERE ID = @RowID", conn, tran)
            updateCmd.Parameters.AddWithValue("@NewValue", "用户修改后的内容")
            updateCmd.Parameters.AddWithValue("@RowID", 1)
            updateCmd.ExecuteNonQuery()
        End If
        reader.Close()

        ' 4. 提交事务，释放锁
        tran.Commit()
        MessageBox.Show("编辑完成")
    Catch ex As Exception
        ' 回滚事务，释放锁
        tran.Rollback()
        MessageBox.Show($"编辑失败：{ex.Message}")
    End Try
End Using

二、Session级自定义锁的实现 #

这种方案需要在数据库中新建一张锁表，用来记录哪些行被哪个用户锁定，锁的生命周期由业务代码控制，适合用户交互型的长编辑场景（比如用户打开编辑页面后可能停留几分钟）。

1. 先创建锁表 #

CREATE TABLE row_locks (
    lock_id INT AUTO_INCREMENT PRIMARY KEY,
    table_name VARCHAR(50) NOT NULL,
    row_id INT NOT NULL,
    locked_by VARCHAR(50) NOT NULL,
    lock_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
    expire_time DATETIME NOT NULL,
    -- 唯一索引，确保同一行只能被锁定一次
    UNIQUE KEY idx_table_row (table_name, row_id)
);

2. VB.NET核心代码示例 #

（1）获取锁的函数

Function AcquireRowLock(tableName As String, rowId As Integer, userId As String, expireMinutes As Integer) As Boolean
    Dim connStr As String = "你的连接字符串"
    Using conn As New MySqlConnection(connStr)
        conn.Open()
        ' 插入锁记录，如果已存在则更新自己的锁或超时的锁
        Dim cmd As New MySqlCommand(
            "INSERT INTO row_locks (table_name, row_id, locked_by, expire_time) 
             VALUES (@Table, @RowID, @User, DATE_ADD(NOW(), INTERVAL @Minute MINUTE)) 
             ON DUPLICATE KEY UPDATE 
             lock_time = NOW(), expire_time = DATE_ADD(NOW(), INTERVAL @Minute MINUTE) 
             WHERE locked_by = @User OR expire_time < NOW()", conn)
        cmd.Parameters.AddWithValue("@Table", tableName)
        cmd.Parameters.AddWithValue("@RowID", rowId)
        cmd.Parameters.AddWithValue("@User", userId)
        cmd.Parameters.AddWithValue("@Minute", expireMinutes)
        ' 影响行数>0表示成功获取锁
        Return cmd.ExecuteNonQuery() > 0
    End Using
End Function

（2）释放锁的函数

Function ReleaseRowLock(tableName As String, rowId As Integer, userId As String) As Boolean
    Dim connStr As String = "你的连接字符串"
    Using conn As New MySqlConnection(connStr)
        conn.Open()
        Dim cmd As New MySqlCommand(
            "DELETE FROM row_locks WHERE table_name = @Table AND row_id = @RowID AND locked_by = @User", conn)
        cmd.Parameters.AddWithValue("@Table", tableName)
        cmd.Parameters.AddWithValue("@RowID", rowId)
        cmd.Parameters.AddWithValue("@User", userId)
        Return cmd.ExecuteNonQuery() > 0
    End Using
End Function

（3）编辑流程逻辑

Dim currentUser As String = "User2" ' 当前登录用户ID
Dim targetRowId As Integer = 1 ' 要编辑的Row1的ID

' 尝试获取锁（锁定10分钟）
If AcquireRowLock("Table1", targetRowId, currentUser, 10) Then
    Try
        ' 打开编辑页面，用户进行交互编辑
        ' ... 你的编辑界面逻辑 ...

        ' 提交修改时，建议增加乐观锁检查（防止锁超时后其他用户已修改数据）
        Using conn As New MySqlConnection("你的连接字符串")
            conn.Open()
            Dim tran As MySqlTransaction = conn.BeginTransaction()
            Try
                ' 假设Table1有一个version字段，每次更新自增1
                Dim checkCmd As New MySqlCommand("SELECT version FROM Table1 WHERE ID = @RowID", conn, tran)
                checkCmd.Parameters.AddWithValue("@RowID", targetRowId)
                Dim currentVersion As Integer = Convert.ToInt32(checkCmd.ExecuteScalar())

                ' userOpenedVersion是用户打开页面时获取的版本号
                If currentVersion = userOpenedVersion Then
                    Dim updateCmd As New MySqlCommand(
                        "UPDATE Table1 SET TargetColumn = @NewValue, version = version + 1 WHERE ID = @RowID", conn, tran)
                    updateCmd.Parameters.AddWithValue("@NewValue", "用户修改后的内容")
                    updateCmd.Parameters.AddWithValue("@RowID", targetRowId)
                    updateCmd.ExecuteNonQuery()
                    tran.Commit()
                    MessageBox.Show("编辑成功")
                Else
                    tran.Rollback()
                    MessageBox.Show("数据已被其他用户修改，请刷新后重试")
                End If
            Catch ex As Exception
                tran.Rollback()
                MessageBox.Show($"提交失败：{ex.Message}")
            End Try
        End Using
    Finally
        ' 无论编辑成功或失败，都释放锁
        ReleaseRowLock("Table1", targetRowId, currentUser)
    End Try
Else
    MessageBox.Show("该记录正在被其他用户编辑，请稍后再试")
End If

三、两种方案的优劣对比 #

四、最优方案建议 #

1. 短时间自动化/批量操作：优先用事务+行级锁，依赖MySQL原生机制，可靠且实现简单，避免额外的锁表维护成本。
2. 用户交互型长编辑：用Session自定义锁+乐观锁组合——自定义锁用来提前阻止其他用户进入编辑，乐观锁用来在提交时做最终冲突检查，双重保障避免数据覆盖。

内容的提问来源于stack exchange，提问作者Ann XR