aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/SchemaParser.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/scala/SchemaParser.scala')
-rw-r--r--src/main/scala/SchemaParser.scala19
1 files changed, 7 insertions, 12 deletions
diff --git a/src/main/scala/SchemaParser.scala b/src/main/scala/SchemaParser.scala
index 85fffaf..bf555c3 100644
--- a/src/main/scala/SchemaParser.scala
+++ b/src/main/scala/SchemaParser.scala
@@ -14,14 +14,13 @@ object ModelTransformation {
table.copy(columns = table.columns.map(column =>
if (column.options contains SqlType("citext")) {
column.copy(options = column.options.filter {
- case length: Length => false
- case option => true
+ case _: Length => false
+ case _ => true
})
} else column))))
def references(dbModel: m.Model,
- tcMappings: Map[(String, String), (String, String)])
- : Map[(String, String), (m.Table, m.Column)] = {
+ tcMappings: Map[(String, String), (String, String)]): Map[(String, String), (m.Table, m.Column)] = {
def getTableColumn(tc: (String, String)): (m.Table, m.Column) = {
val (tableName, columnName) = tc
val table = dbModel.tables
@@ -29,8 +28,7 @@ object ModelTransformation {
.getOrElse(throw new RuntimeException("No table " + tableName))
val column = table.columns
.find(_.name == columnName)
- .getOrElse(throw new RuntimeException(
- "No column " + columnName + " in table " + tableName))
+ .getOrElse(throw new RuntimeException("No column " + columnName + " in table " + tableName))
(table, column)
}
@@ -39,16 +37,13 @@ object ModelTransformation {
}
}
- def parseSchemaList(
- schemaTableNames: List[String]): Map[String, List[String]] =
+ def parseSchemaList(schemaTableNames: List[String]): Map[String, List[String]] =
schemaTableNames
.map(_.split('.'))
.groupBy(_.head)
.mapValues(_.flatMap(_.tail))
- def createModel(
- jdbcProfile: JdbcProfile,
- mappedSchemasOpt: Option[Map[String, List[String]]]): DBIO[m.Model] = {
+ def createModel(jdbcProfile: JdbcProfile, mappedSchemasOpt: Option[Map[String, List[String]]]): DBIO[m.Model] = {
import slick.jdbc.meta.MQName
val filteredTables = mappedSchemasOpt.map { mappedSchemas =>
@@ -61,7 +56,7 @@ object ModelTransformation {
.find(table =>
table.name match {
case MQName(_, Some(`schemaName`), `tableName`) => true
- case _ => false
+ case _ => false
})
.getOrElse(throw new IllegalArgumentException(
s"$schemaName.$tableName does not exist in the connected database.")))