postgresql - 事务查看开始后对数据库行所做的更改

标签 postgresql go transactions isolation-level go-gorm

我发现在使用Postgres和Go GORM时无法解决的问题。

在以下代码段中,我尝试并查找,删除和创建相同的项目,但是在2个不同的事务中,但是我开始第二个事务并在提交第一个事务之前查找该项目。

在第二笔交易中,发生了一些奇怪的事情。当我调用t2.Delete()时,它不会删除任何行。在数据库中,调用t1.Commit()后,该项的主键变为2,但是由于它已经有了旧项,因此删除了主键1

尽管事务2在提交第一行之前创建了,但为什么它仍看到事务2?

db, err := gorm.Open("postgres", "host=localHost port=5432 user=postgres dbname=test password=postgres sslmode=disable")
defer db.Close()
db.DropTableIfExists(&Product{})
db.AutoMigrate(&Product{})
db.LogMode(true)

db.Create(&Product{Code: "A", Price: 1000})
// SQL: INSERT  INTO "products" ("code","price") VALUES ('A',1000) RETURNING "products"."id"

// Start transaction 1, find item, delete it
t1 := db.Begin()
product := &Product{}

err = t1.Find(product, "code = ?", "A").Error
// SQL: SELECT * FROM "products"  WHERE (code = 'A')

err = t1.Delete(product).Error
// SQL: DELETE FROM "products"  WHERE "products"."id" = 1

// Start transaction 2 and get item, before transaction 1 creates new item and commits
t2 := db.Begin()

product2 := &Product{}
err = t2.Find(product2, "code = ?", "A").Error
// SQL: SELECT * FROM "products"  WHERE (code = 'A')

err = t1.Create(&Product{Code: "A", Price: 3000}).Error
// SQL: INSERT  INTO "products" ("code","price") VALUES ('A',3000) RETURNING "products"."id"

err = t1.Commit().Error
// Database now contains

err = t2.Delete(product2).Error
// SQL: DELETE FROM "products"  WHERE "products"."id" = 1
// [0 rows affected or returned ]

err = t2.Save(&Product{Code: "A", Price: 4000}).Error
// SQL: INSERT  INTO "products" ("code","price") VALUES ('A',4000) RETURNING "products"."id"
// ERROR HERE: pq: duplicate key value violates unique constraint "products_code_key"

err = t2.Commit().Error

注意: GORM默认使用Read Committed isolation level。我知道如果工作正常,可能会引起完整性问题。我将改为使用Serializable,如果指定了"FOR UPDATE;",它将在Commit上产生错误,或在Get上发生阻塞

最佳答案

从PostgreSQL docs

读取已提交是PostgreSQL中的默认隔离级别。当一个
事务使用此隔离级别,即SELECT查询(不带FOR
UPDATE / SHARE子句)仅查看在查询开始之前提交的数据;
它永远不会看到未提交的数据或在此期间提交的更改
通过并发事务查询执行。实际上,是一个SELECT查询
从查询开始的那一刻开始查看数据库的快照
跑。

...

另请注意,两个连续的SELECT命令可以看到不同的数据,
即使它们在一次交易中,如果其他
事务在第一个SELECT开始之后和之前提交更改
第二个SELECT开始。

第二段似乎总结了您的情况。提交t2后启动的t1中的任何“SELECT”都可以看到t1应用的更新。

关于postgresql - 事务查看开始后对数据库行所做的更改,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60330646/

相关文章:

postgresql - 高频调用导致 Waterline & Sails 中的 findOrCreate 重复

node.js - 将sails.js 与现有的postgres 数据库一起使用

sql - 合并两个表并定义第三个字段

postgresql - 如何在没有 super 用户帐户的情况下创建 postgresql super 用户?

go - 如何同时搜索一大片 maps[string]string

go - 前往 channel -推送至 channel 会停止执行

mysql - 回滚事务无法正常工作

Spring 忽略@Transactional 注解

go - 如何使用 Server.TLSNextProto 禁用 HTTP/2

javascript - 如何使用 Node.js 和 Tedious 从单个连接/事务进行多个数据库调用