我的Neo4j探索之旅 - 安装Apoc插件以及JAVA集成(二)

简介: 在可视化界面,输入return apoc.version() ,如果报错说明没安装对,显示如下页面,证明apoc 插件安装成功

上一篇文章:


不知道为什么我发不出文章,找不到那里违规了,上一篇文章我发布到思否了:


segmentfault.com/a/119000003…


如何安装neo4j - apoc 插件


有英语阅读能力建议参考官方文档:neo4j.com/developer/n…


1. 下载neo4j - apoc 插件


进入github : github.com/neo4j-contr…


找到和当前neo4j 匹配的版本, 我选择3.5.0.12 的版本


这里提供我的:


链接:pan.baidu.com/s/1Tb7f-bYj…提取码:bzwh


2. 具体的安装步骤


2.下载好之后,放入到 D:\zxd\tool\neo4j-community-3.5.12-windows\neo4j-community-3.5.12\plugins 下面

3.执行neo4j stop,关闭neo4j 服务

4.进入 ~/conf 下面,找到neo4j.conf ~表示你的neo4j 安装位置

5.修改#dbms.security.procedures.whitelist=apoc.coll.*,apoc.load.* 在这一行的下面增加dbms.security.procedures.unrestricted=apoc.*的配置,安装apoc插件


下面的图看起来就像这样:


#dbms.security.procedures.whitelist=apoc.coll.,apoc.load.dbms.security.procedures.unrestricted=apoc.*


网络异常,图片无法展示
|


6.输入 neo4j start 启动neo4j 服务

7.在可视化界面,输入return apoc.version() ,如果报错说明没安装对,显示如下页面,证明apoc 插件安装成功


网络异常,图片无法展示
|


Neo4j 集成到java里面


1. 配置maven,加入依赖


<!-- neo4j 依赖包 -->
<dependency>
    <groupId>org.neo4j.driver</groupId>
    <artifactId>neo4j-java-driver</artifactId>
    <version>1.5.0</version>
</dependency>


2. 使用neo4j 集成java实战


这是之前实战的是用的方式,这里说下我大致的设计记录


需求:


  1. neo4j 实现插拔式配置,没有配置的情况下进行连接不会影响程序运行
  2. 所有的配置都需要放在application_setting.xml当中
  3. 如果连接neo4j 失败,不做处理


抽象接口


core 包里面, 设计公用开放接口。


  /**
     * 构建neo4j url地址
     * @return
     */
    String buildUrl();
    /**
     * 构建neo4j 用户名
     * @return
     */
    String buildUsername();
    /**
     * 构建neo4j 密码
     * @return
     */
    String buildPassword();
    /**
     * 构建neo4j 配置, 目前使用默认 配置
     * @return
     */
    Config buildConfig();
    /**
     * 是否开启自定义配置
     * @return
     */
    boolean enableCustomConfig();
    /**
     * 构建 Neo4j csv同步地址的前置
     * 默认为 file:///
     *
     * @return
     */
    String buildCvsPrefix();
    /**
     * 构建 neo4j csv同步的普通标签文件名
     * @return
     */
    String buildNormalTagSyncFileName();
    /**
     * 构建 neo4j csv同步的业务标签文件名
     * @return
     */
    String buildBusinessTagSyncFileName();
    /**
     * 构建 neo4j csv同步的用户标签文件名
     * @return
     */
    String buildUserTagSyncFileName();
    /**
     * 普通标签和业务标签的关联csv文件名称
     * @return
     */
    String buildNormalTagBizSyncFileName();
    /**
     * 普通标签和用户标签的关联csv文件名称
     * @return
     */
    String buildNormalTagUserSyncFileName();
    /**
     * 业务标签和用户标签的关联csv文件名称
     * @return
     */
    String buildBizTagUserSyncFileName();
    /**
     * 主题分类(业务)标签子父关联csv文件名称
     * @return
     */
    String buildBizChildSyncFileName();
    /**
     * 普通标签标签子父关联csv文件名称
     * TODO: 目前普通标签没有子父关联关系,后续需要拓展请开放此接口 by zhaoxudong
     * @return
     */
//    String buildNormalChildSyncFileName();
    /**
     * 用户标签的子父关联csv文件名称
     * @return
     */
    String buildUserChildSyncFileName();


具体实现


maven的其他项目工程,只要实现了上面的接口,就可以根据自己的设定去设置如何读取配置,下面给出案例


@Override
    public String buildUrl() {
        return Setter.getString("neo4j.address");
    }
    @Override
    public String buildUsername() {
        return Setter.getString("neo4j.username");
    }
    @Override
    public String buildPassword() {
        return Setter.getString("neo4j.password");
    }
    @Override
    public Config buildConfig() {
        return Config.defaultConfig();
    }
    @Override
    public boolean enableCustomConfig() {
        return Setter.getBoolean("neo4j.enablecustomconfig");
    }
    @Override
    public String buildCvsPrefix() {
        return Setter.getString("neo4j.datasyncprefix");
    }
    @Override
    public String buildNormalTagSyncFileName() {
        return Setter.getString("neo4j.normaltagsyncfilename");
    }
    @Override
    public String buildBusinessTagSyncFileName() {
        return Setter.getString("neo4j.businesstagsyncfilename");
    }
    @Override
    public String buildUserTagSyncFileName() {
        return Setter.getString("neo4j.usertagsyncfilename");
    }
    @Override
    public String buildNormalTagBizSyncFileName() {
        return Setter.getString("neo4j.normalbizsyncfilename");
    }
    @Override
    public String buildNormalTagUserSyncFileName() {
        return Setter.getString("neo4j.normalusersyncfilename");
    }
    @Override
    public String buildBizTagUserSyncFileName() {
        return Setter.getString("neo4j.bizusersyncfilename");
    }
    @Override
    public String buildBizChildSyncFileName() {
        return Setter.getString("neo4j.bizrelsyncfilename");
    }
    @Override
    public String buildUserChildSyncFileName() {
        return Setter.getString("neo4j.userrelsyncfilename");
    }


结合到neo4j 连接


  1. 根据上面两个步骤, ssm项目启动之后,会自动装载BEAN, 装载之后,只要在具体的程序里面,拿取配置即可(具体的配置获取实现可以由自己实现)
  2. 根据上面的方法使用java拿到xml配置之后,就实现了下面的方式实现neo4j 的数据连接


/**
     * 连接图数据库
     * @return
     */
private void createDriver(Neo4jConfigBuilder builder) {
    if(driver == null){
        try{
            driver =  GraphDatabase.driver(builder.buildUrl(), AuthTokens.basic(builder.buildUsername(), builder.buildPassword()));
        }catch(Exception e){
            driver = null;
            LOGGER.debug("无法建立图数据库连接,请检查图Neo4j 服务是否启动");
            throw new RuntimeException("无法建立图数据库连接,请检查图Neo4j 服务是否启动");
        }
    }
}


具体开发


 /**
     * 执行添加cql
     *
     * @param cql 查询语句
     */
    @Override
    public StatementResult run(Neo4jConfigBuilder builder,String cql) {
        createDriver(builder);
        Session session = driver.session();
        StatementResult run = null;
        try {
            run = session.run(cql);
        }catch (Exception e){
            e.printStackTrace();
        } finally {
            if(session!=null){
                session.close();
            }
        }
        return run;
    }
    @Override
    public StatementResult run(Neo4jConfigBuilder builder,String cql, Object... objects) {
        createDriver(builder);
        Session session = driver.session();
        StatementResult run = null;
        try {
            run = session.run(cql, Values.parameters(objects));
        }catch (Exception e){
            e.printStackTrace();
        } finally {
            if(session!=null){
                session.close();
            }
        }
        return run;
    }


曾经开发的时候查找的一些博客记录:


NEO4J的安装配置及使用总结


neo4j︱neo4j批量导入neo4j-import (五)


neo4j - 查询效率的几种优化思路


Neo4j如何对大量数据(千万节点及以上)进行初始化


关于Neo4j和Cypher批量更新和批量插入优化的5个建议


Neo4j的查询速度为何这么慢?这能商用吗?


Neo4j清空所有数据


Neo4j安装APOC和图算法Neo.ClientError.Procedure.ProcedureRegistrationFailed?


官方网站对于Apoc插件的介绍


neo4j cypher 语言的语法(非常非常重要):


neo4j--Cypher语法练习(START、CREATE、MERGE)


Neo4j中使用Cypher进行大批量节点删除的优化


thinbug  我的很多前端疑难杂症就是靠这网站解决的

相关文章
|
3月前
|
JavaScript 前端开发 持续交付
Prettier 高级应用:集成 CI/CD 流水线与插件开发
【10月更文挑战第18天】Prettier 是一款流行的代码格式化工具,它能够自动将代码格式化成一致的风格,从而提高代码的可读性和维护性。对于希望进一步发挥 Prettier 潜力的高级用户而言,将 Prettier 集成到持续集成(CI)和持续部署(CD)流程中,确保每次提交的代码都符合团队标准,是非常重要的。此外,通过开发自定义插件来支持更多语言或扩展 Prettier 的功能也是值得探索的方向。本文将详细介绍这两方面的内容。
59 2
|
2月前
|
传感器 前端开发 Android开发
在 Flutter 开发中,插件开发与集成至关重要,它能扩展应用功能,满足复杂业务需求
在 Flutter 开发中,插件开发与集成至关重要,它能扩展应用功能,满足复杂业务需求。本文深入探讨了插件开发的基本概念、流程、集成方法、常见类型及开发实例,如相机插件的开发步骤,同时强调了版本兼容性、性能优化等注意事项,并展望了插件开发的未来趋势。
45 2
|
2月前
|
IDE Java 编译器
开发 Java 程序一定要安装 JDK 吗
开发Java程序通常需要安装JDK(Java Development Kit),因为它包含了编译、运行和调试Java程序所需的各种工具和环境。不过,某些集成开发环境(IDE)可能内置了JDK,或可使用在线Java编辑器,无需单独安装。
81 1
|
2月前
|
Java Linux Windows
如何查看已安装的 Java 版本
要查看已安装的 Java 版本,打开命令提示符或终端,输入 `java -version`,回车后即可显示当前系统中 Java 的版本信息。
767 1
|
3月前
|
Oracle Java 关系型数据库
在 Debian 12 上安装 Java 21
在 Debian 12 上安装 Java 21
|
3月前
|
IDE Java 编译器
java编译器的安装/环境变量的配置
java编译器的安装/环境变量的配置
41 0
|
7天前
|
Java
Java—多线程实现生产消费者
本文介绍了多线程实现生产消费者模式的三个版本。Version1包含四个类:`Producer`(生产者)、`Consumer`(消费者)、`Resource`(公共资源)和`TestMain`(测试类)。通过`synchronized`和`wait/notify`机制控制线程同步,但存在多个生产者或消费者时可能出现多次生产和消费的问题。 Version2将`if`改为`while`,解决了多次生产和消费的问题,但仍可能因`notify()`随机唤醒线程而导致死锁。因此,引入了`notifyAll()`来唤醒所有等待线程,但这会带来性能问题。
Java—多线程实现生产消费者
|
9天前
|
安全 Java Kotlin
Java多线程——synchronized、volatile 保障可见性
Java多线程中,`synchronized` 和 `volatile` 关键字用于保障可见性。`synchronized` 保证原子性、可见性和有序性,通过锁机制确保线程安全;`volatile` 仅保证可见性和有序性,不保证原子性。代码示例展示了如何使用 `synchronized` 和 `volatile` 解决主线程无法感知子线程修改共享变量的问题。总结:`volatile` 确保不同线程对共享变量操作的可见性,使一个线程修改后,其他线程能立即看到最新值。
|
9天前
|
消息中间件 缓存 安全
Java多线程是什么
Java多线程简介:本文介绍了Java中常见的线程池类型,包括`newCachedThreadPool`(适用于短期异步任务)、`newFixedThreadPool`(适用于固定数量的长期任务)、`newScheduledThreadPool`(支持定时和周期性任务)以及`newSingleThreadExecutor`(保证任务顺序执行)。同时,文章还讲解了Java中的锁机制,如`synchronized`关键字、CAS操作及其实现方式,并详细描述了可重入锁`ReentrantLock`和读写锁`ReadWriteLock`的工作原理与应用场景。
|
9天前
|
安全 Java 编译器
深入理解Java中synchronized三种使用方式:助您写出线程安全的代码
`synchronized` 是 Java 中的关键字,用于实现线程同步,确保多个线程互斥访问共享资源。它通过内置的监视器锁机制,防止多个线程同时执行被 `synchronized` 修饰的方法或代码块。`synchronized` 可以修饰非静态方法、静态方法和代码块,分别锁定实例对象、类对象或指定的对象。其底层原理基于 JVM 的指令和对象的监视器,JDK 1.6 后引入了偏向锁、轻量级锁等优化措施,提高了性能。
31 3

热门文章

最新文章