Prerequisiti Fase 1: Configurazione del progetto Fase 2: Inizializzare il driver Fase 3: Creare una tabella e un indice Fase 4: Inserimento di un documento Fase 5: Interrogare il documento Fase 6: Aggiornare il documento Esecuzione dell'applicazione completa

QLDBDriver Amazon per. NET— Tutorial di avvio rapido

Importante

Avviso di fine del supporto: i clienti esistenti potranno utilizzare Amazon QLDB fino alla fine del supporto il 31/07/2025. Per ulteriori dettagli, consulta Migrare un Amazon QLDB Ledger ad Amazon Aurora Postgre. SQL

In questo tutorial, imparerai come configurare una semplice applicazione utilizzando il QLDB driver Amazon per. NET. Questa guida include i passaggi per l'installazione del driver e brevi esempi in codice delle operazioni di base di creazione, lettura, aggiornamento ed eliminazione (CRUD).

Prerequisiti

Prima di iniziare, assicuratevi di fare quanto segue:

Completa il Prerequisiti modulo per. NETautista, se non l'hai già fatto. Ciò include la registrazione AWS, la concessione dell'accesso programmatico per lo sviluppo e l'installazione di. NETNucleo. SDK
Crea un registro denominatoquick-start.

Per informazioni su come creare un registro, consulta Operazioni di base per Amazon QLDB Ledger o Fase 1: Creare un nuovo libro contabile in Guida introduttiva alla console.

Fase 1: Configurazione del progetto

Primo, configura il tuo. NETprogetto.

Per creare ed eseguire un'applicazione modello, inserisci i seguenti dotnet comandi su un terminale come bash o Command Prompt. PowerShell
```
$ dotnet new console --output Amazon.QLDB.QuickStartGuide
$ dotnet run --project Amazon.QLDB.QuickStartGuide
```
Questo modello crea una cartella denominata. Amazon.QLDB.QuickStartGuide In quella cartella, crea un progetto con lo stesso nome e un file denominatoProgram.cs. Il programma contiene codice che visualizza l'outputHello World!.
Usa il gestore di NuGet pacchetti per installare il QLDB driver per. NET. Ti consigliamo di utilizzare Visual Studio o IDE uno a tua scelta per aggiungere dipendenze al tuo progetto. Il nome del pacchetto driver è Amazon. QLDB.Autista.
- Ad esempio, in Visual Studio, apri la console NuGet Package Manager nel menu Strumenti. Quindi, inserisci il seguente comando al PM> prompt.
```
PM> Install-Package Amazon.QLDB.Driver
```
- In alternativa, puoi inserire i seguenti comandi sul tuo terminale.
```
$ cd Amazon.QLDB.QuickStartGuide
$ dotnet add package Amazon.QLDB.Driver
```
L'installazione del driver installa anche le sue dipendenze, incluse le librerie Amazon Ion e AWS SDK for .NETAmazon.

Installa la libreria di serializzazione del driver.


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

Apri il file Program.cs.

Quindi, aggiungi in modo incrementale gli esempi di codice nei passaggi seguenti per provare alcune operazioni di baseCRUD. In alternativa, puoi saltare il step-by-step tutorial ed eseguire invece l'applicazione completa.

Nota

Scelta tra sincrono e asincronoAPIs: il driver fornisce funzionalità sincrone e asincrone. APIs Per le applicazioni ad alta richiesta che gestiscono più richieste senza blocchi, consigliamo di utilizzare la modalità asincrona per migliorare le prestazioni. APIs Il driver offre la funzionalità sincrona APIs come ulteriore comodità per le basi di codice esistenti scritte in modo sincrono.

Questo tutorial include esempi di codice sincrono e asincrono. Per ulteriori informazioni suAPIs, consulta le IAsyncQldbDriverinterfacce IQldbDrivere nella documentazione. API
Elaborazione dei dati Amazon Ion: questo tutorial fornisce esempi di codice di elaborazione dei dati Amazon Ion utilizzando l'object mapper Ion per impostazione predefinita. QLDBha introdotto lo Ion object mapper nella versione 1.3.0 di. NETautista. Ove applicabile, questo tutorial fornisce anche esempi di codice che utilizzano la libreria Ion standard come alternativa. Per ulteriori informazioni, consulta Lavorare con Amazon Ion.

Fase 2: Inizializzare il driver

Inizializza un'istanza del driver che si connette al registro denominato. quick-start Aggiungi il codice seguente al tuo Program.cs file.

Fase 3: Creare una tabella e un indice

Per il resto di questo tutorial fino al Passaggio 6, è necessario aggiungere i seguenti esempi di codice all'esempio di codice precedente.

In questo passaggio, il codice seguente mostra come eseguire CREATE INDEX istruzioni CREATE TABLE e istruzioni. Crea una tabella denominata Person e un indice per il firstName campo in quella tabella. Gli indici sono necessari per ottimizzare le prestazioni delle query e aiutano a limitare le eccezioni ottimistiche relative ai conflitti di concurrency control () OCC.

Fase 4: Inserimento di un documento

Il seguente esempio di codice mostra come eseguire un'INSERTistruzione. QLDBsupporta il linguaggio di interrogazione PartiQL (SQLcompatibile) e il formato dati Amazon Ion (superset di). JSON

Aggiungi il codice seguente che inserisce un documento nella tabella. Person

Suggerimento

Per inserire più documenti utilizzando una singola INSERT istruzione, è possibile passare un parametro di tipo Ion list all'istruzione come segue.


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

Non racchiudete la variabile placeholder (?) tra parentesi angolari doppie (<<...>>) quando passate un elenco Ion. Nelle istruzioni PartiQL manuali, le parentesi doppie angolari indicano una raccolta non ordinata nota come borsa.

Fase 5: Interrogare il documento

Il seguente esempio di codice mostra come eseguire un'SELECTistruzione.

Aggiungere il codice seguente per interrogare un documento dalla Person tabella.

Questo esempio utilizza un punto interrogativo (?) come segnaposto variabile per passare le informazioni del documento all'istruzione. Quando utilizzate i segnaposto, dovete passare un valore di tipo. IonValue

Fase 6: Aggiornare il documento

Il seguente esempio di codice mostra come eseguire un'UPDATEistruzione.

Aggiungere il codice seguente che aggiorna un documento nella Person tabella aggiornandolo age alla versione 42.

Interroga nuovamente il documento per vedere il valore aggiornato.

Per eseguire l'applicazione, immettete il seguente comando dalla directory principale della directory del Amazon.QLDB.QuickStartGuide progetto.
```
$ dotnet run --project Amazon.QLDB.QuickStartGuide
```

Aggiungi il codice seguente che aggiorna un documento nella Person tabella aggiornandolo age a 42.

Interroga nuovamente il documento per vedere il valore aggiornato.

Per eseguire l'applicazione, immettete il seguente comando dalla directory principale della directory del Amazon.QLDB.QuickStartGuide progetto.
```
$ dotnet run --project Amazon.QLDB.QuickStartGuide
```

Esecuzione dell'applicazione completa

Il seguente esempio di codice è la versione completa dell'Program.csapplicazione. Invece di eseguire i passaggi precedenti singolarmente, potete anche copiare ed eseguire questo esempio di codice dall'inizio alla fine. Questa applicazione illustra alcune CRUD operazioni di base sul registro denominato. quick-start

Nota

Prima di eseguire questo codice, assicurati di non avere già una tabella attiva denominata Person nel quick-start registro.

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);
            }
        }
    }
}

Per eseguire l'applicazione completa, immettete il seguente comando dalla directory principale della directory del Amazon.QLDB.QuickStartGuide progetto.


$ dotnet run --project Amazon.QLDB.QuickStartGuide

Avvertimento JavaScript è disabilitato o non è disponibile nel tuo browser.

Per usare la documentazione AWS, JavaScript deve essere abilitato. Consulta le pagine della guida del browser per le istruzioni.

Convenzioni dei documenti

. NETautista

Riferimento al libro di cucina