Scala中的Neo4j 3.0.3存储过程

Question

在Neo4j-3.0.3中，是否有用于创建存储过程的Scala代码示例？

我一直在尝试创建一个简单的基于Scala的存储过程。下面是当我将scala-jar文件复制到neo4j-plugins目录并启动neo4j服务器时收到的错误消息：

=================
Caused by: org.neo4j.kernel.lifecycle.LifecycleException: Component 'org.neo4j.kernel.impl.proc.Procedures@1ac0223' was successfully initialized, but failed to start. Please see attached cause exception.
        at org.neo4j.kernel.lifecycle.LifeSupport$LifecycleInstance.start(LifeSupport.java:444)
        at org.neo4j.kernel.lifecycle.LifeSupport.start(LifeSupport.java:107)
        at org.neo4j.kernel.impl.factory.GraphDatabaseFacadeFactory.newFacade(GraphDatabaseFacadeFactory.java:140)
        ... 10 more
Caused by: org.neo4j.kernel.api.exceptions.ProcedureException: Unable to find a usable public no-argument constructor in the class `neoscala`. Please add a valid, public constructor, recompile the class and try again.
=================

    package neoproc

    import org.neo4j.graphdb.GraphDatabaseService
    import org.neo4j.procedure.Procedure;
    import javax.ws.rs.core.{Context, Response}

    class neoscala(@Context db: GraphDatabaseService) {

     @Procedure
    def alice():String = {
        String.valueOf(db.execute( "MATCH (n:User) return n" ));
     }
    }

Answer 1

以下是解决方案：

我们将在scala中创建类：

  class FullTextIndex extends JavaHelper {
     @Procedure("example.search")
     @PerformsWrites
         def search(@Name("label") label: String,
                    @Name("query") query:  String): Stream[SearchHit] = {
           //declare your method 
           }

        val nodes: Stream[Node] = db.index.forNodes(index).query(query).stream

       val newFunction: java.util.function.Function[Node, SearchHit] = (node: Node) => new SearchHit(node)
           nodes.map {
                 newFunction
           }
      }

       private def indexName(label: String): String = {
           "label-" + label
   }
 }

Neo4j中的过程总是在流中返回结果，这是Java8中的最新特性，因此我们还将使用Java类来返回最终结果和定义公共变量。

我们将为结果创建Java类：

public class JavaHelper {

@Context
public GraphDatabaseService db;

@Context
public Log log;

 public static class SearchHit {
    //your result code here
}

您可以参考knoldus博客了解Neo4j用户定义的过程，该过程用于使用Scala创建和存储Neo4j过程。在这里，您还可以找到git hub repository的示例代码。

Answer 2

Scala类用GraphDatabaseService参数声明了一个构造函数，异常告诉您它只需要一个无参数构造函数。

两者都有记录

>

过程类中只允许使用静态字段和@Context注释字段。

该Javadoc：

过程方法本身可以包含任意Java代码——但是为了使用基础图，它必须能够访问图应用编程接口。这是通过在过程类中声明字段并使用上下文注释对其进行注释来实现的。以这种方式声明的字段会自动注入请求的资源。这就是过程获得API访问权限的方式。

类中包含过程声明的所有字段必须是静态的；或者它必须是公开的、非最终的，并带有上下文注释。

显然，在Scala中不可能创建一个带有公共字段的类，因此您必须创建一个带有公共字段的父Java类，并使用Scala类对其进行扩展：

// ProcedureAdapter.java
public abstract class ScalaProcedureAdapter {
    @Context
    public GraphDatabaseService db;
}

// neoscala.scala
class neoscala extends ScalaProcedureAdapter {
    // ...
}