fix(sqlite): unify adapter path resolution and load from env for stable pipeline execution

adapters/db/sqlite_adapter.py

@@ -2,6 +2,7 @@ import sqlite3
 import logging
 from typing import List, Tuple, Any
 from adapters.db.base import DBAdapter
+from pathlib import Path
 
 log = logging.getLogger(__name__)
 
@@ -11,13 +12,15 @@ class SQLiteAdapter(DBAdapter):
     dialect = "sqlite"
 
     def __init__(self, path: str):
-        self.path = path
+        # resolve absolute path for safety
+        self.path = Path(path).resolve()
         log.info("SQLiteAdapter initialized with DB path: %s", self.path)
 
     def preview_schema(self, limit_per_table: int = 0) -> str:
-        with sqlite3.connect(self.path, uri=True) as conn:
+        uri = self.path.as_uri()
+        with sqlite3.connect(f"{uri}?mode=ro", uri=True) as conn:
             cur = conn.cursor()
-            cur.execute("PRAGMA foreign_keys = ON")
+            cur.execute("SELECT name FROM sqlite_master WHERE type='table';")
             tables = [t[0] for t in cur.fetchall()]
             lines = []
             for t in tables:
@@ -28,9 +31,11 @@ class SQLiteAdapter(DBAdapter):
 
     def execute(self, sql: str) -> Tuple[List[Tuple[Any, ...]], List[str]]:
         # enforce read-only connection
-        uri = f"file:{self.path}?mode=ro&uri=true"
+        uri = self.path.as_uri()
         log.info("SQLiteAdapter opening read-only connection to: %s", uri)
-        with sqlite3.connect(uri, uri=True, timeout=3) as conn:
+        if not self.path.exists():
+            raise FileNotFoundError(f"SQLite DB does not exist: {self.path}")
+        with sqlite3.connect(f"{uri}?mode=ro", uri=True, timeout=3) as conn:
             cur = conn.cursor()
             log.debug("Executing SQL: %s", sql.strip().replace("\n", " "))
             cur.execute(sql)

app/main.py

@@ -87,7 +87,9 @@ def readyz() -> str:
         else:
             from adapters.db.sqlite_adapter import SQLiteAdapter
 
-            sq = SQLiteAdapter(os.getenv("SQLITE_DB_PATH", "data/chinook.db"))
+            sq = SQLiteAdapter(
+                os.getenv("DEFAULT_SQLITE_PATH", "data/Chinook_Sqlite.sqlite")
+            )
             ping_fn = getattr(sq, "ping", None)
             if callable(ping_fn):
                 ping_fn()

app/routers/dev.py

@@ -8,6 +8,11 @@ from adapters.db.sqlite_adapter import SQLiteAdapter
 
 from dataclasses import is_dataclass, asdict
 from typing import Any
+import yaml
+from pathlib import Path
+import os
+
+CONFIG_PATH = os.getenv("PIPELINE_CONFIG", "configs/sqlite_pipeline.yaml")
 
 
 def _is_dataclass_instance(x: Any) -> bool:
@@ -53,10 +58,20 @@ def dev_safety_check(body: SQLBody):
 def dev_verifier_check(body: SQLBody):
     """
     Run the Verifier stage directly on a raw SQL string
-    with a real adapter connection.
+    with a real adapter connection loaded from YAML config.
     """
+    config_path = Path(CONFIG_PATH)
+    if not config_path.exists():
+        raise HTTPException(status_code=500, detail="Config file not found")
+
     try:
-        adapter = SQLiteAdapter("data/chinook.db")
+        with config_path.open("r") as f:
+            config = yaml.safe_load(f)
+        dsn = config.get("adapter", {}).get("dsn")
+        if not dsn:
+            raise ValueError("Missing adapter.dsn in config file")
+
+        adapter = SQLiteAdapter(dsn)
     except Exception as e:
         raise HTTPException(status_code=500, detail=f"Adapter init failed: {e}")
 

configs/sqlite_pipeline.yaml

@@ -8,7 +8,7 @@ repair: default
 
 adapter:
   kind: sqlite
-  dsn: data/chinook.db
+  dsn: data/Chinook_Sqlite.sqlite
 
 llm:
   provider: openai

tests/test_pipeline_factory.py

@@ -3,20 +3,28 @@ from nl2sql.pipeline_factory import (
     pipeline_from_config_with_adapter,
 )
 from adapters.db.sqlite_adapter import SQLiteAdapter
+import yaml
+from pathlib import Path
+import os
+
+CONFIG_PATH = os.getenv("PIPELINE_CONFIG", "configs/sqlite_pipeline.yaml")
+config_path = Path(CONFIG_PATH)
 
 
 def test_pipeline_from_config_builds_and_runs(tmp_path):
-    p = pipeline_from_config("configs/sqlite_pipeline.yaml")
+    p = pipeline_from_config(CONFIG_PATH)
     result = p.run(user_query="Top 3 albums by sales")
     assert result.sql is not None
     assert isinstance(result.traces, list)
 
 
 def test_pipeline_from_config_with_adapter_override(tmp_path):
-    adapter = SQLiteAdapter("data/chinook.db")
-    p = pipeline_from_config_with_adapter(
-        "configs/sqlite_pipeline.yaml", adapter=adapter
-    )
+    with config_path.open("r") as f:
+        config = yaml.safe_load(f)
+    dsn = config.get("adapter", {}).get("dsn")
+
+    adapter = SQLiteAdapter(dsn)
+    p = pipeline_from_config_with_adapter(CONFIG_PATH, adapter=adapter)
     result = p.run(user_query="Count customers")
     assert "SELECT" in result.sql.upper()
     assert isinstance(result.traces, list)
@@ -25,7 +33,7 @@ def test_pipeline_from_config_with_adapter_override(tmp_path):
 def test_full_pipeline_from_yaml(monkeypatch):
     from nl2sql.pipeline_factory import pipeline_from_config
 
-    p = pipeline_from_config("configs/sqlite_pipeline.yaml")
+    p = pipeline_from_config(CONFIG_PATH)
     res = p.run(user_query="List all artists")
     assert res.ok
     assert isinstance(res.sql, str)