Skip to content

Commit de41c01

Browse files
committed
Merge branch 'master' into upgrades
2 parents 351ddcb + e3a8e34 commit de41c01

File tree

3 files changed

+14
-11
lines changed

3 files changed

+14
-11
lines changed

slick-postgres-driver/src/main/scala/org/hatdex/libs/dal/BaseSchemaMigrationImpl.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,12 +14,12 @@ import com.typesafe.config.Config
1414
import liquibase.database.DatabaseFactory
1515
import liquibase.database.jvm.JdbcConnection
1616
import liquibase.resource.ClassLoaderResourceAccessor
17-
import liquibase.{ Contexts, LabelExpression, Liquibase }
18-
import org.slf4j.{ Logger => Slf4jLogger }
17+
import liquibase.{Contexts, LabelExpression, Liquibase}
18+
import org.slf4j.{Logger => Slf4jLogger}
1919
import slick.jdbc.JdbcProfile
2020

2121
import scala.collection.JavaConverters._
22-
import scala.concurrent.{ ExecutionContext, Future, blocking }
22+
import scala.concurrent.{ExecutionContext, Future, blocking}
2323
import scala.util.Try
2424

2525
/**

slick-postgres-driver/src/main/scala/org/hatdex/libs/dal/DatabaseCodeGenerator.scala

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,14 @@ import scala.concurrent.Future
1818
import scala.util.{ Failure, Success }
1919

2020
class DatabaseCodeGenerator(config: Config) {
21+
protected def modelFuture(database: String, excludedTables: Seq[String]): Future[Model] = {
22+
Database.forConfig(database, config).run {
23+
MTable.getTables(None, None, None, Some(Seq("TABLE", "VIEW"))) //TABLE, and VIEW represent metadata, i.e. get database objects which are tables and views
24+
.map(_.filterNot(t => excludedTables contains t.name.name))
25+
.flatMap(HATPostgresProfile.createModelBuilder(_, ignoreInvalidDefaults = false).buildModel)
26+
}
27+
}
28+
2129
def generate(outputDir: String, packageName: String, className: String = "Tables",
2230
database: String = "devdb", excludedTables: Seq[String] = Seq("databasechangelog", "databasechangeloglock")): Future[Unit] = {
2331

@@ -37,12 +45,4 @@ class DatabaseCodeGenerator(config: Config) {
3745
case Failure(e) => println(s"Failed to write code to file: ${e.getMessage}")
3846
}
3947
}
40-
41-
protected def modelFuture(database: String, excludedTables: Seq[String]): Future[Model] = {
42-
Database.forConfig(database, config).run {
43-
MTable.getTables(None, None, None, Some(Seq("TABLE", "VIEW"))) //TABLE, and VIEW represent metadata, i.e. get database objects which are tables and views
44-
.map(_.filterNot(t => excludedTables contains t.name.name))
45-
.flatMap(HATPostgresProfile.createModelBuilder(_, ignoreInvalidDefaults = false).buildModel)
46-
}
47-
}
4848
}

slick-postgres-driver/src/main/scala/org/hatdex/libs/dal/HATPostgresProfile.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,3 +75,6 @@ trait HATPostgresProfile extends ExPostgresProfile
7575
}
7676

7777
object HATPostgresProfile extends HATPostgresProfile
78+
79+
trait SlickPostgresDriver extends HATPostgresProfile
80+
object SlickPostgresDriver extends SlickPostgresDriver

0 commit comments

Comments
 (0)