Oracle 中获取最后插入记录 ID 的完整 Go 实战指南

正确的姿势：RETURNING ... INTO + sqlx.QueryRow

CREATE TABLE t (
    x INT PRIMARY KEY,
    created_at DATE DEFAULT SYSDATE
);
CREATE SEQUENCE x_seq START WITH 1 INCREMENT BY 1;

CREATE OR REPLACE TRIGGER t_bi_trg
    BEFORE INSERT ON t FOR EACH ROW
BEGIN
    SELECT x_seq.NEXTVAL INTO :NEW.x FROM DUAL;
END;

package main

import (
    "fmt"
    "log"
    "github.com/jmoiron/sqlx"
    _ "github.com/mattn/go-oci8"
)

func main() {
    db, err := sqlx.Connect("oci8", "user/pass@localhost:49161/xe")
    if err != nil {
        log.Fatal("连接失败:", err)
    }
    defer db.Close()

    // 关键点：用 RETURNING 子句把刚插入的主键拿回来
    var insertedID int
    err = db.QueryRow(
        "INSERT INTO t (created_at) VALUES (SYSDATE) RETURNING x INTO ?",
        &insertedID,
    ).Err()
    if err != nil {
        log.Fatal("插入并获取 ID 失败:", err)
    }
    fmt.Printf("成功插入，生成主键 ID: %d\n", insertedID)

    // 现在可以安全地用于第二条插入（外键关联）
    _, err = db.Exec(
        "INSERT INTO related_table (t_id, remark) VALUES (?, 'from Go')",
        insertedID,
    )
    if err != nil {
        log.Fatal("插入从表失败:", err)
    }
}

需要留意几个关键点：

• `RETURNING ... INTO ?` 是 Oracle 原生的命令，go-oci8 驱动通过 `QueryRow` 加地址参数就能直接接收返回值；
• 必须使用 `QueryRow()`、`Get()` 或 `Select()`，不能用 `Exec()`——因为 `Exec()` 不支持返回值绑定；
• 虽然 sqlx 对命名参数也有支持，但 go-oci8 对命名参数的支持不太稳定，建议优先用位置占位符 `?`；
• 注意，`RETURNING` 是在同一个事务内原子执行的，不需要额外加锁，天生就保证了事务安全和并发安全；
• 无论你的主键是来自序列、UUID 函数还是 `SYS_GUID()`，只要 `RETURNING` 指定的是你的目标列，都能可靠拿回。

常见误区，挨个澄清一下

• LastInsertId() 就不要想了：Oracle 的 Go 驱动（不管是 go-oci8 还是 goracle）都没有实现这个接口，调用就是报错；
• 千万别用 SELECT MAX(id) 来凑：高并发下读到别的会话插入的 ID 是很常见的事，还得加锁，性能也差；
• 存储函数里包 DML 再 SELECT 也不行：Oracle 禁止在 SELECT 中执行 DML，违反读一致性原则，会直接报 ORA-14551；
• PL/SQL 块加输出变量倒是可行：用 `sqlx.QueryRow().Scan()` 或 `database/sql` 的 `Out` 参数都能搞定，不过相比之下，`QueryRow(...).Scan(&id)` 是最简洁、最不容易出错的写法。

更进一步：封装成一个可复用的函数

func InsertAndGetID(db *sqlx.DB, table, pkCol string, cols []string, values ...interface{}) (int, error) {
    placeholders := make([]string, len(cols))
    for i := range cols {
        placeholders[i] = "?"
    }
    query := fmt.Sprintf(
        "INSERT INTO %s (%s) VALUES (%s) RETURNING %s INTO ?",
        table,
        strings.Join(cols, ", "),
        strings.Join(placeholders, ", "),
        pkCol,
    )
    var id int
    err := db.QueryRow(query, append(values, &id)...).Err()
    return id, err
}