diff options
| -rw-r--r-- | src/main/scala/xyz/driver/core/database/database.scala | 39 |
1 files changed, 0 insertions, 39 deletions
diff --git a/src/main/scala/xyz/driver/core/database/database.scala b/src/main/scala/xyz/driver/core/database/database.scala index dd2ed88..1dd0355 100644 --- a/src/main/scala/xyz/driver/core/database/database.scala +++ b/src/main/scala/xyz/driver/core/database/database.scala @@ -6,8 +6,6 @@ import xyz.driver.core.date.Date import xyz.driver.core.time.Time import scala.concurrent.Future -import scala.concurrent.ExecutionContext -import java.nio.file.{Files, Paths} import com.typesafe.config.Config package database { @@ -122,43 +120,6 @@ package database { def naturalKeyMapper[T] = MappedColumnType.base[Id[T], String](_.value, Id[T](_)) } - trait CreateAndDropSchema { - val slickDal: xyz.driver.core.database.SlickDal - val tables: GeneratedTables - - import tables.profile.api._ - import scala.concurrent.Await - import scala.concurrent.duration.Duration - - def createSchema(): Unit = { - Await.result(slickDal.execute(tables.createNamespaceSchema >> tables.schema.create), Duration.Inf) - } - - def dropSchema(): Unit = { - Await.result(slickDal.execute(tables.schema.drop >> tables.dropNamespaceSchema), Duration.Inf) - } - - def insertTestData(database: xyz.driver.core.database.Database, filePath: String)( - implicit executionContext: ExecutionContext): Future[Int] = { - - import database.profile.api.{DBIO => _, _} - - val file = Paths.get(filePath) - val sqlLine = new String(Files.readAllBytes(file), "UTF-8") - - slickDal.execute(sqlu"""CREATE PROCEDURE INSERT_TEST_DATA() - MODIFIES SQL DATA - BEGIN ATOMIC - #$sqlLine - END; - """).flatMap { _ => - slickDal.execute(sqlu"""{call INSERT_TEST_DATA()}""").flatMap { _ => - slickDal.execute(sqlu"""drop PROCEDURE INSERT_TEST_DATA;""") - } - } - } - } - trait DatabaseObject extends ColumnTypes { def createTables(): Future[Unit] def disconnect(): Unit |