1
2
3
4
5

    <dependency>
        <groupId>org.neo4j.driver</groupId>
        <artifactId>neo4j-java-driver</artifactId>
        <version>4.2.9</version>
    </dependency>

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22

// 驱动配置类
@Component
public class Neo4jDriver {

    private Driver driver;

    @Autowired
    private Neo4jConfig neo4jConfig;

    @PostConstruct
    public void init() {
        Config config = Config.builder()
                .withConnectionTimeout(10, TimeUnit.SECONDS)
                .withMaxConnectionLifetime(30, TimeUnit.MINUTES)
                .withMaxConnectionPoolSize(10).withConnectionAcquisitionTimeout(10, TimeUnit.SECONDS)
                .build();

        this.driver = GraphDatabase.driver(neo4jConfig.getUrl(),
                AuthTokens.basic(neo4jConfig.getUsername(), neo4jConfig.getPassword()), config);
        log.info("Init Neo4j {}", neo4jConfig.getUrl());
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

    // 手动查询和解析
    public List<DiseaseNode> queryDisease(String query) {
        try (Session session = neo4jDriver.getDriver().session()) {
            long start = System.currentTimeMillis();
            List<DiseaseNode> nodes = new ArrayList<>();
            Result result = session.run(new Query(query));
            List<Record> collect = result.stream().distinct().collect(Collectors.toList());
            log.info("result={}", result);
            collect.stream().map(v -> {
                InternalRecord ir = (InternalRecord) v;
                Value tmpNode = ir.get("a");
                Value id = tmpNode.get("id");
                Value name = tmpNode.get("name");
                DiseaseNode node = new DiseaseNode();
                node.setId(id.asString());
                node.setName(name.asString());
                return node;
            }).forEach(nodes::add);
            log.info("Neo4j: {}ms Size: {}", (System.currentTimeMillis() - start), nodes.size());
            return nodes;
        } catch (Exception e) {
            log.error("", e);
        }
        return Collections.emptyList();
    }

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

    // 导入节点 csv内为两列 id 和 name
    LOAD CSV WITH HEADERS FROM 'file:///event.csv' AS row
    CREATE (:`事件` {id: row.id, name: row.name})

    // 导入关系 csv内为两列 id_from id_to
    LOAD CSV WITH HEADERS FROM "file:///Relationships.csv" AS row
    //look up the two nodes we want to connect up
    MATCH (p1:Person {id:row.id_from}), (p2:Person {id:row.id_to})
    //now create a relationship between them
    CREATE (p1)-[:KNOWS]->(p2);
    // TODO 考虑 节点类型和id以及关系类型都是可变的情况 是否引用csv的列来动态化，否则需要切分csv

1
2

    CREATE INDEX ON :Person(firstname)
    CREATE INDEX ON :Person(firstname, surname)