Работа с SDK

./basic_example_v1 -endpoint endpoint -database database
inspecting Database

> describe_table_options:

> describe table: /global/path/todatabase/series
column, name: Optional<Uint64>, series_id
column, name: Optional<Utf8>, title
column, name: Optional<Utf8>, series_info
column, name: Optional<Uint64>, release_date
column, name: Optional<Utf8>, comment

> select_simple_transaction: 1 IT Crowd 2006-02-03

./mvnw -q exec:java -Dexec.args="<accountId> <keyId> <private_key_file_path> <endpoint> <database>"

result: 42

func (cmd *Command) Run(ctx context.Context, params cli.Parameters) error {
	driver, err := (&ydb.Dialer{
		DriverConfig: cmd.config(params),
	}).Dial(ctx, params.Endpoint)
	if err != nil {
		return fmt.Errorf("dial error: %v", err)
	}

	tableClient := table.Client{
		Driver: driver,
	}
	sp := table.SessionPool{
		IdleThreshold: time.Second,
		Builder:       &tableClient,
	}
	defer sp.Close(ctx)
...

tableClient := table.Client{
		Driver: driver,
}

func createTables(ctx context.Context, sp *table.SessionPool, prefix string) (err error) {
	err = table.Retry(ctx, sp,
		table.OperationFunc(func(ctx context.Context, s *table.Session) error {
			return s.CreateTable(ctx, path.Join(prefix, "series"),
				table.WithColumn("series_id", ydb.Optional(ydb.TypeUint64)),
				table.WithColumn("title", ydb.Optional(ydb.TypeUTF8)),
				table.WithColumn("series_info", ydb.Optional(ydb.TypeUTF8)),
				table.WithColumn("release_date", ydb.Optional(ydb.TypeUint64)),
				table.WithColumn("comment", ydb.Optional(ydb.TypeUTF8)),
				table.WithPrimaryKeyColumn("series_id"),
			)
		}),
	)
...

func describeTable(ctx context.Context, sp *table.SessionPool, path string) (err error) {
	err = table.Retry(ctx, sp,
		table.OperationFunc(func(ctx context.Context, s *table.Session) error {
			desc, err := s.DescribeTable(ctx, path)
			if err != nil {
				return err
			}
			log.Printf("\n> describe table: %s", path)
			for _, c := range desc.Columns {
				log.Printf("column, name: %s, %s", c.Type, c.Name)
			}
			return nil
		}),
	)
...

func selectSimple(ctx context.Context, sp *table.SessionPool, prefix string) (err error) {
	query := render(
		template.Must(template.New("").Parse(`
			PRAGMA TablePathPrefix("{{ .TablePathPrefix }}");
			DECLARE $seriesID AS Uint64;
			$format = DateTime::Format("%Y-%m-%d");
			SELECT
				series_id,
				title,
				$format(DateTime::FromSeconds(CAST(DateTime::ToSeconds(DateTime::IntervalFromDays(CAST(release_date AS Int16))) AS Uint32))) AS release_date
			FROM
				series
			WHERE
				series_id = $seriesID;
		`)),
		templateConfig{
			TablePathPrefix: prefix,
		},
	)
	readTx := table.TxControl(
		table.BeginTx(
			table.WithOnlineReadOnly(),
		),
		table.CommitTx(),
	)
	var res *table.Result
	err = table.Retry(ctx, sp,
		table.OperationFunc(func(ctx context.Context, s *table.Session) (err error) {
			_, res, err = s.Execute(ctx, readTx, query,
				table.NewQueryParameters(
					table.ValueParam("$seriesID", ydb.Uint64Value(1)),
				),
				table.WithQueryCachePolicy(
					table.WithQueryCachePolicyKeepInCache(),
				),
				table.WithCollectStatsModeBasic(),
			)
			return
		}),
	)
...

private void selectSimple() {
    String query = String.format(
        "PRAGMA TablePathPrefix(\"%s\");\n" +
        "$format = DateTime::Format(\"%%Y-%%m-%%d\");\n" +
        "\n" +
        "SELECT\n" +
        "    series_id,\n" +
        "    title,\n" +
        "    $format(DateTime::FromSeconds(CAST(DateTime::ToSeconds(DateTime::IntervalFromDays(CAST(release_date AS Int16))) AS Uint32))) AS release_date\n" +
        "FROM series\n" +
        "WHERE series_id = 1;",
        database);

    // Begin new transaction with SerializableRW mode
    TxControl txControl = TxControl.serializableRw().setCommitTx(true);

    // Executes data query with specified transaction control settings.
    DataQueryResult result = executeWithResult(session -> session.executeDataQuery(query, txControl).join());

    System.out.println("\n--[ SelectSimple ]--");
    // Index of result set corresponds to its order in YQL query
    new TablePrinter(result.getResultSet(0)).print();
}

	var res *table.Result
	...
	for res.NextSet() {
		for res.NextRow() {
			res.SeekItem("series_id")
			id := res.OUint64()

			res.NextItem()
			title := res.OUTF8()

			res.NextItem()
			date := res.OString()

			log.Printf(
				"\n> select_simple_transaction: %d %s %s",
				id, title, date,
			)
		}
	}

DataQueryResult result = executeWithResult(session -> session.executeDataQuery(query, txControl).join());
  
System.out.println("\n--[ SelectSimple ]--");
new TablePrinter(result.getResultSet(0)).print();

private void upsertSimple() {
    String query = String.format(
        "PRAGMA TablePathPrefix(\"%s\");\n" +
        "\n" +
        "UPSERT INTO episodes (series_id, season_id, episode_id, title) VALUES\n" +
        "(2, 6, 1, \"TBD\");",
        database);

    // Begin new transaction with SerializableRW mode
    TxControl txControl = TxControl.serializableRw().setCommitTx(true);

    // Executes data query with specified transaction control settings.
    execute(session -> session.executeDataQuery(query, txControl)
        .join()
        .toStatus());
}

private void preparedSelect(long seriesId, long seasonId, long episodeId) {
    final String queryId = "PreparedSelectTransaction";

    DataQuery query = preparedQueries.get(queryId);
    if (query == null) {
        String queryText = String.format(
            "PRAGMA TablePathPrefix(\"%s\");\n" +
            "\n" +
            "DECLARE $seriesId AS Uint64;\n" +
            "DECLARE $seasonId AS Uint64;\n" +
            "DECLARE $episodeId AS Uint64;\n" +
            "\n" +
            "SELECT *\n" +
            "FROM episodes\n" +
            "WHERE series_id = $seriesId AND season_id = $seasonId AND episode_id = $episodeId;",
            database);

        query = executeWithResult(session -> session.prepareDataQuery(queryText).join());
        System.out.println("Finished preparing query: " + queryId);

        preparedQueries.put(queryId, query);
    }

private Status explicitTcl(Session session) {
    Result<Transaction> transactionResult = session.beginTransaction(TransactionMode.SERIALIZABLE_READ_WRITE)
        .join();
    if (!transactionResult.isSuccess()) {
        return transactionResult.toStatus();
    }

    Transaction transaction = transactionResult.expect("cannot begin transaction");
    String query = String.format(
        "PRAGMA TablePathPrefix(\"%s\");\n" +
        "DECLARE $airDate AS Uint64;\n" +
        "UPDATE episodes SET air_date = $airDate WHERE title = \"TBD\";",
        database);

    Params params = Params.of("$airDate", uint64(Duration.between(Instant.EPOCH, Instant.now()).toDays()));

    Result<DataQueryResult> updateResult = session.executeDataQuery(query, TxControl.id(transaction), params)
        .join();
    if (!updateResult.isSuccess()) {
        return updateResult.toStatus();
    }

    return transaction.commit().join();
}