playing with arangodb using java driver and genson serdes / published by https://github.com/dacr/code-examples-manager #d81dc0ba-ca3e-44a7-a1a9-0c95553ef915/cb55026ec8e9c78a03dfb8cb47a714a951446939

arangodb-javadriver-basics-1.sc

// summary : playing with arangodb using java driver and genson serdes
// keywords : arangodb, graphdb, javadriver, genson, @testable,
// publish : gist, corporate
// authors : David Crosson
// license : Apache License Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt)
// id : d81dc0ba-ca3e-44a7-a1a9-0c95553ef915
// created-on : 2021-03-05T09:25:00Z
// managed-by : https://github.com/dacr/code-examples-manager
// execution : scala ammonite script (http://ammonite.io/) - run as follow 'amm scriptname.sc'

// ---------------------
//> using scala "3.4.2"
//> using dep "com.arangodb:arangodb-java-driver:6.9.1"
//> using dep "com.owlike:genson:1.6"
// ---------------------

import java.text.SimpleDateFormat

import com.arangodb._
import com.arangodb.entity._
import com.arangodb.model.AqlQueryOptions
import com.arangodb.util.MapBuilder

import com.owlike.genson._

val dateFormatPattern = "yyyy-MM-dd'T'HH:mm:ss'Z'"
val builder =
  new GensonBuilder()
    .useDateFormat(new SimpleDateFormat(dateFormatPattern))
    .setSkipNull(true)
    .useIndentation(true)
    .useConstructorWithArguments(true) // Take care, with true you may encounter IllegalArgumentException within asm.ClassReader
    .useRuntimeType(true)
    .useDateAsTimestamp(true)
val genson = builder.create()


val arango = {
  new ArangoDB
  .Builder()
    .host("127.0.0.1", 8529)
    .user("root")
    .password("root")
    .build()
}

try {
  arango.createDatabase("example")
} catch {
  case _ =>
}

val db = arango.db("example")

try {
  db.createCollection("sample")
} catch {
  case _ =>
}

def cursorBaseDocument: ArangoCursor[BaseDocument] =
  db.query(
    "FOR i IN @@collection RETURN i",
    new MapBuilder().put("@collection", "sample").get(),
    new AqlQueryOptions(),
    classOf[BaseDocument]
  )


cursorBaseDocument.forEach { basedoc =>
  println(s"${basedoc.getId} ${basedoc.getRevision} ${basedoc.getProperties}")
  val doc = basedoc.getProperties
  val jsonString = genson.serialize(doc)
  println(jsonString)
}

arango.shutdown()