在學習Neo4j的時候網上找了很多資料也參考了很多大牛的部落格，感覺這方面的資料實在太少了有的部落格只是隻言片語表達的很不清晰因此走了很多彎路。查找了很多關於Springboot整合Neo4j的資料大部分都是基於springdata來做的，這方面看似很簡單但是如果執行插入操作就會很慢 影響插入效率。雖然他有@query標籤可以書寫cypher語句但是無法做到拼接組裝cypher,無奈之下只有重構，改成Neo4j的驅動模式開發，具體操作如下：

   1：首先建立一個簡單的Springboot專案

2：在pom.xml中匯入Neo4j的相關聯的Maven座標

<dependency>
 
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-neo4j</artifactId>
</dependency>
<dependency>
   <groupId>org.neo4j</groupId>
   <artifactId>neo4j-ogm-bolt-driver</artifactId>
   <version>2.1.3</version>
 
</dependency>

3：配置檔案中配置行相應的資訊

這個是http訪問的配置 我的專案裡有兩個模式http模式和驅動模式

#neo4j 資料庫配置
spring:
  data:
    neo4j:
      uri: http://192.168.1.108:7474
      username: neo4j
      password: 123456

#Neo4j驅動模式配置
blotUri: bolt://192.168.1.108:7687

4：在程式中配置驅動模式資訊

public class Neo4jV2Application {

    @Value("${blotUri}"
 
)
    private String uri;
@Value("${spring.data.neo4j.username}")
    private String username;
@Value("${spring.data.neo4j.password}")
    private String password;
    public static void main(String[] args) {
        SpringApplication.run(Neo4jV2Application.class, args);
}

    /**
     * 圖資料庫驅動模式
*
     * @return
*/
@Bean
public Driver neo4jDriver() {
        return GraphDatabase.driver(uri, AuthTokens.basic(username,password));
}

5：注入例項訪問Neo4j圖資料庫

@Resource
private Driver driver;

public void getWbswryxxMessage(ConsumerRecord record) {

    Wbswryxx wbswryxx = JSON.parseObject(record.value().toString(), Wbswryxx.class);
    if (wbswryxx != null) {
        Session session = null;
Transaction tx = null;
        try {
            if (wbswryxx.getZjhm() != null) {
                Map map = IdCardUtil.VerifyIdcardAndFullIDCard(wbswryxx.getZjhm());
String idcard = (String)map.get("idcard");
                if ((Boolean) map.get("idcardIsOk")) {

                    Map params = new HashMap<>();
String detailAddress=null;
                    if (wbswryxx.getYycsmc() != null) {
                        StringBuffer sb = new StringBuffer();
                        if (wbswryxx.getYycsxzqh() != null) {
                            sb.append(wbswryxx.getYycsxzqh());
}
                        if (wbswryxx.getYycsdz() != null) {
                            sb.append(wbswryxx.getYycsdz());
}

                        sb.append(wbswryxx.getYycsmc());
detailAddress = sb.toString();
}


                    StringBuffer sbCypher = new StringBuffer();
idcard = IdCardUtil.getFullIDCard(idcard);
params.put("idcard", idcard);
sbCypher.append("Merge(a:Persion{idcard:{idcard}})");
                    if (wbswryxx.getYycsmc() != null) {
                        params.put("detailAddress", detailAddress);
sbCypher.append(" Merge(b:InternetBar{detailAddress:{detailAddress}})").append("Merge (a)-[r:PersionToInternetBar{swsj:{beginTime},xwsj:{endTime}}]->(b)");
}

                    if (wbswryxx.getSwkssjDate() != null) {

                        params.put("beginTime", wbswryxx.getSwkssjDate().getTime());
} else {
                        params.put("beginTime", 0);
}
                    if (wbswryxx.getXwsjDate() != null) {

                        params.put("endTime", wbswryxx.getXwsjDate().getTime());
} else {
                        params.put("endTime", 0);
}
                    params.put("persionName", wbswryxx.getSwryxm());
params.put("persionSex", wbswryxx.getXb());
String birthday = idcard.substring(6, 14);
                    if(IdCardUtil.VerifyBirthday(birthday)){

                        params.put("persionBirthday", Integer.parseInt(birthday));
}else {
                        params.put("persionBirthday", Integer.parseInt("0"));
}
                    sbCypher.append("on create set a.name={persionName},a.sex={persionSex},a.birthday={persionBirthday}");
                    if (wbswryxx.getYycsmc() != null) {

                        params.put("InternetBarName", wbswryxx.getYycsmc());
sbCypher.append(",b.name={InternetBarName}");
                        if (wbswryxx.getYycsdz() != null) {
                            params.put("InternetBarAddress", wbswryxx.getYycsdz());
sbCypher.append(",b.address={InternetBarAddress}");
}
                        if (wbswryxx.getYycsxzqh() != null) {
                            params.put("InternetBarQH", wbswryxx.getYycsxzqh());
sbCypher.append(",b.administrativeDivision={InternetBarQH} ");
}
                    }

                    String cypher = sbCypher.toString();
session = driver.session();
tx = session.beginTransaction();
tx.run(cypher, params);
tx.success();
}

            }


        } catch (Exception e) {
            logger.error("網咖資訊表插入資料報錯具體資訊如下 " + record.toString());
logger.error("異常資訊為： " + e.getMessage());
} finally {
            if (null != tx) {
                tx.close();
}
            if (null != session) {
                session.close();
}

        }
    }
}

6:通過驅動模式進行查詢操作  轉換成實體物件的時候用到了fastJson進行轉換

@Resource
private Driver neo4j;

@Override
public Neo4jResoult getPersionsByImportPersionCase(Long hour, String prevNumber, String name, Neo4jResoult
        neo4jResoult) {
Session session = null;
Transaction tx = null;
    try {
        session = neo4j.session();
tx = session.beginTransaction();
//查詢出案件結點
Map params = new HashMap();
params.put("name", name);
StatementResult result1 = tx.run(" match(a:ImportPersionCase{name:{name}}) return  a", params);
        int indexImportPersionCase = 0;
        while (result1.hasNext()) {
            org.neo4j.driver.v1.types.Node node = result1.next().get("a").asNode();
Map<String, Object> map = node.asMap();
String mapString = JSONObject.toJSONString(map);
ImportPersionCase importPersionCase = JSONObject.parseObject(mapString, ImportPersionCase.class);

        }

        tx.success();
} catch (Exception e) {
        e.printStackTrace();
} finally {

        if (null != tx) {
            tx.close();
}
        if (null != session) {
            session.close();
}

    }


    return new Neo4jResoult();
}