本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

使用 .NET 連接器連接到 Aurora DSQL 叢集

Amazon Aurora DSQL Connector for .NET 是建置在 Npgsql 上的 .NET 連接器，整合 IAM 身分驗證以將 .NET 應用程式連線至 Amazon Aurora DSQL 叢集。

連接器會處理字符產生、SSL 組態和連線集區，讓您可以專注於應用程式邏輯。

關於連接器

Amazon Aurora DSQL 需要使用現有 .NET PostgreSQL 驅動程式原生不支援的時間限制權杖進行 IAM 身分驗證。Aurora DSQL Connector for .NET 在處理產生 IAM 字符的 Npgsql 上新增了身分驗證層，可讓您連線到 Aurora DSQL，而無需變更現有的 Npgsql 工作流程。

什麼是 Aurora DSQL 身分驗證？

在 Aurora DSQL 中，身分驗證涉及：

Aurora DSQL Connector for .NET 了解這些需求，並在建立連線時自動產生 IAM 身分驗證字符。

功能

範例應用程式

如需完整範例，請參閱 GitHub 上的範例應用程式。

快速入門指南

要求

安裝

將套件新增至您的專案：

dotnet add package Amazon.AuroraDsql.Npgsql

Usage

集區連線

using Amazon.AuroraDsql.Npgsql;

// Create a connection pool
await using var ds = await AuroraDsql.CreateDataSourceAsync(new DsqlConfig
{
    Host = "your-cluster.dsql.us-east-1.on.aws",
    OccMaxRetries = 3
});

// Read
await using (var conn = await ds.OpenConnectionAsync())
{
    await using var cmd = conn.CreateCommand();
    cmd.CommandText = "SELECT 'Hello, DSQL!'";
    var greeting = await cmd.ExecuteScalarAsync();
    Console.WriteLine(greeting);
}

// Transactional write with OCC retry
await ds.WithTransactionRetryAsync(async conn =>
{
    await using var cmd = conn.CreateCommand();
    cmd.CommandText = "INSERT INTO users (id, name) VALUES (gen_random_uuid(), @name)";
    cmd.Parameters.AddWithValue("name", "Alice");
    await cmd.ExecuteNonQueryAsync();
});

單一連接

對於簡單的指令碼或當您不需要連線集區時：

await using var conn = await AuroraDsql.ConnectAsync(new DsqlConfig
{
    Host = "your-cluster.dsql.us-east-1.on.aws"
});

await using var cmd = conn.CreateCommand("SELECT 1");
await cmd.ExecuteScalarAsync();

OCC 重試

Aurora DSQL 使用樂觀並行控制 (OCC)。當兩個交易修改相同的資料時，第一個遞交獲勝，第二個收到 OCC 錯誤。

OCC 重試是選擇加入。在組態OccMaxRetries中設定 ，以啟用具有指數退避和抖動的自動重試。WithTransactionRetryAsync 用於交易寫入：

await ds.WithTransactionRetryAsync(async conn =>
{
    await using var cmd = conn.CreateCommand();

    cmd.CommandText = "UPDATE accounts SET balance = balance - 100 WHERE id = @from";
    cmd.Parameters.AddWithValue("from", fromId);
    await cmd.ExecuteNonQueryAsync();

    cmd.CommandText = "UPDATE accounts SET balance = balance + 100 WHERE id = @to";
    cmd.Parameters.Clear();
    cmd.Parameters.AddWithValue("to", toId);
    await cmd.ExecuteNonQueryAsync();
});

對於 DDL 或單一陳述式，請使用 ExecWithRetryAsync：

await ds.ExecWithRetryAsync("CREATE TABLE IF NOT EXISTS users (id UUID PRIMARY KEY, name TEXT)");

組態選項

連接器也接受具有 postgres://和 profile查詢參數的 region和 postgresql://連線字串。

身分驗證

連接器會使用 AWS 登入資料產生字符，自動處理 Aurora DSQL 身分驗證。如果您未提供區域，連接器會從主機名稱剖析該 AWS 區域。

如需 Aurora DSQL 中身分驗證的詳細資訊，請參閱 Aurora DSQL 的身分驗證和授權。

管理員與一般使用者