fk

hantmac · hantmac · commit 7d77736f8716 · 2025-06-05T15:15:23.000+08:00
diff --git a/connection.go b/connection.go
@@ -44,7 +44,7 @@ func (dc *DatabendConn) exec(ctx context.Context, query string, args ...driver.V
 		return emptyResult, err
 	}
 
-	affectedRows, err := parseAffectedRowsFromQueryResponseData(queryResponse)
+	affectedRows, err := parseAffectedRows(queryResponse)
 	if err != nil {
 		return emptyResult, err
 	}
diff --git a/query.go b/query.go
@@ -124,7 +124,7 @@ type ServerInfo struct {
 	StartTime string `json:"start_time"`
 }
 
-func parseAffectedRowsFromQueryResponseData(queryResp *QueryResponse) (int64, error) {
+func parseAffectedRows(queryResp *QueryResponse) (int64, error) {
 	// the schema can be `number of rows inserted`, `number of rows deleted`, `number of rows updated` when sql start with  `insert`, `delete`, `update`
 	if queryResp.Schema != nil && len(*queryResp.Schema) > 0 && strings.Contains((*queryResp.Schema)[0].Name, "number of rows") {
 		if len(queryResp.Data) > 0 && len(queryResp.Data[0]) > 0 && queryResp.Data[0][0] != nil {

Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ func (dc *DatabendConn) exec(ctx context.Context, query string, args ...driver.V`
`44`	`44`	`return emptyResult, err`
`45`	`45`	`}`
`46`	`46`
`47`		`- affectedRows, err := parseAffectedRowsFromQueryResponseData(queryResponse)`
	`47`	`+ affectedRows, err := parseAffectedRows(queryResponse)`
`48`	`48`	`if err != nil {`
`49`	`49`	`return emptyResult, err`
`50`	`50`	`}`
Original file line number	Diff line number	Diff line change
`@@ -124,7 +124,7 @@ type ServerInfo struct {`
`124`	`124`	StartTime string `json:"start_time"`
`125`	`125`	`}`
`126`	`126`
`127`		`-func parseAffectedRowsFromQueryResponseData(queryResp *QueryResponse) (int64, error) {`
	`127`	`+func parseAffectedRows(queryResp *QueryResponse) (int64, error) {`
`128`	`128`	// the schema can be `number of rows inserted`, `number of rows deleted`, `number of rows updated` when sql start with `insert`, `delete`, `update`
`129`	`129`	`if queryResp.Schema != nil && len(queryResp.Schema) > 0 && strings.Contains((queryResp.Schema)[0].Name, "number of rows") {`
`130`	`130`	`if len(queryResp.Data) > 0 && len(queryResp.Data[0]) > 0 && queryResp.Data[0][0] != nil {`