canonization of current uuid behavior

tests/integration/query_regression_test.go

@@ -0,0 +1,127 @@
+//go:build integration
+// +build integration
+
+package integration
+
+import (
+	"testing"
+
+	"github.com/google/uuid"
+	"github.com/stretchr/testify/require"
+
+	"github.com/ydb-platform/ydb-go-sdk/v3"
+	"github.com/ydb-platform/ydb-go-sdk/v3/query"
+)
+
+func TestUUIDSerialization(t *testing.T) {
+	// test with special uuid - all bytes are different for check any byte swaps
+
+	t.Run("old-send", func(t *testing.T) {
+		// test old behavior - for test way of safe work with data, written with bagged API version
+		var (
+			scope = newScope(t)
+			ctx   = scope.Ctx
+			db    = scope.Driver()
+		)
+
+		idString := "6E73B41C-4EDE-4D08-9CFB-B7462D9E498B"
+		expectedResultWithBug := "2d9e498b-b746-9cfb-084d-de4e1cb4736e"
+		id := uuid.MustParse(idString)
+		row, err := db.Query().QueryRow(ctx, `
+DECLARE $val AS UUID;
+
+SELECT CAST($val AS Utf8)`,
+			query.WithIdempotent(),
+			query.WithParameters(ydb.ParamsBuilder().Param("$val").UUID(id).Build()),
+		)
+
+		require.NoError(t, err)
+
+		var res string
+
+		err = row.Scan(&res)
+		require.NoError(t, err)
+		require.Equal(t, expectedResultWithBug, res)
+	})
+	t.Run("old-receive-to-bytes", func(t *testing.T) {
+		// test old behavior - for test way of safe work with data, written with bagged API version
+		var (
+			scope = newScope(t)
+			ctx   = scope.Ctx
+			db    = scope.Driver()
+		)
+
+		idString := "6E73B41C-4EDE-4D08-9CFB-B7462D9E498B"
+		expectedResultWithBug := "8b499e2d-46b7-fb9c-4d08-4ede6e73b41c"
+		row, err := db.Query().QueryRow(ctx, `
+DECLARE $val AS Text;
+
+SELECT CAST($val AS UUID)`,
+			query.WithIdempotent(),
+			query.WithParameters(ydb.ParamsBuilder().Param("$val").Text(idString).Build()),
+		)
+
+		require.NoError(t, err)
+
+		var res [16]byte
+
+		err = row.Scan(&res)
+		require.NoError(t, err)
+
+		resUUID := uuid.UUID(res)
+		require.Equal(t, expectedResultWithBug, resUUID.String())
+	})
+	t.Run("old-receive-to-string", func(t *testing.T) {
+		// test old behavior - for test way of safe work with data, written with bagged API version
+		var (
+			scope = newScope(t)
+			ctx   = scope.Ctx
+			db    = scope.Driver()
+		)
+
+		idString := "6E73B41C-4EDE-4D08-9CFB-B7462D9E498B"
+		expectedResultWithBug := []byte{0x8b, 0x49, 0x9e, 0x2d, 0x46, 0xb7, 0xfb, 0x9c, 0x4d, 0x8, 0x4e, 0xde, 0x6e, 0x73, 0xb4, 0x1c}
+		row, err := db.Query().QueryRow(ctx, `
+SELECT CAST($val AS UUID)`,
+			query.WithIdempotent(),
+			query.WithParameters(ydb.ParamsBuilder().Param("$val").Text(idString).Build()),
+		)
+
+		require.NoError(t, err)
+
+		var res string
+
+		err = row.Scan(&res)
+		require.NoError(t, err)
+
+		require.Equal(t, expectedResultWithBug, []byte(res))
+	})
+	t.Run("send-receive", func(t *testing.T) {
+		// test old behavior - for test way of safe work with data, written with bagged API version
+		var (
+			scope = newScope(t)
+			ctx   = scope.Ctx
+			db    = scope.Driver()
+		)
+
+		idString := "6E73B41C-4EDE-4D08-9CFB-B7462D9E498B"
+		id := uuid.MustParse(idString)
+		row, err := db.Query().QueryRow(ctx, `
+DECLARE $val AS UUID;
+
+SELECT $val`,
+			query.WithIdempotent(),
+			query.WithParameters(ydb.ParamsBuilder().Param("$val").UUID(id).Build()),
+		)
+
+		require.NoError(t, err)
+
+		var resBytes [16]byte
+		err = row.Scan(&resBytes)
+		require.NoError(t, err)
+
+		resUUID := uuid.UUID(resBytes)
+
+		require.Equal(t, id, resUUID)
+	})
+}