version bump to 0.35; add extract relations

.bumpversion.cfg

@@ -1,5 +1,5 @@
 [bumpversion]
-current_version = 0.1.33
+current_version = 0.1.35
 commit = True
 tag = True
 

CHANGELOG.md

@@ -0,0 +1,3 @@
+# 0.1.35
+
+- Added `extract_relations` function to assist in extracting table references from the AST in Rust.

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "sqloxide"
-version = "0.1.33"
+version = "0.1.35"
 authors = ["Will Eaton <me@wseaton.com>"]
 edition = "2018"
 
@@ -9,12 +9,12 @@ name = "sqloxide"
 crate-type = ["cdylib"]
 
 [dependencies]
-pythonize = "0.17"
+pythonize = "0.19"
 
 [dependencies.pyo3]
-version = "0.17.1"
+version = "0.19.0"
 features = ["extension-module"]
 
 [dependencies.sqlparser]
-version = "0.33.0"
-features = ["json_example"]
+version = "0.35.0"
+features = ["serde", "visitor"]

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "sqloxide"
-version = "0.1.33"
+version = "0.1.35"
 repository = "https://github.com/wseaton/sqloxide"
 license = "MIT"
 description = "Python bindings for sqlparser-rs"

setup.py

@@ -7,7 +7,7 @@
 
 setup_kwargs = {
     "name": "sqloxide",
-    "version": "0.1.33",
+    "version": "0.1.35",
     "description": "Python bindings for sqlparser-rs",
     "long_description": open("readme.md").read(),
     "long_description_content_type": "text/markdown",

sqloxide/__init__.py

@@ -1,3 +1,3 @@
-from .sqloxide import parse_sql
+from .sqloxide import parse_sql, extract_relations
 
-__all__ = ["parse_sql"]
+__all__ = ["parse_sql", "extract_relations"]

src/lib.rs

@@ -1,9 +1,12 @@
 use pyo3::exceptions::PyValueError;
 use pyo3::prelude::*;
 use pyo3::wrap_pyfunction;
+use pythonize::PythonizeError;
+use sqlparser::ast::Statement;
 
+use core::ops::ControlFlow;
 use pythonize::pythonize;
-
+use sqlparser::ast::visit_relations;
 use sqlparser::dialect::*;
 use sqlparser::parser::Parser;
 
@@ -65,8 +68,53 @@ fn parse_sql(py: Python, sql: &str, dialect: &str) -> PyResult<PyObject> {
     Ok(output)
 }
 
+///
+/// Function to extract relations from a parsed query.
+/// Returns a nested list of relations, one list per query statement.
+///
+/// Example:
+/// ```python
+/// from sqloxide import parse_sql, extract_relations
+///
+/// sql = "SELECT * FROM table1 JOIN table2 ON table1.id = table2.id"
+/// parsed_query = parse_sql(sql, "generic")
+/// relations = extract_relations(parsed_query)
+/// print(relations)
+/// ```
+///
+#[pyfunction]
+#[pyo3(text_signature = "(parsed_query)")]
+fn extract_relations(py: Python, parsed_query: &PyAny) -> PyResult<PyObject> {
+    let parse_result: Result<Vec<Statement>, PythonizeError> = pythonize::depythonize(parsed_query);
+
+    let mut relations = Vec::new();
+
+    match parse_result {
+        Ok(statements) => {
+            for statement in statements {
+                visit_relations(&statement, |relation| {
+                    relations.push(relation.clone());
+                    ControlFlow::<()>::Continue(())
+                });
+            }
+        }
+        Err(_e) => {
+            let msg = _e.to_string();
+            return Err(PyValueError::new_err(format!(
+                "Query serialization failed.\n\t{}",
+                msg
+            )));
+        }
+    };
+
+    let output = pythonize(py, &relations).expect("Internal python deserialization failed.");
+
+    Ok(output)
+}
+
 #[pymodule]
 fn sqloxide(_py: Python, m: &PyModule) -> PyResult<()> {
     m.add_function(wrap_pyfunction!(parse_sql, m)?)?;
+    m.add_function(wrap_pyfunction!(extract_relations, m)?)?;
     Ok(())
 }

tests/test_sqloxide.py

@@ -1,9 +1,8 @@
 import pytest
-from sqloxide import parse_sql
+from sqloxide import parse_sql, extract_relations
 
 
 def test_parse_sql():
-
     sql = """
     SELECT employee.first_name, employee.last_name,
         call.start_time, call.end_time, call_outcome.outcome_text
@@ -23,9 +22,24 @@ def test_parse_sql():
 
 
 def test_throw_exception():
-
     sql = """
     SELECT $# as 1;
     """
-    with pytest.raises(ValueError, match=r"Query parsing failed.\n\tsql parser error: .+"):
-        ast = parse_sql(sql=sql, dialect="ansi")[0]
+    with pytest.raises(
+        ValueError, match=r"Query parsing failed.\n\tsql parser error: .+"
+    ):
+        _ast = parse_sql(sql=sql, dialect="ansi")[0]
+
+
+def test_extract_relations():
+    sql = """
+    SELECT employee.first_name, employee.last_name,
+        call.start_time, call.end_time, call_outcome.outcome_text
+    FROM employee
+    INNER JOIN call ON call.employee_id = employee.id
+    INNER JOIN call_outcome ON call.call_outcome_id = call_outcome.id
+    ORDER BY call.start_time ASC;
+    """
+
+    ast = parse_sql(sql=sql, dialect="ansi")
+    print(extract_relations(parsed_query=ast))