Function parse_sql

marimo/_sql/parse.py:57–79

Parses an SQL query. Returns syntax errors. Does not check for catalog errors (incorrect table names, etc). Currently only supports DuckDB. Args: query (str): The SQL query to parse. dialect (str): The dialect of the SQL query. Returns: tuple[SqlParseResult,

(
    query: str, dialect: str
)

def parse_sql(
    query: str, dialect: str
) -> tuple[SqlParseResult | None, str | None]:
    """Parses an SQL query. Returns syntax errors.
    Does not check for catalog errors (incorrect table names, etc).
    Currently only supports DuckDB.

    Args:
        query (str): The SQL query to parse.
        dialect (str): The dialect of the SQL query.

    Returns:
        tuple[SqlParseResult, str]: SqlParseResult and unexpected errors
    """
    dialect = dialect.strip().lower()

    try:
        if "duckdb" in dialect:
            return _parse_sql_duckdb(query)
        else:
            return None, "Unsupported dialect: " + dialect
    except Exception as e:
        return None, str(e)


class DuckDBParseError(msgspec.Struct):