remove trailing semicolons
This commit is contained in:
parent
9bff302894
commit
f5c7157b0b
|
@ -165,7 +165,7 @@ impl PostgresSession {
|
|||
let statement = format!(
|
||||
r#"
|
||||
INSERT INTO banking_stage_results_2.transactions(signature) SELECT signature from {}
|
||||
ON CONFLICT DO NOTHING;
|
||||
ON CONFLICT DO NOTHING
|
||||
"#,
|
||||
temp_table
|
||||
);
|
||||
|
@ -214,7 +214,7 @@ impl PostgresSession {
|
|||
let statement = format!(
|
||||
r#"
|
||||
INSERT INTO banking_stage_results_2.accounts(account_key) SELECT key from {}
|
||||
ON CONFLICT DO NOTHING;
|
||||
ON CONFLICT DO NOTHING
|
||||
"#,
|
||||
temp_table
|
||||
);
|
||||
|
@ -291,7 +291,7 @@ impl PostgresSession {
|
|||
FROM (
|
||||
SELECT sig, slot, error_code, count, utc_timestamp from {}
|
||||
)
|
||||
as t (sig, slot, error_code, count, utc_timestamp) ON CONFLICT DO NOTHING;
|
||||
as t (sig, slot, error_code, count, utc_timestamp) ON CONFLICT DO NOTHING
|
||||
"#,
|
||||
temp_table
|
||||
);
|
||||
|
@ -362,7 +362,7 @@ impl PostgresSession {
|
|||
new_amt_data.is_signer,
|
||||
new_amt_data.is_atl
|
||||
FROM {} AS new_amt_data
|
||||
ON CONFLICT DO NOTHING;
|
||||
ON CONFLICT DO NOTHING
|
||||
"#,
|
||||
temp_table
|
||||
);
|
||||
|
@ -403,7 +403,7 @@ impl PostgresSession {
|
|||
r#"
|
||||
INSERT INTO banking_stage_results_2.accounts_map_transaction_latest(acc_id, tx_ids)
|
||||
SELECT acc_id, tx_ids_agg FROM {temp_table_name}
|
||||
ON CONFLICT (acc_id) DO UPDATE SET tx_ids = EXCLUDED.tx_ids;
|
||||
ON CONFLICT (acc_id) DO UPDATE SET tx_ids = EXCLUDED.tx_ids
|
||||
"#,
|
||||
temp_table_name = temp_table_latest_agged
|
||||
);
|
||||
|
@ -432,7 +432,7 @@ impl PostgresSession {
|
|||
cu_consumed BIGINT,
|
||||
prioritization_fees BIGINT,
|
||||
supp_infos text
|
||||
);",
|
||||
)",
|
||||
temp_table
|
||||
)
|
||||
.as_str(),
|
||||
|
@ -495,7 +495,7 @@ impl PostgresSession {
|
|||
t.prioritization_fees,
|
||||
t.supp_infos
|
||||
FROM {} AS t
|
||||
ON CONFLICT DO NOTHING;
|
||||
ON CONFLICT DO NOTHING
|
||||
"#,
|
||||
temp_table
|
||||
);
|
||||
|
@ -517,7 +517,7 @@ impl PostgresSession {
|
|||
total_cu_requested BIGINT,
|
||||
total_cu_consumed BIGINT,
|
||||
prioritization_fees_info text
|
||||
);",
|
||||
)",
|
||||
temp_table
|
||||
)
|
||||
.as_str(),
|
||||
|
@ -598,7 +598,7 @@ impl PostgresSession {
|
|||
total_cu_consumed,
|
||||
prioritization_fees_info
|
||||
)
|
||||
ON CONFLICT DO NOTHING;
|
||||
ON CONFLICT DO NOTHING
|
||||
"#,
|
||||
temp_table
|
||||
);
|
||||
|
@ -620,7 +620,7 @@ impl PostgresSession {
|
|||
total_cu_requested,
|
||||
supp_infos
|
||||
) VALUES ($1, $2, $3, $4, $5, $6, $7, $8)
|
||||
ON CONFLICT DO NOTHING;
|
||||
ON CONFLICT DO NOTHING
|
||||
"#;
|
||||
let num_rows = self.client
|
||||
.execute(
|
||||
|
|
Loading…
Reference in New Issue