本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
步驟 4:查詢分類帳中的表格
重要
支援結束通知:現有客戶將能夠使用 Amazon,QLDB直到 2025 年 7 月 31 日終止支援為止。有關更多詳細信息,請參閱將 Amazon QLDB 分類帳遷移到 Amazon Aurora 郵政. SQL
在 Amazon QLDB 分類帳中建立資料表並將其載入資料後,您可以執行查詢以檢閱剛插入的車輛註冊資料。QLDB使用 PartiQL 作為其查詢語言,Amazon 離子作為其文檔導向的數據模型。
PartiQL 是一種開放原始碼、SQL兼容的查詢語言,已擴展為與 Ion 一起使用。使用 PartiQL,您可以使用熟悉的SQL運算子插入、查詢和管理資料。Amazon 離子是一個超集. JSON Ion 是一種開放原始碼、以文件為基礎的資料格式,可讓您靈活地儲存和處理結構化、半結構化和巢狀資料。
在此步驟中,您可以使用SELECT
陳述式從vehicle-registration
分類帳中的表格讀取資料。
警告
當您在中執行查詢時QLDB沒有索引查閱,它會叫用完整資料表掃描。PartiQL 支持這樣的查詢,因為它是SQL兼容的。但是,請勿針對中的生產使用案例執行表格掃描QLDB。資料表掃描可能會造成大型資料表的效能問題,包括並行衝突和交易逾時。
若要避免資料表掃描,您必須在索引欄位或文件 ID 上使用相等運算子來執行具有述WHERE
詞子句的陳述式;例如,WHERE indexedField = 123
或WHERE indexedField IN (456, 789)
。如需詳細資訊,請參閱 最佳化查詢效能。
若要查詢資料表
-
使用以下程序(
FindVehicles.ts
)查詢在分類帳中以人員註冊的所有車輛。/* * 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. */ import { QldbDriver, Result, TransactionExecutor } from "amazon-qldb-driver-nodejs"; import { dom } from "ion-js"; import { getQldbDriver } from "./ConnectToLedger"; import { PERSON } from "./model/SampleData"; import { PERSON_TABLE_NAME } from "./qldb/Constants"; import { error, log } from "./qldb/LogUtil"; import { getDocumentId } from "./qldb/Util"; import { prettyPrintResultList } from "./ScanTable"; /** * Query 'Vehicle' and 'VehicleRegistration' tables using a unique document ID in one transaction. * @param txn The {@linkcode TransactionExecutor} for lambda execute. * @param govId The owner's government ID. * @returns Promise which fulfills with void. */ async function findVehiclesForOwner(txn: TransactionExecutor, govId: string): Promise<void> { const documentId: string = await getDocumentId(txn, PERSON_TABLE_NAME, "GovId", govId); const query: string = "SELECT Vehicle FROM Vehicle INNER JOIN VehicleRegistration AS r " + "ON Vehicle.VIN = r.VIN WHERE r.Owners.PrimaryOwner.PersonId = ?"; await txn.execute(query, documentId).then((result: Result) => { const resultList: dom.Value[] = result.getResultList(); log(`List of vehicles for owner with GovId: ${govId}`); prettyPrintResultList(resultList); }); } /** * Find all vehicles registered under a person. * @returns Promise which fulfills with void. */ const main = async function(): Promise<void> { try { const qldbDriver: QldbDriver = getQldbDriver(); await qldbDriver.executeLambda(async (txn: TransactionExecutor) => { await findVehiclesForOwner(txn, PERSON[0].GovId); }); } catch (e) { error(`Error getting vehicles for owner: ${e}`); } } if (require.main === module) { main(); }
注意
首先,這個程
Person
序查詢與GovId LEWISR261LL
獲取其id
元數據字段的文檔表。然後,它使用此文檔
id
作為外鍵來查詢VehicleRegistration
表PrimaryOwner.PersonId
。它還VehicleRegistration
與VIN
字段上的Vehicle
表格連接。 -
要運行轉譯程序,請輸入以下命令。
node dist/FindVehicles.js
若要瞭解如何在vehicle-registration
分類帳中修改表格中的文件,請參閱步驟 5:修改分類帳中的文件。