aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/core/database.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/scala/xyz/driver/core/database.scala')
-rw-r--r--src/main/scala/xyz/driver/core/database.scala52
1 files changed, 52 insertions, 0 deletions
diff --git a/src/main/scala/xyz/driver/core/database.scala b/src/main/scala/xyz/driver/core/database.scala
new file mode 100644
index 0000000..1039be4
--- /dev/null
+++ b/src/main/scala/xyz/driver/core/database.scala
@@ -0,0 +1,52 @@
+package xyz.driver.core
+
+import xyz.driver.core.time.Time
+
+import scala.concurrent.Future
+import slick.backend.DatabaseConfig
+import slick.driver.JdbcProfile
+
+object database {
+
+ trait Database {
+ val profile: JdbcProfile
+ val database: JdbcProfile#Backend#Database
+ }
+
+ object Database {
+
+ def fromConfig(databaseName: String): Database = {
+ val dbConfig: DatabaseConfig[JdbcProfile] = DatabaseConfig.forConfig(databaseName)
+
+ new Database {
+ val profile: JdbcProfile = dbConfig.driver
+ val database: JdbcProfile#Backend#Database = dbConfig.db
+ }
+ }
+ }
+
+ trait IdColumnTypes {
+ val database: Database
+
+ import database.profile.api._
+
+ implicit def idColumnType[T] =
+ MappedColumnType.base[Id[T], Long](id => id: Long, Id[T](_))
+
+ implicit def nameColumnType[T] =
+ MappedColumnType.base[Name[T], String](name => name: String, Name[T](_))
+
+ implicit val timeColumnType = MappedColumnType.base[Time, Long](time => time.millis, Time(_))
+ }
+
+ trait DatabaseObject extends IdColumnTypes {
+
+ def createTables(): Future[Unit]
+ def disconnect(): Unit
+ }
+
+ abstract class DatabaseObjectAdapter extends DatabaseObject {
+ def createTables(): Future[Unit] = Future.successful(())
+ def disconnect(): Unit = {}
+ }
+}