mirror of https://gitee.com/bigwinds/arangodb
added lost gharial tests (#6172)
This commit is contained in:
parent
01e39a391b
commit
3e010965db
|
@ -321,8 +321,12 @@ var transformExampleToAQL = function (examples, collections, bindVars, varname)
|
||||||
// //////////////////////////////////////////////////////////////////////////////
|
// //////////////////////////////////////////////////////////////////////////////
|
||||||
|
|
||||||
var sortEdgeDefinitionInplace = function (edgeDefinition) {
|
var sortEdgeDefinitionInplace = function (edgeDefinition) {
|
||||||
|
if (edgeDefinition && edgeDefinition.from && Array.isArray(edgeDefinition.from)) {
|
||||||
edgeDefinition.from.sort();
|
edgeDefinition.from.sort();
|
||||||
|
}
|
||||||
|
if (edgeDefinition && edgeDefinition.to && Array.isArray(edgeDefinition.to)) {
|
||||||
edgeDefinition.to.sort();
|
edgeDefinition.to.sort();
|
||||||
|
}
|
||||||
return edgeDefinition;
|
return edgeDefinition;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
@ -1601,7 +1605,15 @@ class Graph {
|
||||||
}
|
}
|
||||||
);
|
);
|
||||||
|
|
||||||
findOrCreateCollectionsByEdgeDefinitions([edgeDefinition]);
|
var options = {};
|
||||||
|
if (self.__replicationFactor) {
|
||||||
|
options.replicationFactor = self.__replicationFactor;
|
||||||
|
}
|
||||||
|
if (self.__numberOfShards) {
|
||||||
|
options.numberOfShards = self.__numberOfShards;
|
||||||
|
}
|
||||||
|
|
||||||
|
findOrCreateCollectionsByEdgeDefinitions([edgeDefinition], false, options);
|
||||||
|
|
||||||
this.__edgeDefinitions.push(edgeDefinition);
|
this.__edgeDefinitions.push(edgeDefinition);
|
||||||
db._graphs.update(this.__name, {edgeDefinitions: this.__edgeDefinitions});
|
db._graphs.update(this.__name, {edgeDefinitions: this.__edgeDefinitions});
|
||||||
|
@ -1653,7 +1665,15 @@ class Graph {
|
||||||
throw err;
|
throw err;
|
||||||
}
|
}
|
||||||
|
|
||||||
findOrCreateCollectionsByEdgeDefinitions([edgeDefinition]);
|
var options = {};
|
||||||
|
if (self.__replicationFactor) {
|
||||||
|
options.replicationFactor = self.__replicationFactor;
|
||||||
|
}
|
||||||
|
if (self.__numberOfShards) {
|
||||||
|
options.numberOfShards = self.__numberOfShards;
|
||||||
|
}
|
||||||
|
|
||||||
|
findOrCreateCollectionsByEdgeDefinitions([edgeDefinition], false, options);
|
||||||
|
|
||||||
// evaluate collections to add to orphanage
|
// evaluate collections to add to orphanage
|
||||||
var possibleOrphans = [];
|
var possibleOrphans = [];
|
||||||
|
@ -1750,10 +1770,19 @@ class Graph {
|
||||||
_addVertexCollection (vertexCollectionName, createCollection) {
|
_addVertexCollection (vertexCollectionName, createCollection) {
|
||||||
// check edgeCollection
|
// check edgeCollection
|
||||||
var ec = db._collection(vertexCollectionName);
|
var ec = db._collection(vertexCollectionName);
|
||||||
|
var self = this;
|
||||||
var err;
|
var err;
|
||||||
if (ec === null) {
|
if (ec === null) {
|
||||||
if (createCollection !== false) {
|
if (createCollection !== false) {
|
||||||
db._create(vertexCollectionName);
|
// TODO
|
||||||
|
var options = {};
|
||||||
|
if (self.__replicationFactor) {
|
||||||
|
options.replicationFactor = self.__replicationFactor;
|
||||||
|
}
|
||||||
|
if (self.__numberOfShards) {
|
||||||
|
options.numberOfShards = self.__numberOfShards;
|
||||||
|
}
|
||||||
|
db._create(vertexCollectionName, options);
|
||||||
} else {
|
} else {
|
||||||
err = new ArangoError();
|
err = new ArangoError();
|
||||||
err.errorNum = arangodb.errors.ERROR_GRAPH_VERTEX_COL_DOES_NOT_EXIST.code;
|
err.errorNum = arangodb.errors.ERROR_GRAPH_VERTEX_COL_DOES_NOT_EXIST.code;
|
||||||
|
|
|
@ -0,0 +1,475 @@
|
||||||
|
/* global describe, it, beforeEach, afterEach, it, clean, before, after */
|
||||||
|
'use strict';
|
||||||
|
|
||||||
|
// //////////////////////////////////////////////////////////////////////////////
|
||||||
|
// / @brief Spec for general graph options cluster
|
||||||
|
// /
|
||||||
|
// / @file
|
||||||
|
// /
|
||||||
|
// / DISCLAIMER
|
||||||
|
// /
|
||||||
|
// / Copyright 2014 ArangoDB GmbH, Cologne, Germany
|
||||||
|
// /
|
||||||
|
// / Licensed under the Apache License, Version 2.0 (the "License")
|
||||||
|
// / you may not use this file except in compliance with the License.
|
||||||
|
// / You may obtain a copy of the License at
|
||||||
|
// /
|
||||||
|
// / http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
// /
|
||||||
|
// / Unless required by applicable law or agreed to in writing, software
|
||||||
|
// / distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
// / WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
// / See the License for the specific language governing permissions and
|
||||||
|
// / limitations under the License.
|
||||||
|
// /
|
||||||
|
// / Copyright holder is ArangoDB GmbH, Cologne, Germany
|
||||||
|
// /
|
||||||
|
// / @author Michael Hackstein
|
||||||
|
// / @author Copyright 2017, ArangoDB GmbH, Cologne, Germany
|
||||||
|
// //////////////////////////////////////////////////////////////////////////////
|
||||||
|
|
||||||
|
const expect = require('chai').expect;
|
||||||
|
const arangodb = require('@arangodb');
|
||||||
|
const request = require('@arangodb/request');
|
||||||
|
const graph = require('@arangodb/general-graph');
|
||||||
|
const extend = require('lodash').extend;
|
||||||
|
let endpoint = {};
|
||||||
|
|
||||||
|
const db = arangodb.db;
|
||||||
|
|
||||||
|
describe('General graph creation', function () {
|
||||||
|
|
||||||
|
const gn = 'UnitTestGraph';
|
||||||
|
const vn = 'UnitTestVertices';
|
||||||
|
const en = 'UnitTestEdges';
|
||||||
|
const on = 'UnitTestOrphans';
|
||||||
|
|
||||||
|
const vn2 = 'UnitTestVerticesOther';
|
||||||
|
const en2 = 'UnitTestEdgesOther';
|
||||||
|
const on2 = 'UnitTestOrphansOther';
|
||||||
|
const vn3 = 'UnitTestVerticesModified';
|
||||||
|
|
||||||
|
const clean = () => {
|
||||||
|
try {
|
||||||
|
request['delete'](`/_api/gharial/${gn}?dropCollections=true`);
|
||||||
|
} catch (ignore) {
|
||||||
|
}
|
||||||
|
|
||||||
|
expect(db._collection(vn)).to.not.exist;
|
||||||
|
expect(db._collection(en)).to.not.exist;
|
||||||
|
expect(db._collection(on)).to.not.exist;
|
||||||
|
|
||||||
|
expect(db._collection(vn2)).to.not.exist;
|
||||||
|
expect(db._collection(en2)).to.not.exist;
|
||||||
|
expect(db._collection(on2)).to.not.exist;
|
||||||
|
expect(db._collection(vn3)).to.not.exist;
|
||||||
|
};
|
||||||
|
|
||||||
|
before(clean);
|
||||||
|
after(clean);
|
||||||
|
|
||||||
|
describe('with defaults', function () {
|
||||||
|
|
||||||
|
before(function() {
|
||||||
|
let rel = graph._relation(en, vn, vn);
|
||||||
|
let body = {
|
||||||
|
orphanCollections: [on],
|
||||||
|
edgeDefinitions: [rel],
|
||||||
|
name: gn,
|
||||||
|
isSmart: false
|
||||||
|
};
|
||||||
|
|
||||||
|
// Create with default options
|
||||||
|
let res = request.post(`/_api/gharial`, {
|
||||||
|
body: JSON.stringify(body)
|
||||||
|
});
|
||||||
|
expect(res.statusCode).to.equal(202);
|
||||||
|
|
||||||
|
// Do we need to wait here?
|
||||||
|
|
||||||
|
// Validate all collections get created
|
||||||
|
expect(db._collection(vn)).to.exist;
|
||||||
|
expect(db._collection(en)).to.exist;
|
||||||
|
expect(db._collection(on)).to.exist;
|
||||||
|
|
||||||
|
// Validate create later collections to not exist
|
||||||
|
expect(db._collection(vn2)).to.not.exist;
|
||||||
|
expect(db._collection(en2)).to.not.exist;
|
||||||
|
expect(db._collection(on2)).to.not.exist;
|
||||||
|
});
|
||||||
|
|
||||||
|
after(clean);
|
||||||
|
|
||||||
|
describe('during graph construction', function () {
|
||||||
|
|
||||||
|
describe('replication factor', function () {
|
||||||
|
|
||||||
|
it('should be stored in the internal document', function () {
|
||||||
|
let gdoc = db._collection('_graphs').document(gn);
|
||||||
|
expect(gdoc.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for vertex collection', function () {
|
||||||
|
let props = db._collection(vn).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for edge collection', function () {
|
||||||
|
let props = db._collection(en).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for orphan collection', function () {
|
||||||
|
let props = db._collection(on).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('number of shards', function () {
|
||||||
|
|
||||||
|
it('should be stored in the internal document', function () {
|
||||||
|
let gdoc = db._collection('_graphs').document(gn);
|
||||||
|
expect(gdoc.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for vertex collection', function () {
|
||||||
|
let props = db._collection(vn).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for edge collection', function () {
|
||||||
|
let props = db._collection(en).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for orphan collection', function () {
|
||||||
|
let props = db._collection(on).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('adding collections later', function () {
|
||||||
|
|
||||||
|
before(function() {
|
||||||
|
let body = {
|
||||||
|
to: [vn2],
|
||||||
|
from: [vn2],
|
||||||
|
collection: en2
|
||||||
|
};
|
||||||
|
let res = request.post(`/_api/gharial/${gn}/edge`, extend(endpoint, {
|
||||||
|
body: JSON.stringify(body)
|
||||||
|
}));
|
||||||
|
|
||||||
|
expect(res.statusCode).to.equal(202);
|
||||||
|
|
||||||
|
body = {
|
||||||
|
collection: on2
|
||||||
|
};
|
||||||
|
res = request.post(`/_api/gharial/${gn}/vertex`, extend(endpoint, {
|
||||||
|
body: JSON.stringify(body)
|
||||||
|
}));
|
||||||
|
|
||||||
|
expect(res.statusCode).to.equal(202);
|
||||||
|
|
||||||
|
// Do we need to wait here?
|
||||||
|
|
||||||
|
// Validate create later collections to now exist
|
||||||
|
expect(db._collection(vn2)).to.exist;
|
||||||
|
expect(db._collection(en2)).to.exist;
|
||||||
|
expect(db._collection(on2)).to.exist;
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('replication factor', function () {
|
||||||
|
|
||||||
|
it('should be 1 for vertex collection', function () {
|
||||||
|
let props = db._collection(vn2).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for edge collection', function () {
|
||||||
|
let props = db._collection(en2).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for orphan collection', function () {
|
||||||
|
let props = db._collection(on2).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('number of shards', function () {
|
||||||
|
|
||||||
|
it('should be 1 for vertex collection', function () {
|
||||||
|
let props = db._collection(vn2).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for edge collection', function () {
|
||||||
|
let props = db._collection(en2).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for orphan collection', function () {
|
||||||
|
let props = db._collection(on2).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('modify edge definition', function () {
|
||||||
|
|
||||||
|
before(function() {
|
||||||
|
// We modify the first relation by adding a new vertex collection
|
||||||
|
|
||||||
|
let body = {
|
||||||
|
from: [vn],
|
||||||
|
to: [vn3],
|
||||||
|
collection: en
|
||||||
|
};
|
||||||
|
|
||||||
|
let res = request.put(`/_api/gharial/${gn}/edge/${en}`, extend(endpoint, {
|
||||||
|
body: JSON.stringify(body)
|
||||||
|
}));
|
||||||
|
|
||||||
|
expect(res.statusCode).to.equal(202);
|
||||||
|
|
||||||
|
expect(db._collection(vn3)).to.exist;
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('replication factor', function () {
|
||||||
|
|
||||||
|
it(`should be 1 for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn3).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('number of shards', function () {
|
||||||
|
|
||||||
|
it(`should be 1 for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn3).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('with startup options', function () {
|
||||||
|
const replicationFactor = 2;
|
||||||
|
const numberOfShards = 3;
|
||||||
|
|
||||||
|
before(function() {
|
||||||
|
const options = {
|
||||||
|
replicationFactor,
|
||||||
|
numberOfShards
|
||||||
|
};
|
||||||
|
let rel = graph._relation(en, vn, vn);
|
||||||
|
|
||||||
|
let body = {
|
||||||
|
orphanCollections: [on],
|
||||||
|
edgeDefinitions: [rel],
|
||||||
|
name: gn,
|
||||||
|
isSmart: false,
|
||||||
|
options
|
||||||
|
};
|
||||||
|
|
||||||
|
let res = request.post(`/_api/gharial`, {
|
||||||
|
body: JSON.stringify(body)
|
||||||
|
});
|
||||||
|
|
||||||
|
expect(res.statusCode).to.equal(202);
|
||||||
|
|
||||||
|
// Do we need to wait here?
|
||||||
|
|
||||||
|
// Validate all collections get created
|
||||||
|
expect(db._collection(vn)).to.exist;
|
||||||
|
expect(db._collection(en)).to.exist;
|
||||||
|
expect(db._collection(on)).to.exist;
|
||||||
|
|
||||||
|
// Validate create later collections to not exist
|
||||||
|
expect(db._collection(vn2)).to.not.exist;
|
||||||
|
expect(db._collection(en2)).to.not.exist;
|
||||||
|
expect(db._collection(on2)).to.not.exist;
|
||||||
|
});
|
||||||
|
|
||||||
|
after(clean);
|
||||||
|
|
||||||
|
describe('during graph construction', function () {
|
||||||
|
|
||||||
|
describe('replication factor', function () {
|
||||||
|
|
||||||
|
it('should be stored in the internal document', function () {
|
||||||
|
let gdoc = db._collection('_graphs').document(gn);
|
||||||
|
expect(gdoc.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for edge collection`, function () {
|
||||||
|
let props = db._collection(en).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for orphan collection`, function () {
|
||||||
|
let props = db._collection(on).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('number of shards', function () {
|
||||||
|
|
||||||
|
it('should be stored in the internal document', function () {
|
||||||
|
let gdoc = db._collection('_graphs').document(gn);
|
||||||
|
expect(gdoc.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for edge collection`, function () {
|
||||||
|
let props = db._collection(en).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for orphan collection`, function () {
|
||||||
|
let props = db._collection(on).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('adding collections later', function () {
|
||||||
|
|
||||||
|
before(function() {
|
||||||
|
let body = {
|
||||||
|
to: [vn2],
|
||||||
|
from: [vn2],
|
||||||
|
collection: en2
|
||||||
|
};
|
||||||
|
let res = request.post(`/_api/gharial/${gn}/edge`, extend(endpoint, {
|
||||||
|
body: JSON.stringify(body)
|
||||||
|
}));
|
||||||
|
|
||||||
|
expect(res.statusCode).to.equal(202);
|
||||||
|
|
||||||
|
body = {
|
||||||
|
collection: on2
|
||||||
|
};
|
||||||
|
|
||||||
|
res = request.post(`/_api/gharial/${gn}/vertex`, extend(endpoint, {
|
||||||
|
body: JSON.stringify(body)
|
||||||
|
}));
|
||||||
|
|
||||||
|
expect(res.statusCode).to.equal(202);
|
||||||
|
|
||||||
|
// Do we need to wait here?
|
||||||
|
|
||||||
|
// Validate create later collections to now exist
|
||||||
|
expect(db._collection(vn2)).to.exist;
|
||||||
|
expect(db._collection(en2)).to.exist;
|
||||||
|
expect(db._collection(on2)).to.exist;
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('replication factor', function () {
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn2).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for edge collection`, function () {
|
||||||
|
let props = db._collection(en2).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for orphan collection`, function () {
|
||||||
|
let props = db._collection(on2).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('number of shards', function () {
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn2).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for edge collection`, function () {
|
||||||
|
let props = db._collection(en2).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for orphan collection`, function () {
|
||||||
|
let props = db._collection(on2).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('modify edge definition', function () {
|
||||||
|
|
||||||
|
before(function() {
|
||||||
|
// We modify the first relation by adding a new vertex collection
|
||||||
|
|
||||||
|
let body = {
|
||||||
|
from: [vn],
|
||||||
|
to: [vn3],
|
||||||
|
collection: en
|
||||||
|
};
|
||||||
|
|
||||||
|
let res = request.put(`/_api/gharial/${gn}/edge/${en}`, extend(endpoint, {
|
||||||
|
body: JSON.stringify(body)
|
||||||
|
}));
|
||||||
|
|
||||||
|
expect(res.statusCode).to.equal(202);
|
||||||
|
|
||||||
|
expect(db._collection(vn3)).to.exist;
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('replication factor', function () {
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn3).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('number of shards', function () {
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn3).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
|
@ -0,0 +1,388 @@
|
||||||
|
/* global describe, it, beforeEach, afterEach, it, clean, before, after */
|
||||||
|
'use strict';
|
||||||
|
|
||||||
|
// //////////////////////////////////////////////////////////////////////////////
|
||||||
|
// / @brief Spec for general graph options cluster
|
||||||
|
// /
|
||||||
|
// / @file
|
||||||
|
// /
|
||||||
|
// / DISCLAIMER
|
||||||
|
// /
|
||||||
|
// / Copyright 2014 ArangoDB GmbH, Cologne, Germany
|
||||||
|
// /
|
||||||
|
// / Licensed under the Apache License, Version 2.0 (the "License")
|
||||||
|
// / you may not use this file except in compliance with the License.
|
||||||
|
// / You may obtain a copy of the License at
|
||||||
|
// /
|
||||||
|
// / http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
// /
|
||||||
|
// / Unless required by applicable law or agreed to in writing, software
|
||||||
|
// / distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
// / WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
// / See the License for the specific language governing permissions and
|
||||||
|
// / limitations under the License.
|
||||||
|
// /
|
||||||
|
// / Copyright holder is ArangoDB GmbH, Cologne, Germany
|
||||||
|
// /
|
||||||
|
// / @author Michael Hackstein
|
||||||
|
// / @author Copyright 2017, ArangoDB GmbH, Cologne, Germany
|
||||||
|
// //////////////////////////////////////////////////////////////////////////////
|
||||||
|
|
||||||
|
const arangodb = require('@arangodb');
|
||||||
|
const expect = require('chai').expect;
|
||||||
|
const graph = require("@arangodb/general-graph");
|
||||||
|
const db = arangodb.db;
|
||||||
|
|
||||||
|
describe('General graph creation', function () {
|
||||||
|
|
||||||
|
const gn = 'UnitTestGraph';
|
||||||
|
const vn = 'UnitTestVertices';
|
||||||
|
const en = 'UnitTestEdges';
|
||||||
|
const on = 'UnitTestOrphans';
|
||||||
|
|
||||||
|
const vn2 = 'UnitTestVerticesOther';
|
||||||
|
const en2 = 'UnitTestEdgesOther';
|
||||||
|
const on2 = 'UnitTestOrphansOther';
|
||||||
|
const vn3 = 'UnitTestVerticesModified';
|
||||||
|
|
||||||
|
const clean = () => {
|
||||||
|
try {
|
||||||
|
graph._drop(gn, true);
|
||||||
|
} catch (ignore) {
|
||||||
|
}
|
||||||
|
expect(db._collection(vn)).to.not.exist;
|
||||||
|
expect(db._collection(en)).to.not.exist;
|
||||||
|
expect(db._collection(on)).to.not.exist;
|
||||||
|
|
||||||
|
expect(db._collection(vn2)).to.not.exist;
|
||||||
|
expect(db._collection(en2)).to.not.exist;
|
||||||
|
expect(db._collection(on2)).to.not.exist;
|
||||||
|
expect(db._collection(vn3)).to.not.exist;
|
||||||
|
};
|
||||||
|
|
||||||
|
before(clean);
|
||||||
|
after(clean);
|
||||||
|
|
||||||
|
describe('with defaults', function () {
|
||||||
|
let g;
|
||||||
|
|
||||||
|
before(function() {
|
||||||
|
let rel = graph._relation(en, vn, vn);
|
||||||
|
// Create with default options
|
||||||
|
g = graph._create(gn, [rel], [on]);
|
||||||
|
|
||||||
|
// Validate all collections get created
|
||||||
|
expect(db._collection(vn)).to.exist;
|
||||||
|
expect(db._collection(en)).to.exist;
|
||||||
|
expect(db._collection(on)).to.exist;
|
||||||
|
|
||||||
|
// Validate create later collections to not exist
|
||||||
|
expect(db._collection(vn2)).to.not.exist;
|
||||||
|
expect(db._collection(en2)).to.not.exist;
|
||||||
|
expect(db._collection(on2)).to.not.exist;
|
||||||
|
});
|
||||||
|
|
||||||
|
after(clean);
|
||||||
|
|
||||||
|
describe('during graph construction', function () {
|
||||||
|
|
||||||
|
describe('replication factor', function () {
|
||||||
|
|
||||||
|
it('should be stored in the internal document', function () {
|
||||||
|
let gdoc = db._collection('_graphs').document(gn);
|
||||||
|
expect(gdoc.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for vertex collection', function () {
|
||||||
|
let props = db._collection(vn).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for edge collection', function () {
|
||||||
|
let props = db._collection(en).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for orphan collection', function () {
|
||||||
|
let props = db._collection(on).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('number of shards', function () {
|
||||||
|
|
||||||
|
it('should be stored in the internal document', function () {
|
||||||
|
let gdoc = db._collection('_graphs').document(gn);
|
||||||
|
expect(gdoc.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for vertex collection', function () {
|
||||||
|
let props = db._collection(vn).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for edge collection', function () {
|
||||||
|
let props = db._collection(en).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for orphan collection', function () {
|
||||||
|
let props = db._collection(on).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('adding collections later', function () {
|
||||||
|
|
||||||
|
before(function() {
|
||||||
|
let rel = graph._relation(en2, vn2, vn2);
|
||||||
|
g._extendEdgeDefinitions(rel);
|
||||||
|
g._addVertexCollection(on2);
|
||||||
|
|
||||||
|
// Validate create later collections to now exist
|
||||||
|
expect(db._collection(vn2)).to.exist;
|
||||||
|
expect(db._collection(en2)).to.exist;
|
||||||
|
expect(db._collection(on2)).to.exist;
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('replication factor', function () {
|
||||||
|
|
||||||
|
it('should be 1 for vertex collection', function () {
|
||||||
|
let props = db._collection(vn2).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for edge collection', function () {
|
||||||
|
let props = db._collection(en2).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for orphan collection', function () {
|
||||||
|
let props = db._collection(on2).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('number of shards', function () {
|
||||||
|
|
||||||
|
it('should be 1 for vertex collection', function () {
|
||||||
|
let props = db._collection(vn2).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for edge collection', function () {
|
||||||
|
let props = db._collection(en2).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should be 1 for orphan collection', function () {
|
||||||
|
let props = db._collection(on2).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('modify edge definition', function () {
|
||||||
|
before(function() {
|
||||||
|
// We modify the first relation by adding a new vertex collection
|
||||||
|
let rel = graph._relation(en, vn, vn3);
|
||||||
|
g._editEdgeDefinitions(rel);
|
||||||
|
|
||||||
|
expect(db._collection(vn3)).to.exist;
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('replication factor', function () {
|
||||||
|
|
||||||
|
it(`should be 1 for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn3).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('number of shards', function () {
|
||||||
|
|
||||||
|
it(`should be 1 for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn3).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('with startup options', function () {
|
||||||
|
let g;
|
||||||
|
const replicationFactor = 2;
|
||||||
|
const numberOfShards = 3;
|
||||||
|
|
||||||
|
before(function() {
|
||||||
|
const options = {
|
||||||
|
replicationFactor,
|
||||||
|
numberOfShards
|
||||||
|
};
|
||||||
|
let rel = graph._relation(en, vn, vn);
|
||||||
|
// Create with default options
|
||||||
|
g = graph._create(gn, [rel], [on], options);
|
||||||
|
|
||||||
|
// Validate all collections get created
|
||||||
|
expect(db._collection(vn)).to.exist;
|
||||||
|
expect(db._collection(en)).to.exist;
|
||||||
|
expect(db._collection(on)).to.exist;
|
||||||
|
|
||||||
|
// Validate create later collections to not exist
|
||||||
|
expect(db._collection(vn2)).to.not.exist;
|
||||||
|
expect(db._collection(en2)).to.not.exist;
|
||||||
|
expect(db._collection(on2)).to.not.exist;
|
||||||
|
});
|
||||||
|
|
||||||
|
after(clean);
|
||||||
|
|
||||||
|
describe('during graph construction', function () {
|
||||||
|
|
||||||
|
describe('replication factor', function () {
|
||||||
|
|
||||||
|
it('should be stored in the internal document', function () {
|
||||||
|
let gdoc = db._collection('_graphs').document(gn);
|
||||||
|
expect(gdoc.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for edge collection`, function () {
|
||||||
|
let props = db._collection(en).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for orphan collection`, function () {
|
||||||
|
let props = db._collection(on).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('number of shards', function () {
|
||||||
|
|
||||||
|
it('should be stored in the internal document', function () {
|
||||||
|
let gdoc = db._collection('_graphs').document(gn);
|
||||||
|
expect(gdoc.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for edge collection`, function () {
|
||||||
|
let props = db._collection(en).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for orphan collection`, function () {
|
||||||
|
let props = db._collection(on).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('adding collections later', function () {
|
||||||
|
|
||||||
|
before(function() {
|
||||||
|
let rel = graph._relation(en2, vn2, vn2);
|
||||||
|
g = graph._graph(g.__name);
|
||||||
|
g._extendEdgeDefinitions(rel);
|
||||||
|
g._addVertexCollection(on2);
|
||||||
|
|
||||||
|
// Validate create later collections to now exist
|
||||||
|
expect(db._collection(vn2)).to.exist;
|
||||||
|
expect(db._collection(en2)).to.exist;
|
||||||
|
expect(db._collection(on2)).to.exist;
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('replication factor', function () {
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn2).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for edge collection`, function () {
|
||||||
|
let props = db._collection(en2).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for orphan collection`, function () {
|
||||||
|
let props = db._collection(on2).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('number of shards', function () {
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn2).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for edge collection`, function () {
|
||||||
|
let props = db._collection(en2).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for orphan collection`, function () {
|
||||||
|
let props = db._collection(on2).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('modify edge definition', function () {
|
||||||
|
before(function() {
|
||||||
|
// We modify the first relation by adding a new vertex collection
|
||||||
|
let rel = graph._relation(en, vn, vn3);
|
||||||
|
g._editEdgeDefinitions(rel);
|
||||||
|
|
||||||
|
expect(db._collection(vn3)).to.exist;
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('replication factor', function () {
|
||||||
|
|
||||||
|
it(`should be ${replicationFactor} for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn3).properties();
|
||||||
|
expect(props.replicationFactor).to.equal(replicationFactor);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('number of shards', function () {
|
||||||
|
|
||||||
|
it(`should be ${numberOfShards} for vertex collection`, function () {
|
||||||
|
let props = db._collection(vn3).properties();
|
||||||
|
expect(props.numberOfShards).to.equal(numberOfShards);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
Loading…
Reference in New Issue