Данные не вставлены во время запуска приложения Play (с использованием Play 2.4 и reactivemongo 11.11)

Question

Мы используем Play Framework 2.4 с mongodb 2.6. Но так как мы мигрировали в реале от 0.11.10 до 0.11.11-play24, что-то не так.

Мы загружаем некоторые данные в mongodb во время начала приложения. Все выглядит нормально, приложение запущено, ошибок не было в журналах, но В базу данных не было вставлено данных.

Вот код для запуска приложения в Global.scala:

override def onStart(app: Application) { 
    Logger.info("creating object in database...") 
    someProducts.foreach{ product => 
    ProductDB.insertOrUpdate(product._id, product) 
    } 
} 

Чтобы придать reactivemongo, мы решили не использовать @Inject() на данный момент, поэтому мы используем current.injector вместо (в соответствии с Reactivemongo documentation). NB: мы полностью удалили каждый след ReactiveMongoPlugin, поскольку он устарел в play-reactivemongo 0.11.11-play24.

Здесь мы определяем нашу модель и мы вводим ReactiveMongo:

abstract class MongoDB[T: Format, ID: Format] { 
    def collection: JSONCollection 

    def insertOrUpdate(_id: ID, o: T) = collection.update(Json.obj("_id" -> _id), o, upsert = true) 
} 

object ProductDB extends MongoDB[Product, String] { 
    override def collection = current.injector.instanceOf[ReactiveMongoApi].db.collection("products") 
} 

В application.conf, ReactiveMongoModule включен с этой линии: play.modules.enabled += "play.modules.reactivemongo.ReactiveMongoModule"

Журналы приложения:

[debug] p.a.l.c.ActorSystemProvider - Starting application default Akka system: application 
[info] application - starting application, build at: 2016-05-17T13:00:18+0200 
[info] application - creating object in database... 
[info] application - ReactiveMongoApi starting... 
[info] application - ReactiveMongoApi successfully configured with DB 'application'! Servers: 
[localhost:27017] 
[info] play.api.Play - Application started (Dev) 

И вот бревна из mongodb:

2016-05-17T13:00:27.774+0200 [initandlisten] connection accepted from 127.0.0.1:65478 #3 (1 connection now open) 
2016-05-17T13:00:27.833+0200 [conn3] run command admin.$cmd { ismaster: 1 } 
2016-05-17T13:00:27.833+0200 [conn3] command admin.$cmd command: isMaster { ismaster: 1 } ntoreturn:1 keyUpdates:0 numYields:0 reslen:178 0ms 
2016-05-17T13:00:27.880+0200 [initandlisten] connection accepted from 127.0.0.1:65479 #4 (2 connections now open) 
2016-05-17T13:00:27.880+0200 [initandlisten] connection accepted from 127.0.0.1:65480 #5 (3 connections now open) 
2016-05-17T13:00:27.880+0200 [initandlisten] connection accepted from 127.0.0.1:65481 #6 (4 connections now open) 
2016-05-17T13:00:27.880+0200 [initandlisten] connection accepted from 127.0.0.1:65482 #7 (5 connections now open) 
2016-05-17T13:00:27.880+0200 [initandlisten] connection accepted from 127.0.0.1:65483 #8 (6 connections now open) 
2016-05-17T13:00:27.881+0200 [initandlisten] connection accepted from 127.0.0.1:65484 #9 (7 connections now open) 
2016-05-17T13:00:27.881+0200 [initandlisten] connection accepted from 127.0.0.1:65485 #10 (8 connections now open) 
2016-05-17T13:00:27.881+0200 [initandlisten] connection accepted from 127.0.0.1:65486 #11 (9 connections now open) 
2016-05-17T13:00:27.882+0200 [initandlisten] connection accepted from 127.0.0.1:65487 #12 (10 connections now open) 
2016-05-17T13:00:27.888+0200 [conn3] run command admin.$cmd { ismaster: 1 } 
2016-05-17T13:00:27.888+0200 [conn3] command admin.$cmd command: isMaster { ismaster: 1 } ntoreturn:1 keyUpdates:0 numYields:0 reslen:178 0ms 
2016-05-17T13:00:27.888+0200 [conn3] run command admin.$cmd { ismaster: 1 } 
2016-05-17T13:00:27.889+0200 [conn3] command admin.$cmd command: isMaster { ismaster: 1 } ntoreturn:1 keyUpdates:0 numYields:0 reslen:178 0ms 
2016-05-17T13:00:27.889+0200 [conn3] run command admin.$cmd { ismaster: 1 } 
2016-05-17T13:00:27.889+0200 [conn3] command admin.$cmd command: isMaster { ismaster: 1 } ntoreturn:1 keyUpdates:0 numYields:0 reslen:178 0ms 
2016-05-17T13:00:27.889+0200 [conn3] run command admin.$cmd { ismaster: 1 } 
2016-05-17T13:00:27.889+0200 [conn3] command admin.$cmd command: isMaster { ismaster: 1 } ntoreturn:1 keyUpdates:0 numYields:0 reslen:178 0ms 
2016-05-17T13:00:27.889+0200 [conn3] run command admin.$cmd { ismaster: 1 } 
2016-05-17T13:00:27.889+0200 [conn3] command admin.$cmd command: isMaster { ismaster: 1 } ntoreturn:1 keyUpdates:0 numYields:0 reslen:178 0ms 
2016-05-17T13:00:27.890+0200 [conn3] run command admin.$cmd { ismaster: 1 } 
2016-05-17T13:00:27.890+0200 [conn3] command admin.$cmd command: isMaster { ismaster: 1 } ntoreturn:1 keyUpdates:0 numYields:0 reslen:178 0ms 
2016-05-17T13:00:27.890+0200 [conn3] run command admin.$cmd { ismaster: 1 } 
2016-05-17T13:00:27.890+0200 [conn3] command admin.$cmd command: isMaster { ismaster: 1 } ntoreturn:1 keyUpdates:0 numYields:0 reslen:178 0ms 
2016-05-17T13:00:27.891+0200 [conn3] run command admin.$cmd { ismaster: 1 } 
2016-05-17T13:00:27.891+0200 [conn3] command admin.$cmd command: isMaster { ismaster: 1 } ntoreturn:1 keyUpdates:0 numYields:0 reslen:178 0ms 
2016-05-17T13:00:27.891+0200 [conn3] run command admin.$cmd { ismaster: 1 } 
2016-05-17T13:00:27.891+0200 [conn3] command admin.$cmd command: isMaster { ismaster: 1 } ntoreturn:1 keyUpdates:0 numYields:0 reslen:178 0ms 

Answer 1

Вам необходимо подключить после загрузки базы данных:

def db: DefaultDB = Await.result(reactiveMongoApi.database, Duration.Inf) 

Дело в том, что теперь, reactiveMongoApi.db является синхронным, и, если используется непосредственно, соединение еще не сделано (жизненный цикл).

Поэтому я предлагаю, что либо дождаться базы данных (например, код выше) или ваш просто зарегистрировать обратные вызовы в буфер, который будет выполняться, когда база данных имеет нима инициализируется

reactiveMongoApi.database.onSuccess { 
     case _ => callbacks.foreach(_()) 
    }