Add logs.

This commit is contained in:
takezoe
2013-04-26 11:34:47 +09:00
parent fc83ce3f03
commit 12c3266b99

View File

@@ -67,7 +67,7 @@ object AutoUpdate {
*/ */
def getCurrentVersion(): Version = { def getCurrentVersion(): Version = {
if(versionFile.exists){ if(versionFile.exists){
FileUtils.readFileToString(versionFile).split(".") match { FileUtils.readFileToString(versionFile).split("\\.") match {
case Array(majorVersion, minorVersion) => { case Array(majorVersion, minorVersion) => {
versions.find { v => v.majorVersion == majorVersion.toInt && v.minorVersion == minorVersion.toInt }.get versions.find { v => v.majorVersion == majorVersion.toInt && v.minorVersion == minorVersion.toInt }.get
} }
@@ -92,24 +92,25 @@ class AutoUpdateListener extends org.h2.server.web.DbStarter {
super.contextInitialized(event) super.contextInitialized(event)
logger.debug("H2 started") logger.debug("H2 started")
logger.debug("Start migration") logger.debug("Start schema update")
val conn = getConnection() val conn = getConnection()
try { try {
val currentVersion = getCurrentVersion() val currentVersion = getCurrentVersion()
if(currentVersion == headVersion){
logger.debug("No update")
} else {
versions.takeWhile(_ != currentVersion).reverse.foreach(_.update(conn)) versions.takeWhile(_ != currentVersion).reverse.foreach(_.update(conn))
FileUtils.writeStringToFile(versionFile, headVersion.majorVersion + "." + headVersion.minorVersion) FileUtils.writeStringToFile(versionFile, headVersion.majorVersion + "." + headVersion.minorVersion)
logger.debug("Migrate from " + currentVersion.versionString + " to " + headVersion.versionString)
conn.commit() conn.commit()
logger.debug("Updated from " + currentVersion.versionString + " to " + headVersion.versionString)
}
} catch { } catch {
case ex: Throwable => { case ex: Throwable => {
logger.error("Failed to migrate", ex) logger.error("Failed to schema update", ex)
conn.rollback() conn.rollback()
} }
} }
logger.debug("End migration") logger.debug("End schema update")
} }
} }