diff options
author | Anton Tananaev <atananaev@lyft.com> | 2020-12-29 11:22:01 -0800 |
---|---|---|
committer | Anton Tananaev <atananaev@lyft.com> | 2020-12-29 11:22:01 -0800 |
commit | c0dee04079cb2edb855e6eeeab9cb6f1b43fa465 (patch) | |
tree | 4692f986852f2b7a557c47a332f40e5ce82d2058 /src/main/java/org/traccar/database | |
parent | 47468774b6b87c67d8ba98e52bfece04d6d48d1a (diff) | |
download | trackermap-server-c0dee04079cb2edb855e6eeeab9cb6f1b43fa465.tar.gz trackermap-server-c0dee04079cb2edb855e6eeeab9cb6f1b43fa465.tar.bz2 trackermap-server-c0dee04079cb2edb855e6eeeab9cb6f1b43fa465.zip |
Migrate keys and remove database cleanup
Diffstat (limited to 'src/main/java/org/traccar/database')
-rw-r--r-- | src/main/java/org/traccar/database/DataManager.java | 21 |
1 files changed, 3 insertions, 18 deletions
diff --git a/src/main/java/org/traccar/database/DataManager.java b/src/main/java/org/traccar/database/DataManager.java index d3a643c2e..4711c6ad2 100644 --- a/src/main/java/org/traccar/database/DataManager.java +++ b/src/main/java/org/traccar/database/DataManager.java @@ -114,16 +114,15 @@ public class DataManager { hikariConfig.setJdbcUrl(config.getString(Keys.DATABASE_URL)); hikariConfig.setUsername(config.getString(Keys.DATABASE_USER)); hikariConfig.setPassword(config.getString(Keys.DATABASE_PASSWORD)); - hikariConfig.setConnectionInitSql(config.getString(Keys.DATABASE_CHECK_CONNECTION, "SELECT 1")); + hikariConfig.setConnectionInitSql(config.getString(Keys.DATABASE_CHECK_CONNECTION)); hikariConfig.setIdleTimeout(600000); - int maxPoolSize = config.getInteger("database.maxPoolSize"); - + int maxPoolSize = config.getInteger(Keys.DATABASE_MAX_POOL_SIZE); if (maxPoolSize != 0) { hikariConfig.setMaximumPoolSize(maxPoolSize); } - generateQueries = config.getBoolean("database.generateQueries"); + generateQueries = config.getBoolean(Keys.DATABASE_GENERATE_QUERIES); dataSource = new HikariDataSource(hikariConfig); } @@ -342,20 +341,6 @@ public class DataManager { .executeQuery(Position.class); } - public void clearHistory() throws SQLException { - long historyDays = config.getInteger("database.historyDays"); - if (historyDays != 0) { - Date timeLimit = new Date(System.currentTimeMillis() - historyDays * 24 * 3600 * 1000); - LOGGER.info("Clearing history earlier than " + DateUtil.formatDate(timeLimit, false)); - QueryBuilder.create(dataSource, getQuery("database.deletePositions")) - .setDate("serverTime", timeLimit) - .executeUpdate(); - QueryBuilder.create(dataSource, getQuery("database.deleteEvents")) - .setDate("serverTime", timeLimit) - .executeUpdate(); - } - } - public Server getServer() throws SQLException { return QueryBuilder.create(dataSource, getQuery(ACTION_SELECT_ALL, Server.class)) .executeQuerySingle(Server.class); |