【问题标题】:Transaction viewing changes to database rows made after it began事务查看开始后对数据库行所做的更改
【发布时间】: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


    【解决方案1】:

    来自 PostgreSQL docs

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

    ...

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

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2018-10-22
      • 2013-08-22
      • 1970-01-01
      • 2013-02-22
      • 1970-01-01
      相关资源
      最近更新 更多