基于C# WinForm与SQL的多字段位置冲突检测方案咨询

针对你这个需要在用户指定位置放置对象、且要提前检查位置是否被占用的场景，我整理了几个从数据库到代码层面的优化方案，既能保证性能，又能避免竞态问题：

1. 数据库层面：先建联合唯一索引（核心优化） #

这是最基础也是最关键的一步——给Zone、x、y、z这四个字段创建联合唯一索引。这样做有两个核心好处：

• 直接让数据库帮你强制保证位置的唯一性，从根源上杜绝重复数据；
• 大幅提升位置检查的查询速度，因为索引会把这四个字段的组合作为查询键，比全表扫描效率高得多。

创建索引的SQL语句：

CREATE UNIQUE INDEX IX_ObjectPosition ON YourTableName(Zone, x, y, z);

注意：把YourTableName替换成你实际的表名。

2. 单位置检查：极简高效的查询逻辑 #

如果只是检查单个位置是否被占用，不用统计总数，直接查询是否存在匹配记录即可——数据库找到第一条匹配就会停止，比COUNT(1)更高效。

C#代码示例（异步版本，避免UI线程卡顿）：

public async Task<bool> IsPositionOccupiedAsync(int zone, int x, int y, int z, string connectionString)
{
    const string checkQuery = "SELECT 1 FROM YourTableName WHERE Zone = @Zone AND x = @x AND y = @y AND z = @z;";
    
    using (var conn = new SqlConnection(connectionString))
    {
        await conn.OpenAsync();
        using (var cmd = new SqlCommand(checkQuery, conn))
        {
            // 添加参数，避免SQL注入风险
            cmd.Parameters.AddWithValue("@Zone", zone);
            cmd.Parameters.AddWithValue("@x", x);
            cmd.Parameters.AddWithValue("@y", y);
            cmd.Parameters.AddWithValue("@z", z);
            
            // ExecuteScalarAsync返回第一个匹配的结果，没有则返回null
            var result = await cmd.ExecuteScalarAsync();
            return result != null;
        }
    }
}

3. 多位置批量检查：用表值参数（TVP）替代循环查询 #

如果需要一次性检查多个位置（比如用户批量选择多个点），千万不要循环调用单位置查询——这样会产生多次数据库连接开销，效率极低。推荐用SQL表值参数（TVP），一次性把所有待检查的位置传给数据库，批量返回已占用的位置。

步骤1：创建SQL用户定义表类型 #

先在SQL Server里定义一个用于传递位置的表类型：

CREATE TYPE PositionTableType AS TABLE (
    Zone int,
    x int,
    y int,
    z int
);

步骤2：C#批量检查代码 #

// 自定义位置模型（比Tuple更清晰易读）
public class Position
{
    public int Zone { get; set; }
    public int X { get; set; }
    public int Y { get; set; }
    public int Z { get; set; }
}

public async Task<List<Position>> GetOccupiedPositionsAsync(List<Position> positionsToCheck, string connectionString)
{
    var occupiedPositions = new List<Position>();
    
    // 构建表值参数的DataTable
    var positionTable = new DataTable();
    positionTable.Columns.Add("Zone", typeof(int));
    positionTable.Columns.Add("x", typeof(int));
    positionTable.Columns.Add("y", typeof(int));
    positionTable.Columns.Add("z", typeof(int));
    
    foreach (var pos in positionsToCheck)
    {
        positionTable.Rows.Add(pos.Zone, pos.X, pos.Y, pos.Z);
    }
    
    const string batchCheckQuery = @"
        SELECT pl.Zone, pl.x, pl.y, pl.z
        FROM @PositionList pl
        INNER JOIN YourTableName t 
            ON pl.Zone = t.Zone 
            AND pl.x = t.x 
            AND pl.y = t.y 
            AND pl.z = t.z;";
    
    using (var conn = new SqlConnection(connectionString))
    {
        await conn.OpenAsync();
        using (var cmd = new SqlCommand(batchCheckQuery, conn))
        {
            // 添加表值参数
            var tvpParam = new SqlParameter("@PositionList", SqlDbType.Structured);
            tvpParam.TypeName = "PositionTableType"; // 对应SQL里定义的表类型名
            tvpParam.Value = positionTable;
            cmd.Parameters.Add(tvpParam);
            
            // 读取批量查询结果
            using (var reader = await cmd.ExecuteReaderAsync())
            {
                while (await reader.ReadAsync())
                {
                    occupiedPositions.Add(new Position
                    {
                        Zone = reader.GetInt32(0),
                        X = reader.GetInt32(1),
                        Y = reader.GetInt32(2),
                        Z = reader.GetInt32(3)
                    });
                }
            }
        }
    }
    
    return occupiedPositions;
}

4. 高并发场景：避免"检查-插入"的竞态问题 #

如果你的项目可能有多个用户同时操作，仅靠提前检查还是会有问题——比如A用户检查位置为空，在A插入之前，B用户也检查为空并插入，这时候就会出现重复数据。

解决办法：利用之前创建的唯一索引，在插入数据时捕获唯一键冲突异常（SQL错误码2601或2627），这样即使竞态发生，数据库也会阻止插入，你只需要在代码里处理这个异常即可：

public async Task<bool> TryPlaceObjectAsync(Position pos, string objRef, int size, string connectionString)
{
    const string insertQuery = @"
        INSERT INTO YourTableName (Zone, x, y, z, ref, size)
        VALUES (@Zone, @x, @y, @z, @Ref, @Size);";
    
    try
    {
        using (var conn = new SqlConnection(connectionString))
        {
            await conn.OpenAsync();
            using (var cmd = new SqlCommand(insertQuery, conn))
            {
                cmd.Parameters.AddWithValue("@Zone", pos.Zone);
                cmd.Parameters.AddWithValue("@x", pos.X);
                cmd.Parameters.AddWithValue("@y", pos.Y);
                cmd.Parameters.AddWithValue("@z", pos.Z);
                cmd.Parameters.AddWithValue("@Ref", objRef);
                cmd.Parameters.AddWithValue("@Size", size);
                
                await cmd.ExecuteNonQueryAsync();
                return true; // 插入成功，位置可用
            }
        }
    }
    catch (SqlException ex)
    {
        // 捕获唯一键冲突异常
        if (ex.Number == 2601 || ex.Number == 2627)
        {
            return false; // 位置已被占用
        }
        throw; // 其他异常抛出处理
    }
}

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