Skip to content

Commit 2bf7973

Browse files
committed
minor fix
1 parent 7d5ad97 commit 2bf7973

File tree

1 file changed

+2
-9
lines changed

1 file changed

+2
-9
lines changed

internal/libs/clickhouse.go

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@ import (
55
"crypto/tls"
66
"fmt"
77
"math/big"
8-
"strconv"
98
"strings"
109
"sync"
1110

@@ -101,7 +100,6 @@ func initClickhouse(host string, port int, username string, password string, dat
101100
}
102101

103102
func GetMaxBlockNumberFromClickHouseV2(chainId *big.Int) (int64, error) {
104-
// Use toString() to force ClickHouse to return a string instead of UInt256
105103
query := fmt.Sprintf("SELECT max(block_number) FROM blocks WHERE chain_id = %d HAVING count() > 0", chainId.Uint64())
106104
rows, err := ClickhouseConnV2.Query(context.Background(), query)
107105
if err != nil {
@@ -113,16 +111,11 @@ func GetMaxBlockNumberFromClickHouseV2(chainId *big.Int) (int64, error) {
113111
return -1, nil
114112
}
115113

116-
var maxBlockNumberStr string
117-
if err := rows.Scan(&maxBlockNumberStr); err != nil {
114+
var maxBlockNumber int64
115+
if err := rows.Scan(&maxBlockNumber); err != nil {
118116
return -1, err
119117
}
120118

121-
maxBlockNumber, err := strconv.ParseInt(maxBlockNumberStr, 10, 64)
122-
if err != nil {
123-
return -1, fmt.Errorf("failed to parse block number: %s", maxBlockNumberStr)
124-
}
125-
126119
return maxBlockNumber, nil
127120
}
128121

0 commit comments

Comments
 (0)