Slick: create a database

Question

Is there a way to get a spot to create a database if it does not already exist?

Database.forURL("jdbc:mysql://127.0.0.1/database", driver = "com.mysql.jdbc.Driver", user = "root") withSession { // create tables, insert data } 

"database" does not exist, so I want it to create it for me. Any ideas? Thanks.

Answer 1

You can connect to the database engine using only "jdbc:mysql://localhost/" as the JDBC URL, and then issue a clean SQL create database query:

 import scala.slick.driver.MySQLDriver.simple._ import scala.slick.jdbc.{StaticQuery => Q} object Main extends App { Database.forURL("jdbc:mysql://localhost/", driver = "com.mysql.jdbc.Driver") withSession { implicit session => Q.updateNA("CREATE DATABASE `dataBaseName`").execute . . . } } 

Answer 2

The answer above applies to Slick 2.x, where withSession deprecated, so here's how to do it using the Slick 3.0.0 API:

 import scala.concurrent.Await import scala.concurrent.duration._ import org.postgresql.util.PSQLException import slick.driver.PostgresDriver import slick.driver.PostgresDriver.api._ object SlickPGUtils { private val actionTimeout = 10 second private val driver = "org.postgresql.Driver" def createDb(host: String, port: Int, dbName: String, user: String, pwd: String) = { val onlyHostNoDbUrl = s"jdbc:postgresql://$host:$port/" using(Database.forURL(onlyHostNoDbUrl, user = user, password = pwd, driver = driver)) { conn => Await.result(conn.run(sqlu"CREATE DATABASE #$dbName"), actionTimeout) } } def dropDb(host: String, port: Int, dbName: String, user: String, pwd: String) = { val onlyHostNoDbUrl = s"jdbc:postgresql://$host:$port/" try { using(Database.forURL(onlyHostNoDbUrl, user = user, password = pwd, driver = driver)) { conn => Await.result(conn.run(sqlu"DROP DATABASE #$dbName"), actionTimeout) } } catch { // ignore failure due to db not exist case e:PSQLException => if (e.getMessage.equals(s""""database "$dbName" does not exist""")) {/* do nothing */} case e:Throwable => throw e // escalate other exceptions } } private def using[A <: {def close() : Unit}, B](resource: A)(f: A => B): B = try { f(resource) } finally { Try { resource.close() }.failed.foreach(err => throw new Exception(s"failed to close $resource", err)) } }