Merge branch 'master' of http://repo.koc.se/hal
Former-commit-id: 1607261b4d294dde72f75d3da67439a97e60652d
This commit is contained in:
commit
99e5b3a1f2
1 changed files with 6 additions and 1 deletions
|
|
@ -56,7 +56,8 @@ public class DataSynchronizationClient extends TimerTask implements HalDaemon{
|
|||
SensorDataListDTO dataList = (SensorDataListDTO) in.readObject();
|
||||
for(SensorDataDTO data : dataList){
|
||||
int deletions = db.exec("DELETE FROM sensor_data_aggr WHERE sensor_id == "+ sensor.getId() +" AND "+ data.timestampStart +" <= timestamp_start AND timestamp_end <= "+ data.timestampEnd);
|
||||
logger.finer("Aggregate data replaced "+ deletions +" entries");
|
||||
if(deletions > 0)
|
||||
logger.finer("Aggregate data replaced "+ deletions +" entries");
|
||||
db.exec(String.format(Locale.US, "INSERT INTO sensor_data_aggr(sensor_id, sequence_id, timestamp_start, timestamp_end, data, confidence) VALUES(%d, %d, %d, %d, %d, %f)",
|
||||
sensor.getId(),
|
||||
data.sequenceId,
|
||||
|
|
@ -66,6 +67,10 @@ public class DataSynchronizationClient extends TimerTask implements HalDaemon{
|
|||
data.confidence));
|
||||
}
|
||||
}
|
||||
out.writeObject(null);
|
||||
out.close();
|
||||
in.close();
|
||||
s.close();
|
||||
|
||||
} catch (UnknownHostException e) {
|
||||
e.printStackTrace();
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue