Skip to main content

lineage_sql

Function lineage_sql 

Source
pub fn lineage_sql(
    column: &str,
    sql: &str,
    schema: &MappingSchema,
    config: &LineageConfig,
) -> LineageResult<LineageGraph>
Expand description

Build lineage from a SQL string.

Convenience function that parses the SQL and builds lineage.

ยงExample

use sqlglot_rust::dialects::Dialect;
use sqlglot_rust::optimizer::lineage::{lineage_sql, LineageConfig};
use sqlglot_rust::schema::MappingSchema;

let schema = MappingSchema::new(Dialect::Ansi);
let config = LineageConfig::default();

let graph = lineage_sql("c", "SELECT a + b AS c FROM t", &schema, &config).unwrap();
assert_eq!(graph.node.name, "c");