scalikejdbc+play2.5

ConnectionPool.scala

package models

import javax.inject.{Inject, Provider, Singleton}

import play.api.inject.{ApplicationLifecycle, Binding, Module}
import play.api.{Configuration, Environment, Logger}
import scalikejdbc.config.TypesafeConfigReader
import scalikejdbc.{Commons2ConnectionPoolFactory, ConnectionPool}

import scala.concurrent.{ExecutionContext, Future}


class ConnectionPoolProvider extends Provider[ConnectionPool] {
  private val logger = Logger(classOf[ConnectionPoolProvider])
  override def get(): ConnectionPool = {
    val jdbc = TypesafeConfigReader.readJDBCSettings()
    logger.info("Preparing connection pool...")
    Commons2ConnectionPoolFactory(jdbc.url, jdbc.user, jdbc.password)
  }
}

@Singleton
class ConnectionPoolShutdown @Inject() (lifecycle: ApplicationLifecycle,
    connectionPool: ConnectionPool, executionContext: ExecutionContext) {
  private val logger = Logger(classOf[ConnectionPoolShutdown])
  lifecycle.addStopHook(() => Future {
    logger.info("Shutdown connection pool")
    connectionPool.close()
  }(executionContext))
}

class ConnectionPoolModule extends Module {
  override def bindings(environment: Environment, configuration: Configuration): Seq[Binding[_]] = Seq(
    bind[ConnectionPool].toProvider[ConnectionPoolProvider].eagerly(),
    bind[ConnectionPoolShutdown].toSelf.eagerly()
  )
}