如何在连接关闭时终止正在运行的查询

Question

我们在后端使用https://github.com/go-gorm/gorm/ ORM 和脚本来连接到 PostgreSQL 数据库。

有时，当脚本正在进行时，我们会通过按Ctrl + C本地按钮或终止生产中的 pod/进程来手动终止作业。defer DB.Close()我们在所有脚本中都有一个，我还添加了处理 SIGINT / SIGTERM 信号以DB.Close()在终止时执行。

问题是，即使在关闭连接后，任何已经运行的现有查询也不会被终止并继续占用数据库资源。有没有办法在直接从 gorm 或通过其他 hack 退出之前终止此连接池启动的任何查询。

想过使用 usingpg_backend_pid()和终止查询 using pg_stat_activity，但是我们在运行 new 时获得的 pidpg_backend_pid()不会与正在运行的查询相同。

版本：jinzhu/gorm v1.9.2

Answer 1

您可以使用 BeginTx(ctx context.Context, opts *sql.TxOptions)which 将上下文作为参数。

这是一个小例子：

import (
    "context"
    "fmt"
    "os"
    "os/signal"

    "github.com/jinzhu/gorm"
    _ "github.com/jinzhu/gorm/dialects/postgres"
)

func main() {
    db, err := gorm.Open("postgres", "host=localhost port=5432 user=gorm dbname=gorm password=mypassword sslmode=disable")
    if err != nil {
        panic(err)
    }
    defer db.Close()
    ctx := context.Background()

    ctx, cancel := context.WithCancel(ctx)
    c := make(chan os.Signal, 1)
    signal.Notify(c, os.Interrupt)
    defer func() {
        signal.Stop(c)
        cancel()
    }()
    go func() {
        select {
        case <-c:
            cancel()
        case <-ctx.Done():
        }
    }()

    transaction, err := db.DB().BeginTx(ctx, nil)
    _, err = transaction.Exec("SELECT pg_sleep(100)")
    if err != nil {
        fmt.Println(err.Error())
    }
}