Update known_gaps table name

This commit is contained in:
Abdul Rabbani 2022-03-31 14:11:57 -04:00
parent f2b4c0b1ec
commit 08053b039c
2 changed files with 3 additions and 3 deletions

View File

@ -110,7 +110,7 @@ func (db *DB) InsertKnownGapsStm() string {
// InsertKnownGapsStm satisfies the sql.Statements interface
func (db *DB) InsertKnownGapsStm() string {
return `INSERT INTO eth.known_gaps (starting_block_number, ending_block_number, checked_out, processing_key) VALUES ($1, $2, $3, $4)
return `INSERT INTO eth_meta.known_gaps (starting_block_number, ending_block_number, checked_out, processing_key) VALUES ($1, $2, $3, $4)
ON CONFLICT (starting_block_number) DO UPDATE SET (ending_block_number, processing_key) = ($2, $4)
WHERE eth.known_gaps.ending_block_number <= $2`
WHERE eth_meta.known_gaps.ending_block_number <= $2`
}

View File

@ -166,7 +166,7 @@ type KnownGapsModel struct {
ProcessingKey int64 `db:"processing_key"`
}
// KnownGaps is the data structure for eth.known_gaps
// KnownGaps is the data structure for eth_meta.known_gaps
type KnownGapsModel struct {
StartingBlockNumber string `db:"starting_block_number"`
EndingBlockNumber string `db:"ending_block_number"`