amazon-qldb-driver-nodejs

import { QLDBSessionClientConfig } from "@aws-sdk/client-qldb-session"; import { QldbDriver, TransactionExecutor } from "amazon-qldb-driver-nodejs"; // Configure the QLDB session client (using AWS SDK v3) const qldbClientConfig: QLDBSessionClientConfig = { region: "us-east-1", // Specify your AWS region credentials: { accessKeyId: process.env.AWS_ACCESS_KEY_ID ?? '', // Ensure AWS credentials are set secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY ?? '' } }; // Initialize the QLDB Driver for a specific ledger const ledgerName = "my-test-ledger"; // Replace with your QLDB ledger name const qldbDriver: QldbDriver = new QldbDriver(ledgerName, qldbClientConfig); async function main() { try { console.log(`Listing tables in ledger: ${ledgerName}`); const tableNames = await qldbDriver.getTableNames(); console.log("Existing tables:", tableNames); // Example of executing a transaction to insert data const newDocument = { id: `doc-${Date.now()}`, name: "Example Item", quantity: 10, status: "available" }; await qldbDriver.execute(async (txn: TransactionExecutor) => { console.log("Attempting to insert document..."); // The driver automatically handles conversion of plain JS objects to Amazon ION await txn.execute(`INSERT INTO Products VALUE ?`, newDocument); console.log("Document inserted successfully."); }); // Example of querying data await qldbDriver.execute(async (txn: TransactionExecutor) => { console.log("Querying for inserted document..."); const result = await txn.execute(`SELECT * FROM Products WHERE id = ?`, newDocument.id); const docs = await result.toArray(); console.log("Queried documents:", JSON.stringify(docs, null, 2)); }); } catch (error) { console.error("Error interacting with QLDB:", error); } finally { // Close the driver to release resources and end active sessions await qldbDriver.close(); console.log("QLDB Driver closed."); } } main();