RELEASE 1.0.0

Author: sfxcode

build.sbt

@@ -3,9 +3,9 @@ name := "simple-mongo"
 
 organization := "com.sfxcode.nosql"
 
-version := "0.9.3-SNAPSHOT"
+version := "1.0.0"
 
-crossScalaVersions := Seq( "2.12.2","2.11.10")
+crossScalaVersions := Seq( "2.12.2","2.11.11")
 
 scalaVersion := "2.12.2"
 
@@ -24,7 +24,7 @@ parallelExecution in Test := false
 
 // Test
 
-libraryDependencies += "org.specs2" %% "specs2-core" % "3.8.9" % "test"
+libraryDependencies += "org.specs2" %% "specs2-core" % "3.9.1" % "test"
 
 libraryDependencies += "ch.qos.logback" % "logback-classic" % "1.2.3" % "test"
 
@@ -37,7 +37,7 @@ libraryDependencies += "org.json4s" %% "json4s-native" % "3.5.2" % "test"
 libraryDependencies += "org.mongodb.scala" %% "mongo-scala-driver" % "2.1.0"
 
 
-libraryDependencies += "com.typesafe.scala-logging" %% "scala-logging" % "3.5.0"
+libraryDependencies += "com.typesafe.scala-logging" %% "scala-logging" % "3.7.1"
 
 
 licenses += ("Apache-2.0", url("https://www.apache.org/licenses/LICENSE-2.0.html"))

src/main/scala/com/sfxcode/nosql/mongo/MongoDAO.scala

@@ -1,7 +1,7 @@
 package com.sfxcode.nosql.mongo
 
 import com.sfxcode.nosql.mongo.operation.Search
-import org.mongodb.scala.{ MongoCollection, MongoDatabase }
+import org.mongodb.scala.{ Document, MongoCollection, MongoDatabase }
 
 import scala.reflect.ClassTag
 
@@ -14,4 +14,7 @@ abstract class MongoDAO[A](database: MongoDatabase, collectionName: String)(impl
 
   protected def coll: MongoCollection[A] = collection
 
+  // internal object for raw document access
+  object Raw extends MongoDAO[Document](database, collectionName)
+
 }

src/main/scala/com/sfxcode/nosql/mongo/operation/Search.scala

@@ -11,7 +11,7 @@ abstract class Search[A]()(implicit ct: ClassTag[A]) extends Crud[A] {
 
   protected def coll: MongoCollection[A]
 
-  def find(filter: Bson = Document()): FindObservable[A] = coll.find(filter)
+  def find(filter: Bson = Document(), sort: Bson = Document(), projection: Bson = Document()): FindObservable[A] = coll.find(filter).sort(sort).projection(projection)
 
   def findById(oid: Any): FindObservable[A] = {
     oid match {

src/test/scala/com/sfxcode/nosql/mongo/tour/Database.scala

@@ -22,6 +22,8 @@ object Database extends ObservableImplicits {
 
   object BookDAO extends MongoDAO[Book](database, "books")
 
+  class BookDocumentDAO extends MongoDAO[Document](database, "books")
+
   object LineDAO extends MongoDAO[Line](database, "lines")
 
   object PersonDAO extends MongoDAO[Person](database, "person")

src/test/scala/com/sfxcode/nosql/mongo/tour/TestTour.scala

@@ -38,5 +38,9 @@ object TestTour extends App {
 
   println(book.equals(scalaBook))
 
+  val bookJson = new BookDocumentDAO().find(projection = Map("title" -> 1)).headResult().toJson()
+
+  println(bookJson)
+
 }