feat: enable duckdb

Author: frectonz

Cargo.toml

@@ -24,7 +24,7 @@ tokio-postgres = "0.7.13"
 mysql_async = { version = "0.36.1", default-features = false, features = ["rustls-tls", "default-rustls"] }
 humantime = "2.2.0"
 clickhouse = { version = "0.13.3", features = ["rustls-tls"] }
-duckdb = { version = "1.3.2", features = ["bundled"], optional = true }
+duckdb = { version = "1.3.2", features = ["bundled"] }
 libsql = { version = "0.9.19", features = ["remote"] }
 tiberius = { version = "0.12.3", default-features = false, features = ["rustls", "tds73", "tokio", "tokio-util"] }
 tokio-util = "0.7.15"
@@ -39,6 +39,3 @@ codegen-units = 1
 [profile.dist]
 inherits = "release"
 lto = "thin"
-
-[features]
-duckdb = [ "dep:duckdb" ]

src/main.rs

@@ -80,7 +80,6 @@ enum Command {
     },
 
     /// A local DuckDB database.
-    #[cfg(feature = "duckdb")]
     Duckdb {
         /// Path to the the duckdb file.
         #[arg(env)]
@@ -140,7 +139,6 @@ async fn main() -> color_eyre::Result<()> {
             AllDbs::Postgres(postgres::Db::open(url, schema, args.timeout.into()).await?)
         }
         Command::Mysql { url } => AllDbs::Mysql(mysql::Db::open(url, args.timeout.into()).await?),
-        #[cfg(feature = "duckdb")]
         Command::Duckdb { database } => {
             AllDbs::Duckdb(duckdb::Db::open(database, args.timeout.into()).await?)
         }
@@ -337,7 +335,6 @@ enum AllDbs {
     Libsql(libsql::Db),
     Postgres(postgres::Db),
     Mysql(mysql::Db),
-    #[cfg(feature = "duckdb")]
     Duckdb(duckdb::Db),
     Clickhouse(Box<clickhouse::Db>),
     MsSql(mssql::Db),
@@ -350,7 +347,6 @@ impl Database for AllDbs {
             AllDbs::Libsql(x) => x.overview().await,
             AllDbs::Postgres(x) => x.overview().await,
             AllDbs::Mysql(x) => x.overview().await,
-            #[cfg(feature = "duckdb")]
             AllDbs::Duckdb(x) => x.overview().await,
             AllDbs::Clickhouse(x) => x.overview().await,
             AllDbs::MsSql(x) => x.overview().await,
@@ -363,7 +359,6 @@ impl Database for AllDbs {
             AllDbs::Libsql(x) => x.tables().await,
             AllDbs::Postgres(x) => x.tables().await,
             AllDbs::Mysql(x) => x.tables().await,
-            #[cfg(feature = "duckdb")]
             AllDbs::Duckdb(x) => x.tables().await,
             AllDbs::Clickhouse(x) => x.tables().await,
             AllDbs::MsSql(x) => x.tables().await,
@@ -376,7 +371,6 @@ impl Database for AllDbs {
             AllDbs::Libsql(x) => x.table(name).await,
             AllDbs::Postgres(x) => x.table(name).await,
             AllDbs::Mysql(x) => x.table(name).await,
-            #[cfg(feature = "duckdb")]
             AllDbs::Duckdb(x) => x.table(name).await,
             AllDbs::Clickhouse(x) => x.table(name).await,
             AllDbs::MsSql(x) => x.table(name).await,
@@ -393,7 +387,6 @@ impl Database for AllDbs {
             AllDbs::Libsql(x) => x.table_data(name, page).await,
             AllDbs::Postgres(x) => x.table_data(name, page).await,
             AllDbs::Mysql(x) => x.table_data(name, page).await,
-            #[cfg(feature = "duckdb")]
             AllDbs::Duckdb(x) => x.table_data(name, page).await,
             AllDbs::Clickhouse(x) => x.table_data(name, page).await,
             AllDbs::MsSql(x) => x.table_data(name, page).await,
@@ -406,7 +399,6 @@ impl Database for AllDbs {
             AllDbs::Libsql(x) => x.tables_with_columns().await,
             AllDbs::Postgres(x) => x.tables_with_columns().await,
             AllDbs::Mysql(x) => x.tables_with_columns().await,
-            #[cfg(feature = "duckdb")]
             AllDbs::Duckdb(x) => x.tables_with_columns().await,
             AllDbs::Clickhouse(x) => x.tables_with_columns().await,
             AllDbs::MsSql(x) => x.tables_with_columns().await,
@@ -419,7 +411,6 @@ impl Database for AllDbs {
             AllDbs::Libsql(x) => x.query(query).await,
             AllDbs::Postgres(x) => x.query(query).await,
             AllDbs::Mysql(x) => x.query(query).await,
-            #[cfg(feature = "duckdb")]
             AllDbs::Duckdb(x) => x.query(query).await,
             AllDbs::Clickhouse(x) => x.query(query).await,
             AllDbs::MsSql(x) => x.query(query).await,
@@ -2356,7 +2347,6 @@ mod mysql {
     }
 }
 
-#[cfg(feature = "duckdb")]
 mod duckdb {
     use color_eyre::eyre;
     use color_eyre::eyre::OptionExt;
@@ -3713,7 +3703,6 @@ mod mssql {
 }
 
 mod helpers {
-    #[cfg(feature = "duckdb")]
     use duckdb::types::ValueRef as DuckdbValue;
     use libsql::Value as LibsqlValue;
     use tiberius::ColumnData;
@@ -3753,7 +3742,6 @@ mod helpers {
         }
     }
 
-    #[cfg(feature = "duckdb")]
     pub fn duckdb_value_to_json(v: DuckdbValue) -> serde_json::Value {
         use DuckdbValue::*;
         match v {