Skip to content

Commit a6a7a71

Browse files
committed
minor change
1 parent 2bf7973 commit a6a7a71

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

internal/libs/clickhouse.go

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ import (
55
"crypto/tls"
66
"fmt"
77
"math/big"
8+
"strconv"
89
"strings"
910
"sync"
1011

@@ -100,7 +101,8 @@ func initClickhouse(host string, port int, username string, password string, dat
100101
}
101102

102103
func GetMaxBlockNumberFromClickHouseV2(chainId *big.Int) (int64, error) {
103-
query := fmt.Sprintf("SELECT max(block_number) FROM blocks WHERE chain_id = %d HAVING count() > 0", chainId.Uint64())
104+
// Use toString() to convert UInt256 to string, then parse to int64
105+
query := fmt.Sprintf("SELECT toString(max(block_number)) FROM blocks WHERE chain_id = %d HAVING count() > 0", chainId.Uint64())
104106
rows, err := ClickhouseConnV2.Query(context.Background(), query)
105107
if err != nil {
106108
return -1, err
@@ -111,11 +113,16 @@ func GetMaxBlockNumberFromClickHouseV2(chainId *big.Int) (int64, error) {
111113
return -1, nil
112114
}
113115

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

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+
119126
return maxBlockNumber, nil
120127
}
121128

0 commit comments

Comments
 (0)