Skip to content

Commit 043d5d5

Browse files
committed
Reduce minimum tx level for balance-related queries
1 parent c32c20e commit 043d5d5

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

pkg/code/data/action/postgres/model.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -233,7 +233,7 @@ func dbGetNetBalance(ctx context.Context, db *sqlx.DB, account string) (int64, e
233233
(SELECT COALESCE(SUM(quantity), 0) FROM ` + tableName + ` WHERE destination = $1 AND state != $2) -
234234
(SELECT COALESCE(SUM(quantity), 0) FROM ` + tableName + ` WHERE source = $1 AND state != $2);`
235235

236-
err := pgutil.ExecuteInTx(ctx, db, sql.LevelRepeatableRead, func(tx *sqlx.Tx) error {
236+
err := pgutil.ExecuteInTx(ctx, db, sql.LevelDefault, func(tx *sqlx.Tx) error {
237237
return tx.GetContext(
238238
ctx,
239239
&res,
@@ -275,7 +275,7 @@ func dbGetNetBalanceBatch(ctx context.Context, db *sqlx.DB, accounts ...string)
275275
(SELECT source AS account, -COALESCE(SUM(quantity), 0) AS net_balance FROM `+tableName+` WHERE source IN (%s) AND state != $1 GROUP BY source);`,
276276
accountFilter, accountFilter,
277277
)
278-
err := pgutil.ExecuteInTx(ctx, db, sql.LevelRepeatableRead, func(tx *sqlx.Tx) error {
278+
err := pgutil.ExecuteInTx(ctx, db, sql.LevelDefault, func(tx *sqlx.Tx) error {
279279
return tx.SelectContext(
280280
ctx,
281281
&rows,

pkg/code/data/deposit/postgres/model.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ func dbGetQuarkAmount(ctx context.Context, db *sqlx.DB, account string) (uint64,
116116
WHERE destination = $1 AND confirmation_state = $2
117117
`
118118

119-
err := pgutil.ExecuteInTx(ctx, db, sql.LevelRepeatableRead, func(tx *sqlx.Tx) error {
119+
err := pgutil.ExecuteInTx(ctx, db, sql.LevelDefault, func(tx *sqlx.Tx) error {
120120
return db.GetContext(ctx, &res, query, account, transaction.ConfirmationFinalized)
121121
})
122122
if err != nil {
@@ -151,7 +151,7 @@ func dbGetQuarkAmountBatch(ctx context.Context, db *sqlx.DB, accounts ...string)
151151
GROUP BY destination
152152
`, accountFilter)
153153

154-
err := pgutil.ExecuteInTx(ctx, db, sql.LevelRepeatableRead, func(tx *sqlx.Tx) error {
154+
err := pgutil.ExecuteInTx(ctx, db, sql.LevelDefault, func(tx *sqlx.Tx) error {
155155
return tx.SelectContext(ctx, &rows, query, transaction.ConfirmationFinalized)
156156
})
157157
if err != nil {
@@ -175,7 +175,7 @@ func dbGetUsdAmount(ctx context.Context, db *sqlx.DB, account string) (float64,
175175
WHERE destination = $1 AND confirmation_state = $2
176176
`
177177

178-
err := pgutil.ExecuteInTx(ctx, db, sql.LevelRepeatableRead, func(tx *sqlx.Tx) error {
178+
err := pgutil.ExecuteInTx(ctx, db, sql.LevelDefault, func(tx *sqlx.Tx) error {
179179
return db.GetContext(ctx, &res, query, account, transaction.ConfirmationFinalized)
180180
})
181181
if err != nil {

0 commit comments

Comments
 (0)