added test for wrong query

Author: asmyasnikov

internal/xerrors/join.go

@@ -7,7 +7,7 @@ import (
 )
 
 func Join(errs ...error) joinError {
-	return joinError(errs)
+	return errs
 }
 
 type joinError []error

tests/integration/table_scan_error_test.go

@@ -10,7 +10,6 @@ import (
 	"testing"
 
 	"github.com/stretchr/testify/require"
-	"golang.org/x/xerrors"
 
 	"github.com/ydb-platform/ydb-go-sdk/v3"
 	"github.com/ydb-platform/ydb-go-sdk/v3/table"
@@ -54,15 +53,31 @@ func TestIssue415ScanError(t *testing.T) {
 		return res.Err()
 	}, table.WithTxSettings(table.TxSettings(table.WithSnapshotReadOnly())))
 	require.Error(t, err)
-	err = func(err error) error {
-		for {
-			//nolint:errorlint
-			if unwrappedErr, has := err.(xerrors.Wrapper); has {
-				err = unwrappedErr.Unwrap()
-			} else {
-				return err
-			}
-		}
-	}(err)
 	require.ErrorContains(t, err, "not found column 'ghi'")
 }
+
+// https://github.com/ydb-platform/ydb-go-sdk/issues/847
+func TestIssue847ScanError(t *testing.T) {
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+
+	db, err := ydb.Open(ctx,
+		os.Getenv("YDB_CONNECTION_STRING"),
+		ydb.WithAccessTokenCredentials(os.Getenv("YDB_ACCESS_TOKEN_CREDENTIALS")),
+	)
+	require.NoError(t, err)
+	err = db.Table().Do(ctx, func(ctx context.Context, s table.Session) (err error) {
+		res, err := s.StreamExecuteScanQuery(ctx, `SELICT 1;`, nil)
+		if err != nil {
+			return err
+		}
+		err = res.NextResultSetErr(ctx)
+		if err != nil {
+			return err
+		}
+		return res.Err()
+	}, table.WithTxSettings(table.TxSettings(table.WithSnapshotReadOnly())))
+	require.Error(t, err)
+	t.Log(err)
+	require.ErrorContains(t, err, "Unexpected token 'SELICT'")
+}