anormcypher / anormcypher Goto Github PK

Hey guys,
I'm trying to run a query that returns a collect() aggregate (http://docs.neo4j.org/chunked/stable/query-aggregation.html#aggregation-collect)
Kind of like this:

MATCH (n:Person)
RETURN id(n) as id, collect(n.property) as collectProperty

AnormCypher seems to return a mutable.ListBuffer for the collectProperty, and I'm not sure if the library doesn't yet support this type of return or if I'm parsing the CypherRow incorrectly.
I've tried both pattern matching (not supported I understand) and the brute force approach as well.

Pattern matching:
Doesn't work because everything is interpreted as a string?

case CypherRow(id: Long, collectProperty: scala.collection.mutable.ListBuffer[String] 
//Throws in runtime
[MatchError: CypherResultRow('id':35 as String, 'collectProperty':ListBuffer() as String) (of class org.anormcypher.CypherResultRow)]

And brute force doesn't work either because there's no implicit converter for collections.

Result(row[Long]("id"), row[scala.collection.mutable.ListBuffer[String]]("collectProperty"))

//Does not compile because:
could not find implicit value for parameter c: org.anormcypher.Column[scala.collection.mutable.ListBuffer[String]]

Any thoughts on how to solve this?

Hi do you plan on supporting 2.2 ? there is need for authentication support for exemple.

Exception in thread "main" java.lang.NoSuchMethodError: scala.Predef$.ArrowAssoc(Ljava/lang/Object;)Ljava/lang/Object;
    at org.anormcypher.Neo4jREST.<init>(Neo4jREST.scala:14)
    at org.anormcypher.Neo4jREST$.apply(Neo4jREST.scala:56)
    at TagML$.<init>(TagML.scala:26)
    at TagML$.<clinit>(TagML.scala)
    at TagML.main(TagML.scala)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.apache.spark.deploy.SparkSubmit$.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:665)
    at org.apache.spark.deploy.SparkSubmit$.doRunMain$1(SparkSubmit.scala:170)
    at org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:193)
    at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:112)
    at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)

And here is my code

import scala.collection.JavaConverters._
import org.ansj.splitWord.analysis.NlpAnalysis
import org.ansj.splitWord.analysis.ToAnalysis
import org.apache.hadoop.hbase.client._
import org.apache.hadoop.hbase.{HBaseConfiguration, HTableDescriptor, TableName}
import org.apache.hadoop.hbase.filter.PageFilter
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter
import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp
import org.apache.hadoop.hbase.mapreduce.TableInputFormat
import org.apache.hadoop.hbase.protobuf.ProtobufUtil
import org.apache.hadoop.hbase.util.{Base64, Bytes}
import com.feheadline.com.backend.recommend.util.Env
import org.apache.spark.SparkConf
import org.apache.spark.SparkContext
import org.apache.spark.rdd._
import org.apache.spark.mllib.feature.{Word2Vec, Word2VecModel}
import org.anormcypher._

object TagML {
//.....
//exception here
  implicit val connection = Neo4jREST(
        "tree",
        7474,
       "/db/data/"
      )
//......

}

i created a simple test : and the placeholder strings are not replaced and end up with {email} , {name} , {password} in the database

def create(user: User): User = {
Cypher(
"""
CREATE (n:User { email : " {email} ", name : "{name}", password : "{password}" })
""")
.on("email" -> user.email, "name" -> user.name, "password" -> user.password)
.execute()
user
}

Hi,
Please reassign if this is not the right place. I'm trying to download anormcypher packages via SBT. Unfortunately, I'm not able to connect to repo.anormcypher.org (infact www.anormcypher.org is not accessible). Looks like the domain name got expired on 13th Nov 2015.
Any clues on how to get it back? Is there any alternative repo that I can use? Please let us know.

Exact URL that I'm trying: http://repo.anormcypher.org/org/anormcypher/anormcypher_2.11/0.6.0/anormcypher_2.11-0.6.0.pom

I want to create a generic query with a custom label (tag) and a custom relationship. This piece of code does not work. AnormCypher only parse the {userId} placeholder.

val socialTag = "social"
val relationship = "KNOWS"
val id = 123
val req: CypherStatement = Cypher( """ MATCH (a:{tag})-[:`{relationship}`]->(b) WHERE a.id={userId} RETURN a.id """)
          .on("tag" -> socialTag)
          .on("relationship" -> relationship)
          .on("userId" -> id)

Regards,
Gabriel.

Hi,

I'm totally new to Scala and I'm using this library in combination with Play.
In order to render a template in Play easily, I would like to convert a CypherResultRow into a case class.
Say, you run a query like

val query = Cypher("MATCH (p:Person{name:{name}}) return p.name, p.age")
.on("name->"Karl")

and you define the respective case class like:
case class Person (name: String, age: Int)

How can I convert the result into a List of Person class instances?

I tried the pattern matching mechanism. However, every data type seems to be a String, so pattern matching is not successful as soon as there is another data type besides String.

It would be great, if someone could give me a an example on how this works.

Is there anyway you could modularize the backend? I would like to use this for some embedded database work as well and use the same API as for using remote connections. I often use the embedded version with some direct traversals but for many cypher queries, there is nothing special about them and being able to use this library for either embedded or remote databases would help with re-use.

Right now you can do:

case class MyCaseClass(n:String, a:Int)

Cypher("start n=node(1) return n.name, n.age")().map(row =>
  MyCaseClass(row[String]("n.name"), row[Int]("n.age")))
// returns Stream[MyCaseClass]

I'd rather make something like:

Cypher("start n=node(1) return n.name, n.age")().as[MyCaseClass]
// returns Stream[MyCaseClass]

This is a pain in the butt.

Hi,

I would like to understand does the existing functionalities of cypher supports the option of generate dynamic CQL for the CRUD operations i.e., it should perform all the operations using the object mapping without using any of low level CQL.

Please let me know if you need more details on my problem statement.

Starting with version 2.0 the ? and ! operators have been removed from Cypher.
Update the README file to exclude references to the removed operators.

See: Cypher Compatibility at
http://docs.neo4j.org/chunked/2.0.0/deployment-upgrading.html#deployment-upgrading-two-zero

See comment on issue #3

And remove the things that can't be done from the documentation.

To check:

• can we receive #items changed/inserted, etc.

I'm seeing the "unsupported type" exception when mapFormat encounters a JsNull value.

implicit val mapFormat = new Format[Map[String, Any]] {
    def read(xs: Seq[(String, JsValue)]): Map[String, Any] = (xs map {
      ...
      case (k, JsNull) => k -> null
      ...
}

Regarding http://neo4j.com/docs/stable/transactions-events.html, do you plan on implementing any notification mechanism for neo4j transaction events?

I follow below steps and get error.

1. I uncommented the part in build for "initialCommands in console"
2. sbt clean compile
3. sbt console

I get below error. Any help highly appreciated
"[info]
:16: error: could not find implicit value for parameter materializer: akka.stream.Materializer
val wsclient = ning.NingWSClient()
^
:19: error: not enough arguments for method apply: (implicit wsclient: play.api.libs.ws.WSClient, implicit materializer: akka.stream.Materializer)org.anormcypher.Neo4jREST in object Neo4jREST.
Unspecified value parameter materializer.
implicit val connection: Neo4jConnection = Neo4jREST()(wsclient)
^
Welcome to Scala 2.11.8 (Java HotSpot(TM) 64-Bit Server VM, Java 1.8.0_66).
Type in expressions for evaluation. Or try :help."

While implementing some own code dealing with Scala and Neo4j based on AnormCypher, I found a possible issue in your test code. After testing the method afterEach() should clean up the database from test nodes and edges with

MATCH (n) OPTIONAL MATCH (n)-[r]-() WHERE n.tag = "anormcyphertest" DELETE n, r

But that deletes nothing in Neo4j 2.0.3. In version 2.1.2 of Neo4j it yet will delete all nodes and edges from database, not only the tagged ones.

In Neo4j 2.x works the following Cypher statement:

MATCH (n { tag: "anormcyphertest" } ) OPTIONAL MATCH (n)-[r]-() DELETE n, r

It seems AnormCypher doesn't work with Play 2.5,

I got this error while compiling Play:
Error:(12, 35) could not find implicit value for parameter materializer: akka.stream.Materializer val wsclient = ning.NingWSClient() ^

It seems that Java float is supported, but Scala Float is not.

Scala Double is supported though.

It would be nice if the transaction API would support async transactions. I'm thinking about something like this:

def withAsyncTx[A](code: Neo4jTransaction => Future[A])(implicit conn: Neo4jConnection, ec: ExecutionContext): Future[A] =
    (for {
      tx <- conn.beginTx
      r <- code(tx)
    } yield {
      tx.commit
      r
    }) recover {
      case e: ControlThrowable => tx.commit; throw e
      case e: Throwable =>      tx.rollback; throw e
    }

This would allow things like:

Neo4jTransaction.withAsyncTx { implicit tx =>
  for {
    r1 <- cypherStmt1.async()
    r2 <- cypherStmt2(...).async()
   ...
  } yield ...
}

Hi,

Thanks for implementing this library. I am still very new to neo4j.

When i tried out the code example from the docs (as mentioned below), I got UnExpectedNullableException. I managed to figure out why. Each record in the result set is duplicated (one with actual value, one with null). I tried with 0.8.1 version and it works as expected. Here is the code I used:

Code below return duplicate row at v0.9.0

import org.anormcypher._
  import play.api.libs.ws._

  val wsclient = ning.NingWSClient()
  implicit val connection = Neo4jREST()(wsclient)
  implicit val ec = scala.concurrent.ExecutionContext.global

  Cypher("""create (anorm:anormcyphertest {name:"AnormCypher"})""").execute()
  val req = Cypher("match (n:anormcyphertest) return n.name")
  val stream = req()
  stream.foreach(row => {
    println(row[String]("n.name"))
  })
  Cypher("match (n:anormcyphertest) delete n")()
  wsclient.close()

Cheers

I recently attempted to upgrade an application from 0.7.1 (with Play 2.4) to 0.10.0 (with Play 2.5). I noticed that a particular operation involving approximately 500 queries against Neo4J was taking about 6 times longer with the newer version.

After spending some time investigating, it seems that there was a slowdown between version 0.7.1 and 0.8.1 (introduction of Enumerators) and between 0.8.1 and 0.9.1 (introduction of transactions).

Given the obvious difficulties of replicating exactly what I was seeing with my real-world data, I have created a very simple app that repeatedly queries a simple data set 10,000 times. The example is of course contrived, but running it with different versions of AnormCypher seems to reflect the levels of performance differences I was seeing with real world data.

Data set:
`
CREATE (a:Certificate) set a.name='G'

CREATE (b:Certificate) set b.name='Not Rated'

CREATE (c:Certificate) set c.name='U'

CREATE (d:Certificate) set d.name='PG'

CREATE (e:Certificate) set e.name='PG-13'

CREATE (f:Certificate) set f.name='12'

CREATE (g:Certificate) set g.name='12A'

CREATE (h:Certificate) set h.name='15'

CREATE (i:Certificate) set i.name='15A'

CREATE (j:Certificate) set j.name='16'

CREATE (k:Certificate) set k.name='18'

CREATE (l:Certificate) set l.name='R'

CREATE (m:Certificate) set m.name='R18'

CREATE (n:Certificate) set n.name='NC-17'

`

Code
`

val wsClient = NingWSClient(NingWSClientConfig())

// implicit val neoClient = new Neo4jREST(wsClient, "localhost", 7474, "neo4j", "neo4j", false) // 0.9.1

implicit val neoClient = new Neo4jREST(wsClient, "localhost", 7474, "/db/data/", "neo4j", "neo4j")

implicit val ec = scala.concurrent.ExecutionContext.global


val before = ZonedDateTime.now()

Await.result(Future.sequence((1 to 10000).map { _ =>
  Cypher(
    "MATCH (c: Certificate) RETURN c.name"
  ).async()
}).map(_.flatten), Duration.Inf)

val after = ZonedDateTime.now()

println((after.toInstant.toEpochMilli - before.toInstant.toEpochMilli) / 1000 + " seconds")

`

The results, using Play 2.4 dependencies in all cases were:
0.7.1 3 seconds
0.8.1 7 seconds
0.9.1 12 seconds

This is blocking my ability to upgrade to Play 2.5. If it's not easy to improve the performance with transactions/enumerators, perhaps an option would be to add an extra method that doesn't use these features?

Are there any plans for when the CypherRow pattern match will be implemented?

as in... versions of neo4j

I've been trying to send a list of objects, somewhat like this:

Cypher("foreach (o in {objects} | ... )")
  .on("objects" -> List(
    Map("a" -> "b", "c" -> "d"), 
    Map("a" -> "b", "c" -> "d"),
    ...
  )

As far as I can see there are no json Writes available from Seq[Map[String, Any]]. I'm not sure where to add this, but I believe writes in Neo4jRest.scala should contain an extra case statement for this case(list of maps).

However, this functionality is available in the Neo4j Rest API. See Creating multiple nodes with properties. I've also got it to work making the REST request on my own.

I've been able to work around this by moving the foreach into the scala code:

val objects = List(Map("a" -> "b", "c" -> "d"), Map("a" -> "b", "c" -> "d"))
for(o <- objects) {
  Cypher("...").on("object" -> o)
}

But I think we can all see that Cypher is reconstructing the execution path for the query each time, which is not very efficient.

I'm holding off on writing a pull request for this because I'm not too well versed in Play's JSON library to make the proper Writes change, but I hope that this can be fixed soon. It seems to me to be a pretty glaring missing feature.

This is kind of a question. Usually this should be done outside of a framework like this, but it might be nice to have some sort of built-in support.

Need a better way to document between versions... this is becoming a real project!

Think we can add a gitter.im chat for this repo?

Looking at the source code of dispatch, seems it's not difficult to implement.

credentials = new Credentials(username,password)
...
...
val result = Http(cypherRequest OK as.String, credentials).either

New to scala, don't be mad if it doesn't work:-)

Keep up the good work!

If I try to install AnormCypher after cloning it from GitHub by calling sbt, the resolving of dependencies fails, because http://repo.lessis.me and http://repo.codahale.com are dead. The following changes in the plugin.sbt file work:

resolvers ++= Seq(
  "less is" at "http://repository.jetbrains.com",
//   "coda" at "http://repo.codahale.com",
  "Sonatype" at "http://oss.sonatype.org/content/repositories/releases/")

addSbtPlugin("me.lessis" % "ls-sbt" % "0.1.2")

//addSbtPlugin("com.github.mpeltonen" % "sbt-idea" % "1.5.1")

It seems that building AnormCypher works without "coda". Furthermore, current IDEA versions have a excellent sbt support coming with the Scala plugin, thus maybe

addSbtPlugin("com.github.mpeltonen" % "sbt-idea" % "1.5.1")

could be removed too.

I tried to examples using scala 2.10 and play 2.1.1.
when I run "console" in play, I met message such as below.

[error] (*:update) sbt.ResolveException: unresolved dependency: play#play-json_2.10;2.2-SNAPSHOT: not found

should I set SNAPSHOT repository ?

Not really an issue, more of a comment. I ran across this (newish) project https://github.com/neo4j-contrib/neo4j-jdbc - from some basic testing it looks like anorm/Hikari/neo4j-jdbc works just fine.

SQL"""create (tim:twoname {fname:"Tim", lname:"Foo"}), (katie:twoname {fname:"Katie", lname:"Bar"})""".execute
val names = SQL"""match (n:twoname) return n.fname, n.lname""".as(Macro.indexedParser[NameClass].*).map(_.fname)

Is there anything I should be aware of that AnormCypher does that neo4j-jdbc will not be able to handle?

The following code produces error:

import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import org.anormcypher.Neo4jREST
import play.api.libs.json.Json
import play.api.libs.ws.ning

object importTraces extends App {
  implicit val system = ActorSystem("neo4j-system")
  implicit val materializer = ActorMaterializer()
  implicit val wsclient = ning.NingWSClient()
  implicit val connection = Neo4jREST("localhost", 7474, "/db/data/", "guest", "neo4j")
}

Exception in thread "main" java.lang.NoSuchMethodError: play.api.libs.functional.syntax.package$.functionalCanBuildApplicative(Lplay/api/libs/functional/Applicative;)Lplay/api/libs/functional/FunctionalCanBuild;
    at org.anormcypher.Neo4jREST$.<init>(Neo4jREST.scala:141)
    at org.anormcypher.Neo4jREST$.<clinit>(Neo4jREST.scala)
    at importTraces$.delayedEndpoint$importTraces$1(importTraces.scala:12)
    at importTraces$delayedInit$body.apply(importTraces.scala:7)
    at scala.Function0$class.apply$mcV$sp(Function0.scala:34)
    at scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12)
    at scala.App$$anonfun$main$1.apply(App.scala:76)
    at scala.App$$anonfun$main$1.apply(App.scala:76)
    at scala.collection.immutable.List.foreach(List.scala:381)
    at scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:35)
    at scala.App$class.main(App.scala:76)
    at importTraces$.main(importTraces.scala:7)
    at importTraces.main(importTraces.scala)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)

i use

"com.typesafe.play" % "play-ws_2.11" % "2.5.0"
"org.anormcypher" %% "anormcypher" % "0.8.1"

Hey,
I'm trying to run a simple Cypher Query, but keep getting a RuntimeException with no message.

The cypher REST endpoint is running and anormCypher is pointing to the right address:

scala> Neo4jREST.baseURL
res19: String = http://localhost:7474/db/data

And the query is simple

Cypher("MATCH (n) RETURN n")()

When I run it from a running Play! 2.2.1 application, I get the following error:

    at org.anormcypher.Neo4jREST$.sendQuery(Neo4jREST.scala:138) ~[anormcypher_2.10-0.4.4.jar:0.4.4]
    at org.anormcypher.CypherStatement.apply(AnormCypher.scala:342) ~[anormcypher_2.10-0.4.4.jar:0.4.4]
    at services.graph.Neo4jGraphRepository.getRelationship(GraphService.scala:47) ~[classes/:na]
    at services.graph.GraphService.getRelationship(GraphService.scala:13) ~[classes/:na]
    at controllers.GraphController$$anonfun$getRelationship$1.apply(GraphController.scala:25) ~[classes/:na]
    at controllers.GraphController$$anonfun$getRelationship$1.apply(GraphController.scala:25) ~[classes/:na]
    at play.api.mvc.ActionBuilder$$anonfun$apply$11.apply(Action.scala:255) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.api.mvc.ActionBuilder$$anonfun$apply$11.apply(Action.scala:255) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.api.mvc.ActionBuilder$$anonfun$apply$10.apply(Action.scala:221) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.api.mvc.ActionBuilder$$anonfun$apply$10.apply(Action.scala:220) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.api.mvc.Action$.invokeBlock(Action.scala:357) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.api.mvc.ActionBuilder$$anon$1.apply(Action.scala:309) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.api.mvc.Action$$anonfun$apply$1$$anonfun$apply$4$$anonfun$apply$5.apply(Action.scala:109) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.api.mvc.Action$$anonfun$apply$1$$anonfun$apply$4$$anonfun$apply$5.apply(Action.scala:109) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.utils.Threads$.withContextClassLoader(Threads.scala:18) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.api.mvc.Action$$anonfun$apply$1$$anonfun$apply$4.apply(Action.scala:108) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.api.mvc.Action$$anonfun$apply$1$$anonfun$apply$4.apply(Action.scala:107) ~[play_2.10-2.2.1.jar:2.2.1]
    at scala.Option.map(Option.scala:145) ~[scala-library.jar:na]
    at play.api.mvc.Action$$anonfun$apply$1.apply(Action.scala:107) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.api.mvc.Action$$anonfun$apply$1.apply(Action.scala:100) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.api.libs.iteratee.Iteratee$$anonfun$mapM$1.apply(Iteratee.scala:481) ~[play-iteratees_2.10-2.2.1.jar:2.2.1]
    at play.api.libs.iteratee.Iteratee$$anonfun$mapM$1.apply(Iteratee.scala:481) ~[play-iteratees_2.10-2.2.1.jar:2.2.1]
    at play.api.libs.iteratee.Iteratee$$anonfun$flatMapM$1.apply(Iteratee.scala:517) ~[play-iteratees_2.10-2.2.1.jar:2.2.1]
    at play.api.libs.iteratee.Iteratee$$anonfun$flatMapM$1.apply(Iteratee.scala:517) ~[play-iteratees_2.10-2.2.1.jar:2.2.1]
    at play.api.libs.iteratee.Iteratee$$anonfun$flatMap$1$$anonfun$apply$13.apply(Iteratee.scala:493) ~[play-iteratees_2.10-2.2.1.jar:2.2.1]
    at play.api.libs.iteratee.Iteratee$$anonfun$flatMap$1$$anonfun$apply$13.apply(Iteratee.scala:493) ~[play-iteratees_2.10-2.2.1.jar:2.2.1]
    at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24) [scala-library.jar:na]
    at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24) [scala-library.jar:na]
    ... 6 common frames omitted

From REPL I get:

play.api.Application$$anon$1: Execution exception[[RuntimeException: ]]
    at play.api.Application$class.handleError(Application.scala:293) ~[play_2.10-2.2.1.jar:2.2.1]
    at play.api.DefaultApplication.handleError(Application.scala:399) [play_2.10-2.2.1.jar:2.2.1]
    at play.core.server.netty.PlayDefaultUpstreamHandler$$anonfun$12$$anonfun$apply$1.applyOrElse(PlayDefaultUpstreamHandler.scala:165) [play_2.10-2.2.1.jar:2.2.1]
    at play.core.server.netty.PlayDefaultUpstreamHandler$$anonfun$12$$anonfun$apply$1.applyOrElse(PlayDefaultUpstreamHandler.scala:162) [play_2.10-2.2.1.jar:2.2.1]
    at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:33) [scala-library.jar:na]
    at scala.util.Failure$$anonfun$recover$1.apply(Try.scala:185) [scala-library.jar:na]
    at scala.util.Try$.apply(Try.scala:161) [scala-library.jar:na]
    at scala.util.Failure.recover(Try.scala:185) [scala-library.jar:na]
    at scala.concurrent.Future$$anonfun$recover$1.apply(Future.scala:387) [scala-library.jar:na]
    at scala.concurrent.Future$$anonfun$recover$1.apply(Future.scala:387) [scala-library.jar:na]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:29) [scala-library.jar:na]
    at play.api.libs.iteratee.Execution$$anon$1.execute(Execution.scala:43) [play-iteratees_2.10-2.2.1.jar:2.2.1]
    at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:37) [scala-library.jar:na]
    at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:133) [scala-library.jar:na]
    at scala.concurrent.Promise$class.complete(Promise.scala:55) [scala-library.jar:na]
    at scala.concurrent.impl.Promise$DefaultPromise.complete(Promise.scala:58) [scala-library.jar:na]
    at scala.concurrent.Future$$anonfun$flatMap$1$$anonfun$apply$3.apply(Future.scala:278) [scala-library.jar:na]
    at scala.concurrent.Future$$anonfun$flatMap$1$$anonfun$apply$3.apply(Future.scala:278) [scala-library.jar:na]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:29) [scala-library.jar:na]
    at scala.concurrent.Future$InternalCallbackExecutor$Batch$$anonfun$run$1.processBatch$1(Future.scala:731) [scala-library.jar:na]
    at scala.concurrent.Future$InternalCallbackExecutor$Batch$$anonfun$run$1.apply$mcV$sp(Future.scala:746) [scala-library.jar:na]
    at scala.concurrent.Future$InternalCallbackExecutor$Batch$$anonfun$run$1.apply(Future.scala:723) [scala-library.jar:na]
    at scala.concurrent.Future$InternalCallbackExecutor$Batch$$anonfun$run$1.apply(Future.scala:723) [scala-library.jar:na]
    at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) [scala-library.jar:na]
    at scala.concurrent.Future$InternalCallbackExecutor$Batch.run(Future.scala:722) [scala-library.jar:na]
    at scala.concurrent.Future$InternalCallbackExecutor$.scala$concurrent$Future$InternalCallbackExecutor$$unbatchedExecute(Future.scala:782) [scala-library.jar:na]
    at scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:773) [scala-library.jar:na]
    at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:37) [scala-library.jar:na]
    at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:133) [scala-library.jar:na]
    at scala.concurrent.Promise$class.complete(Promise.scala:55) [scala-library.jar:na]
    at scala.concurrent.impl.Promise$DefaultPromise.complete(Promise.scala:58) [scala-library.jar:na]
    at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:274) [scala-library.jar:na]
    at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:274) [scala-library.jar:na]
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:29) [scala-library.jar:na]
    at play.api.libs.iteratee.Execution$$anon$2.execute(Execution.scala:70) [play-iteratees_2.10-2.2.1.jar:2.2.1]
    at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:37) [scala-library.jar:na]
    at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:133) [scala-library.jar:na]
    at scala.concurrent.Promise$class.complete(Promise.scala:55) [scala-library.jar:na]
    at scala.concurrent.impl.Promise$DefaultPromise.complete(Promise.scala:58) [scala-library.jar:na]
    at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:23) [scala-library.jar:na]
    at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:42) [akka-actor_2.10-2.2.0.jar:2.2.0]
    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386) [akka-actor_2.10-2.2.0.jar:2.2.0]
    at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [scala-library.jar:na]
    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [scala-library.jar:na]
    at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [scala-library.jar:na]
    at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [scala-library.jar:na]

And finally, the travis build shows the following error:

[error] /home/travis/build/AnormCypher/AnormCypher/src/main/scala/org/anormcypher/http/neo4jhttp.scala:45: type mismatch;
[error]  found   : play.api.libs.iteratee.Enumeratee[Array[Char],Any]
[error]  required: play.api.libs.iteratee.Iteratee[Array[Char],?]
[error]       jsObject(
[error]               ^
[error] /home/travis/build/AnormCypher/AnormCypher/src/main/scala/org/anormcypher/http/neo4jhttp.scala:59: type mismatch;
[error]  found   : play.api.libs.iteratee.Enumerator[Array[Byte]]
[error]  required: play.api.libs.iteratee.Enumerator[org.anormcypher.CypherRow]
[error]       Enumerator.fromStream(stream)(bodyParser)
[error]                                    ^
[error] two errors found
[error] (compile:compile) Compilation failed
[error] Total time: 62 s, completed Dec 30, 2013 4:01:12 PM

Does this sounds like a version issue or did I entirely miss a configuration step?

Hi

Hope someone might be using intellij as their IDE and may spot what I am doing wrong.
Steps followed to create project:
I have
created a new folder,
added build.sbt (see screen shot for contents),
ran sbt console from command line,
started intellij 14, imported project following instructions from here(https://confluence.jetbrains.com/display/IntelliJIDEA/Getting+Started+with+SBT).

When I create a class based on the sample code on (http://www.anormcypher.org/) I get a "cannot resolve method Nes4jREST.apply", also looking at the AnormCypher.scala source, Intellij is displaying a lot of syntax error indicators.

The image shows the project layout (have tried with java 1.7 same issues) and the contents of key files

Thanks in advance.

(master branch)
Seems like a thread stays alive:

val req = Cypher("MATCH (people:Person) RETURN people.name LIMIT 10")
val stream = req()

I can't find a "close()" or "shutdown()" method. Is there one?

Thread dump:

"DestroyJavaVM" #24 prio=5 os_prio=0 tid=0x00007f5f1c011000 nid=0x6680 waiting on condition [0x0000000000000000]
java.lang.Thread.State: RUNNABLE

"ForkJoinPool-1-worker-3" #23 daemon prio=5 os_prio=0 tid=0x00007f5e90001800 nid=0x66b0 waiting on condition [0x00007f5f019a4000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x000000076eba7618> (a scala.concurrent.forkjoin.ForkJoinPool)
at scala.concurrent.forkjoin.ForkJoinPool.scan(ForkJoinPool.java:2075)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

"Hashed wheel timer #1" #19 prio=5 os_prio=0 tid=0x00007f5ebc001000 nid=0x66ae waiting on condition [0x00007f5f01ba6000]
java.lang.Thread.State: TIMED_WAITING (sleeping)
at java.lang.Thread.sleep(Native Method)
at org.jboss.netty.util.HashedWheelTimer$Worker.waitForNextTick(HashedWheelTimer.java:483)
at org.jboss.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:392)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at java.lang.Thread.run(Thread.java:745)

"Hashed wheel timer #2" #21 prio=5 os_prio=0 tid=0x00007f5f1cccb000 nid=0x66ad waiting on condition [0x00007f5f01ea7000]
java.lang.Thread.State: TIMED_WAITING (sleeping)
at java.lang.Thread.sleep(Native Method)
at org.jboss.netty.util.HashedWheelTimer$Worker.waitForNextTick(HashedWheelTimer.java:483)
at org.jboss.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:392)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at java.lang.Thread.run(Thread.java:745)

"New I/O boss #9" #20 prio=5 os_prio=0 tid=0x00007f5f1cccf000 nid=0x66ab runnable [0x00007f5f01fa8000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79)
at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
- locked <0x000000076e642488> (a sun.nio.ch.Util$2)
- locked <0x000000076e642478> (a java.util.Collections$UnmodifiableSet)
- locked <0x000000076e642360> (a sun.nio.ch.EPollSelectorImpl)
at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
at org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

"New I/O worker #8" #18 daemon prio=5 os_prio=0 tid=0x00007f5f1cbc0000 nid=0x66a8 runnable [0x00007f5f020a9000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79)
at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
- locked <0x000000076df754d0> (a sun.nio.ch.Util$2)
- locked <0x000000076df754c0> (a java.util.Collections$UnmodifiableSet)
- locked <0x000000076df753a8> (a sun.nio.ch.EPollSelectorImpl)
at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

"New I/O worker #7" #17 daemon prio=5 os_prio=0 tid=0x00007f5f1cbd1800 nid=0x66a7 runnable [0x00007f5f021aa000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79)
at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
- locked <0x000000076df73b88> (a sun.nio.ch.Util$2)
- locked <0x000000076df73b78> (a java.util.Collections$UnmodifiableSet)
- locked <0x000000076df73a60> (a sun.nio.ch.EPollSelectorImpl)
at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

"New I/O worker #6" #16 daemon prio=5 os_prio=0 tid=0x00007f5f1cbcf800 nid=0x66a6 runnable [0x00007f5f022aa000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79)
at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
- locked <0x000000076df72290> (a sun.nio.ch.Util$2)
- locked <0x000000076df72280> (a java.util.Collections$UnmodifiableSet)
- locked <0x000000076df72168> (a sun.nio.ch.EPollSelectorImpl)
at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

"New I/O worker #5" #15 daemon prio=5 os_prio=0 tid=0x00007f5f1cbce000 nid=0x66a5 runnable [0x00007f5f023ab000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79)
at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
- locked <0x000000076df70998> (a sun.nio.ch.Util$2)
- locked <0x000000076df70988> (a java.util.Collections$UnmodifiableSet)
- locked <0x000000076df70870> (a sun.nio.ch.EPollSelectorImpl)
at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

"New I/O worker #4" #14 daemon prio=5 os_prio=0 tid=0x00007f5f1cbef000 nid=0x66a4 runnable [0x00007f5f024ad000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79)
at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
- locked <0x000000076df6f0a0> (a sun.nio.ch.Util$2)
- locked <0x000000076df6f090> (a java.util.Collections$UnmodifiableSet)
- locked <0x000000076df6ef78> (a sun.nio.ch.EPollSelectorImpl)
at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

"New I/O worker #3" #13 daemon prio=5 os_prio=0 tid=0x00007f5f1cbf2000 nid=0x66a3 runnable [0x00007f5f025ae000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79)
at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
- locked <0x000000076df6d778> (a sun.nio.ch.Util$2)
- locked <0x000000076df6d768> (a java.util.Collections$UnmodifiableSet)
- locked <0x000000076df6d650> (a sun.nio.ch.EPollSelectorImpl)
at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

"New I/O worker #2" #12 daemon prio=5 os_prio=0 tid=0x00007f5f1cbcb000 nid=0x66a1 runnable [0x00007f5f026af000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79)
at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
- locked <0x000000076df6be80> (a sun.nio.ch.Util$2)
- locked <0x000000076df6be70> (a java.util.Collections$UnmodifiableSet)
- locked <0x000000076df6bd58> (a sun.nio.ch.EPollSelectorImpl)
at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

"New I/O worker #1" #11 daemon prio=5 os_prio=0 tid=0x00007f5f1cbca000 nid=0x669e runnable [0x00007f5f027b0000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79)
at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
- locked <0x000000076de8f720> (a sun.nio.ch.Util$2)
- locked <0x000000076de8f698> (a java.util.Collections$UnmodifiableSet)
- locked <0x000000076de8e340> (a sun.nio.ch.EPollSelectorImpl)
at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

"Monitor Ctrl-Break" #9 daemon prio=5 os_prio=0 tid=0x00007f5f1c89b800 nid=0x669b runnable [0x00007f5f03105000]
java.lang.Thread.State: RUNNABLE
at java.net.SocketInputStream.socketRead0(Native Method)
at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
at java.net.SocketInputStream.read(SocketInputStream.java:170)
at java.net.SocketInputStream.read(SocketInputStream.java:141)
at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284)
at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326)
at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178)
- locked <0x00000007702768c8> (a java.io.InputStreamReader)
at java.io.InputStreamReader.read(InputStreamReader.java:184)
at java.io.BufferedReader.fill(BufferedReader.java:161)
at java.io.BufferedReader.readLine(BufferedReader.java:324)
- locked <0x00000007702768c8> (a java.io.InputStreamReader)
at java.io.BufferedReader.readLine(BufferedReader.java:389)
at com.intellij.rt.execution.application.AppMain$1.run(AppMain.java:93)
at java.lang.Thread.run(Thread.java:745)

"Service Thread" #8 daemon prio=9 os_prio=0 tid=0x00007f5f1c0c9800 nid=0x6699 runnable [0x0000000000000000]
java.lang.Thread.State: RUNNABLE

"C1 CompilerThread2" #7 daemon prio=9 os_prio=0 tid=0x00007f5f1c0c4800 nid=0x6698 waiting on condition [0x0000000000000000]
java.lang.Thread.State: RUNNABLE

"C2 CompilerThread1" #6 daemon prio=9 os_prio=0 tid=0x00007f5f1c0c2800 nid=0x6697 waiting on condition [0x0000000000000000]
java.lang.Thread.State: RUNNABLE

"C2 CompilerThread0" #5 daemon prio=9 os_prio=0 tid=0x00007f5f1c0bf800 nid=0x6696 waiting on condition [0x0000000000000000]
java.lang.Thread.State: RUNNABLE

"Signal Dispatcher" #4 daemon prio=9 os_prio=0 tid=0x00007f5f1c0be000 nid=0x6695 waiting on condition [0x0000000000000000]
java.lang.Thread.State: RUNNABLE

"Finalizer" #3 daemon prio=8 os_prio=0 tid=0x00007f5f1c086000 nid=0x668e in Object.wait() [0x00007f5f088df000]
java.lang.Thread.State: WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
- waiting on <0x0000000770e88bb0> (a java.lang.ref.ReferenceQueue$Lock)
at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143)
- locked <0x0000000770e88bb0> (a java.lang.ref.ReferenceQueue$Lock)
at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164)
at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209)

"Reference Handler" #2 daemon prio=10 os_prio=0 tid=0x00007f5f1c084000 nid=0x668c in Object.wait() [0x00007f5f089e0000]
java.lang.Thread.State: WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
- waiting on <0x0000000770e905e0> (a java.lang.ref.Reference$Lock)
at java.lang.Object.wait(Object.java:502)
at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:157)
- locked <0x0000000770e905e0> (a java.lang.ref.Reference$Lock)

Hello,

I am really interested in using Async support introduced in 37342c9 to use AnormCypher as a non blocking driver.
The 0.6.0 version does not include async support.

Any chance you could upload it to your maven repository ?

After following the instructions in the README.md file:

BELL-MBP-SWHITE:/Users/swhite/projects/AnormCypher> sbt test
[info] Loading project definition from /Users/swhite/projects/AnormCypher/project
[info] Set current project to AnormCypher (in build file:/Users/swhite/projects/AnormCypher/)
[info] Compiling 1 Scala source to /Users/swhite/projects/AnormCypher/target/scala-2.11/test-classes...
[info] AnormCypherAsyncSpec:
[info] Cypher
[info] Exception encountered when attempting to run a suite with class name: org.anormcypher.async.AnormCypherAsyncSpec *** ABORTED ***
[info] java.lang.RuntimeException: Expected '[' but got '"' / chr(34)
[info] at scala.sys.package$.error(package.scala:27)
[info] at play.api.libs.iteratee.Iteratee$$anonfun$run$1.apply(Iteratee.scala:396)
[info] at play.api.libs.iteratee.Iteratee$$anonfun$run$1.apply(Iteratee.scala:389)
[info] at play.api.libs.iteratee.StepIteratee$$anonfun$fold$2.apply(Iteratee.scala:706)
[info] at play.api.libs.iteratee.StepIteratee$$anonfun$fold$2.apply(Iteratee.scala:706)
[info] at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
[info] at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
[info] at play.api.libs.iteratee.Execution$trampoline$.executeScheduled(Execution.scala:120)
[info] at play.api.libs.iteratee.Execution$trampoline$.execute(Execution.scala:71)
[info] at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:40)

...

[info] ...
[info] Run completed in 3 seconds, 465 milliseconds.
[info] Total number of tests run: 13
[info] Suites: completed 2, aborted 7
[info] Tests: succeeded 13, failed 0, canceled 0, ignored 0, pending 0
[info] *** 7 SUITES ABORTED ***
[error] Error during tests:
[error] org.anormcypher.async.Neo4jRESTAsyncSpec
[error] org.anormcypher.async.AnormCypherAsyncSpec
[error] org.anormcypher.CypherParserSpec
[error] org.anormcypher.AnormCypherSpec
[error] org.anormcypher.Neo4jTransactionSpec
[error] org.anormcypher.Neo4jRESTSpec
[error] org.anormcypher.async.CypherParserAsyncSpec
error sbt.TestsFailedException: Tests unsuccessful
[error] Total time: 11 s, completed May 27, 2016 8:08:26 AM
BELL-MBP-SWHITE:/Users/swhite/projects/AnormCypher>

New to this project. When I try this code:
`

val query = Cypher(
  """
    |MATCH (tom:Person {name: "Tom Hanks"})-[:ACTED_IN]->(tomHanksMovies) RETURN tom,tomHanksMovies
  """.stripMargin
)

val rs  = query.apply.map(row=>
  row[String]("tom") -> row[String]("tomHanksMovies")
)
println(rs)

`

I got the following exception:

Exception in thread "main" java.lang.RuntimeException: Expected '[' but got '"' / chr(34)
at scala.sys.package$.error(package.scala:27)
at play.api.libs.iteratee.Iteratee$$anonfun$run$1.apply(Iteratee.scala:396)
at play.api.libs.iteratee.Iteratee$$anonfun$run$1.apply(Iteratee.scala:389)
at play.api.libs.iteratee.StepIteratee$$anonfun$fold$2.apply(Iteratee.scala:706)
at play.api.libs.iteratee.StepIteratee$$anonfun$fold$2.apply(Iteratee.scala:706)
at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
at play.api.libs.iteratee.Execution$trampoline$.executeScheduled(Execution.scala:120)
at play.api.libs.iteratee.Execution$trampoline$.execute(Execution.scala:71)
at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:40)
at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:248)
at scala.concurrent.Promise$class.complete(Promise.scala:55)
at scala.concurrent.impl.Promise$DefaultPromise.complete(Promise.scala:153)
at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:23)
at scala.concurrent.impl.ExecutionContextImpl$AdaptedForkJoinTask.exec(ExecutionContextImpl.scala:121)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

Any help on getting started with it will be greatly appreciated. Thanks!

http://docs.neo4j.org/chunked/preview/rest-api-transactional.html

Hi, I think there may be a compatibility issue with play 2.4. Using AnormCypher 6.0 I got this stack trace:

java.lang.NoSuchMethodError: com.ning.http.client.AsyncHttpClientConfig$Builder.setRequestTimeoutInMs(I)Lcom/ning/http/client/AsyncHttpClientConfig$Builder;
    at dispatch.InternalDefaults$BasicDefaults$.builder(defaults.scala:45)
    at dispatch.InternalDefaults$.client(defaults.scala:32)
    at dispatch.Http$.<init>(execution.scala:30)
    at dispatch.Http$.<clinit>(execution.scala)
    at org.anormcypher.Neo4jREST.sendQuery(Neo4jREST.scala:34)
    at org.anormcypher.CypherStatement.apply(AnormCypher.scala:361)
    at models.daos.UserDAOImpl.find(UserDAOImpl.scala:43)
    at models.services.UserServiceImpl.save(UserServiceImpl.scala:46)
    at controllers.SocialAuthController$$anonfun$authenticate$1$$anonfun$apply$2$$anonfun$apply$3.apply(SocialAuthController.scala:48)
    at controllers.SocialAuthController$$anonfun$authenticate$1$$anonfun$apply$2$$anonfun$apply$3.apply(SocialAuthController.scala:47)
    at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:251)
    at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:249)
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)
    at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
    at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91)
    at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
    at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
    at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
    at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90)
    at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)
    at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

Not defined...

scala> val populations:List[String~Int] = {
     |   Cypher("start n=node(*) where n.type! = 'Country' return n.*").as( str("n.name") ~ int("n.population") * )
     | }
<console>:11: error: value as is not a member of org.anormcypher.CypherStatement
         Cypher("start n=node(*) where n.type! = 'Country' return n.*").as( str("n.name") ~ int("n.population") * )

Cypher("start n=node(*) return n.name as name, n")().map {
     case CypherRow(name: String, n: org.anormcypher.NeoNode) => name -> n
}

fails with an exception:

scala.MatchError: Row('ColumnName(name,None)':AnormCypher as String, 'ColumnName(n,None)':{outgoing_relationships=http://localhost:7474/db/data/node/1144/relationships/out, data={name=AnormCypher}, traverse=http://localhost:7474/db/data/node/1144/traverse/{returnType}, all_typed_relationships=http://localhost:7474/db/data/node/1144/relationships/all/{-list|&|types}, property=http://localhost:7474/db/data/node/1144/properties/{key}, self=http://localhost:7474/db/data/node/1144, properties=http://localhost:7474/db/data/node/1144/properties, outgoing_typed_relationships=http://localhost:7474/db/data/node/1144/relationships/out/{-list|&|types}, incoming_relationships=http://localhost:7474/db/data/node/1144/relationships/in, extensions={}, create_relationship=http://localhost:7474/db/data/node/1144/relationships, paged_traverse=http://localhost:7474/db/data/node/1144/paged/traverse/{returnType}{?pageSize,leaseTime}, all_relationships=http://localhost:7474/db/data/node/1144/relationships/all, incoming_typed_relationships=http://localhost:7474/db/data/node/1144/relationships/in/{-list|&|types}} as String) (of class org.anormcypher.CypherResultRow)
    at $anonfun$1.apply(<console>:11)
    at $anonfun$1.apply(<console>:11)
    at scala.collection.immutable.Stream.map(Stream.scala:175)
    at .<init>(<console>:11)
    at .<clinit>(<console>)
    at .<init>(<console>:11)
    at .<clinit>(<console>)
    at $print(<console>)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:601)
    at scala.tools.nsc.interpreter.IMain$ReadEvalPrint.call(IMain.scala:704)
    at scala.tools.nsc.interpreter.IMain$Request.loadAndRun(IMain.scala:914)
    at scala.tools.nsc.interpreter.IMain.loadAndRunReq$1(IMain.scala:546)
    at scala.tools.nsc.interpreter.IMain.interpret(IMain.scala:577)
    at scala.tools.nsc.interpreter.IMain.interpret(IMain.scala:543)
    at scala.tools.nsc.interpreter.ILoop.reallyInterpret$1(ILoop.scala:694)
    at scala.tools.nsc.interpreter.ILoop.interpretStartingWith(ILoop.scala:745)
    at scala.tools.nsc.interpreter.ILoop.reallyInterpret$1(ILoop.scala:712)
    at scala.tools.nsc.interpreter.ILoop.interpretStartingWith(ILoop.scala:745)
    at scala.tools.nsc.interpreter.ILoop.reallyInterpret$1(ILoop.scala:712)
    at scala.tools.nsc.interpreter.ILoop.interpretStartingWith(ILoop.scala:745)
    at scala.tools.nsc.interpreter.ILoop.command(ILoop.scala:651)
    at scala.tools.nsc.interpreter.ILoop.processLine$1(ILoop.scala:542)
    at scala.tools.nsc.interpreter.ILoop.loop(ILoop.scala:550)
    at scala.tools.nsc.interpreter.ILoop.process(ILoop.scala:822)
    at scala.tools.nsc.interpreter.ILoop.main(ILoop.scala:851)
    at xsbt.ConsoleInterface.run(ConsoleInterface.scala:57)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:601)
    at sbt.compiler.AnalyzingCompiler.call(AnalyzingCompiler.scala:57)
    at sbt.compiler.AnalyzingCompiler.console(AnalyzingCompiler.scala:48)
    at sbt.Console.console0$1(Console.scala:23)
    at sbt.Console$$anonfun$apply$2$$anonfun$apply$1.apply$mcV$sp(Console.scala:24)
    at sbt.TrapExit$.executeMain$1(TrapExit.scala:33)
    at sbt.TrapExit$$anon$1.run(TrapExit.scala:42)