Skip to content

Commit 0a57a13

Browse files
committed
Correct join rewrite optimization
1 parent a7ac59e commit 0a57a13

1 file changed

Lines changed: 0 additions & 6 deletions

File tree

syncanysql/compiler.py

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -3186,9 +3186,6 @@ def resort_join_tables(current_table, on_expressions, join_tables):
31863186
on_expressions = join_table["on_expressions"] + join_table["const_expressions"] + join_table["calculate_expressions"]
31873187
if on_expressions:
31883188
sql.append("ON " + " AND ".join([self.generate_sql(on_expression) for on_expression in on_expressions]))
3189-
if expression.args.get("joins"):
3190-
for join_expression in expression.args["joins"]:
3191-
sql.append(self.generate_sql(join_expression))
31923189

31933190
where_expressions = selected_table["const_expressions"] + primary_table["calculate_expressions"] + selected_table["calculate_expressions"]
31943191
if where_expressions:
@@ -3244,9 +3241,6 @@ def optimize_rewrite_inner_join(self, expression, config, arguments):
32443241
sql.append("LEFT JOIN " + self.generate_sql(join_expression.args["this"]))
32453242
if join_expression.args.get("on"):
32463243
sql.append("ON " + self.generate_sql(join_expression.args["on"]))
3247-
if expression.args.get("joins"):
3248-
for join_expression in expression.args["joins"]:
3249-
sql.append(self.generate_sql(join_expression))
32503244

32513245
inner_condition_sql = " AND ".join(["%s.%s IS NOT NULL" % (calculate_field["table_name"], calculate_field["column_name"])
32523246
for calculate_field in inner_calculate_fields])

0 commit comments

Comments
 (0)