lazy transaction example

Author: asmyasnikov

CHANGELOG.md

@@ -1,3 +1,5 @@
+* Fixed lazy transaction example for `godoc`
+
 ## v3.42.0
 * Added retry policy options for topics: `topic/topicoptions.WithReaderCheckRetryErrorFunction`, `topic/topicoptions.WithReaderStartTimeout`, `topic/topicoptions.WithWriterCheckRetryErrorFunction`, `topic/topicoptions.WithWriterStartTimeout`
 * Refactored `internal/conn` middlewares

table/example_test.go

@@ -3,6 +3,7 @@ package table_test
 import (
 	"context"
 	"fmt"
+	"github.com/ydb-platform/ydb-go-sdk/v3/retry"
 	"path"
 	"time"
 
@@ -200,41 +201,44 @@ func Example_lazyTransaction() {
 				),
 			)
 			if err != nil {
-				panic(err)
+				return err
 			}
 			defer tx.Rollback(ctx)
 			defer result.Close()
-			if result.NextResultSet(ctx) {
-				if result.NextRow() {
-					var (
-						id          uint64
-						title       string
-						description string
-					)
-					if err = result.ScanNamed(
-						named.OptionalWithDefault("id", &id),
-						named.OptionalWithDefault("title", &title),
-						named.OptionalWithDefault("description", &description),
-					); err != nil {
-						panic(err)
-					}
-					fmt.Println(id, title, description)
-					_, err = tx.Execute(ctx,
-						"DECLARE $id AS Uint64; "+
-							"DECLARE $description AS Text; "+
-							"UPSERT INTO `path/to/mytable` "+
-							"(id, description) "+
-							"VALUES ($id, $description);",
-						table.NewQueryParameters(
-							table.ValueParam("$id", types.Uint64Value(1)),
-							table.ValueParam("$description", types.TextValue("changed description")),
-						),
-						options.WithCommit(),
-					)
-					if err != nil {
-						return err
-					}
-				}
+			if !result.NextResultSet(ctx) {
+				return retry.RetryableError(fmt.Errorf("no result sets"))
+			}
+			if !result.NextRow() {
+				return retry.RetryableError(fmt.Errorf("no rows"))
+			}
+			var (
+				id          uint64
+				title       string
+				description string
+			)
+			if err = result.ScanNamed(
+				named.OptionalWithDefault("id", &id),
+				named.OptionalWithDefault("title", &title),
+				named.OptionalWithDefault("description", &description),
+			); err != nil {
+				return err
+			}
+			fmt.Println(id, title, description)
+			// execute query with commit transaction
+			_, err = tx.Execute(ctx,
+				"DECLARE $id AS Uint64; "+
+					"DECLARE $description AS Text; "+
+					"UPSERT INTO `path/to/mytable` "+
+					"(id, description) "+
+					"VALUES ($id, $description);",
+				table.NewQueryParameters(
+					table.ValueParam("$id", types.Uint64Value(1)),
+					table.ValueParam("$description", types.TextValue("changed description")),
+				),
+				options.WithCommit(),
+			)
+			if err != nil {
+				return err
 			}
 			return result.Err()
 		},