使用Dapper获取Oracle插入记录ID时遇ORA-00933错误求排查

看起来你遇到的问题主要是两个核心点：Oracle不支持SQL Server的SCOPE_IDENTITY()函数，以及多语句的执行方式不符合Oracle语法规范，另外代码里还有重复执行SQL的逻辑bug，我一步步帮你理清楚并修正：

错误原因拆解 #

• SCOPE_IDENTITY()是SQL Server专属函数：Oracle没有这个内置函数，直接使用会触发语法解析错误，这是ORA-00933的主要诱因。
• Oracle不允许直接用分号拼接INSERT和SELECT语句：你原SQL把插入和查询用分号连在一起的写法，不符合Oracle的命令执行规范，会被判定为"命令未正确结束"。
• 代码重复执行SQL：你先后调用了ExecuteAsync和QueryAsync，这会导致同一条插入语句执行两次，插入两条重复记录，属于逻辑层面的问题。

正确解决方案：使用Oracle的RETURNING子句 #

Oracle官方推荐用RETURNING ... INTO子句直接获取插入时生成的序列值，不需要额外执行SELECT语句，效率更高也更安全。

修正后的代码示例 #

public async Task<int> InsertSESSIONUSER_TAsync(SESSIONUSER_T obj)
{
    // 改用RETURNING子句直接返回生成的ID
    string sql = @"INSERT INTO SESSIONUSER_T 
                   (ID, USERNAME, PASSWORD, LOCALE, TIMEZONEID, EMAIL, CREATIONDATE, EMAILPEO) 
                   VALUES (USER_SEQUENCE.NEXTVAL, 'TEMP', :PASSWORD, :LOCALE, :TIMEZONEID, :EMAIL, :CREATIONDATE, :EMAILPEO)
                   RETURNING ID INTO :NewId";

    using (OracleConnection cnn = DBCConnectionFactory.Getconnection())
    {
        try
        {
            await cnn.OpenAsync();
            
            // 创建输出参数用于接收返回的ID
            var newIdParam = new OracleParameter("NewId", OracleDbType.Int32)
            {
                Direction = System.Data.ParameterDirection.Output
            };

            // 执行插入并获取返回值
            await cnn.ExecuteAsync(sql, new { 
                obj.PASSWORD, 
                obj.LOCALE, 
                obj.TIMEZONEID, 
                obj.EMAIL, 
                obj.CREATIONDATE, 
                obj.EMAILPEO, 
                NewId = newIdParam 
            });

            return Convert.ToInt32(newIdParam.Value);
        }
        catch (Exception ex)
        {
            ApplicationLogger.Logger.Error(ex, "InsertSESSIONUSER_TAsync");
            // 建议这里可以根据业务需求抛出异常或返回明确错误标识，避免吞掉异常导致问题排查困难
        }
        finally
        {
            if (cnn?.State == System.Data.ConnectionState.Open)
            {
                await cnn.CloseAsync();
            }
        }
        return -1;
    }
}

关键改动说明 #

1. 重构SQL语句：移除了无效的SELECT CAST(SCOPE_IDENTITY() as int)，改用RETURNING ID INTO :NewId将插入的ID输出到参数中。
2. 添加输出参数：创建OracleParameter作为输出参数，用来接收序列生成的ID值。
3. 移除重复执行逻辑：只执行一次ExecuteAsync，避免重复插入记录的问题。
4. 异步优化：将同步的Open()/Close()改为异步的OpenAsync()/CloseAsync()，符合异步编程的最佳实践。

备用方案：先获取序列值再插入 #

如果你需要提前知道ID值再执行插入，可以先查询序列的下一个值，保存后再插入，这种方式适合特定业务场景：

public async Task<int> InsertSESSIONUSER_TAsync(SESSIONUSER_T obj)
{
    using (OracleConnection cnn = DBCConnectionFactory.Getconnection())
    {
        await cnn.OpenAsync();
        
        // 先获取序列的下一个值
        var newId = await cnn.QuerySingleAsync<int>("SELECT USER_SEQUENCE.NEXTVAL FROM DUAL");

        // 使用预获取的ID执行插入
        string sql = @"INSERT INTO SESSIONUSER_T 
                       (ID, USERNAME, PASSWORD, LOCALE, TIMEZONEID, EMAIL, CREATIONDATE, EMAILPEO) 
                       VALUES (:ID, 'TEMP', :PASSWORD, :LOCALE, :TIMEZONEID, :EMAIL, :CREATIONDATE, :EMAILPEO)";

        await cnn.ExecuteAsync(sql, new {
            ID = newId,
            obj.PASSWORD,
            obj.LOCALE,
            obj.TIMEZONEID,
            obj.EMAIL,
            obj.CREATIONDATE,
            obj.EMAILPEO
        });

        return newId;
    }
}

注意：这种方式在高并发场景下可能存在序列值被其他会话占用的小概率问题，但大部分常规业务场景下是安全可用的。

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