mongo_test.scala

object MongoApp extends App {


  case class Data(_id: ObjectId, data: String)

  object Data {
    def apply(data: String): Data = new Data(new ObjectId(), data)
  }

  import org.bson.codecs.configuration.CodecRegistries.{fromProviders, fromRegistries}
  import org.mongodb.scala.bson.codecs.DEFAULT_CODEC_REGISTRY
  import org.mongodb.scala.bson.codecs.Macros._

  val codecRegistry = fromRegistries(fromProviders(classOf[Data]), DEFAULT_CODEC_REGISTRY)


  val mongoClient: MongoClient = MongoClient()
  val database: MongoDatabase = mongoClient.getDatabase("test_007").withCodecRegistry(codecRegistry)
  val collection: MongoCollection[Data] = database.getCollection("data")


  val data1 = Data("Data1")
  val data2 = Data("Data2")

  Await.result(collection.insertOne(data1).head(), 5 seconds)
  Await.result(collection.insertOne(data2).head(), 5 seconds)

  val results = Await.result(collection.find().toFuture(), 10 seconds)

  println(results)
}