forked from sqlancer/sqlancer
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathDatabendJoin.java
More file actions
128 lines (106 loc) · 5.17 KB
/
DatabendJoin.java
File metadata and controls
128 lines (106 loc) · 5.17 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
package sqlancer.databend.ast;
import java.util.ArrayList;
import java.util.List;
import sqlancer.Randomly;
import sqlancer.common.ast.newast.Node;
import sqlancer.common.ast.newast.TableReferenceNode;
import sqlancer.databend.DatabendProvider.DatabendGlobalState;
import sqlancer.databend.DatabendSchema;
import sqlancer.databend.DatabendSchema.DatabendColumn;
import sqlancer.databend.DatabendSchema.DatabendTable;
import sqlancer.databend.gen.DatabendNewExpressionGenerator;
public class DatabendJoin implements Node<DatabendExpression> {
private final TableReferenceNode<DatabendExpression, DatabendTable> leftTable;
private final TableReferenceNode<DatabendExpression, DatabendTable> rightTable;
private final JoinType joinType;
private final Node<DatabendExpression> onCondition;
private OuterType outerType;
public enum JoinType {
INNER, NATURAL, LEFT, RIGHT;
public static JoinType getRandom() {
return Randomly.fromOptions(values());
}
}
public enum OuterType {
LEFT, RIGHT;
public static OuterType getRandom() {
return Randomly.fromOptions(values());
}
}
public DatabendJoin(TableReferenceNode<DatabendExpression, DatabendTable> leftTable,
TableReferenceNode<DatabendExpression, DatabendTable> rightTable, JoinType joinType,
Node<DatabendExpression> whereCondition) {
this.leftTable = leftTable;
this.rightTable = rightTable;
this.joinType = joinType;
this.onCondition = whereCondition;
}
public TableReferenceNode<DatabendExpression, DatabendTable> getLeftTable() {
return leftTable;
}
public TableReferenceNode<DatabendExpression, DatabendTable> getRightTable() {
return rightTable;
}
public JoinType getJoinType() {
return joinType;
}
public Node<DatabendExpression> getOnCondition() {
return onCondition;
}
private void setOuterType(OuterType outerType) {
this.outerType = outerType;
}
public OuterType getOuterType() {
return outerType;
}
public static List<Node<DatabendExpression>> getJoins(
List<TableReferenceNode<DatabendExpression, DatabendTable>> tableList, DatabendGlobalState globalState) {
List<Node<DatabendExpression>> joinExpressions = new ArrayList<>();
while (tableList.size() >= 2 && Randomly.getBooleanWithRatherLowProbability()) {
TableReferenceNode<DatabendExpression, DatabendTable> leftTable = tableList.remove(0);
TableReferenceNode<DatabendExpression, DatabendTable> rightTable = tableList.remove(0);
List<DatabendColumn> columns = new ArrayList<>(leftTable.getTable().getColumns());
columns.addAll(rightTable.getTable().getColumns());
DatabendNewExpressionGenerator joinGen = new DatabendNewExpressionGenerator(globalState)
.setColumns(columns);
switch (JoinType.getRandom()) {
case INNER:
joinExpressions.add(DatabendJoin.createInnerJoin(leftTable, rightTable,
joinGen.generateExpression(DatabendSchema.DatabendDataType.BOOLEAN)));
break;
case NATURAL:
joinExpressions.add(DatabendJoin.createNaturalJoin(leftTable, rightTable, OuterType.getRandom()));
break;
case LEFT:
joinExpressions.add(DatabendJoin.createLeftOuterJoin(leftTable, rightTable,
joinGen.generateExpression(DatabendSchema.DatabendDataType.BOOLEAN)));
break;
case RIGHT:
joinExpressions.add(DatabendJoin.createRightOuterJoin(leftTable, rightTable,
joinGen.generateExpression(DatabendSchema.DatabendDataType.BOOLEAN)));
break;
default:
throw new AssertionError();
}
}
return joinExpressions;
}
public static DatabendJoin createRightOuterJoin(TableReferenceNode<DatabendExpression, DatabendTable> left,
TableReferenceNode<DatabendExpression, DatabendTable> right, Node<DatabendExpression> predicate) {
return new DatabendJoin(left, right, JoinType.RIGHT, predicate);
}
public static DatabendJoin createLeftOuterJoin(TableReferenceNode<DatabendExpression, DatabendTable> left,
TableReferenceNode<DatabendExpression, DatabendTable> right, Node<DatabendExpression> predicate) {
return new DatabendJoin(left, right, JoinType.LEFT, predicate);
}
public static DatabendJoin createInnerJoin(TableReferenceNode<DatabendExpression, DatabendTable> left,
TableReferenceNode<DatabendExpression, DatabendTable> right, Node<DatabendExpression> predicate) {
return new DatabendJoin(left, right, JoinType.INNER, predicate);
}
public static Node<DatabendExpression> createNaturalJoin(TableReferenceNode<DatabendExpression, DatabendTable> left,
TableReferenceNode<DatabendExpression, DatabendTable> right, OuterType naturalJoinType) {
DatabendJoin join = new DatabendJoin(left, right, JoinType.NATURAL, null);
join.setOuterType(naturalJoinType);
return join;
}
}