added examples for helper methods and fixed some review edits

Author: LostImagin4tion

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

@@ -1,4 +1,4 @@
 
 .PHONY: run
 run:
-	go run main.go
+	go run main.go

dev-1/go/lesson-2.1/Makefile renamed to dev-1/lesson-2.1/go/Makefile

@@ -0,0 +1,137 @@
+package main
+
+import (
+	"context"
+	"log"
+	"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)
+	defer cancel()
+
+	// Строка подключения к локальной базе данных YDB
+	// Формат: grpc[s]://<хост>:<порт>/<путь к базе данных>
+	dsn := "grpc://localhost:2136/local"
+
+	// Создаем драйвер для подключения к YDB через gRPC
+	db, err := ydb.Open(ctx, dsn)
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer db.Close(ctx)
+
+	type myStruct struct {
+		Id int32 `sql:"id"`
+	}
+	var structId myStruct
+
+	queryCtx, txCancel := context.WithTimeout(context.Background(), 30*time.Second)
+	defer txCancel()
+
+	// Ниже представлены примеры по обращению к клиенту для выполнения YQL запросов
+	// 
+	// Query(), QueryResultSet() и QueryRow() являются хелперами для неинтерактивных транзакций
+	// (т.е. когда транзакция завершается за одно обращение к серверу)
+	// Ретраи тут происходят внутри, а наружу возвращается уже материализированный в памяти в результат,
+	// Таймаутом транзакции можно управлять через контекст
+
+	result, err := db.Query().Query(queryCtx, "SELECT 1 as id");
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	rs, err := result.NextResultSet(queryCtx)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	row, err := rs.NextRow(ctx)
+	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");
+	if err != nil {
+		log.Fatal(err)
+	}
+	
+	row, err = rs.NextRow(ctx)
+	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");
+	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)
+}