JarCastingMongo Kit
Setup dependency
Scala 2.11.7
Simple API abstraction to quick integration of mongodb CRUD operations.
Usage
- example-playframework [2.5.9]
import com.github.mideo.mongo.reactive.{Crud => ReactiveCrud}]
import com.github.mideo.mongo.inmemory.{Crud => InMemoryCrud}
import com.google.inject.Inject
import play.modules.reactivemongo.ReactiveMongoApi
import reactivemongo.api.collections.bson.BSONCollection
import reactivemongo.bson.{BSONDocumentReader, BSONDocumentWriter, Macros}
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.Future
object Card { implicit val formatter: OFormat[Card] = Json.format[Card] }
case class Card(colour: String)
//Create a document in mongo
class ReactiveCardRepo @Inject()(reactiveMongoApi: ReactiveMongoApi)
extend ReactiveCrud[Card] {
override val reactiveMongo: ReactiveMongoApi = reactiveMongoApi
override val repoName: String = "card"
override val collection: Future[BSONCollection] = reactiveMongo.database map {_.collection[BSONCollection](repoName) }
override implicit def Writer: BSONDocumentWriter[Card] = Macros.writer[Card]
override implicit def Reader: BSONDocumentReader[Card] = Macros.reader[Card]
}
val reactiveCardRepo: ReactiveCardRepo = new ReactiveCardRepo(reactiveMongo)
reactiveCardRepo.create(Card("green"))
//Test with in-memory db
class InMemoryCardRepo extends InMemoryCrud[Card]
val inMemoryCardRepo: InMemoryCardRepo = new InMemoryCardRepo()
inMemoryCardRepo.create(Car("Red"))
- example-scalatra
import com.example.app.AppConfig
import com.github.mideo.mongo.reactive.{Crud, ReactiveMongoApiWrapper}
import com.typesafe.config.Config
import play.api.libs.json.{Json, OFormat}
import play.modules.reactivemongo.ReactiveMongoApi
import reactivemongo.api.collections.bson.BSONCollection
import reactivemongo.bson.{BSONDocumentReader, BSONDocumentWriter, Macros}
import scala.concurrent._
object Card {
implicit val formatter: OFormat[Card] = Json.format[Card]
}
case class Card(colour: String)
trait CardRepo {
def read:Future[List[Card]]
}
class ReactiveCardRepo extends CardRepo with Crud[Card]{
private val config: Config = ConfigFactory.load()
private val reactiveMongoApiWrapper = new ReactiveMongoApiWrapper(config, config.getString("mongo.uri"), config.getString("mongo.db"))
override implicit def Writer: BSONDocumentWriter[Card] = Macros.writer[Card]
override implicit def Reader: BSONDocumentReader[Card] = Macros.reader[Card]
override val repoName: String = "card"
override val reactiveMongo: ReactiveMongoApi = reactiveMongoApiWrapper.mongoApi
override val collection: Future[BSONCollection] = reactiveMongoApiWrapper.mongoCollection(repoName)
}