• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java Node类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.neo4j.driver.v1.types.Node的典型用法代码示例。如果您正苦于以下问题:Java Node类的具体用法?Java Node怎么用?Java Node使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



Node类属于org.neo4j.driver.v1.types包,在下文中一共展示了Node类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: shouldCreateAndPatchANewStateWithoutAdditionalLabelAndDate

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldCreateAndPatchANewStateWithoutAdditionalLabelAndDate() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // Given
        session.run("CREATE (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'})");
        session.run("MATCH (e:Entity)-[:CURRENT]->(s:State) CREATE (e)-[:HAS_STATE {startDate:593910000000}]->(s)");

        // When
        StatementResult result = session.run("MATCH (e:Entity) WITH e CALL graph.versioner.patch(e, {key:'newValue', newKey:'newestValue'}) YIELD node RETURN node");
        Node currentState = result.single().get("node").asNode();
        StatementResult countStateResult = session.run("MATCH (s:State) RETURN count(s) as s");
        StatementResult nextResult = session.run("MATCH (s1:State)-[:PREVIOUS]->(s2:State) return s2");
        StatementResult correctStateResult = session.run("MATCH (s1:State)-[:PREVIOUS]->(s2:State) WITH s1 MATCH (e:Entity)-[:CURRENT]->(s1) return e");

        // Then
        assertThat(currentState.id(), equalTo(20L));
        assertThat(countStateResult.single().get("s").asLong(), equalTo(2L));
        assertThat(nextResult.single().get("s2").asNode().id(), equalTo(1L));
        assertThat(correctStateResult.single().get("e").asNode().id(), equalTo(0L));
        assertThat(currentState.get("key").asString(), equalTo("newValue"));
        assertThat(currentState.get("newKey").asString(), equalTo("newestValue"));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:26,代码来源:UpdateTest.java


示例2: shouldCreateACopyOfTheCurrentStateIfPatchedWithoutStateProps

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldCreateACopyOfTheCurrentStateIfPatchedWithoutStateProps() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // Given
        session.run("CREATE (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'})");
        session.run("MATCH (e:Entity)-[:CURRENT]->(s:State) CREATE (e)-[:HAS_STATE {startDate:593910000000}]->(s)");
        StatementResult stateResult = session.run("MATCH (s:State) RETURN s");
        Node state = stateResult.single().get("s").asNode();

        // When
        StatementResult result = session.run("MATCH (e:Entity) WITH e CALL graph.versioner.patch(e) YIELD node RETURN node");

        // Then
        Node newState = result.single().get("node").asNode();
        assertThat(state.get("key"), equalTo(newState.get("key")));
        assertThat(state.size(), equalTo(newState.size()));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:21,代码来源:UpdateTest.java


示例3: shouldNotCreateACopyOfTheGivenStateSinceItsADifferentEntityState

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test (expected = ClientException.class)
public void shouldNotCreateACopyOfTheGivenStateSinceItsADifferentEntityState() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // Given
        session.run("CREATE (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'})");
        session.run("MATCH (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'}) CREATE (e)-[:HAS_STATE {startDate:593910000000}]->(s)");
        session.run("MATCH (e:Entity) CREATE (e)-[:HAS_STATE {startDate:593900000000, endDate:59391000000}]->(s:State:Test {key:'initialValue'})");
        session.run("MATCH (sc:State)<-[:CURRENT]-(e:Entity)-[:HAS_STATE]->(s:Test) CREATE (sc)-[:PREVIOUS {date:593900000000}]->(s)");
        session.run("CREATE (e:EntityBis {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'})");
        session.run("MATCH (e:EntityBis)-[:CURRENT]->(s:State) CREATE (e)-[:HAS_STATE {startDate:593910000000}]->(s)");

        StatementResult result = session.run("MATCH (e:Entity), (:EntityBis)-[:HAS_STATE]->(s:State) WITH e, s CALL graph.versioner.patch.from(e, s) YIELD node RETURN node");
        Node currentState = result.single().get("node").asNode();
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:18,代码来源:UpdateTest.java


示例4: shouldCreateAnEntityAndAStateNodeWithoutPropsIfEmptyMapIsPassed

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldCreateAnEntityAndAStateNodeWithoutPropsIfEmptyMapIsPassed() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // When
        StatementResult result = session.run("CALL graph.versioner.init('Entity')");
        StatementResult stateResult = session.run("MATCH (s:State) RETURN s");
        StatementResult currentResult = session.run("MATCH (e:Entity)-[:CURRENT]->(s:State) RETURN id(e) as id");
        Node state = stateResult.single().get("s").asNode();

        // Then
        assertThat(result.single().get("node").asNode().id(), equalTo(0L));
        assertThat(state.id(), equalTo(1L));
        assertThat(currentResult.single().get("id").asLong(), equalTo(0L));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:18,代码来源:InitTest.java


示例5: shouldCreateAnEntityWithPropertiesWithAState

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldCreateAnEntityWithPropertiesWithAState() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // When
        StatementResult result = session.run("CALL graph.versioner.init('Entity', {key:'value'})");
        StatementResult entityResult = session.run("MATCH (e:Entity) RETURN properties(e) as props");
        StatementResult stateResult = session.run("MATCH (s:State) RETURN s");
        StatementResult currentResult = session.run("MATCH (e:Entity)-[:CURRENT]->(s:State) RETURN id(e) as id");
        Node state = stateResult.single().get("s").asNode();

        // Then
        assertThat(result.single().get("node").asNode().id(), equalTo(0L));
        assertThat(entityResult.single().get("props").asMap().isEmpty(), equalTo(false));
        assertThat(state.id(), equalTo(1L));
        assertThat(currentResult.single().get("id").asLong(), equalTo(0L));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:20,代码来源:InitTest.java


示例6: shouldCreateAnEntityWithPropertiesWithAStateAndItsPropertiesWithAdditionalLabelButNoDate

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldCreateAnEntityWithPropertiesWithAStateAndItsPropertiesWithAdditionalLabelButNoDate() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // When
        StatementResult result = session.run("CALL graph.versioner.init('Entity', {key:'value'}, {key:'value'}, 'Error')");
        StatementResult entityResult = session.run("MATCH (e:Entity) RETURN properties(e) as props");
        StatementResult stateResult = session.run("MATCH (s:State) RETURN s");
        Node state = stateResult.single().get("s").asNode();
        StatementResult stateProps = session.run("MATCH (s:State) RETURN properties(s) as props");
        StatementResult currentResult = session.run("MATCH (e:Entity)-[:CURRENT]->(s:State) RETURN id(e) as id");
        StatementResult hasStatusResult = session.run("MATCH (e:Entity)-[:HAS_STATE]->(s:State) RETURN id(e) as id");

        // Then
        assertThat(result.single().get("node").asNode().id(), equalTo(0L));
        assertThat(entityResult.single().get("props").asMap().isEmpty(), equalTo(false));
        assertThat(state.id(), equalTo(1L));
        assertThat(stateProps.single().get("props").asMap().isEmpty(), equalTo(false));
        assertThat(currentResult.single().get("id").asLong(), equalTo(0L));
        assertThat(hasStatusResult.single().get("id").asLong(), equalTo(0L));
        assertThat(state.hasLabel("Error"), equalTo(true));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:25,代码来源:InitTest.java


示例7: shouldCreateAnEntityWithPropertiesWithAStateAndItsPropertiesWithAdditionalLabelAndDate

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldCreateAnEntityWithPropertiesWithAStateAndItsPropertiesWithAdditionalLabelAndDate() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // When
        StatementResult result = session.run("CALL graph.versioner.init('Entity', {key:'value'}, {key:'value'}, 'Error', 593920000000)");
        StatementResult entityResult = session.run("MATCH (e:Entity) RETURN properties(e) as props");
        StatementResult stateResult = session.run("MATCH (s:State) RETURN s");
        Node state = stateResult.single().get("s").asNode();
        StatementResult stateProps = session.run("MATCH (s:State) RETURN properties(s) as props");
        StatementResult currentResult = session.run("MATCH (e:Entity)-[:CURRENT]->(s:State) RETURN id(e) as id");
        StatementResult hasStatusResult = session.run("MATCH (e:Entity)-[:HAS_STATE]->(s:State) RETURN id(e) as id");
        StatementResult hasStatusDateResult = session.run("MATCH (e:Entity)-[rel:CURRENT]->(s:State) RETURN rel.date as date");

        // Then
        assertThat(result.single().get("node").asNode().id(), equalTo(0L));
        assertThat(entityResult.single().get("props").asMap().isEmpty(), equalTo(false));
        assertThat(state.id(), equalTo(1L));
        assertThat(stateProps.single().get("props").asMap().isEmpty(), equalTo(false));
        assertThat(currentResult.single().get("id").asLong(), equalTo(0L));
        assertThat(hasStatusResult.single().get("id").asLong(), equalTo(0L));
        assertThat(state.hasLabel("Error"), equalTo(true));
        assertThat(hasStatusDateResult.single().get("date").asLong(), equalTo(593920000000L));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:27,代码来源:InitTest.java


示例8: shouldGetCurrentStateByGivenEntity

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldGetCurrentStateByGivenEntity() {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // Given
        session.run("CREATE (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'})");
        Node state = session.run("MATCH (s:State) RETURN s").single().get("s").asNode();

        // When
        StatementResult result = session.run("MATCH (e:Entity) WITH e CALL graph.versioner.get.current.state(e) YIELD node RETURN node");

        // Then
        assertThat(result.single().get("node").asNode(), equalTo(state));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:17,代码来源:GetTest.java


示例9: loadVertex

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
private Vertex loadVertex(Record record) {
    // node
    Node node = record.get(0).asNode();
    // vertex id
    Object vertexId = vertexIdProvider.get(node);
    // check vertex has been deleted
    if (!deletedVertices.contains(vertexId)) {
        // check this vertex has been already loaded into this session
        Vertex vertex = vertices.get(vertexId);
        if (vertex == null) {
            // check node belongs to partition
            if (partition.containsVertex(StreamSupport.stream(node.labels().spliterator(), false).collect(Collectors.toSet()))) {
                // create and register vertex
                return registerVertex(new Neo4JVertex(graph, this, vertexIdProvider, edgeIdProvider, node));
            }
            // skip vertex (not in partition)
            return null;
        }
        // return vertex
        return vertex;
    }
    // skip vertex (deleted)
    return null;
}
 
开发者ID:SteelBridgeLabs,项目名称:neo4j-gremlin-bolt,代码行数:25,代码来源:Neo4JSession.java


示例10: pathAsString

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Nonnull
default String pathAsString(@Nonnull Path path) {
    List<String> list = new ArrayList<>(path.length());
    Node lastTraversed = path.start();
    if (lastTraversed != null) {
        list.add(nodeAsString(lastTraversed));

        for (Path.Segment segment : path) {
            Relationship relationship = segment.relationship();
            if (relationship.startNodeId() == lastTraversed.id()) {
                list.add("-" + relationshipAsString(relationship) + "->");
            } else {
                list.add("<-" + relationshipAsString(relationship) + "-");
            }
            list.add(nodeAsString(segment.end()));
            lastTraversed = segment.end();
        }
    }

    return list.stream().collect(Collectors.joining());
}
 
开发者ID:neo4j,项目名称:cypher-shell,代码行数:22,代码来源:OutputFormatter.java


示例11: getPropertiesObject

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
private Entity getPropertiesObject(long id, int rowIndex, ElemType typ) {
	Record rec = this.records.get(rowIndex);
	List<Pair<String, Value>> flds = rec.fields();
	for (Pair<String, Value> pair : flds) {
		if (typ == ElemType.NODE && pair.value() instanceof NodeValue) {
			Node nd = pair.value().asNode();
			if (nd.id() == id)
				return nd;
		} else if (typ == ElemType.RELATION && pair.value() instanceof RelationshipValue) {
			Relationship rel = pair.value().asRelationship();
			if (rel.id() == id)
				return rel;
		}
	}
	
	// element with id may not have been loaded
	return this.reloaded.getEntity(id, typ);
}
 
开发者ID:Wolfgang-Schuetzelhofer,项目名称:jcypher,代码行数:19,代码来源:BoltContentHandler.java


示例12: gePathtNodeIdAt

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public long gePathtNodeIdAt(PathInfo pathInfo, int index) {
	Object obj = pathInfo.getContentObject();
	List<Node> nodes = null;
	if (obj instanceof List<?>)
		nodes = (List<Node>) obj;
	else if (obj instanceof Path) {
		nodes = new ArrayList<Node>();
		Iterator<Node> it = ((Path)obj).nodes().iterator();
		while(it.hasNext())
			nodes.add(it.next());
		pathInfo.setContentObject(nodes);
	}
	return nodes.get(index).id();
}
 
开发者ID:Wolfgang-Schuetzelhofer,项目名称:jcypher,代码行数:17,代码来源:BoltContentHandler.java


示例13: shouldCreateAndPatchANewStateWithAdditionalLabelButWithoutDate

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldCreateAndPatchANewStateWithAdditionalLabelButWithoutDate() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // Given
        session.run("CREATE (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'})");
        session.run("MATCH (e:Entity)-[:CURRENT]->(s:State) CREATE (e)-[:HAS_STATE {startDate:593910000000}]->(s)");

        // When
        StatementResult result = session.run("MATCH (e:Entity) WITH e CALL graph.versioner.patch(e, {key:'newValue', newKey:'newestValue'}, 'Error') YIELD node RETURN node");
        Node currentState = result.single().get("node").asNode();
        StatementResult countStateResult = session.run("MATCH (s:State) RETURN count(s) as s");
        StatementResult nextResult = session.run("MATCH (s1:State)-[:PREVIOUS]->(s2:State) return s2");
        StatementResult correctStateResult = session.run("MATCH (s1:State)-[:PREVIOUS]->(s2:State) WITH s1 MATCH (e:Entity)-[:CURRENT]->(s1) return e");
        StatementResult currentStateResult = session.run("MATCH (e:Entity)-[:CURRENT]->(s) return s");

        // Then
        assertThat(currentState.id(), equalTo(20L));
        assertThat(countStateResult.single().get("s").asLong(), equalTo(2L));
        assertThat(nextResult.single().get("s2").asNode().id(), equalTo(1L));
        assertThat(correctStateResult.single().get("e").asNode().id(), equalTo(0L));
        assertThat(currentStateResult.single().get("s").asNode().hasLabel("Error"), equalTo(true));
        assertThat(currentState.get("key").asString(), equalTo("newValue"));
        assertThat(currentState.get("newKey").asString(), equalTo("newestValue"));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:28,代码来源:UpdateTest.java


示例14: shouldCreateAndPatchANewStateWithAdditionalLabelAndDate

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldCreateAndPatchANewStateWithAdditionalLabelAndDate() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // Given
        session.run("CREATE (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'})");
        session.run("MATCH (e:Entity)-[:CURRENT]->(s:State) CREATE (e)-[:HAS_STATE {startDate:593910000000}]->(s)");

        // When
        StatementResult result = session.run("MATCH (e:Entity) WITH e CALL graph.versioner.patch(e, {key:'newValue', newKey:'newestValue'}, 'Error', 593920000000) YIELD node RETURN node");
        Node currentState = result.single().get("node").asNode();
        StatementResult countStateResult = session.run("MATCH (s:State) RETURN count(s) as s");
        StatementResult nextResult = session.run("MATCH (s1:State)-[:PREVIOUS]->(s2:State) return s2");
        StatementResult correctStateResult = session.run("MATCH (s1:State)-[:PREVIOUS]->(s2:State) WITH s1 MATCH (e:Entity)-[:CURRENT]->(s1) return e");
        StatementResult currentStateResult = session.run("MATCH (e:Entity)-[:CURRENT]->(s) return s");
        StatementResult dateResult = session.run("MATCH (e:Entity)-[r:CURRENT]->(s) RETURN r.date as relDate");
        StatementResult hasStatusDateResult = session.run("MATCH (e:Entity)-[:CURRENT]->(s:State)-[:PREVIOUS]->(s2:State)<-[rel:HAS_STATE]-(e) RETURN rel.endDate as endDate");

        // Then
        assertThat(currentState.id(), equalTo(20L));
        assertThat(countStateResult.single().get("s").asLong(), equalTo(2L));
        assertThat(nextResult.single().get("s2").asNode().id(), equalTo(1L));
        assertThat(correctStateResult.single().get("e").asNode().id(), equalTo(0L));
        assertThat(currentStateResult.single().get("s").asNode().hasLabel("Error"), equalTo(true));
        assertThat(dateResult.single().get("relDate").asLong(), equalTo(593920000000L));
        assertThat(hasStatusDateResult.single().get("endDate").asLong(), equalTo(593920000000L));
        assertThat(currentState.get("key").asString(), equalTo("newValue"));
        assertThat(currentState.get("newKey").asString(), equalTo("newestValue"));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:32,代码来源:UpdateTest.java


示例15: shouldCreateAndPatchANewStateWithAdditionalLabelAndDateButWithANewProp

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldCreateAndPatchANewStateWithAdditionalLabelAndDateButWithANewProp() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // Given
        session.run("CREATE (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'})");
        session.run("MATCH (e:Entity)-[:CURRENT]->(s:State) CREATE (e)-[:HAS_STATE {startDate:593910000000}]->(s)");

        // When
        StatementResult result = session.run("MATCH (e:Entity) WITH e CALL graph.versioner.patch(e, {newKey:'newestValue'}, 'Error', 593920000000) YIELD node RETURN node");
        Node currentState = result.single().get("node").asNode();
        StatementResult countStateResult = session.run("MATCH (s:State) RETURN count(s) as s");
        StatementResult nextResult = session.run("MATCH (s1:State)-[:PREVIOUS]->(s2:State) return s2");
        StatementResult correctStateResult = session.run("MATCH (s1:State)-[:PREVIOUS]->(s2:State) WITH s1 MATCH (e:Entity)-[:CURRENT]->(s1) return e");
        StatementResult currentStateResult = session.run("MATCH (e:Entity)-[:CURRENT]->(s) return s");
        StatementResult dateResult = session.run("MATCH (e:Entity)-[r:CURRENT]->(s) RETURN r.date as relDate");
        StatementResult hasStatusDateResult = session.run("MATCH (e:Entity)-[:CURRENT]->(s:State)-[:PREVIOUS]->(s2:State)<-[rel:HAS_STATE]-(e) RETURN rel.endDate as endDate");

        // Then
        assertThat(currentState.id(), equalTo(20L));
        assertThat(countStateResult.single().get("s").asLong(), equalTo(2L));
        assertThat(nextResult.single().get("s2").asNode().id(), equalTo(1L));
        assertThat(correctStateResult.single().get("e").asNode().id(), equalTo(0L));
        assertThat(currentStateResult.single().get("s").asNode().hasLabel("Error"), equalTo(true));
        assertThat(dateResult.single().get("relDate").asLong(), equalTo(593920000000L));
        assertThat(hasStatusDateResult.single().get("endDate").asLong(), equalTo(593920000000L));
        assertThat(currentState.get("key").asString(), equalTo("initialValue"));
        assertThat(currentState.get("newKey").asString(), equalTo("newestValue"));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:32,代码来源:UpdateTest.java


示例16: shouldCreateACopyOfTheGivenStateWithoutAdditionalDate

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldCreateACopyOfTheGivenStateWithoutAdditionalDate() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // Given
        session.run("CREATE (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue', newKey:'oldestValue'})");
        session.run("MATCH (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'}) CREATE (e)-[:HAS_STATE {startDate:593910000000}]->(s)");
        session.run("MATCH (e:Entity) CREATE (e)-[:HAS_STATE {startDate:593900000000, endDate:59391000000}]->(s:State:Test {newKey:'newestValue'})");
        session.run("MATCH (sc:State)<-[:CURRENT]-(e:Entity)-[:HAS_STATE]->(s:Test) CREATE (sc)-[:PREVIOUS {date:593900000000}]->(s)");
        StatementResult stateResult = session.run("MATCH (s:Test) RETURN s");
        Node originalState = stateResult.single().get("s").asNode();

        // When
        StatementResult result = session.run("MATCH (e:Entity)-[:HAS_STATE]->(s:Test) WITH e, s CALL graph.versioner.patch.from(e, s) YIELD node RETURN node");
        Node currentState = result.single().get("node").asNode();
        StatementResult countStateResult = session.run("MATCH (s:State) RETURN count(s) as s");
        StatementResult correctStateResult = session.run("MATCH (s1:State)-[:PREVIOUS]->(s2:State) WITH s1 MATCH (e:Entity)-[:CURRENT]->(s1) return e");

        // Then
        assertThat(currentState.id(), equalTo(21L));
        assertThat(countStateResult.single().get("s").asLong(), equalTo(3L));
        assertThat(correctStateResult.single().get("e").asNode().id(), equalTo(0L));
        assertThat(currentState.get("key").asString(), equalTo("initialValue"));
        assertThat(currentState.get("newKey").asString(), equalTo("newestValue"));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:28,代码来源:UpdateTest.java


示例17: shouldCreateACopyOfTheGivenStateWithAdditionalDate

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldCreateACopyOfTheGivenStateWithAdditionalDate() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // Given
        session.run("CREATE (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue', newKey:'oldestValue'})");
        session.run("MATCH (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'}) CREATE (e)-[:HAS_STATE {startDate:593910000000}]->(s)");
        session.run("MATCH (e:Entity) CREATE (e)-[:HAS_STATE {startDate:593900000000, endDate:59391000000}]->(s:State:Test {newKey:'newestValue'})");
        session.run("MATCH (sc:State)<-[:CURRENT]-(e:Entity)-[:HAS_STATE]->(s:Test) CREATE (sc)-[:PREVIOUS {date:593900000000}]->(s)");
        StatementResult stateResult = session.run("MATCH (s:Test) RETURN s");
        Node originalState = stateResult.single().get("s").asNode();

        // When
        StatementResult result = session.run("MATCH (e:Entity)-[:HAS_STATE]->(s:Test) WITH e, s CALL graph.versioner.patch.from(e, s, 593920000000) YIELD node RETURN node");
        Node currentState = result.single().get("node").asNode();
        StatementResult countStateResult = session.run("MATCH (s:State) RETURN count(s) as s");
        StatementResult correctStateResult = session.run("MATCH (s1:State)-[:PREVIOUS]->(s2:State) WITH s1 MATCH (e:Entity)-[:CURRENT]->(s1) return e");
        StatementResult dateResult = session.run("MATCH (e:Entity)-[r:CURRENT]->(s) RETURN r.date as relDate");
        StatementResult hasStatusDateResult = session.run("MATCH (e:Entity)-[:CURRENT]->(s:State)-[:PREVIOUS]->(s2:State)<-[rel:HAS_STATE]-(e) RETURN rel.endDate as endDate");

        // Then
        assertThat(currentState.id(), equalTo(21L));
        assertThat(countStateResult.single().get("s").asLong(), equalTo(3L));
        assertThat(correctStateResult.single().get("e").asNode().id(), equalTo(0L));
        assertThat(currentState.get("key").asString(), equalTo("initialValue"));
        assertThat(currentState.get("newKey").asString(), equalTo("newestValue"));
        assertThat(dateResult.single().get("relDate").asLong(), equalTo(593920000000L));
        assertThat(hasStatusDateResult.single().get("endDate").asLong(), equalTo(593920000000L));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:32,代码来源:UpdateTest.java


示例18: shouldCreateACopyOfTheGivenStateWithAdditionalDateButWithANewProp

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldCreateACopyOfTheGivenStateWithAdditionalDateButWithANewProp() throws Throwable {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // Given
        session.run("CREATE (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'})");
        session.run("MATCH (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'}) CREATE (e)-[:HAS_STATE {startDate:593910000000}]->(s)");
        session.run("MATCH (e:Entity) CREATE (e)-[:HAS_STATE {startDate:593900000000, endDate:59391000000}]->(s:State:Test {newKey:'newestValue'})");
        session.run("MATCH (sc:State)<-[:CURRENT]-(e:Entity)-[:HAS_STATE]->(s:Test) CREATE (sc)-[:PREVIOUS {date:593900000000}]->(s)");
        StatementResult stateResult = session.run("MATCH (s:Test) RETURN s");
        Node originalState = stateResult.single().get("s").asNode();

        // When
        StatementResult result = session.run("MATCH (e:Entity)-[:HAS_STATE]->(s:Test) WITH e, s CALL graph.versioner.patch.from(e, s, 593920000000) YIELD node RETURN node");
        Node currentState = result.single().get("node").asNode();
        StatementResult countStateResult = session.run("MATCH (s:State) RETURN count(s) as s");
        StatementResult correctStateResult = session.run("MATCH (s1:State)-[:PREVIOUS]->(s2:State) WITH s1 MATCH (e:Entity)-[:CURRENT]->(s1) return e");
        StatementResult dateResult = session.run("MATCH (e:Entity)-[r:CURRENT]->(s) RETURN r.date as relDate");
        StatementResult hasStatusDateResult = session.run("MATCH (e:Entity)-[:CURRENT]->(s:State)-[:PREVIOUS]->(s2:State)<-[rel:HAS_STATE]-(e) RETURN rel.endDate as endDate");

        // Then
        //assertThat(currentState.id(), equalTo(21L));
        assertThat(countStateResult.single().get("s").asLong(), equalTo(3L));
        assertThat(correctStateResult.single().get("e").asNode().id(), equalTo(0L));
        assertThat(currentState.get("key").asString(), equalTo("initialValue"));
        assertThat(currentState.get("newKey").asString(), equalTo("newestValue"));
        assertThat(dateResult.single().get("relDate").asLong(), equalTo(593920000000L));
        assertThat(hasStatusDateResult.single().get("endDate").asLong(), equalTo(593920000000L));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:32,代码来源:UpdateTest.java


示例19: shouldGetCurrentPathByGivenEntity

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldGetCurrentPathByGivenEntity() {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // Given
        session.run("CREATE (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'})");
        session.run("MATCH (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'}) CREATE (e)-[:HAS_STATE {startDate:593910000000}]->(s)");
        Node entity = session.run("MATCH (e:Entity) RETURN e").single().get("e").asNode();
        Node state = session.run("MATCH (s:State) RETURN s").single().get("s").asNode();

        // When
        StatementResult result = session.run("MATCH (e:Entity) WITH e CALL graph.versioner.get.current.path(e) YIELD path RETURN path");

        Path current = result.single().get("path").asPath();
        Iterator<Relationship> relsIterator = current.relationships().iterator();
        Map<String, Object> rels = new HashMap<>();
        while (relsIterator.hasNext()) {
            Relationship support = relsIterator.next();
            rels.put(support.type(), support);
        }

        // Then
        assertThat(current.contains(entity), equalTo(true));
        assertThat(rels.containsKey(Utility.CURRENT_TYPE), equalTo(true));
        assertThat(current.contains(state), equalTo(true));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:29,代码来源:GetTest.java


示例20: shouldGetAllStateNodesByGivenEntity

import org.neo4j.driver.v1.types.Node; //导入依赖的package包/类
@Test
public void shouldGetAllStateNodesByGivenEntity() {
    // This is in a try-block, to make sure we close the driver after the test
    try (Driver driver = GraphDatabase
            .driver(neo4j.boltURI(), Config.build().withEncryption().toConfig()); Session session = driver.session()) {
        // Given
        session.run("CREATE (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'})");
        session.run("MATCH (e:Entity {key:'immutableValue'})-[:CURRENT {date:593910000000}]->(s:State {key:'initialValue'}) CREATE (e)-[:HAS_STATE {startDate:593910000000}]->(s)");
        session.run("MATCH (e)-[hs:HAS_STATE]->(s) CREATE (e)-[:HAS_STATE {startDate: 593900000000, endDate: hs.startDate}]->(:State{key:'oldState'})");
        session.run("MATCH (s1:State {key:'oldState'}), (s2:State {key:'initialValue'}) CREATE (s1)<-[:PREVIOUS {date: 593900000000}]-(s2) ");
        Node entity = session.run("MATCH (e:Entity) RETURN e").single().get("e").asNode();
        Node stateNew = session.run("MATCH (s:State {key:'initialValue'}) RETURN s").single().get("s").asNode();
        Node stateOld = session.run("MATCH (s:State {key:'oldState'}) RETURN s").single().get("s").asNode();

        // When
        StatementResult result = session.run("MATCH (e:Entity) WITH e CALL graph.versioner.get.all(e) YIELD path RETURN path");

        Path current = result.single().get("path").asPath();
        Iterator<Relationship> relsIterator = current.relationships().iterator();
        Map<String, Object> rels = new HashMap<>();
        while (relsIterator.hasNext()) {
            Relationship support = relsIterator.next();
            rels.put(support.type(), support);
        }

        // Then
        assertThat(current.contains(entity), equalTo(true));
        assertThat(current.contains(stateNew), equalTo(true));
        assertThat(rels.containsKey(Utility.PREVIOUS_TYPE), equalTo(true));
        assertThat(current.contains(stateOld), equalTo(true));
    }
}
 
开发者ID:h-omer,项目名称:neo4j-versioner-core,代码行数:33,代码来源:GetTest.java



注:本文中的org.neo4j.driver.v1.types.Node类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java XBooleanLiteral类代码示例发布时间:2022-05-22
下一篇:
Java DirectDecompressor类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap