Update schema (#61)

Updates table to add header_cids.uncles_hash
This commit is contained in:
Roy Crihfield 2022-10-13 13:19:47 -05:00 committed by GitHub
parent 05aeeab581
commit c270f39de9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 4 deletions

View File

@ -34,14 +34,14 @@ var TableHeader = Table{
{"state_root", varchar}, {"state_root", varchar},
{"tx_root", varchar}, {"tx_root", varchar},
{"receipt_root", varchar}, {"receipt_root", varchar},
{"uncle_root", varchar}, {"uncles_hash", varchar},
{"bloom", bytea}, {"bloom", bytea},
{"timestamp", numeric}, {"timestamp", numeric},
{"mh_key", text}, {"mh_key", text},
{"times_validated", integer}, {"times_validated", integer},
{"coinbase", varchar}, {"coinbase", varchar},
}, },
"ON CONFLICT (block_hash, block_number) DO UPDATE SET (parent_hash, cid, td, node_id, reward, state_root, tx_root, receipt_root, uncle_root, bloom, timestamp, mh_key, times_validated, coinbase) = (EXCLUDED.parent_hash, EXCLUDED.cid, EXCLUDED.td, EXCLUDED.node_id, EXCLUDED.reward, EXCLUDED.state_root, EXCLUDED.tx_root, EXCLUDED.receipt_root, EXCLUDED.uncle_root, EXCLUDED.bloom, EXCLUDED.timestamp, EXCLUDED.mh_key, eth.header_cids.times_validated + 1, EXCLUDED.coinbase)", "ON CONFLICT (block_hash, block_number) DO UPDATE SET (parent_hash, cid, td, node_id, reward, state_root, tx_root, receipt_root, uncles_hash, bloom, timestamp, mh_key, times_validated, coinbase) = (EXCLUDED.parent_hash, EXCLUDED.cid, EXCLUDED.td, EXCLUDED.node_id, EXCLUDED.reward, EXCLUDED.state_root, EXCLUDED.tx_root, EXCLUDED.receipt_root, EXCLUDED.uncles_hash, EXCLUDED.bloom, EXCLUDED.timestamp, EXCLUDED.mh_key, eth.header_cids.times_validated + 1, EXCLUDED.coinbase)",
} }
var TableStateNode = Table{ var TableStateNode = Table{

View File

@ -24,7 +24,7 @@ type column struct {
type Table struct { type Table struct {
Name string Name string
Columns []column Columns []column
conflictClause string ConflictClause string
} }
func (tbl *Table) ToCsvRow(args ...interface{}) []string { func (tbl *Table) ToCsvRow(args ...interface{}) []string {
@ -43,7 +43,7 @@ func (tbl *Table) ToInsertStatement() string {
} }
return fmt.Sprintf( return fmt.Sprintf(
"INSERT INTO %s (%s) VALUES (%s) %s", "INSERT INTO %s (%s) VALUES (%s) %s",
tbl.Name, strings.Join(colnames, ", "), strings.Join(placeholders, ", "), tbl.conflictClause, tbl.Name, strings.Join(colnames, ", "), strings.Join(placeholders, ", "), tbl.ConflictClause,
) )
} }