/
init.js
44 lines (40 loc) · 1.2 KB
/
init.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
import { config } from 'dotenv';
import {
QldbDriver,
Result,
TransactionExecutor,
} from 'amazon-qldb-driver-nodejs';
import { getQldbDriver } from './src/qldb-ConnectToLedger.js';
import { createTable } from './src/qldb-CreateTable.js';
import { createIndex } from './src/qldb-CreateIndex.js';
import { insertDocuments } from './src/qldb-InsertDocument.js';
import {
LEDGER_NAME,
DOC_TABLE_NAME,
DOC_INDEX_KEY,
} from './src/qldb-Constants.js';
import { Documents } from './sample-data/SampleData.js';
config();
const main = async function () {
try {
const qldbDriver = getQldbDriver();
await qldbDriver.executeLambda(async txn => {
Promise.all([
createTable(txn, DOC_TABLE_NAME),
createIndex(txn, DOC_TABLE_NAME, DOC_INDEX_KEY),
insertDocuments(txn, DOC_TABLE_NAME, Documents),
// await qldbDriver.executeLambda(async (txn) => {
// const results = (
// await txn.execute('SELECT * FROM Document')
// ).getResultList();
// for (let result of results) {
// console.log(result); // prints [String: 'TOYENC486FH']
// }
// }),
]);
});
} catch (e) {
return e;
}
};
main();