Printing query results from Mongodb in Scala using mongo-scala-driver

Question

I am trying to print results from a MongoDB query in Scala

val mongoClient: MongoClient = MongoClient()
val database: MongoDatabase = mongoClient.getDatabase("tableScala")
val collection: MongoCollection[Document] = database.getCollection("tableScala")

collection.find().printResults()

The error thrown was : Cannot resolve symbol printResults. Answers to some other questions suggested to use mongo-scala-driver version 1.2, as printResults() is not implemented for version 1.1 and below

SBT file:

name := "scalaMongoDriver"

version := "1.0"

scalaVersion := "2.11.8"

libraryDependencies += "org.mongodb.scala" %% "mongo-scala-driver" % "1.2.0-beta1"

Tried to print manually using :

collection.find().subscribe(
      (user: Document) => println(user.toJson()),                         // onNext
      (error: Throwable) => println(s"Query failed: ${error.getMessage}"), // onError
      () => println("Done")                                               // onComplete
    )

resulted in the following info:

INFO: No server chosen by ReadPreferenceServerSelector{readPreference=primary} from cluster description ClusterDescription{type=UNKNOWN, connectionMode=SINGLE, serverDescriptions=[ServerDescription{address=localhost:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out

Is there any way to view the retrieved results in console?

Luke Kroon · Accepted Answer · 2017-02-07 13:44:48Z

9

You have to include Helpers.scala file to use the printResults() function. It is located in their github repository Helpers.scala.

These helper functions waits for the observable to finish before it prints the values.

answered Feb 7, 2017 at 13:44

Luke Kroon

1,12312 silver badges19 bronze badges

Sign up to request clarification or add additional context in comments.

2 Comments

Azoulay Jason Over a year ago

How to include it ?

Luke Kroon Over a year ago

@AzoulayJason just copy and paste the file into your project and use it like any other class.

starball · Accepted Answer · 2023-05-10 21:19:06Z

2

The way that worked for me was adding a Thread.sleep in the end of the code, so the program end after the asynchronous call has the chance to print the elements.

This happens because of the reactive nature of Mongo's Observables, meaning that you have to do most of your operations making the use of Futures.

Just the Thread.sleep should work.

edited May 10, 2023 at 21:19

starball♦

59.8k53 gold badges318 silver badges1k bronze badges

answered Jan 12, 2017 at 1:13

carvalh0ak

212 bronze badges

Comments

user3237183 · Accepted Answer · 2019-10-31 08:13:55Z

MongoDB driver is asynchronous, to make it synchronouse you may apply some of the monads operators

andThen: Allows the chaining of Observables. collect : Collects all the results into a sequence.
flatMap : Create a new Observable by applying a function to each result of the Observable.
foldLeft : Creates a new Observable that contains the single result of the applied accumulator function. foreach : Applies a function applied to each emitted result.
head : Returns the head of the Observable in a Future.
map : Creates a new Observable by applying a function to each emitted result of the Observable.

Full list of observables:

For example:

val doc = Await.result(myCollection
          .find(and(regex("date", s"^${date}T.*"), equal("field", fieldValue)))
          .sort(descending("timestamp"))
          .first().head(), Duration(10, SECONDS))

xing · Accepted Answer · 2023-05-10 20:58:15Z

0

http://mongodb.github.io/mongo-java-driver/4.9/driver-scala/getting-started/quick-start-primer/

It's defined in the Helpers for the quick tour. Of course you can create/copy them in your project.

answered May 10, 2023 at 20:58

xing

5049 silver badges18 bronze badges

2 Comments

starball Over a year ago

I'm a bit confused. How does this answer the question? I have the feeling that this needs expansion.

xing Over a year ago

The methods involved are not "normal" ingredients of the mongo clients library. They are defined in some helpers as part of the tutorials. That is described in the link above.

Collectives™ on Stack Overflow

Printing query results from Mongodb in Scala using mongo-scala-driver

4 Answers 4

2 Comments

Comments

Comments

2 Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

4 Answers 4

2 Comments

Comments

Comments

2 Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related