Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions .github/wordlist.txt
Original file line number Diff line number Diff line change
Expand Up @@ -121,3 +121,6 @@ pytest
Radix
Zod
Dependabot
pymssql
sqlserver
SQLServerLoader
4 changes: 4 additions & 0 deletions api/core/schema_loader.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@
from api.loaders.postgres_loader import PostgresLoader
from api.loaders.mysql_loader import MySQLLoader
from api.loaders.snowflake_loader import SnowflakeLoader
from api.loaders.sqlserver_loader import SQLServerLoader

# Use the same delimiter as in the JavaScript frontend for streaming chunks
MESSAGE_DELIMITER = "|||FALKORDB_MESSAGE_BOUNDARY|||"
Expand Down Expand Up @@ -48,6 +49,9 @@ def _step_detect_db_type(steps_counter: int, url: str) -> tuple[type[BaseLoader]
elif url.startswith("snowflake://"):
db_type = "snowflake"
loader = SnowflakeLoader
elif url.startswith("sqlserver://"):
db_type = "sqlserver"
loader = SQLServerLoader
else:
raise InvalidArgumentError("Invalid database URL format")

Expand Down
3 changes: 3 additions & 0 deletions api/core/text2sql.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@
from api.loaders.postgres_loader import PostgresLoader
from api.loaders.mysql_loader import MySQLLoader
from api.loaders.snowflake_loader import SnowflakeLoader
from api.loaders.sqlserver_loader import SQLServerLoader
from api.memory.graphiti_tool import MemoryTool
from api.sql_utils import SQLIdentifierQuoter, DatabaseSpecificQuoter

Expand Down Expand Up @@ -87,6 +88,8 @@ def get_database_type_and_loader(db_url: str):
return 'mysql', MySQLLoader
if db_url_lower.startswith('snowflake://'):
return 'snowflake', SnowflakeLoader
if db_url_lower.startswith('sqlserver://'):
return 'sqlserver', SQLServerLoader

# Default to PostgresLoader for backward compatibility
return 'postgresql', PostgresLoader
Expand Down
Loading
Loading