fix: synchronize compiler guards with current driver capabilities

Author: yeongseon

src/sqlalchemy_excel/compiler.py

@@ -6,15 +6,18 @@
 Supported:
     SELECT columns FROM table [WHERE ...] [GROUP BY ...] [HAVING ...] [ORDER BY col [ASC|DESC]] [LIMIT n] [OFFSET n]
     SELECT DISTINCT columns FROM table [WHERE ...] ...
-    SELECT cols FROM t1 [INNER|LEFT|RIGHT] JOIN t2 ON ... { JOIN t3 ON ... } [WHERE ...] [ORDER BY ...] [LIMIT n] [OFFSET n]
+    SELECT cols FROM t1 [INNER|LEFT|RIGHT|FULL OUTER] JOIN t2 ON ... { JOIN t3 ON ... } [WHERE ...] [ORDER BY ...] [LIMIT n] [OFFSET n]
+    SELECT cols FROM t1 CROSS JOIN t2 [WHERE ...] [ORDER BY ...] [LIMIT n] [OFFSET n]
+    UNION / UNION ALL / INTERSECT / EXCEPT compound SELECT
     INSERT INTO table (cols) VALUES (vals), (vals2), ...
     INSERT INTO table (cols) SELECT cols FROM source [WHERE ...]
     UPDATE table SET col=val [WHERE ...]
     DELETE FROM table [WHERE ...]
 
     Rejected (raises CompileError):
-    CTEs, window functions, RETURNING, FOR UPDATE,
-    NATURAL JOIN, non-equality/OR/non-column ON clauses
+    CTEs, window functions, aggregate FILTER, RETURNING, FOR UPDATE,
+    NATURAL JOIN, non-equality/OR/non-column ON clauses,
+    DISTINCT with JOIN, grouped/nested compound branches
 
     Partially supported:
     non-correlated subqueries in WHERE ... IN (SELECT single_col FROM table [WHERE ...])

tests/test_e2e.py

@@ -380,6 +380,94 @@ def test_e2e_join_left(tmp_path) -> None:
     engine.dispose()
 
 
+def test_e2e_right_join_raw_sql(tmp_path) -> None:
+    engine = _engine_for(tmp_path)
+    metadata = MetaData()
+    users = _users_table(metadata)
+    orders = Table(
+        "orders",
+        metadata,
+        Column("id", Integer, primary_key=True),
+        Column("user_id", Integer),
+        Column("amount", Integer),
+    )
+    metadata.create_all(engine)
+
+    with engine.begin() as conn:
+        conn.execute(insert(users).values(id=1, name="Alice", age=30))
+        conn.execute(insert(users).values(id=2, name="Bob", age=25))
+        conn.execute(insert(orders).values(id=1, user_id=1, amount=100))
+
+    with engine.connect() as conn:
+        rows = conn.execute(
+            sa.text(
+                "SELECT users.name, orders.amount "
+                "FROM users RIGHT JOIN orders ON users.id = orders.user_id"
+            )
+        ).all()
+        assert rows == [("Alice", 100)]
+
+    engine.dispose()
+
+
+def test_e2e_full_outer_join_raw_sql(tmp_path) -> None:
+    engine = _engine_for(tmp_path)
+    metadata = MetaData()
+    users = _users_table(metadata)
+    orders = Table(
+        "orders",
+        metadata,
+        Column("id", Integer, primary_key=True),
+        Column("user_id", Integer),
+        Column("amount", Integer),
+    )
+    metadata.create_all(engine)
+
+    with engine.begin() as conn:
+        conn.execute(insert(users).values(id=1, name="Alice", age=30))
+        conn.execute(insert(users).values(id=2, name="Bob", age=25))
+        conn.execute(insert(orders).values(id=1, user_id=1, amount=100))
+        conn.execute(insert(orders).values(id=2, user_id=999, amount=200))
+
+    with engine.connect() as conn:
+        rows = conn.execute(
+            sa.text(
+                "SELECT users.name, orders.amount "
+                "FROM users FULL OUTER JOIN orders ON users.id = orders.user_id"
+            )
+        ).all()
+        assert set(rows) == {("Alice", 100), ("Bob", None), (None, 200)}
+
+    engine.dispose()
+
+
+def test_e2e_cross_join_raw_sql(tmp_path) -> None:
+    engine = _engine_for(tmp_path)
+    metadata = MetaData()
+    users = _users_table(metadata)
+    teams = Table(
+        "teams",
+        metadata,
+        Column("id", Integer, primary_key=True),
+        Column("name", String),
+    )
+    metadata.create_all(engine)
+
+    with engine.begin() as conn:
+        conn.execute(insert(users), [{"id": 1, "name": "Alice", "age": 30}, {"id": 2, "name": "Bob", "age": 25}])
+        conn.execute(insert(teams), [{"id": 1, "name": "A"}, {"id": 2, "name": "B"}])
+
+    with engine.connect() as conn:
+        rows = conn.execute(
+            sa.text(
+                "SELECT users.id, teams.id FROM users CROSS JOIN teams ORDER BY users.id, teams.id"
+            )
+        ).all()
+        assert rows == [(1, 1), (1, 2), (2, 1), (2, 2)]
+
+    engine.dispose()
+
+
 def test_e2e_subquery_in_where(tmp_path) -> None:
     engine = _engine_for(tmp_path)
     metadata = MetaData()