added YDB_DATABASE_SQL_OVER_QUERY_SERVICE env for run database/sql ov…

…er query-service + fix rows.Scan

internal/connector/connector.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"database/sql/driver"
 	"io"
+	"os"
 	"time"
 
 	"github.com/google/uuid"
@@ -184,9 +185,15 @@ func (c *Connector) Close() error {
 
 func Open(parent ydbDriver, balancer grpc.ClientConnInterface, opts ...Option) (_ *Connector, err error) {
 	c := &Connector{
-		parent:         parent,
-		balancer:       balancer,
-		queryProcessor: TABLE_SERVICE,
+		parent:   parent,
+		balancer: balancer,
+		queryProcessor: func() queryProcessor {
+			if v, has := os.LookupEnv("YDB_DATABASE_SQL_OVER_QUERY_SERVICE"); has && v != "" {
+				return QUERY_SERVICE
+			}
+
+			return TABLE_SERVICE
+		}(),
 		clock:          clockwork.NewRealClock(),
 		done:           make(chan struct{}),
 		trace:          &trace.DatabaseSQL{},

internal/query/conn/rows.go

@@ -5,6 +5,7 @@ import (
 	"database/sql"
 	"database/sql/driver"
 	"errors"
+	"github.com/ydb-platform/ydb-go-sdk/v3/internal/xslices"
 	"io"
 	"sync"
 
@@ -100,7 +101,9 @@ func (r *rows) Next(dst []driver.Value) error {
 		return badconn.Map(xerrors.WithStackTrace(err))
 	}
 
-	if err = nextRow.Scan(dst); err != nil {
+	if err = nextRow.Scan(xslices.Transform(dst, func(v driver.Value) any {
+		return &v
+	})...); err != nil {
 		return badconn.Map(xerrors.WithStackTrace(err))
 	}