2014-03-12 61 views
0

我使用下面的查询Neo4j的暗号查询使用Java API

 START n=node(*) 
    MATCH(n) 
    WHERE n.Gender ?="Female" 
    RETURN n 

其完美运行在服务器1.9.6问题。

我的程序如下

void query() 
     { 
     ExecutionResult result,; 
     Transaction tx=null; 
    ExecutionEngine engine = new ExecutionEngine(graphDb); 

    try 
    { 
     String name="Female"; 
     tx=graphDb.beginTx(); 
    result=engine.execute("start n=node(*)match(n)where n.Gender ?={Female} return n"); 
     System.out.println(result.dumpToString()); 
     tx.success(); 
    } 

    catch(Exception e) 
    { 
     try 
     {   
      File f=new File("trace.txt"); 
      BufferedWriter br=new BufferedWriter(new FileWriter(f,true)); 
      tx.failure(); 
      k=Arrays.toString(e.getStackTrace()); 
      System.out.println(k); 
      br.write(k); 
      br.close(); 
      throw new IOException(); 
     } 
     catch (Exception ex) 
     { 
     } 
     } 
    finally 
    { 
     tx.finish(); 
    } 

} 

当我尝试通过节目进入catch块,并打印以下的堆栈跟踪

  [org.neo4j.cypher.internal.pipes.QueryState$$anonfun$getParam$1.apply(QueryState.scala:60), 
      org.neo4j.cypher.internal.pipes.QueryState$$anonfun$getParam$1.apply(QueryState.scala:60), 
      scala.collection.MapLike$class.getOrElse(MapLike.scala:128), 
      scala.collection.AbstractMap.getOrElse(Map.scala:58), 
      org.neo4j.cypher.internal.pipes.QueryState.getParam(QueryState.scala:60), 
      org.neo4j.cypher.internal.commands.expressions.ParameterExpression.apply(ParameterExpression.scala:27), 
      org.neo4j.cypher.internal.commands.Equals.isMatch(ComparablePredicate.scala:59), 
      org.neo4j.cypher.internal.commands.NullablePredicate.isMatch(Predicate.scala:59), 
      org.neo4j.cypher.internal.pipes.FilterPipe$$anonfun$internalCreateResults$1.apply(FilterPipe.scala:30), 
      org.neo4j.cypher.internal.pipes.FilterPipe$$anonfun$internalCreateResults$1.apply(FilterPipe.scala:30), 
      scala.collection.Iterator$$anon$14.hasNext(Iterator.scala:390), 
      org.neo4j.cypher.internal.ClosingIterator$$anonfun$next$1.apply(ClosingIterator.scala:45), 
      org.neo4j.cypher.internal.ClosingIterator.failIfThrows(ClosingIterator.scala:86), 
      org.neo4j.cypher.internal.ClosingIterator.next(ClosingIterator.scala:43), 
      scala.collection.Iterator$class.foreach(Iterator.scala:727), 
      org.neo4j.cypher.internal.ClosingIterator.foreach(ClosingIterator.scala:31), 
      scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48), 
      scala.collection.mutable.ListBuffer.$plus$plus$eq(ListBuffer.scala:178), 
      scala.collection.mutable.ListBuffer.$plus$plus$eq(ListBuffer.scala:45), 
      scala.collection.TraversableOnce$class.to(TraversableOnce.scala:259), 
      org.neo4j.cypher.internal.ClosingIterator.to(ClosingIterator.scala:31), 
      scala.collection.TraversableOnce$class.toList(TraversableOnce.scala:243), 
      org.neo4j.cypher.internal.ClosingIterator.toList(ClosingIterator.scala:31), 
      org.neo4j.cypher.PipeExecutionResult.eagerResult(PipeExecutionResult.scala:100), 
      org.neo4j.cypher.PipeExecutionResult.dumpToString(PipeExecutionResult.scala:103), 
      org.neo4j.cypher.PipeExecutionResult.dumpToString$lzycompute(PipeExecutionResult.scala:143), 
      org.neo4j.cypher.PipeExecutionResult.dumpToString(PipeExecutionResult.scala:140), 
      org.neo4j.cypher.javacompat.ExecutionResult.dumpToString(ExecutionResult.java:102), 
      Neo4jQuery.query(Neo4jQuery.java:90), Neo4jQuery.main(Neo4jQuery.java:35), 
      __SHELL3.run(__SHELL3.java:6), sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method), 
      sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57), 
      sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43), 
      java.lang.reflect.Method.invoke(Method.java:606), bluej.runtime.ExecServer$3.run(ExecServer.java:725)] 

我想我传递参数“来执行它女性“的方式是错误的。

+0

你的异常处理块很奇怪。只需使用日志框架(或java.util.logging)将错误消息记录到磁盘即可。 –

+0

您忘记将参数映射传递给cypher的execute方法,'execute(query,params)' –

回答

2

我应该开始说我不熟悉Neo4j的Java API。但是,从我所看到的:

在Cypher支架

MATCH (n) 

不正确。您需要描述完整路径,如MATCH (n)-->(m)MATCH (n)-[:friend_of]-(m),或者一起跳过匹配条款。在你的例子中,你不需要匹配条款,所以你可以跳过它。

第二件事是 - 是你没有正确地传递参数 - 你可以看到如何参数传递给ExecutionEgine这里一些例子:http://docs.neo4j.org/chunked/stable/tutorials-cypher-parameters-java.html

在您的例子,你可以这样做:

void query() { 
    ExecutionResult result,; 
    Transaction tx=null; 
    ExecutionEngine engine = new ExecutionEngine(graphDb); 

    try 
    { 
     Map<String, Object> params = new HashMap<String, Object>(); 
     params.put("gender", "Female"); 
     tx=graphDb.beginTx(); 
     result = engine.execute("start n=node(*) where n.Gender ?= {gender} return n",params); 
     System.out.println(result.dumpToString()); 
     tx.success(); 
    } 
    catch(Exception e) 
    { 
     try 
     {   
      File f=new File("trace.txt"); 
      BufferedWriter br=new BufferedWriter(new FileWriter(f,true)); 
      tx.failure(); 
      k=Arrays.toString(e.getStackTrace()); 
      System.out.println(k); 
      br.write(k); 
      br.close(); 
      throw new IOException(); 
     } 
     catch (Exception ex) 
     { 
     } 
     } 
    finally 
    { 
     tx.finish(); 
    } 

} 
+0

P.S.如果你的查询没有改变,你也可以这样写:'engine.execute(“start n = node(*)where n.Gender?='Female'return n”);'并且完全跳过Map 。 –

+0

谢谢Tsanyo Tsanev ..它工作:) – LearnerFreak

+0

你忘了添加params映射到执行调用。通常你只能使用文字来确定固定值,即常量。 –