Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

added ensureCollections to orphan create method (#9833)

This commit is contained in:
Heiko 2019-08-29 23:01:53 +02:00 committed by Jan
parent 30b36a2a42
commit edba8f73fb
2 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGELOG
View File

@ -1,6 +1,8 @@
devel
-----
* Fixed adding an orphan collections as the first collection in a SmartGraph.
* Geo functions will now have better error reporting on invalid input.
* Fixed issue #9795. Fixed NOT IN clause in ArangoSearch.

25
arangod/Graph/GraphOperations.cpp
View File

@ -287,10 +287,6 @@ OperationResult GraphOperations::addOrphanCollection(VPackSlice document, bool w
std::shared_ptr<LogicalCollection> def;
OperationResult result;
VPackBuilder collectionsOptions;
collectionsOptions.openObject();
_graph.createCollectionOptions(collectionsOptions, waitForSync);
collectionsOptions.close();
if (_graph.hasVertexCollection(collectionName)) {
if (_graph.hasOrphanCollection(collectionName)) {
@ -302,13 +298,19 @@ OperationResult GraphOperations::addOrphanCollection(VPackSlice document, bool w
std::string{TRI_errno_string(TRI_ERROR_GRAPH_COLLECTION_USED_IN_EDGE_DEF)}));
}
// add orphan collection to graph
_graph.addOrphanCollection(std::string(collectionName));
def = GraphManager::getCollectionByName(_vocbase, collectionName);
Result res;
if (def == nullptr) {
if (createCollection) {
result = gmngr.createVertexCollection(collectionName, waitForSync,
collectionsOptions.slice());
if (result.fail()) {
return result;
// ensure that all collections are available
res = gmngr.ensureCollections(&_graph, waitForSync);
if (res.fail()) {
return OperationResult{std::move(res)};
}
} else {
return OperationResult(
@ -320,13 +322,11 @@ OperationResult GraphOperations::addOrphanCollection(VPackSlice document, bool w
if (def->type() != TRI_COL_TYPE_DOCUMENT) {
return OperationResult(TRI_ERROR_GRAPH_WRONG_COLLECTION_TYPE_VERTEX);
}
auto res = _graph.validateCollection(*(def.get()));
res = _graph.validateCollection(*(def.get()));
if (res.fail()) {
return OperationResult{std::move(res)};
}
}
// add orphan collection to graph
_graph.addOrphanCollection(std::move(collectionName));
VPackBuilder builder;
builder.openObject();
@ -336,10 +336,9 @@ OperationResult GraphOperations::addOrphanCollection(VPackSlice document, bool w
SingleCollectionTransaction trx(ctx(), StaticStrings::GraphCollection,
AccessMode::Type::WRITE);
Result res = trx.begin();
res = trx.begin();
if (!res.ok()) {
trx.finish(TRI_ERROR_NO_ERROR);
return OperationResult(res);
}