Langkah 2: Uji konektivitas ke buku besar

penting

Pemberitahuan akhir dukungan: Pelanggan yang ada akan dapat menggunakan Amazon QLDB hingga akhir dukungan pada 07/31/2025. Untuk detail selengkapnya, lihat Memigrasi QLDB Buku Besar Amazon ke Amazon Aurora Postgre. SQL

Pada langkah ini, Anda memverifikasi bahwa Anda dapat terhubung ke vehicle-registration buku besar di Amazon QLDB menggunakan titik akhir data transaksional. API

Untuk menguji konektivitas ke buku besar

Tinjau program berikut (ConnectToLedger.java), yang membuat koneksi sesi data ke vehicle-registration buku besar.

2.x


/*
 * Copyright 2019 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 * SPDX-License-Identifier: MIT-0
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy of this
 * software and associated documentation files (the "Software"), to deal in the Software
 * without restriction, including without limitation the rights to use, copy, modify,
 * merge, publish, distribute, sublicense, and/or sell copies of the Software, and to
 * permit persons to whom the Software is furnished to do so.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED,
 * INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A
 * PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
 * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
 * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 */

package software.amazon.qldb.tutorial;

import java.net.URI;
import java.net.URISyntaxException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
import software.amazon.awssdk.services.qldbsession.QldbSessionClient;
import software.amazon.awssdk.services.qldbsession.QldbSessionClientBuilder;
import software.amazon.qldb.QldbDriver;
import software.amazon.qldb.RetryPolicy;

/**
 * Connect to a session for a given ledger using default settings.
 * <p>
 * This code expects that you have AWS credentials setup per:
 * http://docs.aws.amazon.com/java-sdk/latest/developer-guide/setup-credentials.html
 */
public final class ConnectToLedger {
    public static final Logger log = LoggerFactory.getLogger(ConnectToLedger.class);
    public static AwsCredentialsProvider credentialsProvider;
    public static String endpoint = null;
    public static String ledgerName = Constants.LEDGER_NAME;
    public static String region = null;
    public static QldbDriver driver;

    private ConnectToLedger() {
    }

    /**
     * Create a pooled driver for creating sessions.
     *
     * @param retryAttempts How many times the transaction will be retried in
     * case of a retryable issue happens like Optimistic Concurrency Control exception,
     * server side failures or network issues.
     * @return The pooled driver for creating sessions.
     */
    public static QldbDriver createQldbDriver(int retryAttempts) {
        QldbSessionClientBuilder builder = getAmazonQldbSessionClientBuilder();
        return QldbDriver.builder()
                             .ledger(ledgerName)
                             .transactionRetryPolicy(RetryPolicy
                                   .builder()
                                   .maxRetries(retryAttempts)
                                   .build())
                             .sessionClientBuilder(builder)
                             .build();
    }

    /**
     * Create a pooled driver for creating sessions.
     *
     * @return The pooled driver for creating sessions.
     */
    public static QldbDriver createQldbDriver() {
        QldbSessionClientBuilder builder = getAmazonQldbSessionClientBuilder();
        return QldbDriver.builder()
            .ledger(ledgerName)
            .transactionRetryPolicy(RetryPolicy.builder()
                                               .maxRetries(Constants.RETRY_LIMIT).build())
            .sessionClientBuilder(builder)
            .build();
    }

    /**
     * Creates a QldbSession builder that is passed to the QldbDriver to connect to the Ledger.
     *
     * @return An instance of the AmazonQLDBSessionClientBuilder
     */
    public static QldbSessionClientBuilder getAmazonQldbSessionClientBuilder() {
        QldbSessionClientBuilder builder = QldbSessionClient.builder();
        if (null != endpoint && null != region) {
            try {
                builder.endpointOverride(new URI(endpoint));
            } catch (URISyntaxException e) {
                throw new IllegalArgumentException(e);
            }
        }
        if (null != credentialsProvider) {
            builder.credentialsProvider(credentialsProvider);
        }
        return builder;
    }

    /**
     * Create a pooled driver for creating sessions.
     *
     * @return The pooled driver for creating sessions.
     */
    public static QldbDriver getDriver() {
        if (driver == null) {
            driver = createQldbDriver();
        }
        return driver;
    }


    public static void main(final String... args) {
        Iterable<String> tables = ConnectToLedger.getDriver().getTableNames();
        log.info("Existing tables in the ledger:");
        for (String table : tables) {
            log.info("- {} ", table);
        }
    }
}

catatan

Untuk menjalankan operasi data pada buku besar Anda, Anda harus membuat instance QldbDriver kelas untuk terhubung ke buku besar tertentu. Ini adalah objek klien yang berbeda dari AmazonQLDB klien yang Anda gunakan pada langkah sebelumnya untuk membuat buku besar. Klien sebelumnya hanya digunakan untuk menjalankan API operasi manajemen yang tercantum dalam fileQLDBAPIReferensi Amazon.
Pertama, buat QldbDriver objek. Anda harus menentukan nama buku besar saat Anda membuat driver ini.

Kemudian, Anda dapat menggunakan execute metode driver ini untuk menjalankan pernyataan PartiQL.
Secara opsional, Anda dapat menentukan jumlah maksimum percobaan ulang untuk pengecualian transaksi. executeMetode ini secara otomatis mencoba kembali konflik kontrol konkurensi optimis (OCC) dan pengecualian sementara umum lainnya hingga batas yang dapat dikonfigurasi ini. Nilai default-nya adalah 4.

Jika transaksi masih gagal setelah batas tercapai, maka pengemudi melempar pengecualian. Untuk mempelajari selengkapnya, lihat Memahami kebijakan coba lagi dengan pengemudi di Amazon QLDB.

1.x


/*
 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 * SPDX-License-Identifier: MIT-0
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy of this
 * software and associated documentation files (the "Software"), to deal in the Software
 * without restriction, including without limitation the rights to use, copy, modify,
 * merge, publish, distribute, sublicense, and/or sell copies of the Software, and to
 * permit persons to whom the Software is furnished to do so.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED,
 * INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A
 * PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
 * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
 * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 */

package software.amazon.qldb.tutorial;

import com.amazonaws.auth.AWSCredentialsProvider;
import com.amazonaws.client.builder.AwsClientBuilder;
import com.amazonaws.services.qldbsession.AmazonQLDBSessionClientBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import software.amazon.qldb.PooledQldbDriver;
import software.amazon.qldb.QldbDriver;
import software.amazon.qldb.QldbSession;
import software.amazon.qldb.exceptions.QldbClientException;

/**
 * Connect to a session for a given ledger using default settings.
 * <p>
 * This code expects that you have AWS credentials setup per:
 * http://docs.aws.amazon.com/java-sdk/latest/developer-guide/setup-credentials.html
 */
public final class ConnectToLedger {
    public static final Logger log = LoggerFactory.getLogger(ConnectToLedger.class);
    public static AWSCredentialsProvider credentialsProvider;
    public static String endpoint = null;
    public static String ledgerName = Constants.LEDGER_NAME;
    public static String region = null;
    private static PooledQldbDriver driver;

    private ConnectToLedger() {
    }

    /**
     * Create a pooled driver for creating sessions.
     *
     * @return The pooled driver for creating sessions.
     */
    public static PooledQldbDriver createQldbDriver() {
        AmazonQLDBSessionClientBuilder builder = AmazonQLDBSessionClientBuilder.standard();
        if (null != endpoint && null != region) {
            builder.setEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(endpoint, region));
        }
        if (null != credentialsProvider) {
            builder.setCredentials(credentialsProvider);
        }
        return PooledQldbDriver.builder()
                .withLedger(ledgerName)
                .withRetryLimit(Constants.RETRY_LIMIT)
                .withSessionClientBuilder(builder)
                .build();
    }

    /**
     * Create a pooled driver for creating sessions.
     *
     * @return The pooled driver for creating sessions.
     */
    public static PooledQldbDriver getDriver() {
        if (driver == null) {
            driver = createQldbDriver();
        }
        return driver;
    }

    /**
     * Connect to a ledger through a {@link QldbDriver}.
     *
     * @return {@link QldbSession}.
     */
    public static QldbSession createQldbSession() {
        return getDriver().getSession();
    }

    public static void main(final String... args) {
        try (QldbSession qldbSession = createQldbSession()) {
            log.info("Listing table names ");
            for (String tableName : qldbSession.getTableNames()) {
                log.info(tableName);
            }
        } catch (QldbClientException e) {
            log.error("Unable to create session.", e);
        }
    }
}

catatan

Untuk menjalankan operasi data pada buku besar Anda, Anda harus membuat instance QldbDriver kelas PooledQldbDriver atau untuk terhubung ke buku besar tertentu. Ini adalah objek klien yang berbeda dari AmazonQLDB klien yang Anda gunakan pada langkah sebelumnya untuk membuat buku besar. Klien sebelumnya hanya digunakan untuk menjalankan API operasi manajemen yang tercantum dalam fileQLDBAPIReferensi Amazon.

Kami merekomendasikan penggunaan PooledQldbDriver kecuali Anda perlu menerapkan kumpulan sesi khusus denganQldbDriver. Ukuran kolam default untuk PooledQldbDriver adalah jumlah maksimum HTTP koneksi terbuka yang memungkinkan klien sesi.
Pertama, buat PooledQldbDriver objek. Anda harus menentukan nama buku besar saat Anda membuat driver ini.

Kemudian, Anda dapat menggunakan execute metode driver ini untuk menjalankan pernyataan PartiQL. Atau, Anda dapat membuat sesi secara manual dari objek driver yang dikumpulkan ini dan menggunakan metode sesi. execute Sesi mewakili koneksi tunggal dengan buku besar.
Secara opsional, Anda dapat menentukan jumlah maksimum percobaan ulang untuk pengecualian transaksi. executeMetode ini secara otomatis mencoba kembali konflik kontrol konkurensi optimis (OCC) dan pengecualian sementara umum lainnya hingga batas yang dapat dikonfigurasi ini. Nilai default-nya adalah 4.

Jika transaksi masih gagal setelah batas tercapai, maka pengemudi melempar pengecualian. Untuk mempelajari selengkapnya, lihat Memahami kebijakan coba lagi dengan pengemudi di Amazon QLDB.

Kompilasi dan jalankan ConnectToLedger.java program untuk menguji konektivitas sesi data Anda ke vehicle-registration buku besar.

Mengesampingkan Wilayah AWS

Aplikasi sampel terhubung ke QLDB default Anda Wilayah AWS, yang dapat Anda atur seperti yang dijelaskan dalam langkah prasyarat. Menyetel AWS kredensi default dan Wilayah Anda Anda juga dapat mengubah Wilayah dengan memodifikasi properti pembuat klien QLDB sesi.

Untuk membuat tabel di vehicle-registration buku besar, lanjutkan keLangkah 3: Buat tabel, indeks, dan data sampel.

Awas Javascript dinonaktifkan atau tidak tersedia di browser Anda.

Untuk menggunakan Dokumentasi AWS, Javascript harus diaktifkan. Lihat halaman Bantuan browser Anda untuk petunjuk.

Konvensi Dokumen

Langkah 1: Buat buku besar baru

Langkah 3: Buat tabel, indeks, dan data sampel