feat: add snowflake frontend protocol / backend

crates/queryflux-core/src/config.rs

@@ -322,6 +322,10 @@ pub struct FrontendsConfig {
     pub clickhouse_http: Option<FrontendConfig>,
     #[serde(default)]
     pub flight_sql: Option<FrontendConfig>,
+    #[serde(default)]
+    pub snowflake_http: Option<FrontendConfig>,
+    #[serde(default)]
+    pub snowflake_sql_api: Option<FrontendConfig>,
 }
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
@@ -648,6 +652,12 @@ pub enum RouterConfig {
         mysql_wire: Option<String>,
         #[serde(default)]
         clickhouse_http: Option<String>,
+        #[serde(default)]
+        flight_sql: Option<String>,
+        #[serde(default)]
+        snowflake_http: Option<String>,
+        #[serde(default)]
+        snowflake_sql_api: Option<String>,
     },
     #[serde(rename_all = "camelCase")]
     Header {

crates/queryflux-core/src/query.rs

@@ -67,6 +67,10 @@ pub enum FrontendProtocol {
     MySqlWire,
     ClickHouseHttp,
     FlightSql,
+    /// Snowflake internal wire protocol used by JDBC/ODBC/Python/Go/Node.js connectors.
+    SnowflakeHttp,
+    /// Snowflake public SQL REST API v2 (/api/v2/statements).
+    SnowflakeSqlApi,
 }
 
 impl FrontendProtocol {
@@ -78,6 +82,8 @@ impl FrontendProtocol {
             FrontendProtocol::MySqlWire => SqlDialect::MySql,
             FrontendProtocol::ClickHouseHttp => SqlDialect::ClickHouse,
             FrontendProtocol::FlightSql => SqlDialect::Generic,
+            FrontendProtocol::SnowflakeHttp => SqlDialect::Generic,
+            FrontendProtocol::SnowflakeSqlApi => SqlDialect::Generic,
         }
     }
 }

crates/queryflux-e2e-tests/src/harness.rs

@@ -31,6 +31,7 @@ use queryflux_engine_adapters::{
     starrocks::StarRocksAdapter, trino::TrinoAdapter, EngineAdapterTrait,
 };
 use queryflux_frontend::{
+    snowflake::http::session_store::SnowflakeSessionStore,
     state::LiveConfig,
     trino_http::{state::AppState, TrinoHttpFrontend},
 };
@@ -230,6 +231,7 @@ impl TestHarness {
             auth_provider: Arc::new(NoneAuthProvider::new(false)) as Arc<dyn AuthProvider>,
             authorization: Arc::new(AllowAllAuthorization) as Arc<dyn AuthorizationChecker>,
             identity_resolver: Arc::new(BackendIdentityResolver::new()),
+            snowflake_sessions: SnowflakeSessionStore::new(),
         });
 
         let router: Router = TrinoHttpFrontend::new(state, port).router();

crates/queryflux-frontend/Cargo.toml

@@ -32,3 +32,10 @@ arrow-flight = { version = "58.1.0", features = ["flight-sql"] }
 arrow-ipc = "58.1.0"
 tonic = { version = "0.14.5", features = ["transport"] }
 prost = "0.14.3"
+dashmap = { workspace = true }
+jsonwebtoken = "9"
+rsa = "0.9"
+sha2 = "0.10"
+uuid = { version = "1", features = ["v4"] }
+base64 = "0.22"
+flate2 = "1"

crates/queryflux-frontend/src/admin.rs

@@ -250,6 +250,18 @@ pub fn build_frontends_status(
             "Arrow Flight SQL / gRPC-style access (driver-dependent).",
             frontends.flight_sql.as_ref(),
         ),
+        opt_fe(
+            "snowflake_http",
+            "Snowflake HTTP (wire)",
+            "Snowflake internal HTTP wire protocol (JDBC/ODBC/Python/Go/Node.js connectors).",
+            frontends.snowflake_http.as_ref(),
+        ),
+        opt_fe(
+            "snowflake_sql_api",
+            "Snowflake SQL API",
+            "Snowflake REST SQL API v2 (POST /api/v2/statements).",
+            frontends.snowflake_sql_api.as_ref(),
+        ),
     ];
 
     FrontendsStatusDto {

crates/queryflux-frontend/src/lib.rs

@@ -3,6 +3,7 @@ pub mod dispatch;
 pub mod flight_sql;
 pub mod mysql_wire;
 pub mod postgres_wire;
+pub mod snowflake;
 pub mod state;
 pub mod trino_http;