neotype - a type specimen that is selected subsequent to the description of a species to replace a preexisting type that has been lost or destroyed.
For early adopters:
| Supports Scala 2.11 and 2.12 | |
|---|---|
"com.dimafeng" %% "neotypes" % version |
core functionality. Supports scala.concurrent.Future. |
"com.dimafeng" %% "neotypes-cats-effect" % version |
cats.effect.Async[F] implementation. |
"com.dimafeng" %% "neotypes-monix" % version |
monix.eval.Task implementation. |
"com.dimafeng" %% "neotypes-zio" % version |
zio.Task implementation. |
"com.dimafeng" %% "neotypes-akka-stream" % version |
result streaming for Akka Streams. |
"com.dimafeng" %% "neotypes-fs2-stream" % version |
result streaming for FS2. |
"com.dimafeng" %% "neotypes-monix-stream" % version |
result streaming for Monix Observables. |
"com.dimafeng" %% "neotypes-zio-stream" % version |
result streaming for ZIO ZStreams. |
"com.dimafeng" %% "neotypes-refined" % version |
support to insert and retrieve refined values. |
"com.dimafeng" %% "neotypes-cats-data" % version |
support to insert and retrieve cats.data values. |
Scala lightweight, type-safe, asynchronous driver (not opinionated on side-effect implementation) for neo4j.
- Scala - the driver provides you with support for all standard Scala types without the need to convert Scala <-> Java types back and forth and you can easily add your types.
- Lightweight - the driver depends on
shapelessandneo4j Java driver. - Type-safe - the driver leverages typeclasses to derive all needed conversions at the compile time.
- Asynchronous - the driver sits on top of asynchronous Java driver.
- Not opinionated on side-effect implementation - you can use it with any implementation of side-effects of your chose (scala.Future, cats-effect
IO, Monix Task, etc) by implementing a simple typeclass.
scala.Futureis implemented and comes out of the box.
The project aims to provide seamless integration with most popular scala infrastructures such as lightbend (Akka, Akka-http, Lagom, etc), typelevel (cats, http4s, etc), twitter (finch, etc)...
import org.neo4j.driver.v1._
import neotypes.Async._
import neotypes.implicits._
import shapeless._
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.Future
scala> val driver = GraphDatabase.driver("bolt://localhost:7687", AuthTokens.basic("neo4j", "****"))
Nov 26, 2018 10:42:42 AM org.neo4j.driver.internal.logging.JULogger info
INFO: Direct driver instance 542400040 created for server address localhost:7687
driver: org.neo4j.driver.v1.Driver = org.neo4j.driver.internal.InternalDriver@20545e28
scala> val session = driver.session().asScala[Future]
session: neotypes.Session[scala.concurrent.Future] = neotypes.Session@6f30d4df
import scala.concurrent.Await
import scala.concurrent.duration._
scala> val people = "match (p:Person) return p.name, p.born limit 10".query[(String, Int)].list(session)
people: scala.concurrent.Future[Seq[(String, Int)]] = Future(<not completed>)
scala> Await.result(people, 1 second)
res0: Seq[(String, Int)] = ArrayBuffer((Charlize Theron,1975), (Keanu Reeves,1964), (Carrie-Anne Moss,1967), (Laurence Fishburne,1961), (Hugo Weaving,1960), (Lilly Wachowski,1967), (Lana Wachowski,1965), (Joel Silver,1952), (Emil Eifrem,1978), (Charlize Theron,1975))
scala> case class Person(id: Long, born: Int, name: Option[String], notExists: Option[Int])
defined class Person
scala> val peopleCC = "match (p:Person) return p limit 10".query[Person].list(session)
peopleCC: scala.concurrent.Future[Seq[Person]] = Future(<not completed>)
scala> Await.result(peopleCC, 1 second)
res1: Seq[Person] = ArrayBuffer(Person(0,1975,Some(Charlize Theron),None), Person(4,1964,Some(Keanu Reeves),None), Person(5,1967,Some(Carrie-Anne Moss),None), Person(6,1961,Some(Laurence Fishburne),None), Person(7,1960,Some(Hugo Weaving),None), Person(8,1967,Some(Lilly Wachowski),None), Person(9,1965,Some(Lana Wachowski),None), Person(10,1952,Some(Joel Silver),None), Person(11,1978,Some(Emil Eifrem),None), Person(15,1975,Some(Charlize Theron),None))