fix: clickhouse query issue

housepower · Jan 2, 2024 · a8a1ffa · a8a1ffa
1 parent e21fa86
commit a8a1ffa
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/pool/ck_cli.go b/pool/ck_cli.go
@@ -77,14 +77,14 @@ func (c *Conn) Query(query string, args ...any) (*Rows, error) {
 	var rs Rows
 	rs.protocol = c.protocol
 	if c.protocol == clickhouse.HTTP {
-		rows, err := c.db.Query(query, args)
+		rows, err := c.db.Query(query, args...)
 		if err != nil {
 			return &rs, err
 		} else {
 			rs.rs1 = rows
 		}
 	} else {
-		rows, err := c.c.Query(c.ctx, query, args)
+		rows, err := c.c.Query(c.ctx, query, args...)
 		if err != nil {
 			return &rs, err
 		} else {
@@ -98,19 +98,19 @@ func (c *Conn) QueryRow(query string, args ...any) *Row {
 	var row Row
 	row.proto = c.protocol
 	if c.protocol == clickhouse.HTTP {
-		row.r1 = c.db.QueryRow(query, args)
+		row.r1 = c.db.QueryRow(query, args...)
 	} else {
-		row.r2 = c.c.QueryRow(c.ctx, query, args)
+		row.r2 = c.c.QueryRow(c.ctx, query, args...)
 	}
 	return &row
 }
 
 func (c *Conn) Exec(query string, args ...any) error {
 	if c.protocol == clickhouse.HTTP {
-		_, err := c.db.Exec(query, args)
+		_, err := c.db.Exec(query, args...)
 		return err
 	} else {
-		return c.c.Exec(c.ctx, query, args)
+		return c.c.Exec(c.ctx, query, args...)
 	}
 }