use lightweight deletes

iuwqyir · iuwqyir · commit 5056f399c4ef · 2024-12-03T20:48:35.000+02:00
diff --git a/internal/storage/clickhouse.go b/internal/storage/clickhouse.go
@@ -1003,7 +1003,7 @@ func (c *ClickHouseConnector) DeleteBlockData(chainId *big.Int, blockNumbers []*
 }
 
 func (c *ClickHouseConnector) deleteBatch(chainId *big.Int, blockNumbers []*big.Int, table string, blockNumberColumn string) error {
-	query := fmt.Sprintf("ALTER TABLE %s.%s DELETE WHERE chain_id = ? AND %s IN (?)", c.cfg.Database, table, blockNumberColumn)
+	query := fmt.Sprintf("DELETE FROM %s.%s WHERE chain_id = ? AND %s IN (?)", c.cfg.Database, table, blockNumberColumn)
 
 	blockNumbersStr := make([]string, len(blockNumbers))
 	for i, bn := range blockNumbers {

Original file line number	Diff line number	Diff line change
`@@ -1003,7 +1003,7 @@ func (c ClickHouseConnector) DeleteBlockData(chainId big.Int, blockNumbers []*`
`1003`	`1003`	`}`
`1004`	`1004`
`1005`	`1005`	`func (c ClickHouseConnector) deleteBatch(chainId big.Int, blockNumbers []*big.Int, table string, blockNumberColumn string) error {`
`1006`		`- query := fmt.Sprintf("ALTER TABLE %s.%s DELETE WHERE chain_id = ? AND %s IN (?)", c.cfg.Database, table, blockNumberColumn)`
	`1006`	`+ query := fmt.Sprintf("DELETE FROM %s.%s WHERE chain_id = ? AND %s IN (?)", c.cfg.Database, table, blockNumberColumn)`
`1007`	`1007`
`1008`	`1008`	`blockNumbersStr := make([]string, len(blockNumbers))`
`1009`	`1009`	`for i, bn := range blockNumbers {`