mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-31 18:53:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Default 0 on postgres

Browse source
This commit is contained in:
Kegan Dougal 2022-01-20 18:24:22 +00:00
parent a81c507d62
commit 031cc1876d
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
keyserver/storage/postgres/deltas/2022012016470000_key_changes.go
View file

@ -35,7 +35,7 @@ func UpRefactorKeyChanges(tx *sql.Tx) error {
logrus.Infof("running delta!") logrus.Infof("running delta!")
// start counting from the last max offset, else 0. // start counting from the last max offset, else 0.
var maxOffset int64 var maxOffset int64
_ = tx.QueryRow(`SELECT MAX(log_offset) FROM keyserver_key_changes`).Scan(&maxOffset) _ = tx.QueryRow(`SELECT coalesce(MAX(log_offset), 0) AS offset FROM keyserver_key_changes`).Scan(&maxOffset)
if _, err := tx.Exec(fmt.Sprintf(`CREATE SEQUENCE IF NOT EXISTS keyserver_key_changes_seq START %d`, maxOffset)); err != nil { if _, err := tx.Exec(fmt.Sprintf(`CREATE SEQUENCE IF NOT EXISTS keyserver_key_changes_seq START %d`, maxOffset)); err != nil {
return fmt.Errorf("failed to CREATE SEQUENCE for key changes, starting at %d: %s", maxOffset, err) return fmt.Errorf("failed to CREATE SEQUENCE for key changes, starting at %d: %s", maxOffset, err)
} }