removed Do example

Author: LostImagin4tion

dev-1/lesson-2.1/go/main.go

@@ -6,24 +6,23 @@ import (
 	"time"
 
 	"github.com/ydb-platform/ydb-go-sdk/v3"
-	"github.com/ydb-platform/ydb-go-sdk/v3/query"
 )
 
 // author: Egor Danilov
 func main() {
-	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+	connectionCtx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
 	defer cancel()
 
 	// Строка подключения к локальной базе данных YDB
 	// Формат: grpc[s]://<хост>:<порт>/<путь к базе данных>
 	dsn := "grpc://localhost:2136/local"
 
 	// Создаем драйвер для подключения к YDB через gRPC
-	db, err := ydb.Open(ctx, dsn)
+	db, err := ydb.Open(connectionCtx, dsn)
 	if err != nil {
 		log.Fatal(err)
 	}
-	defer db.Close(ctx)
+	defer db.Close(connectionCtx)
 
 	type myStruct struct {
 		Id int32 `sql:"id"`
@@ -34,13 +33,13 @@ func main() {
 	defer txCancel()
 
 	// Ниже представлены примеры по обращению к клиенту для выполнения YQL запросов
-	// 
+	//
 	// Query(), QueryResultSet() и QueryRow() являются хелперами для неинтерактивных транзакций
 	// (т.е. когда транзакция завершается за одно обращение к серверу)
 	// Ретраи тут происходят внутри, а наружу возвращается уже материализированный в памяти в результат,
 	// Таймаутом транзакции можно управлять через контекст
 
-	result, err := db.Query().Query(queryCtx, "SELECT 1 as id");
+	result, err := db.Query().Query(queryCtx, "SELECT 1 as id")
 	if err != nil {
 		log.Fatal(err)
 	}
@@ -50,88 +49,45 @@ func main() {
 		log.Fatal(err)
 	}
 
-	row, err := rs.NextRow(ctx)
+	row, err := rs.NextRow(connectionCtx)
 	if err != nil {
 		log.Fatal(err)
 	}
 
-	// Материализуем результат
+	// Читаем результат
 	if err = row.ScanStruct(&structId); err != nil {
 		log.Fatal(err)
 	}
 	println(structId.Id)
 
 	// ======
-	rs, err = db.Query().QueryResultSet(queryCtx, "SELECT 2 as id");
+	
+	rs, err = db.Query().QueryResultSet(queryCtx, "SELECT 2 as id")
 	if err != nil {
 		log.Fatal(err)
 	}
-	
-	row, err = rs.NextRow(ctx)
+
+	row, err = rs.NextRow(connectionCtx)
 	if err != nil {
 		log.Fatal(err)
 	}
 
-	// Материализуем результат
+	// Читаем результат
 	if err = row.ScanStruct(&structId); err != nil {
 		log.Fatal(err)
 	}
 	println(structId.Id)
 
 	// ======
 
-	row, err = db.Query().QueryRow(queryCtx, "SELECT 3 as id");
+	row, err = db.Query().QueryRow(queryCtx, "SELECT 3 as id")
 	if err != nil {
 		log.Fatal(err)
 	}
 
-	// Материализуем результат
+	// Читаем результат
 	if err = row.ScanStruct(&structId); err != nil {
 		log.Fatal(err)
 	}
 	println(structId.Id)
-
-	// ======
-
-	// Ниже представлен пример общего случая выполнения YQL запросов через метод Do
-	// По типу ошибки, которую вернет лямбда op Operation, драйвер поймет, надо ретраить запрос или нет
-	// За счет этого можно более гранулярно управлять ходом выполнения запроса и материализацией данных
-	err = db.Query().Do(
-		queryCtx,
-		func(ctx context.Context, s query.Session) error {
-			res, err := s.Query(ctx, "SELECT 4 as id;")
-
-			if err != nil {
-				return err
-			}
-
-			defer func() { _ = res.Close(ctx) }()
-
-			// Итерируемся по набору результатов
-			for rs, err := range res.ResultSets(ctx) {
-				if err != nil {
-					return err
-				}
-
-				// Итерируемся по строкам в каждом наборе результате
-				for row, err := range rs.Rows(ctx) {
-					if err != nil {
-						return err
-					}
-
-					// Материализуем результат
-					if err = row.ScanStruct(&structId); err != nil {
-						return err
-					}
-				}
-			}
-			return nil
-		},
-		query.WithIdempotent(),
-	)
-	if err != nil {
-		log.Fatal(err)
-	}
-
-	println(structId.Id)
 }