Golang操作PostgreSQL报错：pq: 当前事务已中止，需结束事务块

错误原因 #

• 未处理事务内前置操作的错误：仓库层代码中调用tx.Get(&new_id, "select gen_random_uuid()")时未捕获错误，一旦这行执行失败（比如PostgreSQL未安装pgcrypto扩展，gen_random_uuid()依赖该扩展），事务会直接进入中止状态，后续的tx.NamedExec()会触发"current transaction is aborted"错误，且原代码未对该情况执行回滚，导致事务一直处于无效状态。
• 事务异常后未及时终止：PostgreSQL中，事务内某一步出错会标记整个事务为无效，必须通过回滚结束事务，原代码仅在NamedExec出错时回滚，忽略了前面步骤的错误，导致无效事务持续引发后续操作报错。

解决办法 #

1. 为所有事务内操作添加错误处理 #

修改仓库层代码，捕获每一步事务操作的错误，出错立即回滚：

func (r *RepoProduct) CreateProductData(data *models.Products) (string, error) {
    tx := r.MustBegin()
    var new_id string
    // 捕获tx.Get的错误，出错立即回滚
    err := tx.Get(&new_id, "select gen_random_uuid()")
    if err != nil {
        tx.Rollback()
        return "", err
    }
    data.Id_product = new_id
    _, err = tx.NamedExec(`INSERT INTO golang.products (id_product, id_category, banner_product, product_title, price, favorite) VALUES(:id_product, :id_category, :banner_product, :product_title, :price, :favorite) ON CONFLICT DO NOTHING`, data)
    if err != nil {
        tx.Rollback()
        return "", err
    }

    // 提交时也捕获错误，避免提交失败未处理
    if err := tx.Commit(); err != nil {
        return "", err
    }

    return "add product data successful", nil
}

2. 检查并启用PostgreSQL依赖扩展 #

gen_random_uuid()函数需要依赖pgcrypto扩展，若未安装，执行以下SQL启用：

CREATE EXTENSION IF NOT EXISTS pgcrypto;

3. 优化事务错误处理（可选） #

使用defer确保事务在异常时自动回滚，避免遗漏：

func (r *RepoProduct) CreateProductData(data *models.Products) (string, error) {
    tx := r.MustBegin()
    // 延迟执行，确保panic或未捕获错误时回滚事务
    defer func() {
        if r := recover(); r != nil {
            _ = tx.Rollback()
        }
    }()

    var new_id string
    err := tx.Get(&new_id, "select gen_random_uuid()")
    if err != nil {
        _ = tx.Rollback()
        return "", err
    }
    data.Id_product = new_id
    _, err = tx.NamedExec(`INSERT INTO golang.products (id_product, id_category, banner_product, product_title, price, favorite) VALUES(:id_product, :id_category, :banner_product, :product_title, :price, :favorite) ON CONFLICT DO NOTHING`, data)
    if err != nil {
        _ = tx.Rollback()
        return "", err
    }

    if err := tx.Commit(); err != nil {
        return "", err
    }

    return "add product data successful", nil
}

内容的提问来源于stack exchange，提问作者Ekha-Dev