mirror of https://github.com/jackc/pgx.git
Merge pull request #572 from mastercactapus/repeatable-read
Allow specifying sql.LevelRepeatableRead in BeginTxpull/576/head
commit
652d695065
|
@ -277,7 +277,7 @@ func (c *Conn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, e
|
||||||
pgxOpts.IsoLevel = pgx.ReadUncommitted
|
pgxOpts.IsoLevel = pgx.ReadUncommitted
|
||||||
case sql.LevelReadCommitted:
|
case sql.LevelReadCommitted:
|
||||||
pgxOpts.IsoLevel = pgx.ReadCommitted
|
pgxOpts.IsoLevel = pgx.ReadCommitted
|
||||||
case sql.LevelSnapshot:
|
case sql.LevelRepeatableRead, sql.LevelSnapshot:
|
||||||
pgxOpts.IsoLevel = pgx.RepeatableRead
|
pgxOpts.IsoLevel = pgx.RepeatableRead
|
||||||
case sql.LevelSerializable:
|
case sql.LevelSerializable:
|
||||||
pgxOpts.IsoLevel = pgx.Serializable
|
pgxOpts.IsoLevel = pgx.Serializable
|
||||||
|
|
|
@ -629,6 +629,7 @@ func TestConnBeginTxIsolation(t *testing.T) {
|
||||||
{sqlIso: sql.LevelDefault, pgIso: defaultIsoLevel},
|
{sqlIso: sql.LevelDefault, pgIso: defaultIsoLevel},
|
||||||
{sqlIso: sql.LevelReadUncommitted, pgIso: "read uncommitted"},
|
{sqlIso: sql.LevelReadUncommitted, pgIso: "read uncommitted"},
|
||||||
{sqlIso: sql.LevelReadCommitted, pgIso: "read committed"},
|
{sqlIso: sql.LevelReadCommitted, pgIso: "read committed"},
|
||||||
|
{sqlIso: sql.LevelRepeatableRead, pgIso: "repeatable read"},
|
||||||
{sqlIso: sql.LevelSnapshot, pgIso: "repeatable read"},
|
{sqlIso: sql.LevelSnapshot, pgIso: "repeatable read"},
|
||||||
{sqlIso: sql.LevelSerializable, pgIso: "serializable"},
|
{sqlIso: sql.LevelSerializable, pgIso: "serializable"},
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue