feat(sql): plan Snowflake directed joins

Cargo.toml

@@ -196,7 +196,7 @@ regex = "1.12"
 rstest = "0.26.1"
 serde_json = "1"
 sha2 = "^0.11.0"
-sqlparser = { git = "https://github.com/Embucket/datafusion-sqlparser-rs.git", rev = "ff0378d5b2205e839360ab473efe9bcfa520f65f", default-features = false, features = [
+sqlparser = { git = "https://github.com/Embucket/datafusion-sqlparser-rs.git", rev = "707457f75c46c99c441b2859ad5bb01e21e5f105", default-features = false, features = [
     "std",
     "visitor",
 ] }

datafusion/sql/src/unparser/plan.rs

@@ -609,6 +609,7 @@ impl Unparser<'_> {
                 let cross_join = ast::Join {
                     relation: flatten_factor,
                     global: false,
+                    directed: false,
                     join_operator: ast::JoinOperator::CrossJoin(
                         ast::JoinConstraint::None,
                     ),
@@ -1449,6 +1450,7 @@ impl Unparser<'_> {
                         let ast_join = ast::Join {
                             relation,
                             global: false,
+                            directed: false,
                             join_operator: self
                                 .join_operator_to_sql(join.join_type, join_constraint)?,
                         };
@@ -1870,6 +1872,7 @@ impl Unparser<'_> {
         let ast_join = ast::Join {
             relation,
             global: false,
+            directed: false,
             join_operator: ast::JoinOperator::AsOf {
                 match_condition,
                 constraint,

datafusion/sql/tests/sql_integration.rs

@@ -3455,6 +3455,24 @@ fn minus_is_an_alias_for_except() {
     );
 }
 
+#[test]
+fn snowflake_directed_join_plans() {
+    let sql = "SELECT person.id, orders.order_id \
+               FROM person \
+               INNER DIRECTED JOIN orders \
+               ON person.id = orders.customer_id";
+    let plan = logical_plan_with_dialect(sql, &SnowflakeDialect {}).unwrap();
+    assert_snapshot!(
+        plan,
+        @r"
+    Projection: person.id, orders.order_id
+      Inner Join:  Filter: person.id = orders.customer_id
+        TableScan: person
+        TableScan: orders
+    "
+    );
+}
+
 #[test]
 fn empty_over() {
     let sql = "SELECT order_id, MAX(order_id) OVER () from orders";