fix(drivers): resolve warehouse SDKs from disk instead of reporting them missing

packages/drivers/src/bigquery.ts

@@ -3,16 +3,11 @@
  */
 
 import type { ConnectionConfig, Connector, ConnectorResult, ExecuteOptions, SchemaColumn } from "./types"
+import { loadOptionalDriver } from "./resolve"
 
 export async function connect(config: ConnectionConfig): Promise<Connector> {
   let BigQueryModule: any
-  try {
-    BigQueryModule = await import("@google-cloud/bigquery")
-  } catch {
-    throw new Error(
-      "BigQuery driver not installed. Run: npm install @google-cloud/bigquery",
-    )
-  }
+  BigQueryModule = await loadOptionalDriver("bigquery", "@google-cloud/bigquery")
 
   const BigQuery = BigQueryModule.BigQuery ?? BigQueryModule.default?.BigQuery
   let client: any

packages/drivers/src/clickhouse.ts

@@ -6,26 +6,62 @@
  */
 
 import type { ConnectionConfig, Connector, ConnectorResult, ExecuteOptions, SchemaColumn } from "./types"
+import { loadOptionalDriver } from "./resolve"
+
+function connectionUrl(config: ConnectionConfig): string {
+  const tlsRequested = Boolean(config.tls || config.ssl)
+  const configuredProtocol = typeof config.protocol === "string" ? config.protocol.trim().toLowerCase() : ""
+  const secureIntent = tlsRequested || configuredProtocol === "https"
+  const configured = typeof config.connection_string === "string" ? config.connection_string.trim() : ""
+
+  if (configured) {
+    if (secureIntent) {
+      let protocol: string
+      try {
+        protocol = new URL(configured).protocol.toLowerCase()
+      } catch {
+        throw new Error("ClickHouse TLS requires a valid https:// connection_string")
+      }
+      if (protocol !== "https:") {
+        throw new Error("ClickHouse TLS was requested, but connection_string is not https://")
+      }
+    }
+    return configured
+  }
+
+  if (tlsRequested && configuredProtocol && configuredProtocol !== "https") {
+    throw new Error("ClickHouse TLS was requested, but protocol is not https")
+  }
+
+  const protocol = configuredProtocol || (tlsRequested ? "https" : "http")
+  const defaultPort = protocol === "https" ? 8443 : 8123
+  const hasExplicitPort = config.port !== undefined && config.port !== null
+  const parsedPort =
+    typeof config.port === "number"
+      ? config.port
+      : typeof config.port === "string" && config.port.trim()
+        ? Number(config.port)
+        : Number.NaN
+  if (hasExplicitPort && (!Number.isInteger(parsedPort) || parsedPort < 1 || parsedPort > 65535)) {
+    throw new Error("ClickHouse port must be an integer between 1 and 65535")
+  }
+  const port = hasExplicitPort ? parsedPort : defaultPort
+  return `${protocol}://${config.host ?? "localhost"}:${port}`
+}
 
 export async function connect(config: ConnectionConfig): Promise<Connector> {
   let createClient: any
-  try {
-    const mod = await import("@clickhouse/client")
-    createClient = mod.createClient ?? mod.default?.createClient
-    if (!createClient) {
-      throw new Error("createClient export not found in @clickhouse/client")
-    }
-  } catch {
-    throw new Error("ClickHouse driver not installed. Run: npm install @clickhouse/client")
+  const clickhouseModule = await loadOptionalDriver("clickhouse", "@clickhouse/client")
+  createClient = clickhouseModule.createClient ?? clickhouseModule.default?.createClient
+  if (!createClient) {
+    throw new Error("createClient export not found in @clickhouse/client — check the installed package version")
   }
 
   let client: any
 
   return {
     async connect() {
-      const url =
-        config.connection_string ??
-        `${config.protocol ?? "http"}://${config.host ?? "localhost"}:${config.port ?? 8123}`
+      const url = connectionUrl(config)
 
       const clientConfig: Record<string, unknown> = {
         url,

packages/drivers/src/databricks.ts

@@ -3,17 +3,12 @@
  */
 
 import type { ConnectionConfig, Connector, ConnectorResult, ExecuteOptions, SchemaColumn } from "./types"
+import { loadOptionalDriver } from "./resolve"
 
 export async function connect(config: ConnectionConfig): Promise<Connector> {
   let databricksModule: any
-  try {
-    databricksModule = await import("@databricks/sql")
-    databricksModule = databricksModule.default || databricksModule
-  } catch {
-    throw new Error(
-      "Databricks driver not installed. Run: npm install @databricks/sql",
-    )
-  }
+  databricksModule = await loadOptionalDriver("databricks", "@databricks/sql")
+  databricksModule = databricksModule.default || databricksModule
 
   let client: any
   let session: any

packages/drivers/src/duckdb.ts

@@ -3,15 +3,12 @@
  */
 
 import type { ConnectionConfig, Connector, ConnectorResult, ExecuteOptions, SchemaColumn } from "./types"
+import { loadOptionalDriver } from "./resolve"
 
 export async function connect(config: ConnectionConfig): Promise<Connector> {
   let duckdb: any
-  try {
-    duckdb = await import("duckdb")
-    duckdb = duckdb.default || duckdb
-  } catch {
-    throw new Error("DuckDB driver not installed. Run: npm install duckdb")
-  }
+  duckdb = await loadOptionalDriver("duckdb", "duckdb")
+  duckdb = duckdb.default || duckdb
 
   const dbPath = (config.path as string) ?? ":memory:"
   let db: any

packages/drivers/src/mongodb.ts

@@ -15,6 +15,7 @@
  */
 
 import type { ConnectionConfig, Connector, ConnectorResult, SchemaColumn } from "./types"
+import { loadOptionalDriver } from "./resolve"
 
 /** Supported MQL commands. */
 type MqlCommand =
@@ -130,12 +131,8 @@ function extractFields(docs: Record<string, unknown>[]): Map<string, Set<string>
 
 export async function connect(config: ConnectionConfig): Promise<Connector> {
   let mongoModule: any
-  try {
-    mongoModule = await import("mongodb")
-    mongoModule = mongoModule.default || mongoModule
-  } catch {
-    throw new Error("MongoDB driver not installed. Run: npm install mongodb")
-  }
+  mongoModule = await loadOptionalDriver("mongodb", "mongodb")
+  mongoModule = mongoModule.default || mongoModule
 
   const MongoClient = mongoModule.MongoClient
 

packages/drivers/src/mysql.ts

@@ -3,15 +3,12 @@
  */
 
 import type { ConnectionConfig, Connector, ConnectorResult, ExecuteOptions, SchemaColumn } from "./types"
+import { loadOptionalDriver } from "./resolve"
 
 export async function connect(config: ConnectionConfig): Promise<Connector> {
   let mysql: any
-  try {
-    mysql = await import("mysql2/promise")
-    mysql = mysql.default || mysql
-  } catch {
-    throw new Error("MySQL driver not installed. Run: npm install mysql2")
-  }
+  mysql = await loadOptionalDriver("mysql", "mysql2/promise")
+  mysql = mysql.default || mysql
 
   let pool: any
 

packages/drivers/src/oracle.ts

@@ -3,18 +3,12 @@
  */
 
 import type { ConnectionConfig, Connector, ConnectorResult, ExecuteOptions, SchemaColumn } from "./types"
+import { loadOptionalDriver } from "./resolve"
 
 export async function connect(config: ConnectionConfig): Promise<Connector> {
   let oracledb: any
-  try {
-    // @ts-expect-error — optional dependency, loaded at runtime
-    oracledb = await import("oracledb")
-    oracledb = oracledb.default || oracledb
-  } catch {
-    throw new Error(
-      "Oracle driver not installed. Run: npm install oracledb",
-    )
-  }
+  oracledb = await loadOptionalDriver("oracle", "oracledb")
+  oracledb = oracledb.default || oracledb
 
   // Use thin mode (pure JS, no Oracle client needed)
   oracledb.initOracleClient = undefined

packages/drivers/src/postgres.ts

@@ -3,14 +3,11 @@
  */
 
 import type { ConnectionConfig, Connector, ConnectorResult, ExecuteOptions, SchemaColumn } from "./types"
+import { loadOptionalDriver } from "./resolve"
 
 export async function connect(config: ConnectionConfig): Promise<Connector> {
   let pg: any
-  try {
-    pg = await import("pg")
-  } catch {
-    throw new Error("PostgreSQL driver not installed. Run: npm install pg @types/pg")
-  }
+  pg = await loadOptionalDriver("postgres", "pg")
 
   const Pool = pg.default?.Pool ?? pg.Pool
   let pool: any

packages/drivers/src/redshift.ts

@@ -4,16 +4,11 @@
  */
 
 import type { ConnectionConfig, Connector, ConnectorResult, ExecuteOptions, SchemaColumn } from "./types"
+import { loadOptionalDriver } from "./resolve"
 
 export async function connect(config: ConnectionConfig): Promise<Connector> {
   let pg: any
-  try {
-    pg = await import("pg")
-  } catch {
-    throw new Error(
-      "Redshift driver not installed (uses pg). Run: npm install pg @types/pg",
-    )
-  }
+  pg = await loadOptionalDriver("redshift", "pg")
 
   const Pool = pg.default?.Pool ?? pg.Pool
   let pool: any