Skip to content

Commit e499f99

Browse files
committed
Fix to bug that alters subquery columns in Citus subquery joins
1 parent 2adc673 commit e499f99

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

src/sqlancer/citus/oracle/tlp/CitusTLPBase.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -208,11 +208,12 @@ private void addSubqueryJoinStatements(PostgresGlobalState globalState, List<Pos
208208
// JOIN with subquery
209209
for (int i = 0; i < Randomly.smallNumber(); i++) {
210210
PostgresTables subqueryTables = new PostgresTables(Randomly.nonEmptySubset(localTables));
211-
List<PostgresColumn> columns = subqueryTables.getColumns();
211+
List<PostgresColumn> columns = new ArrayList<>();
212+
columns.addAll(subqueryTables.getColumns());
212213
columns.addAll(fromTable.getColumns());
214+
PostgresExpression subquery = createSubquery(globalState, String.format("sub%d", i), subqueryTables);
213215
PostgresExpressionGenerator subqueryJoinGen = new PostgresExpressionGenerator(globalState)
214216
.setColumns(columns);
215-
PostgresExpression subquery = createSubquery(globalState, String.format("sub%d", i), subqueryTables);
216217
PostgresExpression joinClause = subqueryJoinGen.generateExpression(PostgresDataType.BOOLEAN);
217218
PostgresJoinType options = PostgresJoinType.getRandom();
218219
PostgresJoin j = new PostgresJoin(subquery, joinClause, options);

0 commit comments

Comments
 (0)