23.3 integration tests

Author: asmyasnikov

.github/workflows/tests.yml

@@ -45,7 +45,7 @@ jobs:
       fail-fast: false
       matrix:
         go-version: [1.17.x, 1.20.x, 1.21.x]
-        ydb-version: [22.5, 23.1, 23.2, 23.2-slim]
+        ydb-version: [22.5, 23.1, 23.2, 23.3]
     services:
       ydb:
         image: cr.yandex/yc/yandex-docker-local-ydb:${{ matrix.ydb-version }}

tests/integration/kv_test.go

@@ -40,7 +40,10 @@ func TestKeyValue(t *testing.T) {
 
 	// get
 	err = driver.Table().Do(scope.Ctx, func(ctx context.Context, s table.Session) error {
-		rows, err := s.ReadRows(ctx, tablePath, types.ListValue(types.Int64Value(id)),
+		rows, err := s.ReadRows(ctx, tablePath,
+			types.ListValue(types.StructValue(
+				types.StructFieldValue("id", types.Int64Value(id)),
+			)),
 			options.ReadColumn("val"),
 		)
 		if err != nil {
@@ -49,10 +52,10 @@ func TestKeyValue(t *testing.T) {
 		defer func() {
 			_ = rows.Close()
 		}()
-		if !rows.HasNextResultSet() {
+		if !rows.NextResultSet(ctx) {
 			return fmt.Errorf("no result sets")
 		}
-		if !rows.HasNextRow() {
+		if !rows.NextRow() {
 			return fmt.Errorf("no rows")
 		}
 		if rows.CurrentResultSet().RowCount() != 1 {
@@ -61,10 +64,11 @@ func TestKeyValue(t *testing.T) {
 		if rows.CurrentResultSet().ColumnCount() != 1 {
 			return fmt.Errorf("wrong column count (%d)", rows.CurrentResultSet().ColumnCount())
 		}
-		var actualValue int64
-		if err := rows.ScanNamed(named.Optional("val", &actualValue)); err != nil {
+		var actualValue string
+		if err := rows.ScanNamed(named.OptionalWithDefault("val", &actualValue)); err != nil {
 			return err
 		}
+		t.Logf("%s[%d] = %q", tablePath, id, actualValue)
 		return rows.Err()
 	})
 	scope.Require.NoError(err)