Initial cut at presto connector

.github/workflows/db-trino.yaml

@@ -38,5 +38,16 @@ jobs:
           BQ_CREDENTIALS_KEY: ${{ secrets.BQ_PRESTO_TRINO_KEY }}
           TRINO_CATALOG: bigquery
           TRINO_SCHEMA: malloytest
-          TRINO_SERVER: http://localhost:8090
+          TRINO_SERVER: http://localhost:8080
           TRINO_USER: malloy-ci-bot@malloydata.org
+      # - name: Show docker logs
+      #   if: always()
+      #   run: |
+      #     docker logs --since=1h trino-malloy
+      # - name: Archive production artifacts
+      #   if: always()
+      #   uses: actions/upload-artifact@v4
+      #   with:
+      #     name: trino-logs
+      #     path: |
+      #       .tmp/**

packages/malloy-db-trino/package.json

@@ -23,6 +23,7 @@
   },
   "dependencies": {
     "@malloydata/malloy": "^0.0.130",
+    "@prestodb/presto-js-client": "^1.0.0",
     "gaxios": "^4.2.0",
     "trino-client": "^0.2.2"
   },

packages/malloy-db-trino/src/test.nonspec.ts

@@ -0,0 +1,76 @@
+export {};
+/*import {Trino, BasicAuth} from 'trino-client';
+import PrestoClient from '@prestodb/presto-js-client';
+
+// function CallPresto(client: Client, query: string ) {
+//   return new Promise (resolve => {
+//     client.execute({query, data => resolve(response)})
+//   });
+// }
+
+describe('Trino connection', () => {
+  console.log('hello');
+
+  test('says hello1', async () => {
+    const trino: Trino = Trino.create({
+      server: 'http://localhost:8090',
+      catalog: 'bigquery',
+      schema: 'malloytest',
+      auth: new BasicAuth('test'),
+    });
+    const limit = 50;
+    const result = await trino.query(
+      // 'explain SELECT 1 as one'
+      'explain SELECT * FROM malloytest.ga_sample limit 2'
+    );
+    let queryResult = await result.next();
+    const columns = queryResult.value.columns;
+
+    const outputRows: unknown[] = [];
+    while (queryResult !== null && outputRows.length < limit) {
+      const rows = queryResult.value.data ?? [];
+      for (const row of rows) {
+        if (outputRows.length < limit) {
+          outputRows.push(row);
+        }
+      }
+      if (!queryResult.done) {
+        queryResult = await result.next();
+      } else {
+        break;
+      }
+    }
+
+    const d = outputRows![0]![0];
+    console.log(d);
+
+    // console.log(outputRows);
+    // console.log(columns);
+  });
+
+  test('says hello presto', async () => {
+    const client = new PrestoClient({
+      catalog: 'bigquery',
+      host: 'http://localhost',
+      port: 8080,
+      schema: 'malloytest',
+      timezone: 'America/Costa_Rica',
+      user: 'root',
+    });
+
+    try {
+      const ret = await client.query(
+        'explain SELECT totals  FROM malloytest.ga_sample limit 2'
+        // 'explain select 1 as one, 2 as two'
+      );
+      const d = ret.data![0][0];
+
+
+      // console.log(ret);
+      console.log(d);
+    } catch (error) {
+      console.log(error);
+    }
+  });
+});
+*/

packages/malloy-db-trino/src/trino_connection.spec.ts

@@ -43,7 +43,7 @@ describe('Trino connection', () => {
     connection = new TrinoConnection(
       'trino',
       {},
-      TrinoExecutor.getConnectionOptionsFromEnv()
+      TrinoExecutor.getConnectionOptionsFromEnv('trino')
     );
   });