Features

Requirements

Install

Usage

Create a Trino client

consttrino:Trino=Trino.create({server:'http://localhost:8080',catalog:'tpcds',schema:'sf100000',auth:newBasicAuth('test'),});

Submit a query

constiter:Iterator<QueryResult>=awaittrino.query('select * from customer limit 100');

Iterate through the query results

forawait(constqueryResultofiter){console.log(queryResult.data);}

Alternative: map and aggregate the data

constdata:QueryData[]=awaititer.map(r=>r.data??[]).fold<QueryData[]>([],(row,acc)=>[...acc, ...row]);

Examples

Build

yarn install --frozen-lockfile

yarn test:lint

yarn build

Integration test

kind create cluster

kubectl apply -f tests/it/trino.yml

kubectlwait --for=condition=ready pods -n trino-system --all --timeout=120s

kubectl -n trino-system port-forward svc/trino 8080:8080

yarn test:it --testTimeout=60000

 PASS  tests/it/client.spec.ts  trino    ✓ exhaust query results (1567 ms)    ✓ close running query (200 ms)    ✓ cancel running query (17 ms)    ✓ get query info (1 ms)    ✓ client extra header propagation    ✓ query request header propagation (88 ms)    ✓ QueryResult has error info    ✓ QueryInfo has failure info (1 ms)    ✓ prepare statement (98 ms)    ✓ multiple prepare statement (432 ms)Test Suites: 1 passed, 1 totalTests:       10 passed, 10 totalSnapshots:   0 totalTime:        3.457 sRan all test suites matching /tests\/it/i.

kind delete cluster

Contributing

Releasing