Coverage Summary for Class: DocumentationUsecases (org.umlg.sqlg.test.docs)
| Class |
Class, %
|
Method, %
|
Branch, %
|
Line, %
|
| DocumentationUsecases |
0%
(0/1)
|
0%
(0/2)
|
0%
(0/8)
|
0%
(0/23)
|
package org.umlg.sqlg.test.docs;
import org.apache.commons.lang3.time.StopWatch;
import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.junit.Assume;
import org.junit.Test;
import org.umlg.sqlg.test.BaseTest;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
/**
* Created by pieter on 2015/11/27.
*/
public class DocumentationUsecases extends BaseTest {
// @Test
// public void schemaDoc() {
// Vertex john = this.sqlgGraph.addVertex(T.label, "manager", "name", "john");
// Vertex palace1 = this.sqlgGraph.addVertex(T.label, "continent.house", "name", "palace1");
// Vertex corrola = this.sqlgGraph.addVertex(T.label, "fleet.car", "model", "corrola");
// palace1.addEdge("managedBy", john);
// corrola.addEdge("owner", john);
// this.sqlgGraph.tx().commit();
// }
//
// @Test
// public void testIndexOnVertex() throws SQLException {
// this.sqlgGraph.createVertexLabeledIndex("Person", "name", "dummy");
// this.sqlgGraph.tx().commit();
// for (int i = 0; i < 5000; i++) {
// this.sqlgGraph.addVertex(T.label, "Person", "name", "john" + i);
// }
// this.sqlgGraph.tx().commit();
// assertEquals(1, this.sqlgGraph.traversal().V().existVertexLabel(T.label, "Person").existVertexLabel("name", "john50").count().next(), 0);
//
// //Check if the index is being used
// Connection conn = this.sqlgGraph.tx().getConnection();
// Statement statement = conn.createStatement();
// ResultSet rs = statement.executeQuery("explain analyze SELECT * FROM \"public\".\"V_Person\" a WHERE a.\"name\" = 'john50'");
// assertTrue(rs.next());
// String result = rs.getString(1);
// System.out.println(result);
// assertTrue(result.contains("Index Scan") || result.contains("Bitmap Heap Scan"));
// statement.close();
// this.sqlgGraph.tx().rollback();
// }
//
// @Test
// public void testIndexOnVertex22() throws SQLException {
// this.sqlgGraph.tx().commit();
// for (int i = 0; i < 5000; i++) {
// this.sqlgGraph.addVertex(T.label, "Person", "name", "john" + i);
// }
// this.sqlgGraph.tx().commit();
// this.sqlgGraph.createVertexLabeledIndex("Person", "name", "dummy");
// this.sqlgGraph.tx().commit();
// assertEquals(1, this.sqlgGraph.traversal().V().existVertexLabel(T.label, "Person").existVertexLabel("name", "john50").count().next(), 0);
//
// //Check if the index is being used
// Connection conn = this.sqlgGraph.tx().getConnection();
// Statement statement = conn.createStatement();
// ResultSet rs = statement.executeQuery("explain analyze SELECT * FROM \"public\".\"V_Person\" a WHERE a.\"name\" = 'john50'");
// assertTrue(rs.next());
// String result = rs.getString(1);
// System.out.println(result);
// assertTrue(result.contains("Index Scan") || result.contains("Bitmap Heap Scan"));
// statement.close();
// this.sqlgGraph.tx().rollback();
// }
//
// @Test
// public void showHighLatency() {
// Vertex easternUnion = this.sqlgGraph.addVertex(T.label, "Organization", "name", "EasternUnion");
// Vertex legal = this.sqlgGraph.addVertex(T.label, "Division", "name", "Legal");
// Vertex dispatch = this.sqlgGraph.addVertex(T.label, "Division", "name", "Dispatch");
// Vertex newYork = this.sqlgGraph.addVertex(T.label, "Office", "name", "NewYork");
// Vertex singapore = this.sqlgGraph.addVertex(T.label, "Office", "name", "Singapore");
// easternUnion.addEdge("organization_division", legal);
// easternUnion.addEdge("organization_division", dispatch);
// legal.addEdge("division_office", newYork);
// dispatch.addEdge("division_office", singapore);
// this.sqlgGraph.tx().commit();
// GraphTraversal<Vertex, Vertex> traversal = this.sqlgGraph.traversal().V().hasLabel("Organization").out().out();
// System.out.println(traversal);
// traversal.hasNext();
// System.out.println(traversal);
// List<Vertex> offices = traversal.toList();
// assertEquals(2, offices.size());
// }
//
// @Test
// public void showComparePredicate() {
// Vertex easternUnion = this.sqlgGraph.addVertex(T.label, "Organization", "name", "EasternUnion");
// Vertex legal = this.sqlgGraph.addVertex(T.label, "Division", "name", "Legal");
// Vertex dispatch = this.sqlgGraph.addVertex(T.label, "Division", "name", "Dispatch");
// Vertex newYork = this.sqlgGraph.addVertex(T.label, "Office", "name", "NewYork");
// Vertex singapore = this.sqlgGraph.addVertex(T.label, "Office", "name", "Singapore");
// easternUnion.addEdge("organization_division", legal);
// easternUnion.addEdge("organization_division", dispatch);
// legal.addEdge("division_office", newYork);
// dispatch.addEdge("division_office", singapore);
// this.sqlgGraph.tx().commit();
//
// GraphTraversal<Vertex, Vertex> traversal = this.sqlgGraph.traversal().V().hasLabel("Organization").out().out().has("name", P.eq("Singapore"));
// System.out.println(traversal);
// traversal.hasNext();
// System.out.println(traversal);
// List<Vertex> offices = traversal.toList();
// assertEquals(1, offices.size());
// assertEquals(singapore, offices.get(0));
// }
//
// @Test
// public void showContainsPredicate() {
// List<Integer> numbers = new ArrayList<>(10000);
// for (int i = 0; i < 10000; i++) {
// this.sqlgGraph.addVertex(T.label, "Person", "number", i);
// numbers.add(i);
// }
// this.sqlgGraph.tx().commit();
//
// List<Vertex> persons = this.sqlgGraph.traversal().V()
// .hasLabel("Person")
// .has("number", P.within(numbers))
// .toList();
// assertEquals(10000, persons.size());
// }
//
// @Test
// public void showTextPredicate() {
// Vertex john = this.sqlgGraph.addVertex(T.label, "Person", "name", "John XXX Doe");
// Vertex peter = this.sqlgGraph.addVertex(T.label, "Person", "name", "Peter YYY Snow");
// this.sqlgGraph.tx().commit();
//
// List<Vertex> persons = this.sqlgGraph.traversal().V()
// .hasLabel("Person")
// .has("name", Text.contains("XXX")).toList();
//
// assertEquals(1, persons.size());
// assertEquals(john, persons.get(0));
// }
//
// @Test
// public void showSearchOnLocalDateTime() {
// LocalDateTime born1 = LocalDateTime.of(1990, 1, 1, 1, 1, 1);
// LocalDateTime born2 = LocalDateTime.of(1990, 1, 1, 1, 1, 2);
// LocalDateTime born3 = LocalDateTime.of(1990, 1, 1, 1, 1, 3);
// Vertex john = this.sqlgGraph.addVertex(T.label, "Person", "name", "John", "born", born1);
// Vertex peter = this.sqlgGraph.addVertex(T.label, "Person", "name", "Peter", "born", born2);
// Vertex paul = this.sqlgGraph.addVertex(T.label, "Person", "name", "Paul", "born", born3);
// this.sqlgGraph.tx().commit();
//
// List<Vertex> persons = this.sqlgGraph.traversal().V().hasLabel("Person")
// .has("born", P.eq(born1))
// .toList();
// assertEquals(1, persons.size());
// assertEquals(john, persons.get(0));
//
// persons = this.sqlgGraph.traversal().V().hasLabel("Person")
// .has("born", P.between(LocalDateTime.of(1990, 1, 1, 1, 1, 1), LocalDateTime.of(1990, 1, 1, 1, 1, 3)))
// .toList();
// //P.between is inclusive to exclusive
// assertEquals(2, persons.size());
// assertTrue(persons.contains(john));
// assertTrue(persons.contains(peter));
// }
//
// @Test
// public void testOrderBy() {
// Vertex a1 = this.sqlgGraph.addVertex(T.label, "A", "name", "a", "surname", "a");
// Vertex a2 = this.sqlgGraph.addVertex(T.label, "A", "name", "a", "surname", "b");
// Vertex a3 = this.sqlgGraph.addVertex(T.label, "A", "name", "a", "surname", "c");
// Vertex b1 = this.sqlgGraph.addVertex(T.label, "A", "name", "b", "surname", "a");
// Vertex b2 = this.sqlgGraph.addVertex(T.label, "A", "name", "b", "surname", "b");
// Vertex b3 = this.sqlgGraph.addVertex(T.label, "A", "name", "b", "surname", "c");
// this.sqlgGraph.tx().commit();
//
// List<Vertex> result = this.sqlgGraph.traversal().V().hasLabel("A")
// .order().by("name", Order.incr).by("surname", Order.decr)
// .toList();
//
// assertEquals(6, result.size());
// assertEquals(a3, result.get(0));
// assertEquals(a2, result.get(1));
// assertEquals(a1, result.get(2));
// assertEquals(b3, result.get(3));
// assertEquals(b2, result.get(4));
// assertEquals(b1, result.get(5));
// }
//
// @Test
// public void showRepeat() {
// Vertex john = this.sqlgGraph.addVertex(T.label, "Person", "name", "John");
// Vertex peterski = this.sqlgGraph.addVertex(T.label, "Person", "name", "Peterski");
// Vertex paul = this.sqlgGraph.addVertex(T.label, "Person", "name", "Paul");
// Vertex usa = this.sqlgGraph.addVertex(T.label, "Country", "name", "USA");
// Vertex russia = this.sqlgGraph.addVertex(T.label, "Country", "name", "Russia");
// Vertex washington = this.sqlgGraph.addVertex(T.label, "City", "name", "Washington");
// john.addEdge("lives", usa);
// peterski.addEdge("lives", russia);
// usa.addEdge("capital", washington);
// this.sqlgGraph.tx().commit();
//
// List<Path> paths = this.sqlgGraph.traversal().V().hasLabel("Person").emit().times(2).repeat(__.out("lives", "capital")).path().by("name").toList();
// for (Path path : paths) {
// System.out.println(path);
// }
// }
//
// @Test
// public void showNormalBatchMode() {
// Assume.assumeTrue(this.sqlgGraph.getSqlDialect().supportsBatchMode());
// StopWatch stopWatch = new StopWatch();
// stopWatch.start();
// this.sqlgGraph.tx().normalBatchModeOn();
// for (int i = 1; i <= 10_000_000; i++) {
// Vertex person = this.sqlgGraph.addVertex(T.label, "Person", "name", "John" + i);
// Vertex car = this.sqlgGraph.addVertex(T.label, "Car", "name", "Dodge" + i);
// person.addEdge("drives", car);
// //To preserve memory commit or flush every so often
// if (i % 100_000 == 0) {
// this.sqlgGraph.tx().commit();
// this.sqlgGraph.tx().normalBatchModeOn();
// }
// }
// this.sqlgGraph.tx().commit();
// stopWatch.stop();
// System.out.println(stopWatch.toString());
// }
//
// @Test
// public void showStreamingBatchMode() {
// Assume.assumeTrue(this.sqlgGraph.getSqlDialect().supportsBatchMode());
// StopWatch stopWatch = new StopWatch();
// stopWatch.start();
// //enable streaming mode
// this.sqlgGraph.tx().streamingBatchModeOn();
// for (int i = 1; i <= 10_000_000; i++) {
// this.sqlgGraph.streamVertex(T.label, "Person", "name", "John" + i);
// }
// //flushing is needed before starting streaming Car. Only only one label/table can stream at a time.
// this.sqlgGraph.tx().flush();
// for (int i = 1; i <= 10_000_000; i++) {
// this.sqlgGraph.streamVertex(T.label, "Car", "name", "Dodge" + i);
// }
// this.sqlgGraph.tx().commit();
// stopWatch.stop();
// System.out.println(stopWatch.toString());
// }
//
// @Test
// public void showBulkEdgeCreation() {
// Assume.assumeTrue(this.sqlgGraph.getSqlDialect().supportsBatchMode());
// StopWatch stopWatch = new StopWatch();
// stopWatch.start();
// int count = 0;
// for (int i = 1; i <= 10; i++) {
// List<Pair<String, String>> identifiers = new ArrayList<>();
// this.sqlgGraph.tx().streamingBatchModeOn();
// for (int j = 1; j <= 1_000_000; j++) {
// this.sqlgGraph.streamVertex(T.label, "Person", "name", "John" + count, "personUid", String.valueOf(count));
// }
// this.sqlgGraph.tx().flush();
// for (int j = 1; j <= 1_000_000; j++) {
// this.sqlgGraph.streamVertex(T.label, "Car", "name", "Dodge" + count, "carUid", String.valueOf(count));
// identifiers.add(Pair.of(String.valueOf(count), String.valueOf(count++)));
// }
// this.sqlgGraph.tx().flush();
// this.sqlgGraph.bulkAddEdges("Person", "Car", "drives", Pair.of("personUid", "carUid"), identifiers);
// this.sqlgGraph.tx().commit();
// }
// stopWatch.stop();
// System.out.println(stopWatch.toString());
// }
//
// @Test
// public void showStreamingWithLockBatchMode() {
// Assume.assumeTrue(this.sqlgGraph.getSqlDialect().supportsBatchMode());
// StopWatch stopWatch = new StopWatch();
// stopWatch.start();
// //enable streaming mode
// this.sqlgGraph.tx().streamingWithLockBatchModeOn();
// for (int i = 1; i <= 10_000_000; i++) {
// Vertex person = this.sqlgGraph.addVertex(T.label, "Person", "name", "John" + i);
// }
// //flushing is needed before starting streaming Car. Only only one label/table can stream at a time.
// this.sqlgGraph.tx().flush();
// for (int i = 1; i <= 10_000_000; i++) {
// Vertex car = this.sqlgGraph.addVertex(T.label, "Car", "name", "Dodge" + i);
// }
// this.sqlgGraph.tx().commit();
// stopWatch.stop();
// System.out.println(stopWatch.toString());
// }
//
@Test
public void showStreamingWithLockBulkEdgeCreation() {
Assume.assumeTrue(this.sqlgGraph.getSqlDialect().supportsBatchMode());
StopWatch stopWatch = new StopWatch();
stopWatch.start();
int count = 0;
for (int i = 1; i <= 10; i++) {
List<Vertex> persons = new ArrayList<>();
this.sqlgGraph.tx().streamingWithLockBatchModeOn();
for (int j = 1; j <= 1_000_000; j++) {
Vertex person = this.sqlgGraph.addVertex(T.label, "Person", "name", "John" + count);
persons.add(person);
}
this.sqlgGraph.tx().flush();
List<Vertex> cars = new ArrayList<>();
for (int j = 1; j <= 1_000_000; j++) {
Vertex car = this.sqlgGraph.addVertex(T.label, "Car", "name", "Dodge" + count++);
cars.add(car);
}
this.sqlgGraph.tx().flush();
Iterator<Vertex> carIter = cars.iterator();
for (Vertex person : persons) {
person.addEdge("drives", carIter.next());
}
this.sqlgGraph.tx().commit();
}
stopWatch.stop();
System.out.println(stopWatch.toString());
}
}