Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

chore: fix TinkerPop unit test #2055

Merged
merged 14 commits into from
Dec 26, 2022
Merged

chore: fix TinkerPop unit test #2055

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
2830974
chore: don't support persistence for memory backend
zyxxoo Dec 18, 2022
b76394a
chore: setup graph by first step graph when graph is null
zyxxoo Dec 18, 2022
cd76807
chore: apply relations optimize logic
zyxxoo Dec 19, 2022
00e50be
chore: don't support null properties
zyxxoo Dec 19, 2022
c3317b1
chore: reflactor code
zyxxoo Dec 19, 2022
694a787
fix: g.V().has(empty).count() and g.V().count().as('a').select('a')
zyxxoo Dec 22, 2022
1e4a910
fix: specify the code generation directory for raft.proto (#2057)
simon824 Dec 21, 2022
02963d5
chore: reflactor code
zyxxoo Dec 22, 2022
62f9fed
fix: tinkerpop unit schema no define
zyxxoo Dec 22, 2022
ae7266d
chore: reflactor code
zyxxoo Dec 22, 2022
d2a494c
chore: improve code
zyxxoo Dec 22, 2022
9b5ee56
fix: core test
zyxxoo Dec 23, 2022
4a71089
Merge branch 'master' into zy_dev
zyxxoo Dec 26, 2022
225854c
fix the style & clean some outdated code
imbajin Dec 26, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 20 additions & 17 deletions hugegraph-core/src/main/java/org/apache/hugegraph/backend/query/ConditionQueryFlatten.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -51,23 +51,7 @@ public static List<ConditionQuery> flatten(ConditionQuery query) {
public static List<ConditionQuery> flatten(ConditionQuery query,
boolean supportIn) {
if (query.isFlattened() && !query.mayHasDupKeys(SPECIAL_KEYS)) {
Relations relations = new Relations();
List<Condition> noRelations = new ArrayList<>();
for (Condition condition : query.conditions()) {
if (condition.isRelation()) {
relations.add((Relation) condition);
} else {
noRelations.add(condition);
}
}
relations = optimizeRelations(relations);
if (relations != null) {
ConditionQuery cq = newQueryFromRelations(query, relations);
cq.query(noRelations);
return ImmutableList.of(cq);
}

return ImmutableList.of(query);
return flattenRelations(query);
}

List<ConditionQuery> queries = new ArrayList<>();
Expand Down Expand Up @@ -267,6 +251,25 @@ private static ConditionQuery newQueryFromRelations(ConditionQuery query,
return cq;
}

private static ImmutableList<ConditionQuery> flattenRelations(ConditionQuery query) {
Relations relations = new Relations();
List<Condition> noRelations = new ArrayList<>();
zyxxoo marked this conversation as resolved.
Show resolved Hide resolved
for (Condition condition : query.conditions()) {
if (condition.isRelation()) {
relations.add((Relation) condition);
zyxxoo marked this conversation as resolved.
Show resolved Hide resolved
} else {
noRelations.add(condition);
}
}
relations = optimizeRelations(relations);
if (relations != null) {
ConditionQuery cq = newQueryFromRelations(query, relations);
cq.query(noRelations);
return ImmutableList.of(cq);
}
return ImmutableList.of(query);
}

private static Relations optimizeRelations(Relations relations) {
// Optimize and-relations in one query
// e.g. (age>1 and age>2) -> (age>2)
Expand Down
2 changes: 2 additions & 0 deletions hugegraph-core/src/main/java/org/apache/hugegraph/traversal/optimize/TraversalUtil.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -107,6 +107,7 @@ public static HugeGraph getGraph(Step<?, ?> step) {
}

public static HugeGraph tryGetGraph(Step<?, ?> step) {
// TODO: remove these EmptyGraph judgments when upgrading tinkerpop to a fixed version
zyxxoo marked this conversation as resolved.
Show resolved Hide resolved
zyxxoo marked this conversation as resolved.
Show resolved Hide resolved
Optional<Graph> graph = step.getTraversal()
.getGraph()
.filter(g -> {
Expand Down Expand Up @@ -139,6 +140,7 @@ public static void trySetGraph(Step<?, ?> step, HugeGraph graph) {
return;
}

// TODO: remove these EmptyGraph judgments when upgrading tinkerpop to a fixed version
Optional<Graph> stepGraph = step.getTraversal()
.getGraph()
.filter(g -> {
Expand Down