P2Pool/consensus
P2Pool/consensus
1
1
Fork 0
Code Issues 3 Pull requests Releases Activity

index: faster materialized view refresh in some cases

Browse source
This commit is contained in:
DataHoarder 2023-05-29 13:14:18 +02:00
parent 25f58426a7
commit 6286a8ab24
Signed by: DataHoarder
SSH key fingerprint: SHA256:OLTRf6Fl87G52SiR7sWLGNzlJt4WOX+tfI2yxo0z7xk
2 changed files with 23 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
index/index.go
View file

@ -707,11 +707,12 @@ func (i *Index) InsertOrUpdateMainBlock(b *MainBlock) error {
return err
}
if _, err := tx.Exec("REFRESH MATERIALIZED VIEW " + i.views["payouts"] + ";"); err != nil {
// Refresh materialized views
if _, err := tx.Exec("DELETE FROM "+i.views["payouts"]+" WHERE main_id = $1;", oldBlock.Id[:]); err != nil {
return err
}
if _, err := tx.Exec("REFRESH MATERIALIZED VIEW " + i.views["found_main_blocks"] + ";"); err != nil {
if _, err := tx.Exec("DELETE FROM "+i.views["found_main_blocks"]+" WHERE main_id = $1;", oldBlock.Id[:]); err != nil {
return err
}
@ -728,7 +729,7 @@ func (i *Index) InsertOrUpdateMainBlock(b *MainBlock) error {
return err
} else {
defer tx.Rollback()
if _, err := tx.Exec(
if result, err := tx.Exec(
"INSERT INTO main_blocks (id, height, timestamp, reward, coinbase_id, difficulty, metadata, side_template_id, coinbase_private_key) VALUES ($1, $2, $3, $4, $5, $6, $7::jsonb, $8, $9) ON CONFLICT (id) DO UPDATE SET metadata = $7, side_template_id = $8, coinbase_private_key = $9;",
b.Id[:],
b.Height,
@ -741,11 +742,14 @@ func (i *Index) InsertOrUpdateMainBlock(b *MainBlock) error {
&b.CoinbasePrivateKey,
); err != nil {
return err
} else if n, err := result.RowsAffected(); err != nil {
return err
} else if n > 0 {
if _, err := tx.Exec("REFRESH MATERIALIZED VIEW CONCURRENTLY " + i.views["found_main_blocks"] + ";"); err != nil {
return err
}
}
if _, err := tx.Exec("REFRESH MATERIALIZED VIEW " + i.views["found_main_blocks"] + ";"); err != nil {
return err
}
return tx.Commit()
}
}
@ -1169,8 +1173,9 @@ func (i *Index) InsertOrUpdateMainCoinbaseOutputs(outputs MainCoinbaseOutputs) e
return err
} else {
defer tx.Rollback()
inserted := 0
for _, o := range outputs {
if _, err = tx.Exec(
if result, err := tx.Exec(
"INSERT INTO main_coinbase_outputs (id, index, global_output_index, miner, value) VALUES ($1, $2, $3, $4, $5) ON CONFLICT DO NOTHING;",
o.Id[:],
o.Index,
@ -1179,10 +1184,16 @@ func (i *Index) InsertOrUpdateMainCoinbaseOutputs(outputs MainCoinbaseOutputs) e
o.Value,
); err != nil {
return err
} else if n, err := result.RowsAffected(); err != nil {
return err
} else if n > 0 {
inserted++
}
}
if _, err := tx.Exec("REFRESH MATERIALIZED VIEW " + i.views["payouts"] + ";"); err != nil {
return err
if inserted > 0 {
if _, err := tx.Exec("REFRESH MATERIALIZED VIEW CONCURRENTLY " + i.views["payouts"] + ";"); err != nil {
return err
}
}
return tx.Commit()
}

3
index/schema.sql
View file

@ -156,6 +156,7 @@ CREATE MATERIALIZED VIEW found_main_blocks_v1 AS
(SELECT * FROM side_blocks) AS s ON s.main_id = m.id
WITH NO DATA;
CREATE UNIQUE INDEX IF NOT EXISTS found_main_blocks_main_id_idx ON found_main_blocks_v1 (main_id);
CREATE INDEX IF NOT EXISTS found_main_blocks_miner_idx ON found_main_blocks_v1 (miner);
CREATE INDEX IF NOT EXISTS found_main_blocks_side_height_idx ON found_main_blocks_v1 (side_height);
@ -183,6 +184,8 @@ CREATE MATERIALIZED VIEW payouts_v2 AS
(SELECT template_id, main_id, side_height, uncle_of, GREATEST(0, GREATEST(effective_height, side_height) - window_depth) AS including_height FROM side_blocks) AS s ON s.main_id = m.id
WITH NO DATA;
CREATE UNIQUE INDEX IF NOT EXISTS found_main_blocks_global_output_index_idx ON payouts_v2 (global_output_index);
CREATE INDEX IF NOT EXISTS payouts_miner_idx ON payouts_v2 (miner);
CREATE INDEX IF NOT EXISTS payouts_main_id_idx ON payouts_v2 (main_id);
CREATE INDEX IF NOT EXISTS payouts_side_height_idx ON payouts_v2 (side_height);