Инициализация драйвера
Примечание
Материал статьи дополняется.
Для подключения к YDB требуется указать обязательные параметры (подробнее читайте в разделе Подключение к серверу YDB) и дополнительные, которые определяют поведение драйвера при работе.
Ниже приведены примеры кода подлкючения к YDB (создания драйвера) в разных YDB SDK.
Go (native)
Go (database/sql)
Java
Python
Python (asyncio)
C# (.NET)
PHP
package main
import (
"context"
"github.com/ydb-platform/ydb-go-sdk/v3"
)
func main() {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
db, err := ydb.Open(ctx, "grpc://localhost:2136/local")
if err != nil {
panic(err)
}
defer db.Close()
// ...
}
С помощью коннектора (рекомендуемый способ)
package main
import (
"context"
"database/sql"
"os"
"github.com/ydb-platform/ydb-go-sdk/v3"
)
func main() {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
nativeDriver, err := ydb.Open(ctx,
os.Getenv("YDB_CONNECTION_STRING"),
)
if err != nil {
panic(err)
}
defer nativeDriver.Close(ctx)
connector, err := ydb.Connector(nativeDriver)
if err != nil {
panic(err)
}
defer connector.Close()
db := sql.OpenDB(connector)
defer db.Close()
// ...
}
С помощью строки подключения
Регистрация драйвера database/sql
реализуется в момент импорта пакета конкретного драйвера через символ подчеркивавния:
package main
import (
"database/sql"
_ "github.com/ydb-platform/ydb-go-sdk/v3"
)
func main() {
db, err := sql.Open("ydb", "grpc://localhost:2136/local")
if err != nil {
panic(err)
}
defer db.Close()
// ...
}
Примечание
Материал статьи дополняется.
import ydb
with ydb.Driver(connection_string="grpc://localhost:2136?database=/local") as driver:
driver.wait(timeout=5)
...
import ydb
import asyncio
async def ydb_init():
async with ydb.aio.Driver(endpoint="grpc://localhost:2136", database="/local") as driver:
await driver.wait()
...
asyncio.run(ydb_init())
using Ydb.Sdk;
var config = new DriverConfig(
endpoint: "grpc://localhost:2136",
database: "/local"
);
await using var driver = await Driver.CreateInitialized(config);
<?php
use YdbPlatform\Ydb\Ydb;
$config = [
// Database path
'database' => '/ru-central1/b1glxxxxxxxxxxxxxxxx/etn0xxxxxxxxxxxxxxxx',
// Database endpoint
'endpoint' => 'ydb.serverless.yandexcloud.net:2135',
// Auto discovery (dedicated server only)
'discovery' => false,
// IAM config
'iam_config' => [
// 'root_cert_file' => './CA.pem', // Root CA file (uncomment for dedicated server)
],
'credentials' => new \YdbPlatform\Ydb\Auth\Implement\AccessTokenAuthentication('AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA') // use from reference/ydb-sdk/auth
];
$ydb = new Ydb($config);