go 和 psql 之间事务内的游标行为不同

一分耕耘，一分收获！既然打开了这篇文章《go 和 psql 之间事务内的游标行为不同》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

我有一个问题。由于某种原因，这完全超出了我的范围，当我在 psql （它工作的地方）中运行它时，我创建的游标的行为与我通过 go 代码运行它时不同。

我接收一部分名称并将它们作为 pq.array 传递给事务执行函数调用。根据我所读到的内容，这应该能够将任意计数的多个值传递给查询。但显然不是..我不知道这种情况是否发生，因为它位于事务中的游标内，这是我唯一能想到的事情。

其想法是查询 tenants 中名称未出现在此列表中的所有 id，因此使用 <> 运算符。这些名称在数据库中是唯一的。

当我通过 go 代码运行它时，我最终得到了所有 id，而不仅仅是列表中未出现的那些。

我已在此处包含该函数，事务在调用函数中启动并传递给该函数。请告知是否需要包含其他内容以进一步澄清！

我错过了什么吗？

func DeleteTenants(orphanTenants []string, tx *sql.Tx) error {
    query := `
    DECLARE tenants_cursor CURSOR FOR
    SELECT id FROM tenants
    WHERE name <> ALL(ARRAY[$1])
    FOR UPDATE
    `
    if _, err := tx.Exec(query, pq.Array(orphanTenants)); err != nil {
        log.Println("DeleteTenants: Error creating Tenant cursor")
        return err
    }
    defer tx.Exec("CLOSE tenants_cursor")
    for {
        id := -1
        if err := tx.QueryRow("FETCH NEXT FROM tenants_cursor").Scan(&id); err != nil {
            if err == sql.ErrNoRows {
                log.Println("No rows found in tenants_cursor")
                break
            }
            log.Println("DeleteTenants: Error when fetching next row from Tenant cursor")
            return err
        }
        log.Println("Tenant ID to be deleted:", id)
        if err := deleteTenant(id, tx); err != nil {
            log.Println("DeleteTenants: Error returned from deleteTenant")
        }
    }
    return nil
}

解决方案

没关系..想通了。将 pq.array 传递给查询时，我不需要在查询中包含 array 表示法。

这太尴尬了！在几分钟内回答我自己的问题。

因此查询将如下所示：

query := `
DECLARE tenants_cursor CURSOR FOR
SELECT id FROM tenants
WHERE name <> ALL($1)
FOR UPDATE
`
if _, err := tx.Exec(query, pq.Array(orphanTenants)); err != nil {
    log.Println("DeleteTenants: Error creating Tenant cursor")
    return err
}
defer tx.Exec("CLOSE tenants_cursor")

本篇关于《go 和 psql 之间事务内的游标行为不同》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！