forked from hugegraph/hugegraph
fix: error when start gremlin-console with sample script (#2231)
* fix: add `-i` parameter in `gremlin-console.sh`, add `serverStarted` in `example.groovy` * fix: modify hugegraph conf path * fix: remove unnecessary index on properties on [name]
This commit is contained in:
parent
b8c7743616
commit
b4e67e1dfb
|
|
@ -113,7 +113,7 @@ if [ -z "${HADOOP_GREMLIN_LIBS:-}" ]; then
|
|||
fi
|
||||
|
||||
if [ -z "${JAVA_OPTIONS:-}" ]; then
|
||||
JAVA_OPTIONS="-Dtinkerpop.ext=$EXT -Dlog4j.configuration=conf/log4j-console.properties -Dgremlin.log4j.level=$GREMLIN_LOG_LEVEL -javaagent:$LIB/jamm-0.3.0.jar"
|
||||
JAVA_OPTIONS="-Dtinkerpop.ext=$EXT -Dlog4j.configurationFile=conf/log4j2.xml -Dgremlin.log4j.level=$GREMLIN_LOG_LEVEL -javaagent:$LIB/jamm-0.3.0.jar"
|
||||
fi
|
||||
|
||||
if [ "$PROFILING_ENABLED" = true ]; then
|
||||
|
|
|
|||
|
|
@ -15,53 +15,54 @@
|
|||
* under the License.
|
||||
*/
|
||||
import org.apache.hugegraph.HugeFactory
|
||||
import org.apache.hugegraph.backend.id.IdGenerator
|
||||
import org.apache.hugegraph.dist.RegisterUtil
|
||||
import org.apache.hugegraph.type.define.NodeRole
|
||||
import org.apache.tinkerpop.gremlin.structure.T
|
||||
|
||||
RegisterUtil.registerCassandra();
|
||||
RegisterUtil.registerScyllaDB();
|
||||
RegisterUtil.registerRocksDB()
|
||||
|
||||
conf = "conf/hugegraph.properties"
|
||||
graph = HugeFactory.open(conf);
|
||||
schema = graph.schema();
|
||||
conf = "conf/graphs/hugegraph.properties"
|
||||
graph = HugeFactory.open(conf)
|
||||
graph.serverStarted(IdGenerator.of("server-tinkerpop"), NodeRole.MASTER)
|
||||
schema = graph.schema()
|
||||
|
||||
schema.propertyKey("name").asText().ifNotExist().create();
|
||||
schema.propertyKey("age").asInt().ifNotExist().create();
|
||||
schema.propertyKey("city").asText().ifNotExist().create();
|
||||
schema.propertyKey("weight").asDouble().ifNotExist().create();
|
||||
schema.propertyKey("lang").asText().ifNotExist().create();
|
||||
schema.propertyKey("date").asText().ifNotExist().create();
|
||||
schema.propertyKey("price").asInt().ifNotExist().create();
|
||||
schema.propertyKey("name").asText().ifNotExist().create()
|
||||
schema.propertyKey("age").asInt().ifNotExist().create()
|
||||
schema.propertyKey("city").asText().ifNotExist().create()
|
||||
schema.propertyKey("weight").asDouble().ifNotExist().create()
|
||||
schema.propertyKey("lang").asText().ifNotExist().create()
|
||||
schema.propertyKey("date").asText().ifNotExist().create()
|
||||
schema.propertyKey("price").asInt().ifNotExist().create()
|
||||
|
||||
schema.vertexLabel("person").properties("name", "age", "city").primaryKeys("name").ifNotExist().create();
|
||||
schema.vertexLabel("software").properties("name", "lang", "price").primaryKeys("name").ifNotExist().create();
|
||||
schema.indexLabel("personByName").onV("person").by("name").secondary().ifNotExist().create();
|
||||
schema.indexLabel("personByCity").onV("person").by("city").secondary().ifNotExist().create();
|
||||
schema.indexLabel("personByAgeAndCity").onV("person").by("age", "city").secondary().ifNotExist().create();
|
||||
schema.indexLabel("softwareByPrice").onV("software").by("price").range().ifNotExist().create();
|
||||
schema.edgeLabel("knows").sourceLabel("person").targetLabel("person").properties("date", "weight").ifNotExist().create();
|
||||
schema.edgeLabel("created").sourceLabel("person").targetLabel("software").properties("date", "weight").ifNotExist().create();
|
||||
schema.indexLabel("createdByDate").onE("created").by("date").secondary().ifNotExist().create();
|
||||
schema.indexLabel("createdByWeight").onE("created").by("weight").range().ifNotExist().create();
|
||||
schema.indexLabel("knowsByWeight").onE("knows").by("weight").range().ifNotExist().create();
|
||||
schema.vertexLabel("person").properties("name", "age", "city").primaryKeys("name").ifNotExist().create()
|
||||
schema.vertexLabel("software").properties("name", "lang", "price").primaryKeys("name").ifNotExist().create()
|
||||
schema.indexLabel("personByCity").onV("person").by("city").secondary().ifNotExist().create()
|
||||
schema.indexLabel("personByAgeAndCity").onV("person").by("age", "city").secondary().ifNotExist().create()
|
||||
schema.indexLabel("softwareByPrice").onV("software").by("price").range().ifNotExist().create()
|
||||
schema.edgeLabel("knows").sourceLabel("person").targetLabel("person").properties("date", "weight").ifNotExist().create()
|
||||
schema.edgeLabel("created").sourceLabel("person").targetLabel("software").properties("date", "weight").ifNotExist().create()
|
||||
schema.indexLabel("createdByDate").onE("created").by("date").secondary().ifNotExist().create()
|
||||
schema.indexLabel("createdByWeight").onE("created").by("weight").range().ifNotExist().create()
|
||||
schema.indexLabel("knowsByWeight").onE("knows").by("weight").range().ifNotExist().create()
|
||||
|
||||
marko = graph.addVertex(T.label, "person", "name", "marko", "age", 29, "city", "Beijing");
|
||||
vadas = graph.addVertex(T.label, "person", "name", "vadas", "age", 27, "city", "Hongkong");
|
||||
lop = graph.addVertex(T.label, "software", "name", "lop", "lang", "java", "price", 328);
|
||||
josh = graph.addVertex(T.label, "person", "name", "josh", "age", 32, "city", "Beijing");
|
||||
ripple = graph.addVertex(T.label, "software", "name", "ripple", "lang", "java", "price", 199);
|
||||
peter = graph.addVertex(T.label, "person", "name", "peter", "age", 35, "city", "Shanghai");
|
||||
marko = graph.addVertex(T.label, "person", "name", "marko", "age", 29, "city", "Beijing")
|
||||
vadas = graph.addVertex(T.label, "person", "name", "vadas", "age", 27, "city", "Hongkong")
|
||||
lop = graph.addVertex(T.label, "software", "name", "lop", "lang", "java", "price", 328)
|
||||
josh = graph.addVertex(T.label, "person", "name", "josh", "age", 32, "city", "Beijing")
|
||||
ripple = graph.addVertex(T.label, "software", "name", "ripple", "lang", "java", "price", 199)
|
||||
peter = graph.addVertex(T.label, "person", "name", "peter", "age", 35, "city", "Shanghai")
|
||||
|
||||
marko.addEdge("knows", vadas, "date", "20160110", "weight", 0.5);
|
||||
marko.addEdge("knows", josh, "date", "20130220", "weight", 1.0);
|
||||
marko.addEdge("created", lop, "date", "20171210", "weight", 0.4);
|
||||
josh.addEdge("created", lop, "date", "20091111", "weight", 0.4);
|
||||
josh.addEdge("created", ripple, "date", "20171210", "weight", 1.0);
|
||||
peter.addEdge("created", lop, "date", "20170324", "weight", 0.2);
|
||||
marko.addEdge("knows", vadas, "date", "20160110", "weight", 0.5)
|
||||
marko.addEdge("knows", josh, "date", "20130220", "weight", 1.0)
|
||||
marko.addEdge("created", lop, "date", "20171210", "weight", 0.4)
|
||||
josh.addEdge("created", lop, "date", "20091111", "weight", 0.4)
|
||||
josh.addEdge("created", ripple, "date", "20171210", "weight", 1.0)
|
||||
peter.addEdge("created", lop, "date", "20170324", "weight", 0.2)
|
||||
|
||||
graph.tx().commit();
|
||||
graph.tx().commit()
|
||||
|
||||
g = graph.traversal();
|
||||
g = graph.traversal()
|
||||
|
||||
System.out.println(">>>> query all vertices: size=" + g.V().toList().size());
|
||||
System.out.println(">>>> query all edges: size=" + g.E().toList().size());
|
||||
System.out.println(">>>> query all vertices: size=" + g.V().toList().size())
|
||||
System.out.println(">>>> query all edges: size=" + g.E().toList().size())
|
||||
|
|
|
|||
Loading…
Reference in New Issue