Merge pull request #585 from domnikl/trino-source

implement Trino source
sfu-db · Apr 22, 2024 · d20ddc5 · d20ddc5
2 parents 2d71237 + cbe16b5
commit d20ddc5
Show file tree

Hide file tree

Showing 28 changed files with 1,875 additions and 10 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Justfile b/Justfile
@@ -23,6 +23,7 @@ test-feature-gate:
     cargo c --features src_oracle
     cargo c --features src_csv
     cargo c --features src_dummy
+    cargo c --features src_trino
     cargo c --features dst_arrow
     cargo c --features dst_arrow2
 
@@ -62,6 +63,7 @@ seed-db-more:
     ORACLE_URL_SCRIPT=`echo ${ORACLE_URL#oracle://} | sed "s/:/\//"`
     cat scripts/oracle.sql | sqlplus $ORACLE_URL_SCRIPT
     mysql --protocol tcp -h$MARIADB_HOST -P$MARIADB_PORT -u$MARIADB_USER -p$MARIADB_PASSWORD $MARIADB_DB < scripts/mysql.sql
+    trino $TRINO_URL --catalog=$TRINO_CATALOG < scripts/trino.sql
 
 # benches 
 flame-tpch conn="POSTGRES_URL":

diff --git a/README.md b/README.md
@@ -94,6 +94,7 @@ For more planned data sources, please check out our [discussion](https://github.
 - [x] Oracle
 - [x] Big Query
 - [ ] ODBC (WIP)
+- [ ] Trino (WIP)
 - [ ] ...
 
 ## Destinations

diff --git a/connectorx-cpp/Cargo.toml b/connectorx-cpp/Cargo.toml
@@ -34,4 +34,5 @@ srcs = [
   "connectorx/src_mssql",
   "connectorx/src_oracle",
   "connectorx/src_bigquery",
+  "connectorx/src_trino",
 ]
diff --git a/connectorx-python/Cargo.lock b/connectorx-python/Cargo.lock
diff --git a/connectorx-python/Cargo.toml b/connectorx-python/Cargo.toml
@@ -75,5 +75,6 @@ srcs = [
   "connectorx/src_mssql",
   "connectorx/src_oracle",
   "connectorx/src_bigquery",
+  "connectorx/src_trino",
 ]
 integrated-auth-gssapi = ["connectorx/integrated-auth-gssapi"]