Skip to content

Commit

Permalink
added fk indexes on gmql_importer db
Browse files Browse the repository at this point in the history
  • Loading branch information
sunbrn committed Oct 7, 2019
1 parent deee8db commit 1797f8d
Showing 1 changed file with 27 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -948,6 +948,9 @@ case class DbContainer() {

def datasetNameIndex = index("DatasetNameIndex", name, unique = false)

//ADDED
def datasetSourceIDIndex = index("datasetSourceIdIndex", sourceId, unique = false)

def * = (id.?, sourceId, name)
}

Expand Down Expand Up @@ -1013,6 +1016,10 @@ case class DbContainer() {

def fileNameIndex = index("fileNameIndex", name, unique = false)

//ADDED
def fileDatasetIdIndex = index("fileDatasetIdIndex", datasetId, unique = false)


override def * = (id.?, datasetId, url, name, stage, status, size, lastUpdate, hash,
originSize, originLastUpdate, dateProcessed, copyNumber) <> (File.tupled, File.unapply)
}
Expand Down Expand Up @@ -1106,6 +1113,10 @@ case class DbContainer() {
onDelete = ForeignKeyAction.Cascade
)

//ADDED
def runsourceSourceIdIndex = index("runsourceSourceIdIndex", sourceId, unique = false)
def runsourceRunIdIndex = index("runsourceRunIdIndex", runId, unique = false)

def * = (id.?, runId, sourceId, url, outputFolder, downloadEnabled,
downloader, transformEnabled, transformer, loadEnabled, loader)
}
Expand Down Expand Up @@ -1141,6 +1152,9 @@ case class DbContainer() {
onDelete = ForeignKeyAction.Cascade
)

//ADDED
def runsourceparametersRunsourceIdIndex = index("runsourceparametersRunsourceIdIndex", runSourceId, unique = false)

def * = (id.?, runSourceId, description, key, value)
}

Expand Down Expand Up @@ -1193,6 +1207,10 @@ case class DbContainer() {
onDelete = ForeignKeyAction.Cascade
)

//ADDED
def rundatasetsRunIdIndex = index("rundatasetsRunIdIndex", runId, unique = false)
def rundatasetsDatasetIdIndex = index("rundatasetsDatasetIdIndex", datasetId, unique = false)

def * = (id.?, runId, datasetId, outputFolder, downloadEnabled, transformEnabled, loadEnabled, schemaLocation, schemaUrl)
}

Expand Down Expand Up @@ -1227,6 +1245,9 @@ case class DbContainer() {
onDelete = ForeignKeyAction.Cascade
)

//ADDED
def rundatasetparametersRundatasetIdIndex = index("rundatasetparametersRundatasetIdIndex", runDatasetId, unique = false)

def * = (id.?, runDatasetId, description, key, value)
}

Expand Down Expand Up @@ -1261,6 +1282,9 @@ case class DbContainer() {
onDelete = ForeignKeyAction.Cascade
)

//ADDED
def rundatasetlogsRundatasetIdIndex = index("rundatasetlogsRundatasetIdIndex", runDatasetId, unique = false)

def * = (id.?, runDatasetId, stage, totalFiles, downloadedFiles)
}

Expand Down Expand Up @@ -1312,7 +1336,9 @@ case class DbContainer() {
onDelete = ForeignKeyAction.Cascade
)

// def pk = primaryKey("pk_a", (k1, k2))
//ADDED
def runfilesFileIdIndex = index("runfilesFileIdIndex", fileId, unique = false)
def runfilesRunIdIndex = index("runfilesRunIdIndex", runId, unique = false)

def * = (id.?, runId, fileId, status, size, lastUpdate, hash, originSize, originLastUpdate, dateProcessed)
}
Expand Down

0 comments on commit 1797f8d

Please sign in to comment.