fix: try query command without reading rows

adrienaury · adrienaury · commit 186b108ba62f · 2024-06-04T09:56:00.000+02:00
diff --git a/internal/infra/query/sql.go b/internal/infra/query/sql.go
@@ -88,14 +88,16 @@ func (ds *DataSource) Close() error {
 }
 
 func (ds *DataSource) Query(query string) (query.DataReader, error) {
-	rows, err := ds.dbx.Queryx(query)
+	result, err := ds.dbx.Exec(query)
 	if err != nil {
 		return nil, fmt.Errorf("%w", err)
 	}
 
-	log.Info().Str("query", query).Msg("success executing SQL query")
+	if nbrows, err := result.RowsAffected(); err != nil {
+		log.Info().Str("query", query).Int64("rows", nbrows).Msg("success executing SQL query")
+	}
 
-	return &DataReader{rows, nil, nil}, nil
+	return nil, nil
 }
 
 type DataSourceFactory struct{}

Original file line number	Diff line number	Diff line change
`@@ -88,14 +88,16 @@ func (ds *DataSource) Close() error {`
`88`	`88`	`}`
`89`	`89`
`90`	`90`	`func (ds *DataSource) Query(query string) (query.DataReader, error) {`
`91`		`- rows, err := ds.dbx.Queryx(query)`
	`91`	`+ result, err := ds.dbx.Exec(query)`
`92`	`92`	`if err != nil {`
`93`	`93`	`return nil, fmt.Errorf("%w", err)`
`94`	`94`	`}`
`95`	`95`
`96`		`- log.Info().Str("query", query).Msg("success executing SQL query")`
	`96`	`+ if nbrows, err := result.RowsAffected(); err != nil {`
	`97`	`+ log.Info().Str("query", query).Int64("rows", nbrows).Msg("success executing SQL query")`
	`98`	`+ }`
`97`	`99`
`98`		`- return &DataReader{rows, nil, nil}, nil`
	`100`	`+ return nil, nil`
`99`	`101`	`}`
`100`	`102`
`101`	`103`	`type DataSourceFactory struct{}`