diff --git a/.github/workflows/build.yaml b/.github/workflows/build.yaml
index 0937dc628..3d762b62a 100644
--- a/.github/workflows/build.yaml
+++ b/.github/workflows/build.yaml
@@ -32,6 +32,11 @@ jobs:
       - name: Install LLVM
         run: sudo apt-get install -y llvm
 
+      - name: Install protobuf compiler
+        # adbc_datafusion (dev-dep) → datafusion → substrait → prost-build,
+        # which invokes `protoc` at build time. Required for the ADBC test path.
+        run: sudo apt-get install -y protobuf-compiler
+
       - name: Install Rust
         uses: dtolnay/rust-toolchain@stable
 
@@ -61,6 +66,17 @@ jobs:
       - name: Run Rust tests
         run: cargo test --lib --bins
 
+      - name: Install dbc CLI and SQLite ADBC driver
+        run: |
+          curl -LsSf https://dbc.columnar.tech/install.sh | sh
+          "$HOME/.local/bin/dbc" install sqlite
+
+      - name: Run ADBC unit tests
+        run: cargo test --features "adbc sqlite" --lib
+
+      - name: Run ADBC SQLite equivalence tests
+        run: cargo test --features "adbc sqlite" --lib -- --ignored equivalence
+
       - name: Build WASM library
         working-directory: ggsql-wasm/library
         run: npm install && npm run build
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 1a9b20d65..7076c3b27 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,7 +1,12 @@
 ## [Unreleased]
 
 ### Added
-
+- New `AdbcReader<D: Driver>` for connecting to data sources via
+  [ADBC](https://arrow.apache.org/adbc/) (Arrow Database Connectivity), behind
+  a new off-by-default `adbc` feature flag. Generic over any concrete
+  `adbc_core::sync::Driver`, so concrete drivers (Flight SQL, Snowflake, etc.)
+  compose at the call site. Tested against `adbc_datafusion` for in-process
+  unit coverage.
 - New `aggregate` SETTING on Identity-stat layers (point, line, area, bar, ribbon,
   range, segment, arrow, rule, text). By default it collapses each group to a
   single row by replacing every numeric mapping in place with its aggregated
diff --git a/Cargo.lock b/Cargo.lock
index 18d04d75a..c21b1b448 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -2,6 +2,61 @@
 # It is not intended for manual editing.
 version = 4
 
+[[package]]
+name = "adbc_core"
+version = "0.23.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "46b169525a7c41670fe95874103c7c6ce713ac699123f81a200bc31f9ad3b02e"
+dependencies = [
+ "arrow-array",
+ "arrow-schema",
+]
+
+[[package]]
+name = "adbc_datafusion"
+version = "0.23.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5055538c63972f2a56854b855e1b85c21de4ee32afaba408658537bcae6f04f0"
+dependencies = [
+ "adbc_core",
+ "arrow-array",
+ "arrow-buffer",
+ "arrow-schema",
+ "datafusion",
+ "datafusion-substrait",
+ "prost",
+ "tokio",
+]
+
+[[package]]
+name = "adbc_driver_manager"
+version = "0.23.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "12aa1ae565ec6d45cfe71c20b5c2b3cbd6ba5d7176ecd0c0a448e970a93c35e4"
+dependencies = [
+ "adbc_core",
+ "adbc_ffi",
+ "arrow-array",
+ "arrow-schema",
+ "libloading",
+ "path-slash",
+ "regex",
+ "toml",
+ "windows-registry",
+ "windows-sys 0.61.2",
+]
+
+[[package]]
+name = "adbc_ffi"
+version = "0.23.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e6851c2ab953511cf7a244aadcbc0586442fd3c67dfe371457369048880dd513"
+dependencies = [
+ "adbc_core",
+ "arrow-array",
+ "arrow-schema",
+]
+
 [[package]]
 name = "adler2"
 version = "2.0.1"
@@ -148,7 +203,10 @@ dependencies = [
  "arrow-array",
  "arrow-buffer",
  "arrow-cast",
+ "arrow-csv",
  "arrow-data",
+ "arrow-ipc",
+ "arrow-json",
  "arrow-ord",
  "arrow-row",
  "arrow-schema",
@@ -181,8 +239,9 @@ dependencies = [
  "arrow-data",
  "arrow-schema",
  "chrono",
+ "chrono-tz",
  "half",
- "hashbrown 0.17.0",
+ "hashbrown 0.17.1",
  "num-complex",
  "num-integer",
  "num-traits",
@@ -222,6 +281,21 @@ dependencies = [
  "ryu",
 ]
 
+[[package]]
+name = "arrow-csv"
+version = "58.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e94e8cf7e517657a52b91ea1263acf38c4ca62a84655d72458a3359b12ab97de"
+dependencies = [
+ "arrow-array",
+ "arrow-cast",
+ "arrow-schema",
+ "chrono",
+ "csv",
+ "csv-core",
+ "regex",
+]
+
 [[package]]
 name = "arrow-data"
 version = "58.3.0"
@@ -247,6 +321,32 @@ dependencies = [
  "arrow-schema",
  "arrow-select",
  "flatbuffers",
+ "lz4_flex",
+]
+
+[[package]]
+name = "arrow-json"
+version = "58.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "205ca2119e6d679d5c133c6f30e68f027738d95ed948cf77677ea69c7800036b"
+dependencies = [
+ "arrow-array",
+ "arrow-buffer",
+ "arrow-cast",
+ "arrow-ord",
+ "arrow-schema",
+ "arrow-select",
+ "chrono",
+ "half",
+ "indexmap",
+ "itoa",
+ "lexical-core",
+ "memchr",
+ "num-traits",
+ "ryu",
+ "serde_core",
+ "serde_json",
+ "simdutf8",
 ]
 
 [[package]]
@@ -282,6 +382,8 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "f633dbfdf39c039ada1bf9e34c694816eb71fbb7dc78f613993b7245e078a1ed"
 dependencies = [
  "bitflags",
+ "serde_core",
+ "serde_json",
 ]
 
 [[package]]
@@ -315,6 +417,17 @@ dependencies = [
  "regex-syntax",
 ]
 
+[[package]]
+name = "async-recursion"
+version = "1.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3b43422f69d8ff38f95f1b2bb76517c91589a924d1559a0e935d7c8ce0274c11"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 2.0.117",
+]
+
 [[package]]
 name = "async-trait"
 version = "0.1.89"
@@ -366,6 +479,19 @@ version = "0.22.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "72b3254f16251a8381aa12e40e3c4d2f0199f8c6508fbecb9d91f575e0fbb8c6"
 
+[[package]]
+name = "bigdecimal"
+version = "0.4.10"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4d6867f1565b3aad85681f1015055b087fcfd840d6aeee6eee7f2da317603695"
+dependencies = [
+ "autocfg",
+ "libm",
+ "num-bigint",
+ "num-integer",
+ "num-traits",
+]
+
 [[package]]
 name = "bit-set"
 version = "0.8.0"
@@ -498,9 +624,9 @@ checksum = "37b2a672a2cb129a2e41c10b1224bb368f9f37a2b16b612598138befd7b37eb5"
 
 [[package]]
 name = "cc"
-version = "1.2.60"
+version = "1.2.62"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "43c5703da9466b66a946814e1adf53ea2c90f10063b86290cc9eb67ce3478a20"
+checksum = "a1dce859f0832a7d088c4f1119888ab94ef4b5d6795d1ce05afb7fe159d79f98"
 dependencies = [
  "find-msvc-tools",
  "jobserver",
@@ -533,6 +659,16 @@ dependencies = [
  "windows-link",
 ]
 
+[[package]]
+name = "chrono-tz"
+version = "0.10.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a6139a8597ed92cf816dfb33f5dd6cf0bb93a6adc938f11039f371bc5bcd26c3"
+dependencies = [
+ "chrono",
+ "phf 0.12.1",
+]
+
 [[package]]
 name = "clap"
 version = "4.6.1"
@@ -581,14 +717,12 @@ checksum = "1d07550c9036bf2ae0c684c4297d503f838287c83c53686d05370d0e139ae570"
 
 [[package]]
 name = "comfy-table"
-version = "7.1.2"
+version = "7.1.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e0d05af1e006a2407bedef5af410552494ce5be9090444dbbcb57258c1af3d56"
+checksum = "4a65ebfec4fb190b6f90e944a817d60499ee0744e582530e2c9900a22e591d9a"
 dependencies = [
- "crossterm 0.27.0",
  "crossterm 0.28.1",
- "strum 0.26.3",
- "strum_macros 0.26.4",
+ "unicode-segmentation",
  "unicode-width 0.2.2",
 ]
 
@@ -715,145 +849,800 @@ dependencies = [
 ]
 
 [[package]]
-name = "crossbeam-channel"
-version = "0.5.15"
+name = "crossbeam-channel"
+version = "0.5.15"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "82b8f8f868b36967f9606790d1903570de9ceaf870a7bf9fbbd3016d636a2cb2"
+dependencies = [
+ "crossbeam-utils",
+]
+
+[[package]]
+name = "crossbeam-deque"
+version = "0.8.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9dd111b7b7f7d55b72c0a6ae361660ee5853c9af73f70c3c2ef6858b950e2e51"
+dependencies = [
+ "crossbeam-epoch",
+ "crossbeam-utils",
+]
+
+[[package]]
+name = "crossbeam-epoch"
+version = "0.9.18"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5b82ac4a3c2ca9c3460964f020e1402edd5753411d7737aa39c3714ad1b5420e"
+dependencies = [
+ "crossbeam-utils",
+]
+
+[[package]]
+name = "crossbeam-queue"
+version = "0.3.12"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0f58bbc28f91df819d0aa2a2c00cd19754769c2fad90579b3592b1c9ba7a3115"
+dependencies = [
+ "crossbeam-utils",
+]
+
+[[package]]
+name = "crossbeam-utils"
+version = "0.8.21"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d0a5c400df2834b80a4c3327b3aad3a4c4cd4de0629063962b03235697506a28"
+
+[[package]]
+name = "crossterm"
+version = "0.28.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "829d955a0bb380ef178a640b91779e3987da38c9aea133b20614cfed8cdea9c6"
+dependencies = [
+ "bitflags",
+ "crossterm_winapi",
+ "parking_lot",
+ "rustix 0.38.44",
+ "winapi",
+]
+
+[[package]]
+name = "crossterm"
+version = "0.29.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d8b9f2e4c67f833b660cdb0a3523065869fb35570177239812ed4c905aeff87b"
+dependencies = [
+ "bitflags",
+ "crossterm_winapi",
+ "derive_more",
+ "document-features",
+ "mio",
+ "parking_lot",
+ "rustix 1.1.4",
+ "signal-hook",
+ "signal-hook-mio",
+ "winapi",
+]
+
+[[package]]
+name = "crossterm_winapi"
+version = "0.9.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "acdd7c62a3665c7f6830a51635d9ac9b23ed385797f70a83bb8bafe9c572ab2b"
+dependencies = [
+ "winapi",
+]
+
+[[package]]
+name = "crunchy"
+version = "0.2.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "460fbee9c2c2f33933d720630a6a0bac33ba7053db5344fac858d4b8952d77d5"
+
+[[package]]
+name = "crypto-common"
+version = "0.1.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "78c8292055d1c1df0cce5d180393dc8cce0abec0a7102adb6c7b1eef6016d60a"
+dependencies = [
+ "generic-array",
+ "typenum",
+]
+
+[[package]]
+name = "csscolorparser"
+version = "0.8.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "199f851bd3cb5004c09474252c7f74e7c047441ed0979bf3688a7106a13da952"
+dependencies = [
+ "num-traits",
+ "phf 0.13.1",
+ "serde",
+ "uncased",
+]
+
+[[package]]
+name = "csv"
+version = "1.4.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "52cd9d68cf7efc6ddfaaee42e7288d3a99d613d4b50f76ce9827ae0c6e14f938"
+dependencies = [
+ "csv-core",
+ "itoa",
+ "ryu",
+ "serde_core",
+]
+
+[[package]]
+name = "csv-core"
+version = "0.1.13"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "704a3c26996a80471189265814dbc2c257598b96b8a7feae2d31ace646bb9782"
+dependencies = [
+ "memchr",
+]
+
+[[package]]
+name = "dashmap"
+version = "5.5.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "978747c1d849a7d2ee5e8adc0159961c48fb7e5db2f06af6723b80123bb53856"
+dependencies = [
+ "cfg-if",
+ "hashbrown 0.14.5",
+ "lock_api",
+ "once_cell",
+ "parking_lot_core",
+]
+
+[[package]]
+name = "dashmap"
+version = "6.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5041cc499144891f3790297212f32a74fb938e5136a14943f338ef9e0ae276cf"
+dependencies = [
+ "cfg-if",
+ "crossbeam-utils",
+ "hashbrown 0.14.5",
+ "lock_api",
+ "once_cell",
+ "parking_lot_core",
+]
+
+[[package]]
+name = "data-encoding"
+version = "2.11.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a4ae5f15dda3c708c0ade84bfee31ccab44a3da4f88015ed22f63732abe300c8"
+
+[[package]]
+name = "datafusion"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "93db0e623840612f7f2cd757f7e8a8922064192363732c88692e0870016e141b"
+dependencies = [
+ "arrow",
+ "arrow-schema",
+ "async-trait",
+ "bytes",
+ "chrono",
+ "datafusion-catalog",
+ "datafusion-catalog-listing",
+ "datafusion-common",
+ "datafusion-common-runtime",
+ "datafusion-datasource",
+ "datafusion-datasource-arrow",
+ "datafusion-datasource-csv",
+ "datafusion-datasource-json",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-expr-common",
+ "datafusion-functions",
+ "datafusion-functions-aggregate",
+ "datafusion-functions-nested",
+ "datafusion-functions-table",
+ "datafusion-functions-window",
+ "datafusion-optimizer",
+ "datafusion-physical-expr",
+ "datafusion-physical-expr-adapter",
+ "datafusion-physical-expr-common",
+ "datafusion-physical-optimizer",
+ "datafusion-physical-plan",
+ "datafusion-session",
+ "datafusion-sql",
+ "futures",
+ "itertools",
+ "log",
+ "object_store",
+ "parking_lot",
+ "rand 0.9.4",
+ "regex",
+ "sqlparser",
+ "tempfile",
+ "tokio",
+ "url",
+ "uuid",
+]
+
+[[package]]
+name = "datafusion-catalog"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "37cefde60b26a7f4ff61e9d2ff2833322f91df2b568d7238afe67bde5bdffb66"
+dependencies = [
+ "arrow",
+ "async-trait",
+ "dashmap 6.1.0",
+ "datafusion-common",
+ "datafusion-common-runtime",
+ "datafusion-datasource",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-physical-expr",
+ "datafusion-physical-plan",
+ "datafusion-session",
+ "futures",
+ "itertools",
+ "log",
+ "object_store",
+ "parking_lot",
+ "tokio",
+]
+
+[[package]]
+name = "datafusion-catalog-listing"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "17e112307715d6a7a331111a4c2330ff54bc237183511c319e3708a4cff431fb"
+dependencies = [
+ "arrow",
+ "async-trait",
+ "datafusion-catalog",
+ "datafusion-common",
+ "datafusion-datasource",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-physical-expr",
+ "datafusion-physical-expr-adapter",
+ "datafusion-physical-expr-common",
+ "datafusion-physical-plan",
+ "futures",
+ "itertools",
+ "log",
+ "object_store",
+]
+
+[[package]]
+name = "datafusion-common"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d72a11ca44a95e1081870d3abb80c717496e8a7acb467a1d3e932bb636af5cc2"
+dependencies = [
+ "ahash 0.8.12",
+ "arrow",
+ "arrow-ipc",
+ "chrono",
+ "half",
+ "hashbrown 0.16.1",
+ "indexmap",
+ "itertools",
+ "libc",
+ "log",
+ "object_store",
+ "paste",
+ "sqlparser",
+ "tokio",
+ "web-time",
+]
+
+[[package]]
+name = "datafusion-common-runtime"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "89f4afaed29670ec4fd6053643adc749fe3f4bc9d1ce1b8c5679b22c67d12def"
+dependencies = [
+ "futures",
+ "log",
+ "tokio",
+]
+
+[[package]]
+name = "datafusion-datasource"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e9fb386e1691355355a96419978a0022b7947b44d4a24a6ea99f00b6b485cbb6"
+dependencies = [
+ "arrow",
+ "async-trait",
+ "bytes",
+ "chrono",
+ "datafusion-common",
+ "datafusion-common-runtime",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-physical-expr",
+ "datafusion-physical-expr-adapter",
+ "datafusion-physical-expr-common",
+ "datafusion-physical-plan",
+ "datafusion-session",
+ "futures",
+ "glob",
+ "itertools",
+ "log",
+ "object_store",
+ "rand 0.9.4",
+ "tokio",
+ "url",
+]
+
+[[package]]
+name = "datafusion-datasource-arrow"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ffa6c52cfed0734c5f93754d1c0175f558175248bf686c944fb05c373e5fc096"
+dependencies = [
+ "arrow",
+ "arrow-ipc",
+ "async-trait",
+ "bytes",
+ "datafusion-common",
+ "datafusion-common-runtime",
+ "datafusion-datasource",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-physical-expr-common",
+ "datafusion-physical-plan",
+ "datafusion-session",
+ "futures",
+ "itertools",
+ "object_store",
+ "tokio",
+]
+
+[[package]]
+name = "datafusion-datasource-csv"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "503f29e0582c1fc189578d665ff57d9300da1f80c282777d7eb67bb79fb8cdca"
+dependencies = [
+ "arrow",
+ "async-trait",
+ "bytes",
+ "datafusion-common",
+ "datafusion-common-runtime",
+ "datafusion-datasource",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-physical-expr-common",
+ "datafusion-physical-plan",
+ "datafusion-session",
+ "futures",
+ "object_store",
+ "regex",
+ "tokio",
+]
+
+[[package]]
+name = "datafusion-datasource-json"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e33804749abc8d0c8cb7473228483cb8070e524c6f6086ee1b85a64debe2b3d2"
+dependencies = [
+ "arrow",
+ "async-trait",
+ "bytes",
+ "datafusion-common",
+ "datafusion-common-runtime",
+ "datafusion-datasource",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-physical-expr-common",
+ "datafusion-physical-plan",
+ "datafusion-session",
+ "futures",
+ "object_store",
+ "serde_json",
+ "tokio",
+ "tokio-stream",
+]
+
+[[package]]
+name = "datafusion-doc"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8de6ac0df1662b9148ad3c987978b32cbec7c772f199b1d53520c8fa764a87ee"
+
+[[package]]
+name = "datafusion-execution"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c03c7fbdaefcca4ef6ffe425a5fc2325763bfb426599bb0bf4536466efabe709"
+dependencies = [
+ "arrow",
+ "arrow-buffer",
+ "async-trait",
+ "chrono",
+ "dashmap 6.1.0",
+ "datafusion-common",
+ "datafusion-expr",
+ "datafusion-physical-expr-common",
+ "futures",
+ "log",
+ "object_store",
+ "parking_lot",
+ "rand 0.9.4",
+ "tempfile",
+ "url",
+]
+
+[[package]]
+name = "datafusion-expr"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "574b9b6977fedbd2a611cbff12e5caf90f31640ad9dc5870f152836d94bad0dd"
+dependencies = [
+ "arrow",
+ "async-trait",
+ "chrono",
+ "datafusion-common",
+ "datafusion-doc",
+ "datafusion-expr-common",
+ "datafusion-functions-aggregate-common",
+ "datafusion-functions-window-common",
+ "datafusion-physical-expr-common",
+ "indexmap",
+ "itertools",
+ "paste",
+ "serde_json",
+ "sqlparser",
+]
+
+[[package]]
+name = "datafusion-expr-common"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7d7c3adf3db8bf61e92eb90cb659c8e8b734593a8f7c8e12a843c7ddba24b87e"
+dependencies = [
+ "arrow",
+ "datafusion-common",
+ "indexmap",
+ "itertools",
+ "paste",
+]
+
+[[package]]
+name = "datafusion-functions"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f28aa4e10384e782774b10e72aca4d93ef7b31aa653095d9d4536b0a3dbc51b6"
+dependencies = [
+ "arrow",
+ "arrow-buffer",
+ "base64",
+ "chrono",
+ "chrono-tz",
+ "datafusion-common",
+ "datafusion-doc",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-expr-common",
+ "datafusion-macros",
+ "hex",
+ "itertools",
+ "log",
+ "memchr",
+ "num-traits",
+ "rand 0.9.4",
+ "regex",
+ "unicode-segmentation",
+ "uuid",
+]
+
+[[package]]
+name = "datafusion-functions-aggregate"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "00aa6217e56098ba84e0a338176fe52f0a84cca398021512c6c8c5eff806d0ad"
+dependencies = [
+ "ahash 0.8.12",
+ "arrow",
+ "datafusion-common",
+ "datafusion-doc",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-functions-aggregate-common",
+ "datafusion-macros",
+ "datafusion-physical-expr",
+ "datafusion-physical-expr-common",
+ "half",
+ "log",
+ "num-traits",
+ "paste",
+]
+
+[[package]]
+name = "datafusion-functions-aggregate-common"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b511250349407db7c43832ab2de63f5557b19a20dfd236b39ca2c04468b50d47"
+dependencies = [
+ "ahash 0.8.12",
+ "arrow",
+ "datafusion-common",
+ "datafusion-expr-common",
+ "datafusion-physical-expr-common",
+]
+
+[[package]]
+name = "datafusion-functions-nested"
+version = "53.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ef13a858e20d50f0a9bb5e96e7ac82b4e7597f247515bccca4fdd2992df0212a"
+dependencies = [
+ "arrow",
+ "arrow-ord",
+ "datafusion-common",
+ "datafusion-doc",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-expr-common",
+ "datafusion-functions",
+ "datafusion-functions-aggregate",
+ "datafusion-functions-aggregate-common",
+ "datafusion-macros",
+ "datafusion-physical-expr-common",
+ "hashbrown 0.16.1",
+ "itertools",
+ "itoa",
+ "log",
+ "paste",
+]
+
+[[package]]
+name = "datafusion-functions-table"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "82b8f8f868b36967f9606790d1903570de9ceaf870a7bf9fbbd3016d636a2cb2"
+checksum = "72b40d3f5bbb3905f9ccb1ce9485a9595c77b69758a7c24d3ba79e334ff51e7e"
 dependencies = [
- "crossbeam-utils",
+ "arrow",
+ "async-trait",
+ "datafusion-catalog",
+ "datafusion-common",
+ "datafusion-expr",
+ "datafusion-physical-plan",
+ "parking_lot",
+ "paste",
 ]
 
 [[package]]
-name = "crossbeam-deque"
-version = "0.8.6"
+name = "datafusion-functions-window"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9dd111b7b7f7d55b72c0a6ae361660ee5853c9af73f70c3c2ef6858b950e2e51"
+checksum = "d4e88ec9d57c9b685d02f58bfee7be62d72610430ddcedb82a08e5d9925dbfb6"
 dependencies = [
- "crossbeam-epoch",
- "crossbeam-utils",
+ "arrow",
+ "datafusion-common",
+ "datafusion-doc",
+ "datafusion-expr",
+ "datafusion-functions-window-common",
+ "datafusion-macros",
+ "datafusion-physical-expr",
+ "datafusion-physical-expr-common",
+ "log",
+ "paste",
 ]
 
 [[package]]
-name = "crossbeam-epoch"
-version = "0.9.18"
+name = "datafusion-functions-window-common"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "5b82ac4a3c2ca9c3460964f020e1402edd5753411d7737aa39c3714ad1b5420e"
+checksum = "8307bb93519b1a91913723a1130cfafeee3f72200d870d88e91a6fc5470ede5c"
 dependencies = [
- "crossbeam-utils",
+ "datafusion-common",
+ "datafusion-physical-expr-common",
 ]
 
 [[package]]
-name = "crossbeam-queue"
-version = "0.3.12"
+name = "datafusion-macros"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0f58bbc28f91df819d0aa2a2c00cd19754769c2fad90579b3592b1c9ba7a3115"
+checksum = "2e367e6a71051d0ebdd29b2f85d12059b38b1d1f172c6906e80016da662226bd"
 dependencies = [
- "crossbeam-utils",
+ "datafusion-doc",
+ "quote",
+ "syn 2.0.117",
 ]
 
 [[package]]
-name = "crossbeam-utils"
-version = "0.8.21"
+name = "datafusion-optimizer"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d0a5c400df2834b80a4c3327b3aad3a4c4cd4de0629063962b03235697506a28"
+checksum = "e929015451a67f77d9d8b727b2bf3a40c4445fdef6cdc53281d7d97c76888ace"
+dependencies = [
+ "arrow",
+ "chrono",
+ "datafusion-common",
+ "datafusion-expr",
+ "datafusion-expr-common",
+ "datafusion-physical-expr",
+ "indexmap",
+ "itertools",
+ "log",
+ "regex",
+ "regex-syntax",
+]
 
 [[package]]
-name = "crossterm"
-version = "0.27.0"
+name = "datafusion-physical-expr"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f476fe445d41c9e991fd07515a6f463074b782242ccf4a5b7b1d1012e70824df"
+checksum = "4b1e68aba7a4b350401cfdf25a3d6f989ad898a7410164afe9ca52080244cb59"
 dependencies = [
- "bitflags",
- "crossterm_winapi",
- "libc",
+ "ahash 0.8.12",
+ "arrow",
+ "datafusion-common",
+ "datafusion-expr",
+ "datafusion-expr-common",
+ "datafusion-functions-aggregate-common",
+ "datafusion-physical-expr-common",
+ "half",
+ "hashbrown 0.16.1",
+ "indexmap",
+ "itertools",
  "parking_lot",
- "winapi",
+ "paste",
+ "petgraph",
+ "tokio",
 ]
 
 [[package]]
-name = "crossterm"
-version = "0.28.1"
+name = "datafusion-physical-expr-adapter"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "829d955a0bb380ef178a640b91779e3987da38c9aea133b20614cfed8cdea9c6"
+checksum = "ea22315f33cf2e0adc104e8ec42e285f6ed93998d565c65e82fec6a9ee9f9db4"
 dependencies = [
- "bitflags",
- "parking_lot",
- "rustix 0.38.44",
+ "arrow",
+ "datafusion-common",
+ "datafusion-expr",
+ "datafusion-functions",
+ "datafusion-physical-expr",
+ "datafusion-physical-expr-common",
+ "itertools",
 ]
 
 [[package]]
-name = "crossterm"
-version = "0.29.0"
+name = "datafusion-physical-expr-common"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d8b9f2e4c67f833b660cdb0a3523065869fb35570177239812ed4c905aeff87b"
+checksum = "b04b45ea8ad3ac2d78f2ea2a76053e06591c9629c7a603eda16c10649ecf4362"
 dependencies = [
- "bitflags",
- "crossterm_winapi",
- "derive_more",
- "document-features",
- "mio",
+ "ahash 0.8.12",
+ "arrow",
+ "chrono",
+ "datafusion-common",
+ "datafusion-expr-common",
+ "hashbrown 0.16.1",
+ "indexmap",
+ "itertools",
  "parking_lot",
- "rustix 1.1.4",
- "signal-hook",
- "signal-hook-mio",
- "winapi",
 ]
 
 [[package]]
-name = "crossterm_winapi"
-version = "0.9.1"
+name = "datafusion-physical-optimizer"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "acdd7c62a3665c7f6830a51635d9ac9b23ed385797f70a83bb8bafe9c572ab2b"
+checksum = "7cb13397809a425918f608dfe8653f332015a3e330004ab191b4404187238b95"
 dependencies = [
- "winapi",
+ "arrow",
+ "datafusion-common",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-expr-common",
+ "datafusion-physical-expr",
+ "datafusion-physical-expr-common",
+ "datafusion-physical-plan",
+ "datafusion-pruning",
+ "itertools",
 ]
 
 [[package]]
-name = "crunchy"
-version = "0.2.4"
+name = "datafusion-physical-plan"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "460fbee9c2c2f33933d720630a6a0bac33ba7053db5344fac858d4b8952d77d5"
+checksum = "5edc023675791af9d5fb4cc4c24abf5f7bd3bd4dcf9e5bd90ea1eff6976dcc79"
+dependencies = [
+ "ahash 0.8.12",
+ "arrow",
+ "arrow-ord",
+ "arrow-schema",
+ "async-trait",
+ "datafusion-common",
+ "datafusion-common-runtime",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-functions",
+ "datafusion-functions-aggregate-common",
+ "datafusion-functions-window-common",
+ "datafusion-physical-expr",
+ "datafusion-physical-expr-common",
+ "futures",
+ "half",
+ "hashbrown 0.16.1",
+ "indexmap",
+ "itertools",
+ "log",
+ "num-traits",
+ "parking_lot",
+ "pin-project-lite",
+ "tokio",
+]
 
 [[package]]
-name = "crypto-common"
-version = "0.1.7"
+name = "datafusion-pruning"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "78c8292055d1c1df0cce5d180393dc8cce0abec0a7102adb6c7b1eef6016d60a"
+checksum = "ac8c76860e355616555081cab5968cec1af7a80701ff374510860bcd567e365a"
 dependencies = [
- "generic-array",
- "typenum",
+ "arrow",
+ "datafusion-common",
+ "datafusion-datasource",
+ "datafusion-expr-common",
+ "datafusion-physical-expr",
+ "datafusion-physical-expr-common",
+ "datafusion-physical-plan",
+ "itertools",
+ "log",
 ]
 
 [[package]]
-name = "csscolorparser"
-version = "0.8.3"
+name = "datafusion-session"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "199f851bd3cb5004c09474252c7f74e7c047441ed0979bf3688a7106a13da952"
+checksum = "5412111aa48e2424ba926112e192f7a6b7e4ccb450145d25ce5ede9f19dc491e"
 dependencies = [
- "num-traits",
- "phf",
- "serde",
- "uncased",
+ "async-trait",
+ "datafusion-common",
+ "datafusion-execution",
+ "datafusion-expr",
+ "datafusion-physical-plan",
+ "parking_lot",
 ]
 
 [[package]]
-name = "dashmap"
-version = "5.5.3"
+name = "datafusion-sql"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "978747c1d849a7d2ee5e8adc0159961c48fb7e5db2f06af6723b80123bb53856"
+checksum = "fa0d133ddf8b9b3b872acac900157f783e7b879fe9a6bccf389abebbfac45ec1"
 dependencies = [
- "cfg-if",
- "hashbrown 0.14.5",
- "lock_api",
- "once_cell",
- "parking_lot_core",
+ "arrow",
+ "bigdecimal",
+ "chrono",
+ "datafusion-common",
+ "datafusion-expr",
+ "datafusion-functions-nested",
+ "indexmap",
+ "log",
+ "regex",
+ "sqlparser",
 ]
 
 [[package]]
-name = "data-encoding"
-version = "2.10.0"
+name = "datafusion-substrait"
+version = "53.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d7a1e2f27636f116493b8b860f5546edb47c8d8f8ea73e1d2a20be88e28d1fea"
+checksum = "98494539a5468979cc42d86c7bc5f0f8cb71ee5c742694c26fc34efdd29dd2e5"
+dependencies = [
+ "async-recursion",
+ "async-trait",
+ "chrono",
+ "datafusion",
+ "half",
+ "itertools",
+ "object_store",
+ "pbjson-types",
+ "prost",
+ "substrait",
+ "tokio",
+ "url",
+]
 
 [[package]]
 name = "derive_arbitrary"
@@ -935,9 +1724,21 @@ dependencies = [
  "num",
  "num-integer",
  "rust_decimal",
- "strum 0.27.2",
+ "strum",
 ]
 
+[[package]]
+name = "dyn-clone"
+version = "1.0.20"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d0881ea181b1df73ff77ffaaf9c7544ecc11e82fba9b5f27b262a3c73a332555"
+
+[[package]]
+name = "either"
+version = "1.15.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "48c757948c5ede0e46177b7add2e67155f70e33c07fea8284df6576da70b3719"
+
 [[package]]
 name = "email_address"
 version = "0.2.9"
@@ -1000,13 +1801,12 @@ checksum = "9f1f227452a390804cdb637b74a86990f2a7d7ba4b7d5693aac9b4dd6defd8d6"
 
 [[package]]
 name = "filetime"
-version = "0.2.27"
+version = "0.2.29"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f98844151eee8917efc50bd9e8318cb963ae8b297431495d3f758616ea5c57db"
+checksum = "5c287a33c7f0a620c38e641e7f60827713987b3c0f26e8ddc9462cc69cf75759"
 dependencies = [
  "cfg-if",
  "libc",
- "libredox",
 ]
 
 [[package]]
@@ -1015,6 +1815,12 @@ version = "0.1.9"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "5baebc0774151f905a1a2cc41989300b1e6fbb29aff0ceffa1064fdd3088d582"
 
+[[package]]
+name = "fixedbitset"
+version = "0.5.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1d674e81391d1e1ab681a28d99df07927c6d4aa5b027d7da16ba32d1d21ecd99"
+
 [[package]]
 name = "flatbuffers"
 version = "25.12.19"
@@ -1084,6 +1890,21 @@ version = "2.0.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "e6d5a32815ae3f33302d95fdcb2ce17862f8c65363dcfd29360480ba1001fc9c"
 
+[[package]]
+name = "futures"
+version = "0.3.32"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8b147ee9d1f6d097cef9ce628cd2ee62288d963e16fb287bd9286455b241382d"
+dependencies = [
+ "futures-channel",
+ "futures-core",
+ "futures-executor",
+ "futures-io",
+ "futures-sink",
+ "futures-task",
+ "futures-util",
+]
+
 [[package]]
 name = "futures-channel"
 version = "0.3.32"
@@ -1100,6 +1921,17 @@ version = "0.3.32"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "7e3450815272ef58cec6d564423f6e755e25379b217b0bc688e295ba24df6b1d"
 
+[[package]]
+name = "futures-executor"
+version = "0.3.32"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "baf29c38818342a3b26b5b923639e7b1f4a61fc5e76102d4b1981c6dc7a7579d"
+dependencies = [
+ "futures-core",
+ "futures-task",
+ "futures-util",
+]
+
 [[package]]
 name = "futures-io"
 version = "0.3.32"
@@ -1135,6 +1967,7 @@ version = "0.3.32"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "389ca41296e6190b48053de0321d02a77f32f8a5d2461dd38762c0593805c6d6"
 dependencies = [
+ "futures-channel",
  "futures-core",
  "futures-io",
  "futures-macro",
@@ -1236,6 +2069,9 @@ dependencies = [
 name = "ggsql"
 version = "0.3.2"
 dependencies = [
+ "adbc_core",
+ "adbc_datafusion",
+ "adbc_driver_manager",
  "arrow",
  "bytes",
  "chrono",
@@ -1315,6 +2151,12 @@ dependencies = [
  "wasm-bindgen-futures",
 ]
 
+[[package]]
+name = "glob"
+version = "0.3.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0cc23270f6e1808e30a928bdc84dea0b9b4136a8bc82338574f23baf47bbd280"
+
 [[package]]
 name = "half"
 version = "2.7.1"
@@ -1364,9 +2206,9 @@ dependencies = [
 
 [[package]]
 name = "hashbrown"
-version = "0.17.0"
+version = "0.17.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4f467dd6dccf739c208452f8014c75c18bb8301b050ad1cfb27153803edb0f51"
+checksum = "ed5909b6e89a2db4456e54cd5f673791d7eca6732202bbf2a9cc504fe2f9b84a"
 
 [[package]]
 name = "hashlink"
@@ -1446,6 +2288,12 @@ version = "1.10.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "6dbf3de79e51f3d586ab4cb9d5c3e2c14aa28ed23d180cf89b4df0454a69cc87"
 
+[[package]]
+name = "humantime"
+version = "2.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "135b12329e5e3ce057a9f972339ea52bc954fe1e9358ef27f95e89716fbc5424"
+
 [[package]]
 name = "hyper"
 version = "1.9.0"
@@ -1630,9 +2478,9 @@ dependencies = [
 
 [[package]]
 name = "idna_adapter"
-version = "1.2.1"
+version = "1.2.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "3acae9609540aa318d1bc588455225fb2085b9ed0c4f6bd0d9d5bcd86f1a0344"
+checksum = "cb68373c0d6620ef8105e855e7745e18b0d00d3bdb07fb532e434244cdb9a714"
 dependencies = [
  "icu_normalizer",
  "icu_properties",
@@ -1645,7 +2493,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "d466e9454f08e4a911e14806c24e16fba1b4c121d1ea474396f396069cf949d9"
 dependencies = [
  "equivalent",
- "hashbrown 0.17.0",
+ "hashbrown 0.17.1",
  "serde",
  "serde_core",
 ]
@@ -1662,22 +2510,21 @@ version = "2.12.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "d98f6fed1fde3f8c21bc40a1abb88dd75e67924f9cffc3ef95607bad8017f8e2"
 
-[[package]]
-name = "iri-string"
-version = "0.7.12"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "25e659a4bb38e810ebc252e53b5814ff908a8c58c2a9ce2fae1bbec24cbf4e20"
-dependencies = [
- "memchr",
- "serde",
-]
-
 [[package]]
 name = "is_terminal_polyfill"
 version = "1.70.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "a6cb138bb79a146c1bd460005623e142ef0181e3d0219cb493e02f7d08a35695"
 
+[[package]]
+name = "itertools"
+version = "0.14.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2b192c782037fadd9cfa75548310488aabdbf3d2da73885b31bd0abd03351285"
+dependencies = [
+ "either",
+]
+
 [[package]]
 name = "itoa"
 version = "1.0.18"
@@ -1696,9 +2543,9 @@ dependencies = [
 
 [[package]]
 name = "js-sys"
-version = "0.3.95"
+version = "0.3.98"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2964e92d1d9dc3364cae4d718d93f227e3abb088e747d92e0395bfdedf1c12ca"
+checksum = "67df7112613f8bfd9150013a0314e196f4800d3201ae742489d999db2f979f08"
 dependencies = [
  "cfg-if",
  "futures-util",
@@ -1879,18 +2726,6 @@ version = "0.2.16"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "b6d2cec3eae94f9f509c767b45932f1ada8350c4bdb85af2fcab4a3c14807981"
 
-[[package]]
-name = "libredox"
-version = "0.1.16"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e02f3bb43d335493c96bf3fd3a321600bf6bd07ed34bc64118e9293bdffea46c"
-dependencies = [
- "bitflags",
- "libc",
- "plain",
- "redox_syscall 0.7.4",
-]
-
 [[package]]
 name = "libsqlite3-sys"
 version = "0.36.0"
@@ -1947,6 +2782,15 @@ version = "0.1.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "112b39cec0b298b6c1999fee3e31427f74f676e4cb9879ed1a121b43661a4154"
 
+[[package]]
+name = "lz4_flex"
+version = "0.13.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7ef0d4ed8669f8f8826eb00dc878084aa8f253506c4fd5e8f58f5bce72ddb97e"
+dependencies = [
+ "twox-hash",
+]
+
 [[package]]
 name = "matchers"
 version = "0.2.0"
@@ -1993,6 +2837,12 @@ dependencies = [
  "windows-sys 0.61.2",
 ]
 
+[[package]]
+name = "multimap"
+version = "0.10.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1d87ecb2933e8aeadb3e3a02b828fed80a7528047e68b4f424523a0981a3a084"
+
 [[package]]
 name = "nu-ansi-term"
 version = "0.50.3"
@@ -2082,6 +2932,32 @@ dependencies = [
  "libm",
 ]
 
+[[package]]
+name = "object_store"
+version = "0.13.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "622acbc9100d3c10e2ee15804b0caa40e55c933d5aa53814cd520805b7958a49"
+dependencies = [
+ "async-trait",
+ "bytes",
+ "chrono",
+ "futures-channel",
+ "futures-core",
+ "futures-util",
+ "http",
+ "humantime",
+ "itertools",
+ "parking_lot",
+ "percent-encoding",
+ "thiserror 2.0.18",
+ "tokio",
+ "tracing",
+ "url",
+ "walkdir",
+ "wasm-bindgen-futures",
+ "web-time",
+]
+
 [[package]]
 name = "once_cell"
 version = "1.21.4"
@@ -2150,7 +3026,7 @@ checksum = "2621685985a2ebf1c516881c026032ac7deafcda1a2c9b7850dc81e3dfcb64c1"
 dependencies = [
  "cfg-if",
  "libc",
- "redox_syscall 0.5.18",
+ "redox_syscall",
  "smallvec",
  "windows-link",
 ]
@@ -2172,7 +3048,7 @@ dependencies = [
  "bytes",
  "chrono",
  "half",
- "hashbrown 0.17.0",
+ "hashbrown 0.17.1",
  "num-bigint",
  "num-integer",
  "num-traits",
@@ -2189,12 +3065,76 @@ version = "1.0.15"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "57c0d7b74b563b49d38dae00a0c37d4d6de9b432382b2892f0574ddcae73fd0a"
 
+[[package]]
+name = "path-slash"
+version = "0.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1e91099d4268b0e11973f036e885d652fb0b21fedcf69738c627f94db6a44f42"
+
+[[package]]
+name = "pbjson"
+version = "0.8.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "898bac3fa00d0ba57a4e8289837e965baa2dee8c3749f3b11d45a64b4223d9c3"
+dependencies = [
+ "base64",
+ "serde",
+]
+
+[[package]]
+name = "pbjson-build"
+version = "0.8.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "af22d08a625a2213a78dbb0ffa253318c5c79ce3133d32d296655a7bdfb02095"
+dependencies = [
+ "heck",
+ "itertools",
+ "prost",
+ "prost-types",
+]
+
+[[package]]
+name = "pbjson-types"
+version = "0.8.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8e748e28374f10a330ee3bb9f29b828c0ac79831a32bab65015ad9b661ead526"
+dependencies = [
+ "bytes",
+ "chrono",
+ "pbjson",
+ "pbjson-build",
+ "prost",
+ "prost-build",
+ "serde",
+]
+
 [[package]]
 name = "percent-encoding"
 version = "2.3.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "9b4f627cb1b25917193a259e49bdad08f671f8d9708acfd5fe0a8c1455d87220"
 
+[[package]]
+name = "petgraph"
+version = "0.8.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8701b58ea97060d5e5b155d383a69952a60943f0e6dfe30b04c287beb0b27455"
+dependencies = [
+ "fixedbitset",
+ "hashbrown 0.15.5",
+ "indexmap",
+ "serde",
+]
+
+[[package]]
+name = "phf"
+version = "0.12.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "913273894cec178f401a31ec4b656318d95473527be05c0752cc41cdc32be8b7"
+dependencies = [
+ "phf_shared 0.12.1",
+]
+
 [[package]]
 name = "phf"
 version = "0.13.1"
@@ -2202,7 +3142,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "c1562dc717473dbaa4c1f85a36410e03c047b2e7df7f45ee938fbef64ae7fadf"
 dependencies = [
  "phf_macros",
- "phf_shared",
+ "phf_shared 0.13.1",
  "serde",
 ]
 
@@ -2213,7 +3153,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "135ace3a761e564ec88c03a77317a7c6b80bb7f7135ef2544dbe054243b89737"
 dependencies = [
  "fastrand",
- "phf_shared",
+ "phf_shared 0.13.1",
 ]
 
 [[package]]
@@ -2223,13 +3163,22 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "812f032b54b1e759ccd5f8b6677695d5268c588701effba24601f6932f8269ef"
 dependencies = [
  "phf_generator",
- "phf_shared",
+ "phf_shared 0.13.1",
  "proc-macro2",
  "quote",
  "syn 2.0.117",
  "uncased",
 ]
 
+[[package]]
+name = "phf_shared"
+version = "0.12.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "06005508882fb681fd97892ecff4b7fd0fee13ef1aa569f8695dae7ab9099981"
+dependencies = [
+ "siphasher",
+]
+
 [[package]]
 name = "phf_shared"
 version = "0.13.1"
@@ -2252,12 +3201,6 @@ version = "0.3.33"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "19f132c84eca552bf34cab8ec81f1c1dcc229b811638f9d283dceabe58c5569e"
 
-[[package]]
-name = "plain"
-version = "0.2.3"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b4596b6d070b27117e987119b4dac604f3c58cfb0b191112e24771b2faeac1a6"
-
 [[package]]
 name = "potential_utf"
 version = "0.1.5"
@@ -2304,6 +3247,57 @@ dependencies = [
  "unicode-ident",
 ]
 
+[[package]]
+name = "prost"
+version = "0.14.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d2ea70524a2f82d518bce41317d0fae74151505651af45faf1ffbd6fd33f0568"
+dependencies = [
+ "bytes",
+ "prost-derive",
+]
+
+[[package]]
+name = "prost-build"
+version = "0.14.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "343d3bd7056eda839b03204e68deff7d1b13aba7af2b2fd16890697274262ee7"
+dependencies = [
+ "heck",
+ "itertools",
+ "log",
+ "multimap",
+ "petgraph",
+ "prettyplease",
+ "prost",
+ "prost-types",
+ "regex",
+ "syn 2.0.117",
+ "tempfile",
+]
+
+[[package]]
+name = "prost-derive"
+version = "0.14.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "27c6023962132f4b30eb4c172c91ce92d933da334c59c23cddee82358ddafb0b"
+dependencies = [
+ "anyhow",
+ "itertools",
+ "proc-macro2",
+ "quote",
+ "syn 2.0.117",
+]
+
+[[package]]
+name = "prost-types"
+version = "0.14.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8991c4cbdb8bc5b11f0b074ffe286c30e523de90fee5ba8132f1399f23cb3dd7"
+dependencies = [
+ "prost",
+]
+
 [[package]]
 name = "ptr_meta"
 version = "0.1.4"
@@ -2474,15 +3468,6 @@ dependencies = [
  "bitflags",
 ]
 
-[[package]]
-name = "redox_syscall"
-version = "0.7.4"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f450ad9c3b1da563fb6948a8e0fb0fb9269711c9c73d9ea1de5058c79c8d643a"
-dependencies = [
- "bitflags",
-]
-
 [[package]]
 name = "ref-cast"
 version = "1.0.25"
@@ -2547,6 +3532,16 @@ version = "0.8.10"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "dc897dd8d9e8bd1ed8cdad82b5966c3e0ecae09fb1907d58efaa013543185d0a"
 
+[[package]]
+name = "regress"
+version = "0.10.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2057b2325e68a893284d1538021ab90279adac1139957ca2a74426c6f118fb48"
+dependencies = [
+ "hashbrown 0.16.1",
+ "memchr",
+]
+
 [[package]]
 name = "rend"
 version = "0.4.2"
@@ -2667,9 +3662,9 @@ dependencies = [
 
 [[package]]
 name = "rust_decimal"
-version = "1.41.0"
+version = "1.42.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2ce901f9a19d251159075a4c37af514c3b8ef99c22e02dd8c19161cf397ee94a"
+checksum = "0c5108e3d4d903e21aac27f12ba5377b6b34f9f44b325e4894c7924169d06995"
 dependencies = [
  "arrayvec",
  "borsh",
@@ -2707,7 +3702,7 @@ dependencies = [
  "errno",
  "libc",
  "linux-raw-sys 0.4.15",
- "windows-sys 0.52.0",
+ "windows-sys 0.59.0",
 ]
 
 [[package]]
@@ -2725,9 +3720,9 @@ dependencies = [
 
 [[package]]
 name = "rustls"
-version = "0.23.39"
+version = "0.23.40"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "7c2c118cb077cca2822033836dfb1b975355dfb784b5e8da48f7b6c5db74e60e"
+checksum = "ef86cd5876211988985292b91c96a8f2d298df24e75989a43a3c73f2d4d8168b"
 dependencies = [
  "log",
  "once_cell",
@@ -2740,9 +3735,9 @@ dependencies = [
 
 [[package]]
 name = "rustls-pki-types"
-version = "1.14.0"
+version = "1.14.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "be040f8b0a225e40375822a563fa9524378b9d63112f53e19ffff34df5d33fdd"
+checksum = "30a7197ae7eb376e574fe940d068c30fe0462554a3ddbe4eca7838e049c937a9"
 dependencies = [
  "web-time",
  "zeroize",
@@ -2771,6 +3766,39 @@ version = "1.0.23"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "9774ba4a74de5f7b1c1451ed6cd5285a32eddb5cccb8cc655a4e50009e06477f"
 
+[[package]]
+name = "same-file"
+version = "1.0.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "93fc1dc3aaa9bfed95e02e6eadabb4baf7e3078b0bd1b4d7b6b0b68378900502"
+dependencies = [
+ "winapi-util",
+]
+
+[[package]]
+name = "schemars"
+version = "0.8.22"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3fbf2ae1b8bc8e02df939598064d22402220cd5bbcca1c76f7d6a310974d5615"
+dependencies = [
+ "dyn-clone",
+ "schemars_derive",
+ "serde",
+ "serde_json",
+]
+
+[[package]]
+name = "schemars_derive"
+version = "0.8.22"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "32e265784ad618884abaea0600a9adf15393368d840e0222d101a072f3f7534d"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "serde_derive_internals",
+ "syn 2.0.117",
+]
+
 [[package]]
 name = "scopeguard"
 version = "1.2.0"
@@ -2794,6 +3822,10 @@ name = "semver"
 version = "1.0.28"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "8a7852d02fc848982e0c167ef163aaff9cd91dc640ba85e263cb1ce46fae51cd"
+dependencies = [
+ "serde",
+ "serde_core",
+]
 
 [[package]]
 name = "seq-macro"
@@ -2831,6 +3863,17 @@ dependencies = [
  "syn 2.0.117",
 ]
 
+[[package]]
+name = "serde_derive_internals"
+version = "0.29.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "18d26a20a969b9e3fdf2fc2d9f21eda6c40e2de84c9408bb5d3b05d499aae711"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 2.0.117",
+]
+
 [[package]]
 name = "serde_json"
 version = "1.0.149"
@@ -2845,6 +3888,27 @@ dependencies = [
  "zmij",
 ]
 
+[[package]]
+name = "serde_spanned"
+version = "1.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6662b5879511e06e8999a8a235d848113e942c9124f211511b16466ee2995f26"
+dependencies = [
+ "serde_core",
+]
+
+[[package]]
+name = "serde_tokenstream"
+version = "0.2.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d7c49585c52c01f13c5c2ebb333f14f6885d76daa768d8a037d28017ec538c69"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "serde",
+ "syn 2.0.117",
+]
+
 [[package]]
 name = "serde_urlencoded"
 version = "0.7.1"
@@ -2857,6 +3921,19 @@ dependencies = [
  "serde",
 ]
 
+[[package]]
+name = "serde_yaml"
+version = "0.9.34+deprecated"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6a8b1a1a2ebf674015cc02edccce75287f1a0130d394307b36743c2f5d504b47"
+dependencies = [
+ "indexmap",
+ "itoa",
+ "ryu",
+ "serde",
+ "unsafe-libyaml",
+]
+
 [[package]]
 name = "sha2"
 version = "0.10.9"
@@ -2928,9 +4005,9 @@ checksum = "e3a9fe34e3e7a50316060351f37187a3f546bce95496156754b601a5fa71b76e"
 
 [[package]]
 name = "siphasher"
-version = "1.0.2"
+version = "1.0.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b2aa850e253778c88a04c3d7323b043aeda9d3e30d5971937c1855769763678e"
+checksum = "8ee5873ec9cce0195efcb7a4e9507a04cd49aec9c83d0389df45b1ef7ba2e649"
 
 [[package]]
 name = "slab"
@@ -2981,6 +4058,27 @@ dependencies = [
  "wasm-bindgen",
 ]
 
+[[package]]
+name = "sqlparser"
+version = "0.61.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "dbf5ea8d4d7c808e1af1cbabebca9a2abe603bcefc22294c5b95018d53200cb7"
+dependencies = [
+ "log",
+ "sqlparser_derive",
+]
+
+[[package]]
+name = "sqlparser_derive"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a6dd45d8fc1c79299bfbb7190e42ccbbdf6a5f52e4a6ad98d92357ea965bd289"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 2.0.117",
+]
+
 [[package]]
 name = "stable_deref_trait"
 version = "1.2.1"
@@ -3005,44 +4103,50 @@ version = "0.11.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "7da8b5736845d9f2fcb837ea5d9e2628564b3b043a70948a3f0b778838c5fb4f"
 
-[[package]]
-name = "strum"
-version = "0.26.3"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "8fec0f0aef304996cf250b31b5a10dee7980c85da9d759361292b8bca5a18f06"
-
 [[package]]
 name = "strum"
 version = "0.27.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "af23d6f6c1a224baef9d3f61e287d2761385a5b88fdab4eb4c6f11aeb54c4bcf"
 dependencies = [
- "strum_macros 0.27.2",
+ "strum_macros",
 ]
 
 [[package]]
 name = "strum_macros"
-version = "0.26.4"
+version = "0.27.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4c6bee85a5a24955dc440386795aa378cd9cf82acd5f764469152d2270e581be"
+checksum = "7695ce3845ea4b33927c055a39dc438a45b059f7c1b3d91d38d10355fb8cbca7"
 dependencies = [
  "heck",
  "proc-macro2",
  "quote",
- "rustversion",
  "syn 2.0.117",
 ]
 
 [[package]]
-name = "strum_macros"
-version = "0.27.2"
+name = "substrait"
+version = "0.62.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "7695ce3845ea4b33927c055a39dc438a45b059f7c1b3d91d38d10355fb8cbca7"
+checksum = "62fc4b483a129b9772ccb9c3f7945a472112fdd9140da87f8a4e7f1d44e045d0"
 dependencies = [
  "heck",
- "proc-macro2",
- "quote",
+ "pbjson",
+ "pbjson-build",
+ "pbjson-types",
+ "prettyplease",
+ "prost",
+ "prost-build",
+ "prost-types",
+ "regress",
+ "schemars",
+ "semver",
+ "serde",
+ "serde_json",
+ "serde_yaml",
  "syn 2.0.117",
+ "typify",
+ "walkdir",
 ]
 
 [[package]]
@@ -3235,9 +4339,9 @@ checksum = "1f3ccbac311fea05f86f61904b462b55fb3df8837a366dfc601a0161d0532f20"
 
 [[package]]
 name = "tokio"
-version = "1.52.1"
+version = "1.52.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b67dee974fe86fd92cc45b7a95fdd2f99a36a6d7b0d431a231178d3d670bbcc6"
+checksum = "8fc7f01b389ac15039e4dc9531aa973a135d7a4135281b12d7c1bc79fd57fffe"
 dependencies = [
  "bytes",
  "libc",
@@ -3271,6 +4375,18 @@ dependencies = [
  "tokio",
 ]
 
+[[package]]
+name = "tokio-stream"
+version = "0.1.18"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "32da49809aab5c3bc678af03902d4ccddea2a87d028d86392a4b1560c6906c70"
+dependencies = [
+ "futures-core",
+ "pin-project-lite",
+ "tokio",
+ "tokio-util",
+]
+
 [[package]]
 name = "tokio-util"
 version = "0.7.18"
@@ -3285,6 +4401,19 @@ dependencies = [
  "tokio",
 ]
 
+[[package]]
+name = "toml"
+version = "1.1.2+spec-1.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "81f3d15e84cbcd896376e6730314d59fb5a87f31e4b038454184435cd57defee"
+dependencies = [
+ "serde_spanned",
+ "toml_datetime 1.1.1+spec-1.1.0",
+ "toml_parser",
+ "toml_writer",
+ "winnow 1.0.2",
+]
+
 [[package]]
 name = "toml_datetime"
 version = "0.6.11"
@@ -3339,6 +4468,12 @@ version = "0.1.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "5d99f8c9a7727884afe522e9bd5edbfc91a3312b36a77b5fb8926e4c31a41801"
 
+[[package]]
+name = "toml_writer"
+version = "1.1.1+spec-1.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "756daf9b1013ebe47a8776667b466417e2d4c5679d441c26230efd9ef78692db"
+
 [[package]]
 name = "tower"
 version = "0.5.3"
@@ -3356,20 +4491,20 @@ dependencies = [
 
 [[package]]
 name = "tower-http"
-version = "0.6.8"
+version = "0.6.10"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d4e6559d53cc268e5031cd8429d05415bc4cb4aefc4aa5d6cc35fbf5b924a1f8"
+checksum = "68d6fdd9f81c2819c9a8b0e0cd91660e7746a8e6ea2ba7c6b2b057985f6bcb51"
 dependencies = [
  "bitflags",
  "bytes",
  "futures-util",
  "http",
  "http-body",
- "iri-string",
  "pin-project-lite",
  "tower",
  "tower-layer",
  "tower-service",
+ "url",
 ]
 
 [[package]]
@@ -3491,6 +4626,53 @@ version = "1.20.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "40ce102ab67701b8526c123c1bab5cbe42d7040ccfd0f64af1a385808d2f43de"
 
+[[package]]
+name = "typify"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e6d5bcc6f62eb1fa8aa4098f39b29f93dcb914e17158b76c50360911257aa629"
+dependencies = [
+ "typify-impl",
+ "typify-macro",
+]
+
+[[package]]
+name = "typify-impl"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a1eb359f7ffa4f9ebe947fa11a1b2da054564502968db5f317b7e37693cb2240"
+dependencies = [
+ "heck",
+ "log",
+ "proc-macro2",
+ "quote",
+ "regress",
+ "schemars",
+ "semver",
+ "serde",
+ "serde_json",
+ "syn 2.0.117",
+ "thiserror 2.0.18",
+ "unicode-ident",
+]
+
+[[package]]
+name = "typify-macro"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "911c32f3c8514b048c1b228361bebb5e6d73aeec01696e8cc0e82e2ffef8ab7a"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "schemars",
+ "semver",
+ "serde",
+ "serde_json",
+ "serde_tokenstream",
+ "syn 2.0.117",
+ "typify-impl",
+]
+
 [[package]]
 name = "uncased"
 version = "0.9.10"
@@ -3536,6 +4718,12 @@ version = "0.2.6"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "ebc1c04c71510c7f702b52b7c350734c9ff1295c464a03335b00bb84fc54f853"
 
+[[package]]
+name = "unsafe-libyaml"
+version = "0.2.11"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "673aac59facbab8a9007c7f6108d11f63b603f7cabff99fabf650fea5c32b861"
+
 [[package]]
 name = "untrusted"
 version = "0.9.0"
@@ -3646,6 +4834,16 @@ version = "0.8.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "5c3082ca00d5a5ef149bb8b555a72ae84c9c59f7250f013ac822ac2e49b19c64"
 
+[[package]]
+name = "walkdir"
+version = "2.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "29790946404f91d9c5d06f9874efddea1dc06c5efe94541a7d6863108e3a5e4b"
+dependencies = [
+ "same-file",
+ "winapi-util",
+]
+
 [[package]]
 name = "want"
 version = "0.3.1"
@@ -3681,9 +4879,9 @@ dependencies = [
 
 [[package]]
 name = "wasm-bindgen"
-version = "0.2.118"
+version = "0.2.121"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0bf938a0bacb0469e83c1e148908bd7d5a6010354cf4fb73279b7447422e3a89"
+checksum = "49ace1d07c165b0864824eee619580c4689389afa9dc9ed3a4c75040d82e6790"
 dependencies = [
  "cfg-if",
  "once_cell",
@@ -3695,9 +4893,9 @@ dependencies = [
 
 [[package]]
 name = "wasm-bindgen-futures"
-version = "0.4.68"
+version = "0.4.71"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f371d383f2fb139252e0bfac3b81b265689bf45b6874af544ffa4c975ac1ebf8"
+checksum = "96492d0d3ffba25305a7dc88720d250b1401d7edca02cc3bcd50633b424673b8"
 dependencies = [
  "js-sys",
  "wasm-bindgen",
@@ -3705,9 +4903,9 @@ dependencies = [
 
 [[package]]
 name = "wasm-bindgen-macro"
-version = "0.2.118"
+version = "0.2.121"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "eeff24f84126c0ec2db7a449f0c2ec963c6a49efe0698c4242929da037ca28ed"
+checksum = "8e68e6f4afd367a562002c05637acb8578ff2dea1943df76afb9e83d177c8578"
 dependencies = [
  "quote",
  "wasm-bindgen-macro-support",
@@ -3715,9 +4913,9 @@ dependencies = [
 
 [[package]]
 name = "wasm-bindgen-macro-support"
-version = "0.2.118"
+version = "0.2.121"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9d08065faf983b2b80a79fd87d8254c409281cf7de75fc4b773019824196c904"
+checksum = "d95a9ec35c64b2a7cb35d3fead40c4238d0940c86d107136999567a4703259f2"
 dependencies = [
  "bumpalo",
  "proc-macro2",
@@ -3728,9 +4926,9 @@ dependencies = [
 
 [[package]]
 name = "wasm-bindgen-shared"
-version = "0.2.118"
+version = "0.2.121"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "5fd04d9e306f1907bd13c6361b5c6bfc7b3b3c095ed3f8a9246390f8dbdee129"
+checksum = "c4e0100b01e9f0d03189a92b96772a1fb998639d981193d7dbab487302513441"
 dependencies = [
  "unicode-ident",
 ]
@@ -3771,9 +4969,9 @@ dependencies = [
 
 [[package]]
 name = "web-sys"
-version = "0.3.95"
+version = "0.3.98"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4f2dfbb17949fa2088e5d39408c48368947b86f7834484e87b73de55bc14d97d"
+checksum = "4b572dff8bcf38bad0fa19729c89bb5748b2b9b1d8be70cf90df697e3a8f32aa"
 dependencies = [
  "js-sys",
  "wasm-bindgen",
@@ -3814,6 +5012,15 @@ version = "0.4.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "ac3b87c63620426dd9b991e5ce0329eff545bccbbb34f3be09ff6fb6ab51b7b6"
 
+[[package]]
+name = "winapi-util"
+version = "0.1.11"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c2a7b1c03c876122aa43f3020e6c3c3ee5c05081c9a00739faf7503aeba10d22"
+dependencies = [
+ "windows-sys 0.61.2",
+]
+
 [[package]]
 name = "winapi-x86_64-pc-windows-gnu"
 version = "0.4.0"
@@ -3861,6 +5068,17 @@ version = "0.2.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "f0805222e57f7521d6a62e36fa9163bc891acd422f971defe97d64e70d0a4fe5"
 
+[[package]]
+name = "windows-registry"
+version = "0.6.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "02752bf7fbdcce7f2a27a742f798510f3e5ad88dbe84871e5168e2120c3d5720"
+dependencies = [
+ "windows-link",
+ "windows-result",
+ "windows-strings",
+]
+
 [[package]]
 name = "windows-result"
 version = "0.4.1"
@@ -3888,6 +5106,15 @@ dependencies = [
  "windows-targets 0.52.6",
 ]
 
+[[package]]
+name = "windows-sys"
+version = "0.59.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1e38bc4d79ed67fd075bcc251a1c39b32a1776bbe92e5bef1f0bf1f8c531853b"
+dependencies = [
+ "windows-targets 0.52.6",
+]
+
 [[package]]
 name = "windows-sys"
 version = "0.60.2"
@@ -4229,9 +5456,9 @@ dependencies = [
 
 [[package]]
 name = "zerofrom"
-version = "0.1.7"
+version = "0.1.8"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "69faa1f2a1ea75661980b013019ed6687ed0e83d069bc1114e2cc74c6c04c4df"
+checksum = "0ec05a11813ea801ff6d75110ad09cd0824ddba17dfe17128ea0d5f68e6c5272"
 dependencies = [
  "zerofrom-derive",
 ]
@@ -4264,7 +5491,7 @@ dependencies = [
  "asynchronous-codec",
  "bytes",
  "crossbeam-queue",
- "dashmap",
+ "dashmap 5.5.3",
  "futures-channel",
  "futures-io",
  "futures-task",
diff --git a/src/Cargo.toml b/src/Cargo.toml
index 9bcd0d8d9..264ae7061 100644
--- a/src/Cargo.toml
+++ b/src/Cargo.toml
@@ -32,6 +32,9 @@ libloading = { workspace = true, optional = true }
 parquet = { workspace = true, optional = true }
 bytes = { workspace = true }
 
+# ADBC reader
+adbc_core = { version = "0.23", optional = true }
+
 # Spatial
 geozero = { workspace = true, optional = true, features = ["with-wkb", "with-geojson"] }
 
@@ -54,12 +57,15 @@ uuid.workspace = true
 jsonschema = { version = "0.44", default-features = false, features = ["resolve-file"] }
 tempfile = "3.8"
 ureq = "3"
+adbc_datafusion = "0.23"
+adbc_driver_manager = "0.23"
 
 [features]
-default = ["duckdb", "sqlite", "vegalite", "parquet", "builtin-data", "odbc", "spatial"]
+default = ["adbc", "duckdb", "sqlite", "vegalite", "parquet", "builtin-data", "odbc", "spatial"]
 duckdb = ["dep:duckdb"]
 parquet = ["dep:parquet"]
 sqlite = ["dep:rusqlite"]
+adbc = ["dep:adbc_core"]
 odbc = ["dep:toml_edit", "dep:libloading"]
 spatial = ["dep:geozero"]
 vegalite = []
diff --git a/src/reader/adbc.rs b/src/reader/adbc.rs
new file mode 100644
index 000000000..8de00b01d
--- /dev/null
+++ b/src/reader/adbc.rs
@@ -0,0 +1,821 @@
+//! ADBC (Arrow Database Connectivity) reader.
+//!
+//! Generic over any concrete ADBC `Driver` implementation. Verified against
+//! two drivers in this crate's tests:
+//!
+//! - `adbc_datafusion` — pure-Rust, in-process. Used for routing and
+//!   conversion unit tests where loading a native driver isn't worth the
+//!   build complexity.
+//! - `adbc_driver_duckdb` (loaded via `adbc_driver_manager::ManagedDriver`)
+//!   — a real ADBC C driver, used for an equivalence suite that compares
+//!   `AdbcReader<DuckDB>` output against ggsql's existing `DuckDBReader`.
+//!
+//! The `Reader` trait takes `&self`, but ADBC's `Statement` API takes
+//! `&mut self`. We bridge this with `RefCell` around the `Connection`,
+//! mirroring the interior-mutability pattern used by `OdbcReader`.
+
+use crate::reader::{AnsiDialect, Reader, SqlDialect};
+use crate::{DataFrame, GgsqlError, Result};
+use adbc_core::sync::{Connection, Database, Driver};
+use std::cell::RefCell;
+use std::collections::HashSet;
+
+pub struct AdbcReader<D: Driver> {
+    // Driver must stay alive as long as the Database does (per ADBC contract).
+    _driver: D,
+    // Database must stay alive as long as the Connection does.
+    _database: D::DatabaseType,
+    // Connection is what Statements are made from. Wrapped in RefCell because
+    // new_statement / set_sql_query / execute all take &mut, but Reader::execute_sql
+    // takes &self.
+    connection: RefCell<<D::DatabaseType as Database>::ConnectionType>,
+    dialect: Box<dyn SqlDialect + Send>,
+    registered_tables: RefCell<HashSet<String>>,
+}
+
+impl<D: Driver> AdbcReader<D> {
+    /// Construct an `AdbcReader` with an explicit `SqlDialect`. Use this to
+    /// plug in backend-specific dialects (e.g. a TrinoDialect, SnowflakeDialect)
+    /// when the reader is pointed at that backend.
+    pub fn with_dialect(driver: D, dialect: Box<dyn SqlDialect + Send>) -> Result<Self> {
+        Self::new(driver, dialect)
+    }
+
+    /// Create a new `AdbcReader` from an already-initialized ADBC driver.
+    ///
+    /// Callers are responsible for any pre-init `Database` / `Connection`
+    /// options. For convenience, use `from_driver` for the common case
+    /// with the ANSI dialect, or pass a custom `SqlDialect`
+    /// (e.g. a Trino / Snowflake dialect) here directly.
+    pub fn new(mut driver: D, dialect: Box<dyn SqlDialect + Send>) -> Result<Self> {
+        let database = driver
+            .new_database()
+            .map_err(|e| GgsqlError::ReaderError(format!("ADBC new_database failed: {}", e)))?;
+        let connection = database
+            .new_connection()
+            .map_err(|e| GgsqlError::ReaderError(format!("ADBC new_connection failed: {}", e)))?;
+        Ok(Self {
+            _driver: driver,
+            _database: database,
+            connection: RefCell::new(connection),
+            dialect,
+            registered_tables: RefCell::new(HashSet::new()),
+        })
+    }
+
+    /// Create a new `AdbcReader`, passing pre-init options to the underlying
+    /// `Database`. Use this when the driver requires URI / credentials / RPC
+    /// header options to be set before the first connection (e.g. Flight SQL
+    /// or other auth-required backends).
+    pub fn new_with_database_opts(
+        mut driver: D,
+        dialect: Box<dyn SqlDialect + Send>,
+        opts: impl IntoIterator<
+            Item = (
+                adbc_core::options::OptionDatabase,
+                adbc_core::options::OptionValue,
+            ),
+        >,
+    ) -> Result<Self> {
+        let database = driver.new_database_with_opts(opts).map_err(|e| {
+            GgsqlError::ReaderError(format!("ADBC new_database_with_opts failed: {}", e))
+        })?;
+        let connection = database
+            .new_connection()
+            .map_err(|e| GgsqlError::ReaderError(format!("ADBC new_connection failed: {}", e)))?;
+        Ok(Self {
+            _driver: driver,
+            _database: database,
+            connection: RefCell::new(connection),
+            dialect,
+            registered_tables: RefCell::new(HashSet::new()),
+        })
+    }
+
+    /// Convenience: construct with the ANSI dialect. Good default for
+    /// standards-compliant backends; use `new` directly to plug in a
+    /// backend-specific dialect.
+    pub fn from_driver(driver: D) -> Result<Self> {
+        Self::new(driver, Box::new(AnsiDialect))
+    }
+}
+
+use adbc_core::sync::Statement;
+use arrow::record_batch::RecordBatch;
+
+impl<D: Driver + 'static> Reader for AdbcReader<D>
+where
+    D::DatabaseType: 'static,
+    <D::DatabaseType as Database>::ConnectionType: 'static,
+{
+    fn execute_sql(&self, sql: &str) -> Result<DataFrame> {
+        use arrow::array::RecordBatchReader as _;
+
+        // Drain the `RecordBatchReader` *inside* the connection-borrow scope
+        // so `stmt` and the `RefMut<Connection>` stay alive while batches are
+        // streamed from the server. The `FlightSQL` driver's reader holds a
+        // gRPC stream whose context is tied to the Statement; if `stmt` drops
+        // before iteration completes, the first `DoGet` call cancels with
+        // `Canceled; DoGet: endpoint 0: []`. Other ADBC drivers (DataFusion,
+        // etc.) return self-sufficient readers, but paying for an extra early
+        // release on those is worthwhile to keep a single correct code path.
+        let (schema, batches) = {
+            let mut conn = self.connection.try_borrow_mut().map_err(|_| {
+                GgsqlError::ReaderError(
+                    "AdbcReader is already mutably borrowed — another \
+                     `execute_sql`/`register`/`unregister` is in progress \
+                     on this reader"
+                        .into(),
+                )
+            })?;
+            let mut stmt = conn
+                .new_statement()
+                .map_err(|e| GgsqlError::ReaderError(format!("ADBC new_statement: {}", e)))?;
+            stmt.set_sql_query(sql)
+                .map_err(|e| GgsqlError::ReaderError(format!("ADBC set_sql_query: {}", e)))?;
+            let reader = stmt
+                .execute()
+                .map_err(|e| GgsqlError::ReaderError(format!("ADBC execute: {}", e)))?;
+
+            // Capture the declared result schema before draining batches —
+            // the reader carries it even when zero batches are produced, and
+            // we need it to preserve column names on empty results.
+            let schema = reader.schema();
+            let mut batches: Vec<RecordBatch> = Vec::new();
+            for batch in reader {
+                batches.push(batch.map_err(|e| {
+                    GgsqlError::ReaderError(format!("ADBC RecordBatch iter: {}", e))
+                })?);
+            }
+            (schema, batches)
+        };
+
+        let merged = if batches.is_empty() {
+            RecordBatch::new_empty(schema)
+        } else if batches.len() == 1 {
+            batches.into_iter().next().unwrap()
+        } else {
+            arrow::compute::concat_batches(&schema, &batches)
+                .map_err(|e| GgsqlError::ReaderError(format!("concat_batches: {}", e)))?
+        };
+        Ok(DataFrame::from_record_batch(merged))
+    }
+
+    fn register(&self, name: &str, df: DataFrame, replace: bool) -> Result<()> {
+        super::validate_table_name(name)?;
+
+        use adbc_core::options::{IngestMode, OptionStatement, OptionValue};
+        use adbc_core::Optionable;
+
+        if df.height() == 0 {
+            return Err(GgsqlError::ReaderError(
+                "AdbcReader::register: empty DataFrame not supported".into(),
+            ));
+        }
+        let batch = df.into_inner();
+
+        let mut conn = self.connection.try_borrow_mut().map_err(|_| {
+            GgsqlError::ReaderError(
+                "AdbcReader::register called re-entrantly — another operation \
+                 is still holding the connection on this reader"
+                    .into(),
+            )
+        })?;
+
+        // Bulk-insert path: CREATE TABLE via SQL DDL, then for each batch set
+        // `TargetTable` + `IngestMode::Append` + `bind(batch)` +
+        // `execute_update()`. We do the CREATE ourselves (rather than relying
+        // on `IngestMode::Create`) so we control the column types via the
+        // `SqlDialect` and so registers behave identically across drivers
+        // with varying ingest-option support — in particular,
+        // `adbc_datafusion` 0.23 has `bind_stream` as `todo!()` and rejects
+        // the `IngestMode` option key (`set_option` returns `NotFound`),
+        // which is silently tolerated below.
+        let schema = batch.schema();
+        if replace {
+            let drop_sql = format!("DROP TABLE IF EXISTS {}", crate::naming::quote_ident(name));
+            let mut drop_stmt = conn
+                .new_statement()
+                .map_err(|e| GgsqlError::ReaderError(format!("ADBC new_statement: {}", e)))?;
+            drop_stmt
+                .set_sql_query(&drop_sql)
+                .map_err(|e| GgsqlError::ReaderError(format!("ADBC set_sql_query DROP: {}", e)))?;
+            drop_stmt
+                .execute_update()
+                .map_err(|e| GgsqlError::ReaderError(format!("ADBC execute_update DROP: {}", e)))?;
+        }
+
+        let create_sql = create_table_sql(name, &schema, &*self.dialect)?;
+        let mut create_stmt = conn
+            .new_statement()
+            .map_err(|e| GgsqlError::ReaderError(format!("ADBC new_statement: {}", e)))?;
+        create_stmt
+            .set_sql_query(&create_sql)
+            .map_err(|e| GgsqlError::ReaderError(format!("ADBC set_sql_query CREATE: {}", e)))?;
+        create_stmt
+            .execute_update()
+            .map_err(|e| GgsqlError::ReaderError(format!("ADBC execute_update CREATE: {}", e)))?;
+
+        // Track the table in our set as soon as CREATE succeeds — BEFORE the
+        // potentially-multi-batch ingest loop. If a bind or execute_update
+        // fails mid-way, the (partial) table still exists on the server;
+        // having the name tracked lets the caller `unregister()` to clean
+        // up, and a subsequent `register(name, ..., replace=true)` will
+        // drop-and-recreate. Without this, a mid-ingest failure would leave
+        // an orphan table the reader can't reach.
+        self.registered_tables.borrow_mut().insert(name.to_string());
+
+        {
+            let mut stmt = conn
+                .new_statement()
+                .map_err(|e| GgsqlError::ReaderError(format!("ADBC new_statement: {}", e)))?;
+            stmt.set_option(
+                OptionStatement::TargetTable,
+                OptionValue::String(name.to_string()),
+            )
+            .map_err(|e| GgsqlError::ReaderError(format!("ADBC set TargetTable: {}", e)))?;
+            // Tell the driver this is an append into the table we just
+            // CREATEd above. Compliant ADBC drivers (e.g. the Apache SQLite
+            // driver) default `IngestMode` to `Create` when only `TargetTable`
+            // is set, which would then fail because the table already exists.
+            // DataFusion 0.23 doesn't expose this option key and returns
+            // `Status::NotFound` from `set_option`; that's expected for
+            // DataFusion's bind path (it appends by default), so swallow it
+            // and continue rather than failing register().
+            if let Err(e) = stmt.set_option(
+                OptionStatement::IngestMode,
+                OptionValue::from(IngestMode::Append),
+            ) {
+                if e.status != adbc_core::error::Status::NotFound {
+                    return Err(GgsqlError::ReaderError(format!(
+                        "ADBC set IngestMode=Append: {}",
+                        e
+                    )));
+                }
+            }
+            stmt.bind(batch)
+                .map_err(|e| GgsqlError::ReaderError(format!("ADBC bind: {}", e)))?;
+            stmt.execute_update().map_err(|e| {
+                GgsqlError::ReaderError(format!(
+                    "ADBC execute_update: {} — \
+                     table left on server; call unregister() to drop it \
+                     or register() with replace=true to retry",
+                    e
+                ))
+            })?;
+        }
+
+        Ok(())
+    }
+
+    fn unregister(&self, name: &str) -> Result<()> {
+        if !self.registered_tables.borrow().contains(name) {
+            return Err(GgsqlError::ReaderError(format!(
+                "Table '{}' was not registered via this reader",
+                name
+            )));
+        }
+        let sql = format!("DROP TABLE IF EXISTS {}", crate::naming::quote_ident(name));
+        // Ignore the returned DataFrame — DROP TABLE has no result rows.
+        self.execute_sql(&sql)?;
+        self.registered_tables.borrow_mut().remove(name);
+        Ok(())
+    }
+
+    fn execute(&self, query: &str) -> Result<crate::reader::Spec> {
+        crate::reader::execute_with_reader(self, query)
+    }
+
+    fn dialect(&self) -> &dyn SqlDialect {
+        &*self.dialect
+    }
+}
+
+/// Build a `CREATE TABLE <name> (col1 TYPE, col2 TYPE, ...)` statement from
+/// an Arrow schema, using the reader's `SqlDialect` for type names.
+///
+/// Used by `register()` to create the destination table before binding
+/// batches with `IngestMode::Append`; see the `register` impl for context.
+fn create_table_sql(
+    name: &str,
+    schema: &arrow::datatypes::Schema,
+    dialect: &dyn SqlDialect,
+) -> Result<String> {
+    use arrow::datatypes::DataType;
+
+    let mut cols: Vec<String> = Vec::with_capacity(schema.fields().len());
+    for field in schema.fields() {
+        let ty_name: &str = match field.data_type() {
+            DataType::Boolean => dialect.boolean_type_name().unwrap_or("BOOLEAN"),
+            DataType::Int8
+            | DataType::Int16
+            | DataType::Int32
+            | DataType::Int64
+            | DataType::UInt8
+            | DataType::UInt16
+            | DataType::UInt32
+            | DataType::UInt64 => dialect.integer_type_name().unwrap_or("BIGINT"),
+            DataType::Float16 | DataType::Float32 | DataType::Float64 => {
+                dialect.number_type_name().unwrap_or("DOUBLE PRECISION")
+            }
+            DataType::Utf8 | DataType::LargeUtf8 | DataType::Utf8View => {
+                dialect.string_type_name().unwrap_or("VARCHAR")
+            }
+            DataType::Date32 | DataType::Date64 => dialect.date_type_name().unwrap_or("DATE"),
+            DataType::Timestamp(_, _) => dialect.datetime_type_name().unwrap_or("TIMESTAMP"),
+            DataType::Time32(_) | DataType::Time64(_) => dialect.time_type_name().unwrap_or("TIME"),
+            other => {
+                return Err(GgsqlError::ReaderError(format!(
+                    "AdbcReader::register: unsupported Arrow type for column '{}': {:?}",
+                    field.name(),
+                    other
+                )));
+            }
+        };
+        cols.push(format!(
+            "{} {}",
+            crate::naming::quote_ident(field.name()),
+            ty_name
+        ));
+    }
+
+    Ok(format!(
+        "CREATE TABLE {} ({})",
+        crate::naming::quote_ident(name),
+        cols.join(", ")
+    ))
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use adbc_datafusion::DataFusionDriver;
+
+    /// Construct a reader over an in-process DataFusion ADBC driver.
+    /// DataFusion starts empty; callers register tables via the reader's
+    /// `register()` method (added in Task 4) or via raw SQL DDL.
+    fn fixture_reader() -> AdbcReader<DataFusionDriver> {
+        AdbcReader::from_driver(DataFusionDriver::new(None)).expect("datafusion init")
+    }
+
+    #[test]
+    fn execute_sql_returns_scalar_result() {
+        use crate::array_util::as_i64;
+        let reader = fixture_reader();
+        let df = reader
+            .execute_sql("SELECT 1 AS one, 'hello' AS greeting")
+            .expect("query ok");
+        assert_eq!(df.height(), 1);
+        assert_eq!(df.width(), 2);
+        let one = as_i64(df.column("one").unwrap()).unwrap().value(0);
+        assert_eq!(one, 1);
+    }
+
+    #[test]
+    fn register_then_query_roundtrip() {
+        use crate::array_util::as_i64;
+        use crate::df;
+
+        let reader = fixture_reader();
+        let df = df! {
+            "x" => vec![1i64, 2, 3],
+            "y" => vec!["a", "b", "c"],
+        }
+        .unwrap();
+        reader.register("t", df, false).expect("register ok");
+
+        let out = reader
+            .execute_sql("SELECT COUNT(*) AS n FROM t")
+            .expect("count ok");
+        let n = as_i64(out.column("n").unwrap()).unwrap().value(0);
+        assert_eq!(n, 3);
+    }
+
+    #[test]
+    fn unregister_removes_table() {
+        use crate::df;
+
+        let reader = fixture_reader();
+        let df = df! { "x" => vec![1i64] }.unwrap();
+        reader.register("tmp", df, false).unwrap();
+
+        // First unregister should succeed: table was registered via this reader.
+        reader.unregister("tmp").expect("unregister ok");
+
+        // Second unregister must fail: the name was removed from
+        // registered_tables, so the guard in unregister() triggers.
+        // This verifies the bookkeeping without triggering the
+        // adbc_datafusion 0.23 Statement::execute panic that happens on
+        // `SELECT * FROM <dropped-table>` (the driver .unwrap()s a DataFusion
+        // planning error at lib.rs:913 instead of returning a proper ADBC
+        // error — captured in Task 9 findings).
+        let err = reader.unregister("tmp").unwrap_err();
+        assert!(matches!(err, GgsqlError::ReaderError(_)));
+    }
+
+    #[test]
+    fn with_dialect_plumbs_custom_dialect_through() {
+        // Dummy dialect that overrides a recognizable method so we can verify
+        // the reader actually stored and exposes our dialect rather than the
+        // default AnsiDialect.
+        struct ShoutyDialect;
+        impl super::SqlDialect for ShoutyDialect {
+            fn integer_type_name(&self) -> Option<&str> {
+                Some("SHOUTY_BIGINT")
+            }
+        }
+
+        let reader = AdbcReader::with_dialect(DataFusionDriver::new(None), Box::new(ShoutyDialect))
+            .expect("reader");
+
+        // The Reader trait's dialect() accessor should return our ShoutyDialect.
+        assert_eq!(reader.dialect().integer_type_name(), Some("SHOUTY_BIGINT"));
+    }
+
+    #[test]
+    #[ignore = "ggsql's execute pipeline issues `CREATE OR REPLACE TEMP TABLE` for layer/stat \
+                materialization, which adbc_datafusion 0.23 rejects with `NotImplemented(\"Temporary \
+                tables not supported\")`. The full pipeline works against any driver that supports \
+                TEMP TABLE (DuckDB, Trino, etc.) — see the equivalence tests for that path."]
+    fn reader_executes_full_ggsql_visualise_query() {
+        use crate::df;
+
+        let reader = fixture_reader();
+        let data = df! {
+            "date"   => vec!["2024-01-01", "2024-01-02", "2024-01-03"],
+            "value"  => vec![10i64, 20, 30],
+            "region" => vec!["N", "S", "N"],
+        }
+        .unwrap();
+        reader.register("sales", data, false).unwrap();
+
+        let query = r#"
+            SELECT date, value, region FROM sales WHERE value > 5
+            VISUALISE date AS x, value AS y, region AS color
+            DRAW line
+        "#;
+        let spec = reader.execute(query).expect("ggsql execute ok");
+        let meta = spec.metadata();
+        // Full pipeline verification: SQL executed (3 rows after WHERE),
+        // VISUALISE parsed, plot resolved with 1 layer.
+        assert_eq!(meta.rows, 3);
+        assert_eq!(meta.layer_count, 1);
+        // The `columns` list reports the *transformed aesthetic* column names
+        // (e.g. x -> pos1, y -> pos2, color -> stroke on a line layer) not the
+        // raw SQL column names. See `test_execute_metadata` in reader/mod.rs
+        // for the same convention.
+        assert!(
+            meta.columns.iter().any(|c| c == "pos1"),
+            "expected pos1 (x aesthetic) in columns: {:?}",
+            meta.columns
+        );
+        assert!(
+            meta.columns.iter().any(|c| c == "pos2"),
+            "expected pos2 (y aesthetic) in columns: {:?}",
+            meta.columns
+        );
+        assert!(
+            meta.columns.iter().any(|c| c == "stroke"),
+            "expected stroke (color aesthetic on line) in columns: {:?}",
+            meta.columns
+        );
+    }
+
+    #[test]
+    fn execute_sql_handles_multi_batch_result() {
+        use crate::array_util::as_i64;
+        use crate::df;
+
+        // Register a 50k-row frame. DataFusion's default batch size is typically
+        // around 8k rows, so the result read-side should produce >1 RecordBatch
+        // and exercise the `for batch in reader` loop.
+        let reader = fixture_reader();
+        let xs: Vec<i64> = (0..50_000i64).collect();
+        let df = df! { "x" => xs }.unwrap();
+        reader.register("big", df, false).expect("register ok");
+
+        let out = reader
+            .execute_sql("SELECT x FROM big ORDER BY x")
+            .expect("query ok");
+        assert_eq!(out.height(), 50_000);
+
+        // Spot-check: first + last rows should round-trip correctly.
+        let col = out.column("x").unwrap();
+        let arr = as_i64(col).unwrap();
+        assert_eq!(arr.value(0), 0);
+        assert_eq!(arr.value(49_999), 49_999);
+    }
+
+    #[test]
+    fn execute_sql_handles_nulls() {
+        use crate::array_util::as_i64;
+        use arrow::array::Array;
+
+        let reader = fixture_reader();
+        // Use DataFusion DDL to create a table with a NULL.
+        reader
+            .execute_sql("CREATE TABLE nulltest (x BIGINT) AS VALUES (1), (NULL), (3)")
+            .expect("ddl ok");
+
+        let out = reader
+            .execute_sql("SELECT x FROM nulltest ORDER BY x NULLS LAST")
+            .expect("query ok");
+        assert_eq!(out.height(), 3);
+
+        let col = out.column("x").unwrap();
+        let arr = as_i64(col).unwrap();
+        // Row 2 should be NULL in the returned DataFrame.
+        assert!(arr.is_null(2));
+        // Rows 0 and 1 are the non-null values.
+        assert_eq!(arr.value(0), 1);
+        assert_eq!(arr.value(1), 3);
+    }
+
+    #[test]
+    #[ignore]
+    fn bench_register_and_query_100k_rows() {
+        use crate::array_util::as_i64;
+        use crate::df;
+        use std::time::Instant;
+
+        let reader = fixture_reader();
+        let n = 100_000i64;
+        let xs: Vec<i64> = (0..n).collect();
+        let df = df! { "x" => xs }.unwrap();
+
+        let t0 = Instant::now();
+        reader.register("big", df, false).unwrap();
+        let reg_ms = t0.elapsed().as_millis();
+
+        let t1 = Instant::now();
+        let out = reader.execute_sql("SELECT COUNT(*) AS n FROM big").unwrap();
+        let q_ms = t1.elapsed().as_millis();
+
+        let n_out = as_i64(out.column("n").unwrap()).unwrap().value(0);
+        assert_eq!(n_out, n);
+        eprintln!("register 100k rows: {} ms | query: {} ms", reg_ms, q_ms);
+    }
+
+    /// Issue #12: `execute_sql` must hold `conn.borrow_mut()` only long enough
+    /// to build + execute the Statement — the returned `RecordBatchReader` is
+    /// `Box<dyn ... + 'static>`, so iteration must not require the statement
+    /// or the connection borrow to stay alive.
+    ///
+    /// This mirrors the exact borrow pattern `execute_sql` uses post-fix:
+    /// borrow, build+execute, drop the borrow, then iterate. It also kicks
+    /// off a second `execute_sql` while the first stream is still alive —
+    /// only possible if the first borrow was released.
+    #[test]
+    fn record_batch_reader_outlives_statement_and_allows_second_query() {
+        use arrow::array::RecordBatchReader as _;
+
+        let reader = fixture_reader();
+
+        let stream = {
+            // Use `try_borrow_mut` here to mirror `execute_sql`'s production
+            // path — if this ever panics in the test, the fix in `execute_sql`
+            // has regressed and the borrow scope has crept wider again.
+            let mut conn = reader
+                .connection
+                .try_borrow_mut()
+                .expect("fresh reader should allow a mutable borrow");
+            let mut stmt = conn.new_statement().expect("new_statement");
+            stmt.set_sql_query("SELECT 1 AS v UNION ALL SELECT 2 UNION ALL SELECT 3")
+                .expect("set_sql_query");
+            stmt.execute().expect("execute")
+            // `stmt` and the `RefMut<Connection>` both drop here.
+        };
+
+        // With the borrow released, another query on the same reader must
+        // work while `stream` is still live.
+        let df2 = reader
+            .execute_sql("SELECT 42 AS answer")
+            .expect("second query");
+        assert_eq!(df2.height(), 1);
+
+        // `stream` must still iterate — it does not depend on `stmt` or the
+        // original borrow. `schema()` is called before `collect()` consumes
+        // the reader.
+        let schema = stream.schema();
+        let batches = stream
+            .collect::<std::result::Result<Vec<_>, _>>()
+            .expect("drain");
+        let total: usize = batches.iter().map(|b| b.num_rows()).sum();
+        assert_eq!(total, 3);
+        assert_eq!(schema.fields().len(), 1);
+        assert_eq!(schema.field(0).name(), "v");
+    }
+
+    #[test]
+    fn execute_sql_handles_empty_result_with_schema() {
+        let reader = fixture_reader();
+        let df = reader
+            .execute_sql("SELECT 1 AS a, 'x' AS b WHERE false")
+            .expect("query ok");
+        // The schema is preserved on zero-batch results: we now pull the
+        // declared schema off the `RecordBatchReader` *before* draining
+        // batches and hand it to the IPC bridge so an empty result still
+        // produces a 0-row DataFrame with the correct columns.
+        assert_eq!(df.height(), 0);
+        assert_eq!(df.width(), 2);
+        let names: Vec<String> = df
+            .get_column_names()
+            .iter()
+            .map(|s| s.to_string())
+            .collect();
+        assert!(names.contains(&"a".to_string()));
+        assert!(names.contains(&"b".to_string()));
+    }
+}
+
+#[cfg(all(test, feature = "sqlite"))]
+mod equivalence_tests {
+    //! Equivalence tests: `AdbcReader<sqlite via ManagedDriver>` vs ggsql's
+    //! `SqliteReader` on the same query against the same SQLite DB. Validates
+    //! correctness of the ADBC abstraction's routing, type bridging, and
+    //! ingest paths against a real, fully-functional ADBC driver.
+    //!
+    //! Skipped by default (gated `#[ignore]`). To run them:
+    //!
+    //! 1. Install dbc: `curl -LsSf https://dbc.columnar.tech/install.sh | sh`
+    //! 2. Install the SQLite driver: `dbc install sqlite`
+    //! 3. Run: `cargo test --features "adbc sqlite" -- --ignored equivalence`
+    //!
+    //! `dbc install` writes the driver to a manifest location that
+    //! `ManagedDriver::load_from_name("sqlite", ...)` discovers automatically
+    //! (on macOS: `~/Library/Application Support/ADBC/Drivers/sqlite.toml`).
+    //!
+    //! Why SQLite (and not DuckDB) as the equivalence oracle: `libduckdb` is
+    //! distributed as a bundled-static archive, so it can't be loaded as the
+    //! shared library that `ManagedDriver` requires. The Apache-published
+    //! SQLite ADBC driver ships as `libadbc_driver_sqlite.dylib` and is the
+    //! reference C-driver path for round-tripping through `adbc_driver_manager`.
+
+    use crate::reader::sqlite::SqliteDialect;
+    use crate::reader::{AdbcReader, Reader, SqliteReader};
+    use adbc_core::options::{AdbcVersion, OptionDatabase, OptionValue};
+    use adbc_core::LOAD_FLAG_DEFAULT;
+    use adbc_driver_manager::ManagedDriver;
+    use tempfile::NamedTempFile;
+
+    /// Construct an `AdbcReader` pointed at a specific SQLite file.
+    /// Both readers in each test point at the SAME file so equivalence is
+    /// over the same physical database.
+    fn make_adbc_reader(db_path: &str) -> AdbcReader<ManagedDriver> {
+        let driver = ManagedDriver::load_from_name(
+            "sqlite",
+            None,
+            AdbcVersion::V110,
+            LOAD_FLAG_DEFAULT,
+            None,
+        )
+        .expect("`dbc install sqlite` first; see module docs");
+        let dialect: Box<dyn crate::reader::SqlDialect + Send> = Box::new(SqliteDialect);
+        AdbcReader::new_with_database_opts(
+            driver,
+            dialect,
+            std::iter::once((
+                OptionDatabase::Uri,
+                OptionValue::String(format!("file:{}", db_path)),
+            )),
+        )
+        .expect("construct AdbcReader<sqlite>")
+    }
+
+    fn make_sqlite_reader(db_path: &str) -> SqliteReader {
+        SqliteReader::from_connection_string(&format!("sqlite://{}", db_path))
+            .expect("SqliteReader at the same path")
+    }
+
+    /// Compare two DataFrames by schema (field names + types) and by
+    /// per-column Arrow array contents. We don't use a blanket
+    /// `assert_eq!(df, df)` because `DataFrame` doesn't implement `PartialEq`;
+    /// going through schema + per-column equality is also more diagnostic
+    /// when one of them diverges.
+    fn assert_dataframes_equal(
+        adbc_df: &crate::DataFrame,
+        sqlite_df: &crate::DataFrame,
+        ctx: &str,
+    ) {
+        let adbc_schema = adbc_df.schema();
+        let sqlite_schema = sqlite_df.schema();
+        assert_eq!(
+            adbc_schema.fields().len(),
+            sqlite_schema.fields().len(),
+            "{}: column count mismatch (adbc={}, sqlite={})",
+            ctx,
+            adbc_schema.fields().len(),
+            sqlite_schema.fields().len(),
+        );
+        for (i, (a, s)) in adbc_schema
+            .fields()
+            .iter()
+            .zip(sqlite_schema.fields().iter())
+            .enumerate()
+        {
+            assert_eq!(
+                a.name(),
+                s.name(),
+                "{}: column {} name mismatch (adbc='{}', sqlite='{}')",
+                ctx,
+                i,
+                a.name(),
+                s.name(),
+            );
+            assert_eq!(
+                a.data_type(),
+                s.data_type(),
+                "{}: column '{}' type mismatch (adbc={:?}, sqlite={:?})",
+                ctx,
+                a.name(),
+                a.data_type(),
+                s.data_type(),
+            );
+        }
+        assert_eq!(
+            adbc_df.height(),
+            sqlite_df.height(),
+            "{}: row count mismatch (adbc={}, sqlite={})",
+            ctx,
+            adbc_df.height(),
+            sqlite_df.height(),
+        );
+        for field in adbc_schema.fields() {
+            let a = adbc_df.column(field.name()).unwrap();
+            let s = sqlite_df.column(field.name()).unwrap();
+            assert_eq!(
+                a.as_ref(),
+                s.as_ref(),
+                "{}: column '{}' data mismatch",
+                ctx,
+                field.name(),
+            );
+        }
+    }
+
+    #[test]
+    #[ignore = "requires `dbc install sqlite`; see module docs"]
+    fn equiv_simple_select() {
+        let db = NamedTempFile::new().unwrap();
+        let db_path = db.path().to_str().unwrap();
+        let adbc = make_adbc_reader(db_path);
+        let direct = make_sqlite_reader(db_path);
+        let sql = "SELECT 1 AS x, 'hello' AS y, 3.14 AS z";
+        let a = adbc.execute_sql(sql).unwrap();
+        let d = direct.execute_sql(sql).unwrap();
+        assert_dataframes_equal(&a, &d, "simple select");
+    }
+
+    #[test]
+    #[ignore = "requires `dbc install sqlite`; see module docs"]
+    fn equiv_register_and_query() {
+        // Register through the ADBC reader (exercises the standard ADBC
+        // bulk-ingest path), then read back through SqliteReader (talks to
+        // rusqlite directly against the same file) AND through the ADBC
+        // reader. Both should agree.
+        let db = NamedTempFile::new().unwrap();
+        let db_path = db.path().to_str().unwrap();
+        let adbc = make_adbc_reader(db_path);
+        let df = crate::df! {
+            "x" => vec![1i64, 2, 3, 4, 5],
+            "y" => vec![10i64, 20, 30, 40, 50],
+        }
+        .unwrap();
+        adbc.register("t", df, false).unwrap();
+
+        // Open the SqliteReader AFTER the ADBC reader has CREATEd + ingested,
+        // so its `Connection::open` sees the on-disk schema written by ADBC.
+        let direct = make_sqlite_reader(db_path);
+
+        let sql = "SELECT x, y, x*y AS xy FROM t WHERE y > 15 ORDER BY x";
+        let a = adbc.execute_sql(sql).unwrap();
+        let d = direct.execute_sql(sql).unwrap();
+        assert_dataframes_equal(&a, &d, "register + filter + projection");
+    }
+
+    #[test]
+    #[ignore = "requires `dbc install sqlite`; see module docs"]
+    fn equiv_nulls() {
+        // Mix nulls with typed values so both readers infer the same type.
+        // (SqliteReader's per-row type inference falls back to Utf8 when a
+        // column is *exclusively* NULL, while ADBC carries through the
+        // declared INTEGER from the projection metadata. That's a
+        // SqliteReader limitation, not an AdbcReader bug, so we steer
+        // around it here — see the divergence note in the PR description.)
+        let db = NamedTempFile::new().unwrap();
+        let db_path = db.path().to_str().unwrap();
+        let adbc = make_adbc_reader(db_path);
+        let direct = make_sqlite_reader(db_path);
+        // SQLite doesn't accept `VALUES (..) AS t(col, ...)` column-list
+        // aliases, so build the source rows with UNION ALL — both readers
+        // handle this identically.
+        let sql = "SELECT i, s FROM ( \
+                SELECT CAST(1 AS INTEGER) AS i, CAST('a' AS TEXT) AS s \
+                UNION ALL SELECT NULL, 'b' \
+                UNION ALL SELECT 3, NULL \
+            ) ORDER BY i";
+        let a = adbc.execute_sql(sql).unwrap();
+        let d = direct.execute_sql(sql).unwrap();
+        assert_dataframes_equal(&a, &d, "mixed null + typed values");
+    }
+}
diff --git a/src/reader/mod.rs b/src/reader/mod.rs
index 84a54f2da..a2ca57bcf 100644
--- a/src/reader/mod.rs
+++ b/src/reader/mod.rs
@@ -339,6 +339,9 @@ pub mod sqlite;
 #[cfg(feature = "odbc")]
 pub mod odbc;
 
+#[cfg(feature = "adbc")]
+pub mod adbc;
+
 pub mod connection;
 pub mod data;
 mod spec;
@@ -352,6 +355,9 @@ pub use sqlite::SqliteReader;
 #[cfg(feature = "odbc")]
 pub use odbc::OdbcReader;
 
+#[cfg(feature = "adbc")]
+pub use adbc::AdbcReader;
+
 // ============================================================================
 // Shared utilities
 // ============================================================================