.NET Framework后端Oracle 19g并发请求重复编号问题求最佳实践

你的问题本质是查询最大值→加1→写入的非原子操作引发的竞态条件——不管请求是并发（同一CPU交替处理）还是并行（多CPU同时处理），只要没有原子性保障，就会出现两个请求读到相同最大值的情况。以下是生产环境可用的最佳实践，按可靠性优先级排序：

1. 用Oracle序列（Sequence）生成唯一值 #

这是Oracle原生的最优解决方案，完全由数据库保证原子性，彻底避免重复。

操作步骤： #

• 创建序列（按需调整起始值、步长）：

CREATE SEQUENCE SEQ_TARGET_TABLE_ID
START WITH 1
INCREMENT BY 1
NOCACHE; -- 若追求性能可设CACHE，但会出现跳号（仍不会重复）

• 在插入/更新时直接调用序列的NEXTVAL获取唯一值：

INSERT INTO TARGET_TABLE (ID, COLUMN1, COLUMN2) 
VALUES (SEQ_TARGET_TABLE_ID.NEXTVAL, '值1', '值2');

2. 使用Oracle自增列（Identity Column） #

Oracle 12c及以上版本支持自增列，19g完全兼容，用法更简洁，适合无需自定义序列规则的场景。

操作步骤： #

• 创建表时指定自增列：

CREATE TABLE TARGET_TABLE (
    ID NUMBER GENERATED ALWAYS AS IDENTITY (START WITH 1 INCREMENT BY 1),
    COLUMN1 VARCHAR2(50),
    COLUMN2 NUMBER
);

• 插入时无需手动指定ID，数据库自动生成唯一值：

INSERT INTO TARGET_TABLE (COLUMN1, COLUMN2) VALUES ('值1', 100);

3. 事务+行级锁（适用于必须基于现有最大值生成的场景） #

如果业务逻辑必须依赖现有数据的最大值加1（比如非连续编号规则），可以通过数据库事务加行级锁实现原子性。

.NET Framework代码示例： #

using (var conn = new OracleConnection("你的数据库连接字符串"))
{
    conn.Open();
    // 用Serializable隔离级别或FOR UPDATE锁定数据，防止其他事务读取未提交值
    using (var trans = conn.BeginTransaction(System.Data.IsolationLevel.Serializable))
    {
        try
        {
            // 锁定目标表的相关数据，避免并发读取
            var queryCmd = new OracleCommand("SELECT MAX(ID) AS MAX_ID FROM TARGET_TABLE FOR UPDATE", conn, trans);
            var maxId = Convert.ToInt32(queryCmd.ExecuteScalar() ?? 0);
            var newId = maxId + 1;

            // 执行插入/更新操作
            var insertCmd = new OracleCommand("INSERT INTO TARGET_TABLE (ID, COLUMN1) VALUES (:newId, :val)", conn, trans);
            insertCmd.Parameters.Add(":newId", OracleDbType.Int32).Value = newId;
            insertCmd.Parameters.Add(":val", OracleDbType.Varchar2).Value = "测试值";
            insertCmd.ExecuteNonQuery();

            trans.Commit();
        }
        catch (Exception ex)
        {
            trans.Rollback();
            throw; // 抛出异常让上层处理
        }
    }
}

4. 应用层锁（仅适用于单服务器部署） #

如果你的后端是单服务器实例，可以用.NET的静态锁对象串行化ID生成操作，但多服务器部署时会失效。

代码示例： #

// 静态锁对象，确保全局唯一
private static readonly object _idGenerateLock = new object();

public int GenerateUniqueId()
{
    lock (_idGenerateLock)
    {
        using (var conn = new OracleConnection("连接字符串"))
        {
            conn.Open();
            var cmd = new OracleCommand("SELECT MAX(ID) FROM TARGET_TABLE", conn);
            var maxId = Convert.ToInt32(cmd.ExecuteScalar() ?? 0);
            var newId = maxId + 1;
            
            // 执行插入操作
            var insertCmd = new OracleCommand("INSERT INTO TARGET_TABLE (ID) VALUES (:newId)", conn);
            insertCmd.Parameters.Add(":newId", OracleDbType.Int32).Value = newId;
            insertCmd.ExecuteNonQuery();
            
            return newId;
        }
    }
}

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