diff options
| author | Jonathan Amsterdam <jba@google.com> | 2020-06-01 15:32:59 -0400 |
|---|---|---|
| committer | Jonathan Amsterdam <jba@google.com> | 2020-06-02 15:12:19 +0000 |
| commit | e66341ffa9aaedd9fee511576e2e501738faa281 (patch) | |
| tree | 081bf2bea81e7118e164dafd3787ad638658153e /internal/postgres/versionstate.go | |
| parent | 7557ba489297ee225fc0cad232619d21fbc93f83 (diff) | |
| download | go-x-pkgsite-e66341ffa9aaedd9fee511576e2e501738faa281.tar.xz | |
internal/database: Transact supports any isolation level
- Add an arg to Transact for the isolation level
- Remove TransactSerializable
This makes it possible to use other levels, and makes it easier to see
which level is being used for each transaction.
Change-Id: Iba5e2920b4139e5e2f0f8c6b331a658d7c84f60f
Reviewed-on: https://team-review.git.corp.google.com/c/golang/discovery/+/758942
CI-Result: Cloud Build <devtools-proctor-result-processor@system.gserviceaccount.com>
Reviewed-by: Julie Qiu <julieqiu@google.com>
Diffstat (limited to 'internal/postgres/versionstate.go')
| -rw-r--r-- | internal/postgres/versionstate.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/internal/postgres/versionstate.go b/internal/postgres/versionstate.go index 22a38e13..f2bfc99d 100644 --- a/internal/postgres/versionstate.go +++ b/internal/postgres/versionstate.go @@ -36,7 +36,7 @@ func (db *DB) InsertIndexVersions(ctx context.Context, versions []*internal.Inde DO UPDATE SET index_timestamp=excluded.index_timestamp, next_processed_after=CURRENT_TIMESTAMP` - return db.db.Transact(ctx, func(tx *database.DB) error { + return db.db.Transact(ctx, sql.LevelDefault, func(tx *database.DB) error { return tx.BulkInsert(ctx, "module_version_states", cols, vals, conflictAction) }) } @@ -57,7 +57,7 @@ func (db *DB) UpsertModuleVersionState(ctx context.Context, modulePath, vers, ap numPackages = &n } - return db.db.Transact(ctx, func(tx *database.DB) error { + return db.db.Transact(ctx, sql.LevelDefault, func(tx *database.DB) error { if err := upsertModuleVersionState(ctx, tx, modulePath, vers, appVersion, numPackages, timestamp, status, goModPath, fetchErr); err != nil { return err } |
