【发布时间】:2020-06-05 09:51:42
【问题描述】:
在使用 Postgres 和 Go GORM 时,我发现了一些我无法理解的东西。
在下面的代码 sn-p 中,我尝试查找、删除和创建相同的项目,但在 2 个不同的事务中,但是我开始第二个事务并在提交第一个事务之前找到该项目。
在第二次交易中,发生了一些奇怪的事情。当我调用t2.Delete() 时,它不会删除任何行。在数据库中,调用t1.Commit()后,item的主键变成了2,但是由于已经拿到了旧的item,所以删除了主键1。
为什么事务 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;",它将在提交时出错,或者在获取时阻塞。
【问题讨论】:
标签: postgresql go transactions isolation-level go-gorm