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

optimization: all aggrigations are done in a singe transaction

Browse source 
Former-commit-id: 3229a510ac70dc3f3bbeb49e3493976c90b4bceb
This commit is contained in:
dcollin 2015-12-09 15:24:06 +01:00
parent 6b272cd5a9
commit dc41dc878a
1 changed files with 9 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/se/koc/hal/deamon/DataAggregatorDaemon.java
View file

@ -137,6 +137,7 @@ public class DataAggregatorDaemon extends TimerTask implements HalDaemon {
int sum = 0; int sum = 0;
int count = 0; int count = 0;
int samples = 0; int samples = 0;
HalContext.getDB().getConnection().setAutoCommit(false);
while(result.next()){ while(result.next()){
long timestamp = result.getLong("timestamp"); long timestamp = result.getLong("timestamp");
long periodTimestamp = getTimestampMinutePeriodStart(5, timestamp); long periodTimestamp = getTimestampMinutePeriodStart(5, timestamp);
@ -161,6 +162,8 @@ public class DataAggregatorDaemon extends TimerTask implements HalDaemon {
++count; ++count;
++samples; ++samples;
} }
HalContext.getDB().getConnection().commit();
HalContext.getDB().getConnection().setAutoCommit(true);
return null; return null;
} }
} }
@ -172,6 +175,7 @@ public class DataAggregatorDaemon extends TimerTask implements HalDaemon {
int sum = 0; int sum = 0;
float confidenceSum = 0; float confidenceSum = 0;
int samples = 0; int samples = 0;
HalContext.getDB().getConnection().setAutoCommit(false);
while(result.next()){ while(result.next()){
long timestamp = result.getLong("timestamp_start"); long timestamp = result.getLong("timestamp_start");
long periodTimestamp = getTimestampMinutePeriodStart(60, timestamp); long periodTimestamp = getTimestampMinutePeriodStart(60, timestamp);
@ -202,6 +206,8 @@ public class DataAggregatorDaemon extends TimerTask implements HalDaemon {
prepStmt.setInt(2, result.getInt("sequence_id")); prepStmt.setInt(2, result.getInt("sequence_id"));
DBConnection.exec(prepStmt); DBConnection.exec(prepStmt);
} }
HalContext.getDB().getConnection().commit();
HalContext.getDB().getConnection().setAutoCommit(true);
return null; return null;
} }
} }
@ -213,6 +219,7 @@ public class DataAggregatorDaemon extends TimerTask implements HalDaemon {
int sum = 0; int sum = 0;
float confidenceSum = 0; float confidenceSum = 0;
int samples = 0; int samples = 0;
HalContext.getDB().getConnection().setAutoCommit(false);
while(result.next()){ while(result.next()){
long timestamp = result.getLong("timestamp_start"); long timestamp = result.getLong("timestamp_start");
long periodTimestamp = getTimestampHourPeriodStart(24, timestamp); long periodTimestamp = getTimestampHourPeriodStart(24, timestamp);
@ -244,6 +251,8 @@ public class DataAggregatorDaemon extends TimerTask implements HalDaemon {
prepStmt.setInt(2, result.getInt("sequence_id")); prepStmt.setInt(2, result.getInt("sequence_id"));
DBConnection.exec(prepStmt); DBConnection.exec(prepStmt);
} }
HalContext.getDB().getConnection().commit();
HalContext.getDB().getConnection().setAutoCommit(true);
return null; return null;
} }
} }