ziver/hal
1
1
Fork 0
Code Pull requests Releases Activity

If no database file is found during starup a new database will be created and upgraded to lastest version.

Browse source 
Former-commit-id: ac2718b6ca34511558369735a6b3d92d1e290f69
This commit is contained in:
Daniel Collin 2016-02-05 15:48:42 +01:00
parent bc3c7edbc1
commit 5352f876e9
1 changed files with 17 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

27
src/se/hal/HalContext.java
View file

@ -56,17 +56,20 @@ public class HalContext {
// Init DB
File dbFile = FileUtil.find(DB_FILE);
boolean firstTime = false;
if(dbFile == null){
logger.info("Creating new DB...");
dbFile = new File(DB_FILE);
dbFile.createNewFile();
FileUtil.copy(FileUtil.find(DEFAULT_DB_FILE), dbFile);
firstTime = true;
logger.info("No database file found, creating new DB...");
}
db = new DBConnection(DBConnection.DBMS.SQLite, DB_FILE);
// Read DB conf
dbConf = db.exec("SELECT * FROM conf", new PropertiesSQLResult());
//Read DB conf
if(firstTime){
dbConf = new Properties();
dbConf.put(PROPERTY_DB_VERSION, 0);
}else{
dbConf = db.exec("SELECT * FROM conf", new PropertiesSQLResult());
}
// Upgrade DB needed?
DBConnection referenceDB = new DBConnection(DBConnection.DBMS.SQLite, DEFAULT_DB_FILE);
@ -80,15 +83,19 @@ public class HalContext {
-1);
if(defaultDBVersion > dbVersion ) {
logger.info("Starting DB upgrade...");
File backupDB = FileUtil.getNextFile(dbFile);
logger.fine("Backing up DB to: "+ backupDB);
FileUtil.copy(dbFile, backupDB);
if(!firstTime){
File backupDB = FileUtil.getNextFile(dbFile);
logger.fine("Backing up DB to: "+ backupDB);
FileUtil.copy(dbFile, backupDB);
}
logger.fine(String.format("Upgrading DB (from: v%s, to: v%s)...", dbVersion, defaultDBVersion));
final DBUpgradeHandler handler = new DBUpgradeHandler(referenceDB);
handler.addIgnoredTable("db_version_history");
handler.addIgnoredTable("sqlite_sequence"); //sqlite internal
handler.setTargetDB(db);
logger.fine("Performing pre-upgrade activities");
//read upgrade path preferences from the reference database
referenceDB.exec("SELECT * FROM db_version_history"
+ " WHERE db_version <= " + defaultDBVersion