必要條件步驟 1：設定您的專案步驟 2：初始化驅動程式第 3 步：創建一個表和索引步驟 4：插入文件步驟 5：查詢文件步驟 6：更新文件執行完整的應用程式

Amazon QLDB 驅動程序. NET— 快速入門教程

重要

支援結束通知：現有客戶將能夠使用 Amazon，QLDB直到 2025 年 7 月 31 日終止支援為止。有關更多詳細信息，請參閱將 Amazon QLDB 分類帳遷移到 Amazon Aurora 郵政. SQL

在本教學中，您將學習如何使用的 Amazon QLDB 驅動程式設定簡單的應用程式。 NET。本指南包含安裝驅動程式的步驟，以及基本建立、讀取、更新和刪除 (CRUD) 操作的簡短程式碼範例。

必要條件

在開始之前，請確保您執行以下操作：

完成必要條件的. NET司機，如果你還沒有這樣做。這包括註冊 AWS、授與程式設計存取以供開發，以及安裝. NET核心SDK。
建立名為的分類帳quick-start。

若要瞭解如何建立分類帳，請參閱Amazon QLDB 分類帳的基本操作或步驟 1：建立新分類帳在「開始使用主控台」中的。

步驟 1：設定您的專案

首先，設定您的. NET項目。

若要建立並執行範本應用程式，請在終端機上輸入下列命dotnet令，例如 bash PowerShell、或命令提示字元。
```
$ dotnet new console --output Amazon.QLDB.QuickStartGuide
$ dotnet run --project Amazon.QLDB.QuickStartGuide
```
此範本會建立名為的資料夾Amazon.QLDB.QuickStartGuide。在該文件夾中，它創建一個具有相同名稱的項目和一個名為的文件Program.cs。該程序包含顯示輸出的代碼Hello World!。
使用 NuGet 套件管理員安裝的QLDB驅動程式。 NET。我們建議您使用 Visual Studio 或您選擇IDE的項目添加依賴關係。驅動程序包名稱是 Amazon。 QLDB. 驅動程式。
- 例如，在 Visual Studio 中，開啟 [工具] 功能表上的 [P NuGet ackage 管理員主控台]。然後，在提示符下輸入以下命PM>令。
```
PM> Install-Package Amazon.QLDB.Driver
```
- 或者，您可以在終端機上輸入以下命令。
```
$ cd Amazon.QLDB.QuickStartGuide
$ dotnet add package Amazon.QLDB.Driver
```
安裝驅動程序還會安裝其依賴項，包括AWS SDK for .NET和 Amazon Ion 庫。

安裝驅動程式的序列化程式庫。


PM> Install-Package Amazon.QLDB.Driver.Serialization

開啟 Program.cs 檔案。

然後，在以下步驟中逐步添加代碼示例以嘗試一些基本CRUD操作。或者，您可以略過 step-by-step 教學課程，而是執行完整的應用程式。

注意

在同步和非同步之間進行選擇 APIs — 驅動程式提供同步和非同步APIs。對於在不阻塞的情況下處理多個請求的高需求應用程序，我們建議使用非同步來APIs提高性能。該驅動程序提供了APIs同步編寫的現有代碼庫的附加便利性。

本教學課程包含同步和非同步程式碼範例。如需有關的詳細資訊APIs，請參閱API文件中的IQldbDriver和IAsyncQldbDriver介面。
處理 Amazon Ion 資料 — 本教學提供預設使用 Ion 物件對應程式處理 Amazon Ion 資料的程式碼範例。QLDB在版本 1.3.0 中引入了離子對象映射器。 NET驅動程序。在適用的情況下，本教程還提供了使用標準 Ion 庫作為替代方案的代碼示例。如需進一步了解，請參閱與 Amazon 離子工作。

步驟 2：初始化驅動程式

初始化連線至名為之分類帳之驅動程式的執行個體quick-start。將以下代碼添加到您的Program.cs文件中。

第 3 步：創建一個表和索引

對於本教學課程透過步驟 6 的其餘部分，您需要將下列程式碼範例附加至上一個程式碼範例。

在這個步驟中，下面的代碼演示了如何運行CREATE TABLE和CREATE INDEX語句。它創建一個名為表Person和該表上的firstName字段的索引。需要索引來優化查詢性能並有助於限制樂觀的並發控制（OCC）衝突異常。

步驟 4：插入文件

下列程式碼範例會示範如何執行INSERT陳述式。QLDB支援 P artiQL 查詢語言 (SQL相容) 和 Amazon 離子資料格式 (的JSON超集)。

添加以下插入文檔到Person表中的代碼。

提示

若要使用單一INSERT陳述式插入多個文件，您可以將 Ion 清單型別參數傳遞至陳述式，如下所示。


// people is an Ion list
txn.Execute("INSERT INTO Person ?", people);

傳遞離子清單時，您不會將變數預留位置 (?<<...>>) 括在雙尖括號 () 中。在手動 PartiQL 陳述式中，雙角括號表示稱為袋子的無序集合。

步驟 5：查詢文件

下列程式碼範例會示範如何執行SELECT陳述式。

添加以下代碼查詢從Person表中的文檔。

此範例使用問號 (?) 做為變數預留位置，將文件資訊傳遞至陳述式。當您使用預留位置時，您必須傳遞 type IonValue 的值。

步驟 6：更新文件

下列程式碼範例會示範如何執行UPDATE陳述式。

添加以下代碼，通過更新age到 42 更新Person表中的文檔。

再次查詢文件以查看更新的值。

若要執行應用程式，請從Amazon.QLDB.QuickStartGuide專案目錄的父目錄中輸入下列指令。
```
$ dotnet run --project Amazon.QLDB.QuickStartGuide
```

添加以下代碼，通過更新age到 42 更新Person表中的文檔。

再次查詢文件以查看更新的值。

若要執行應用程式，請從Amazon.QLDB.QuickStartGuide專案目錄的父目錄中輸入下列指令。
```
$ dotnet run --project Amazon.QLDB.QuickStartGuide
```

執行完整的應用程式

下列程式碼範例是應Program.cs用程式的完整版本。您也可以從頭到尾複製並執行此程式碼範例，而不是個別執行前述步驟。此應用程序演示了名為的分類帳上的一些基本CRUD操作quick-start。

注意

在執行此程式碼之前，請確定您尚未在quick-start分類帳Person中命名為使用中的資料表。

Async


using Amazon.QLDB.Driver;
using Amazon.QLDB.Driver.Generic;
using Amazon.QLDB.Driver.Serialization;

namespace Amazon.QLDB.QuickStartGuide
{
    class Program
    {
        public class Person
        {
            public string FirstName { get; set; }

            public string LastName { get; set; }

            public int Age { get; set; }

            public override string ToString()
            {
                return FirstName + ", " + LastName + ", " + Age.ToString();
            }
        }

        static async Task Main(string[] args)
        {
            Console.WriteLine("Create the async QLDB driver");
            IAsyncQldbDriver driver = AsyncQldbDriver.Builder()
                .WithLedger("quick-start")
                .WithSerializer(new ObjectSerializer())
                .Build();

            Console.WriteLine("Creating the table and index");

            // Creates the table and the index in the same transaction.
            // Note: Any code within the lambda can potentially execute multiple times due to retries.
            // For more information, see: https://docs.aws.amazon.com/qldb/latest/developerguide/driver-retry-policy
            await driver.Execute(async txn =>
            {
                await txn.Execute("CREATE TABLE Person");
                await txn.Execute("CREATE INDEX ON Person(firstName)");
            });

            Console.WriteLine("Inserting a document");

            Person myPerson = new Person {
                FirstName = "John",
                LastName = "Doe",
                Age = 32
            };

            await driver.Execute(async txn =>
            {
                IQuery<Person> myQuery = txn.Query<Person>("INSERT INTO Person ?", myPerson);
                await txn.Execute(myQuery);
            });

            Console.WriteLine("Querying the table");

            // The result from driver.Execute() is buffered into memory because once the
            // transaction is committed, streaming the result is no longer possible.
            IAsyncResult<Person> selectResult = await driver.Execute(async txn =>
            {
                IQuery<Person> myQuery = txn.Query<Person>("SELECT * FROM Person WHERE FirstName = ?", "John");
                return await txn.Execute(myQuery);
            });

            await foreach (Person person in selectResult)
            {
                Console.WriteLine(person);
                // John, Doe, 32
            }

            Console.WriteLine("Updating the document");

            await driver.Execute(async txn =>
            {
                IQuery<Person> myQuery = txn.Query<Person>("UPDATE Person SET Age = ? WHERE FirstName = ?", 42, "John");
                await txn.Execute(myQuery);
            });

            Console.WriteLine("Querying the table for the updated document");

            IAsyncResult<Person> updateResult = await driver.Execute(async txn =>
            {
                IQuery<Person> myQuery = txn.Query<Person>("SELECT * FROM Person WHERE FirstName = ?", "John");
                return await txn.Execute(myQuery);
            });

            await foreach (Person person in updateResult)
            {
                Console.WriteLine(person);
                // John, Doe, 42
            }
        }
    }
}

Sync


using Amazon.QLDB.Driver;
using Amazon.QLDB.Driver.Generic;
using Amazon.QLDB.Driver.Serialization;

namespace Amazon.QLDB.QuickStartGuide
{
    class Program
    {
        public class Person
        {
            public string FirstName { get; set; }

            public string LastName { get; set; }

            public int Age { get; set; }

            public override string ToString()
            {
                return FirstName + ", " + LastName + ", " + Age.ToString();
            }
        }

        static void Main(string[] args)
        {
            Console.WriteLine("Create the sync QLDB driver");
            IQldbDriver driver = QldbDriver.Builder()
                .WithLedger("quick-start")
                .WithSerializer(new ObjectSerializer())
                .Build();

            Console.WriteLine("Creating the table and index");

            // Creates the table and the index in the same transaction.
            // Note: Any code within the lambda can potentially execute multiple times due to retries.
            // For more information, see: https://docs.aws.amazon.com/qldb/latest/developerguide/driver-retry-policy
            driver.Execute(txn =>
            {
                txn.Execute("CREATE TABLE Person");
                txn.Execute("CREATE INDEX ON Person(firstName)");
            });

            Console.WriteLine("Inserting a document");

            Person myPerson = new Person {
                FirstName = "John",
                LastName = "Doe",
                Age = 32
            };

            driver.Execute(txn =>
            {
                IQuery<Person> myQuery = txn.Query<Person>("INSERT INTO Person ?", myPerson);
                txn.Execute(myQuery);
            });

            Console.WriteLine("Querying the table");

            // The result from driver.Execute() is buffered into memory because once the
            // transaction is committed, streaming the result is no longer possible.
            IResult<Person> selectResult = driver.Execute(txn =>
            {
                IQuery<Person> myQuery = txn.Query<Person>("SELECT * FROM Person WHERE FirstName = ?", "John");
                return txn.Execute(myQuery);
            });

            foreach (Person person in selectResult)
            {
                Console.WriteLine(person);
                // John, Doe, 32
            }

            Console.WriteLine("Updating the document");

            driver.Execute(txn =>
            {
                IQuery<Person> myQuery = txn.Query<Person>("UPDATE Person SET Age = ? WHERE FirstName = ?", 42, "John");
                txn.Execute(myQuery);
            });

            Console.WriteLine("Querying the table for the updated document");

            IResult<Person> updateResult = driver.Execute(txn =>
            {
                IQuery<Person> myQuery = txn.Query<Person>("SELECT * FROM Person WHERE FirstName = ?", "John");
                return txn.Execute(myQuery);
            });

            foreach (Person person in updateResult)
            {
                Console.WriteLine(person);
                // John, Doe, 42
            }

        }
    }
}

Async


using System;
using System.Threading.Tasks;
using Amazon.IonDotnet.Tree;
using Amazon.IonDotnet.Tree.Impl;
using Amazon.QLDB.Driver;
using IAsyncResult = Amazon.QLDB.Driver.IAsyncResult;

namespace Amazon.QLDB.QuickStartGuide
{
    class Program
    {
        static IValueFactory valueFactory = new ValueFactory();

        static async Task Main(string[] args)
        {
            Console.WriteLine("Create the async QLDB driver");
            IAsyncQldbDriver driver = AsyncQldbDriver.Builder()
                .WithLedger("quick-start")
                .Build();

            Console.WriteLine("Creating the table and index");

            // Creates the table and the index in the same transaction.
            // Note: Any code within the lambda can potentially execute multiple times due to retries.
            // For more information, see: https://docs.aws.amazon.com/qldb/latest/developerguide/driver-retry-policy
            await driver.Execute(async txn =>
            {
                await txn.Execute("CREATE TABLE Person");
                await txn.Execute("CREATE INDEX ON Person(firstName)");
            });

            Console.WriteLine("Inserting a document");

            // This is one way of creating Ion values. We can also use an IonLoader.
            // For more details, see: https://docs.aws.amazon.com/qldb/latest/developerguide/driver-cookbook-dotnet.html#cookbook-dotnet.ion
            IIonValue ionPerson = valueFactory.NewEmptyStruct();
            ionPerson.SetField("firstName", valueFactory.NewString("John"));
            ionPerson.SetField("lastName", valueFactory.NewString("Doe"));
            ionPerson.SetField("age", valueFactory.NewInt(32));

            await driver.Execute(async txn =>
            {
                await txn.Execute("INSERT INTO Person ?", ionPerson);
            });

            Console.WriteLine("Querying the table");

            IIonValue ionFirstName = valueFactory.NewString("John");

            // The result from driver.Execute() is buffered into memory because once the
            // transaction is committed, streaming the result is no longer possible.
            IAsyncResult selectResult = await driver.Execute(async txn =>
            {
                return await txn.Execute("SELECT * FROM Person WHERE firstName = ?", ionFirstName);
            });

            await foreach (IIonValue row in selectResult)
            {
                Console.WriteLine(row.GetField("firstName").StringValue);
                Console.WriteLine(row.GetField("lastName").StringValue);
                Console.WriteLine(row.GetField("age").IntValue);
            }

            Console.WriteLine("Updating the document");

            IIonValue ionIntAge = valueFactory.NewInt(42);
            IIonValue ionFirstName2 = valueFactory.NewString("John");

            await driver.Execute(async txn =>
            {
                await txn.Execute("UPDATE Person SET age = ? WHERE firstName = ?", ionIntAge, ionFirstName2);
            });

            Console.WriteLine("Querying the table for the updated document");

            IIonValue ionFirstName3 = valueFactory.NewString("John");

            IAsyncResult updateResult = await driver.Execute(async txn =>
            {
                return await txn.Execute("SELECT * FROM Person WHERE firstName = ?", ionFirstName3);
            });

            await foreach (IIonValue row in updateResult)
            {
                Console.WriteLine(row.GetField("firstName").StringValue);
                Console.WriteLine(row.GetField("lastName").StringValue);
                Console.WriteLine(row.GetField("age").IntValue);
            }
        }
    }
}

Sync


using System;
using Amazon.IonDotnet.Tree;
using Amazon.IonDotnet.Tree.Impl;
using Amazon.QLDB.Driver;

namespace Amazon.QLDB.QuickStartGuide
{
    class Program
    {
        static IValueFactory valueFactory = new ValueFactory();

        static void Main(string[] args)
        {
            Console.WriteLine("Create the sync QLDB Driver");
            IQldbDriver driver = QldbDriver.Builder()
                .WithLedger("quick-start")
                .Build();

            Console.WriteLine("Creating the tables and index");

            // Creates the table and the index in the same transaction.
            // Note: Any code within the lambda can potentially execute multiple times due to retries.
            // For more information, see: https://docs.aws.amazon.com/qldb/latest/developerguide/driver-retry-policy
            driver.Execute(txn =>
            {
                txn.Execute("CREATE TABLE Person");
                txn.Execute("CREATE INDEX ON Person(firstName)");
            });

            Console.WriteLine("Inserting a document");

            // This is one way of creating Ion values. We can also use an IonLoader.
            // For more details, see: https://docs.aws.amazon.com/qldb/latest/developerguide/driver-cookbook-dotnet.html#cookbook-dotnet.ion
            IIonValue ionPerson = valueFactory.NewEmptyStruct();
            ionPerson.SetField("firstName", valueFactory.NewString("John"));
            ionPerson.SetField("lastName", valueFactory.NewString("Doe"));
            ionPerson.SetField("age", valueFactory.NewInt(32));

            driver.Execute(txn =>
            {
                txn.Execute("INSERT INTO Person ?", ionPerson);
            });

            Console.WriteLine("Querying the table");

            IIonValue ionFirstName = valueFactory.NewString("John");

            // The result from driver.Execute() is buffered into memory because once the
            // transaction is committed, streaming the result is no longer possible.
            IResult selectResult = driver.Execute(txn =>
            {
                return txn.Execute("SELECT * FROM Person WHERE firstName = ?", ionFirstName);
            });

            foreach (IIonValue row in selectResult)
            {
                Console.WriteLine(row.GetField("firstName").StringValue);
                Console.WriteLine(row.GetField("lastName").StringValue);
                Console.WriteLine(row.GetField("age").IntValue);
            }

            Console.WriteLine("Updating a document");

            IIonValue ionIntAge = valueFactory.NewInt(42);
            IIonValue ionFirstName2 = valueFactory.NewString("John");

            driver.Execute(txn =>
            {
                txn.Execute("UPDATE Person SET age = ? WHERE firstName = ?", ionIntAge, ionFirstName2);
            });

            Console.WriteLine("Querying the table for the updated document");

            IIonValue ionFirstName3 = valueFactory.NewString("John");

            IResult updateResult = driver.Execute(txn =>
            {
                return txn.Execute("SELECT * FROM Person WHERE firstName = ?", ionFirstName3);
            });

            foreach (IIonValue row in updateResult)
            {
                Console.WriteLine(row.GetField("firstName").StringValue);
                Console.WriteLine(row.GetField("lastName").StringValue);
                Console.WriteLine(row.GetField("age").IntValue);
            }
        }
    }
}

若要執行完整的應用程式，請從Amazon.QLDB.QuickStartGuide專案目錄的父目錄中輸入下列指令。


$ dotnet run --project Amazon.QLDB.QuickStartGuide

您的瀏覽器已停用或無法使用 Javascript。

您必須啟用 Javascript，才能使用 AWS 文件。請參閱您的瀏覽器說明頁以取得說明。

文件慣用形式

。 NET驅動

食譜參考