Added sqlx based postgres implementation

Cargo.toml

@@ -54,6 +54,7 @@ serde_json = "1.0"
 serde_yaml = "0.9"
 skardi-engine = { path = "crates/engine" }
 sqlparser = "0.55.0"
+sqlx = { version = "0.8", features = ["runtime-tokio", "tls-native-tls", "postgres"] }
 substrait = "0.27"
 tempfile = "3.23.0"
 tokio = { version = "1.44.2", features = ["macros", "rt", "sync"] }

crates/cli/src/main.rs

@@ -19,7 +19,7 @@ use serde::Deserialize;
 use source::lance::knn_table_function::register_lance_knn_udtf;
 use source::providers::{
     iceberg::register_iceberg_table, lance::register_lance_table, mongo::register_mongo_tables,
-    mysql::register_mysql_tables, postgres::register_postgres_tables,
+    mysql::register_mysql_tables, sqlx::postgres::register_postgres_tables,
 };
 use std::collections::HashMap;
 use std::fmt;

crates/server/src/config.rs

@@ -713,8 +713,8 @@ async fn register_data_source(
                 source.options
             );
 
-            // Register PostgreSQL table using the providers module
-            source::providers::postgres::register_postgres_tables(
+            // Register PostgreSQL table using the sqlx-based provider
+            source::providers::sqlx::postgres::register_postgres_tables(
                 session_ctx,
                 &source.name,
                 connection_string,

crates/source/Cargo.toml

@@ -27,6 +27,7 @@ mysql_async = "0.36"
 percent-encoding = "2.3"
 redis = { version = "1.0.0-rc.2", default-features = false, features = ["cluster"] }
 secrecy = "0.10"
+sqlx = { workspace = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
 sqlparser = "0.53"

crates/source/src/providers/mod.rs

@@ -2,4 +2,4 @@ pub mod iceberg;
 pub mod lance;
 pub mod mongo;
 pub mod mysql;
-pub mod postgres;
+pub mod sqlx;