如何在Spark worker节点中连接到NEO4J？

import org.neo4j.driver.*;

public class SparkNeo4JExample {
    public static void main(String[] args) {
        // 创建NEO4J连接配置
        Config config = Config.builder()
                .withDriverClassName("org.neo4j.driver.Driver")
                .withURI("bolt://neo4j-host:7687")
                .withEncryptionLevel(Config.EncryptionLevel.NONE)
                .withUser("neo4j")
                .withPassword("password")
                .build();

        // 创建NEO4J连接
        try (Driver driver = GraphDatabase.driver(config)) {
            // 在Spark任务中执行NEO4J查询
            // ...
        }
    }
}