我发现在使用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/