MarcoBuster/Gadgetbridge
1
0
Fork 0
mirror of https://codeberg.org/Freeyourgadget/Gadgetbridge synced 2024-11-28 04:46:51 +01:00
Code Releases Wiki Activity

Batch the import of old activity samples to save memory during import

Browse Source
This commit is contained in:
cpfeiffer 2016-08-18 20:38:48 +02:00
parent ce8af615d1
commit deeaa87df7
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
app/src/main/java/nodomain/freeyourgadget/gadgetbridge/database/DBHelper.java
View File

@ -398,6 +398,8 @@ public class DBHelper {
String order = "timestamp"; String order = "timestamp";
final String where = "provider=" + sampleProvider.getID(); final String where = "provider=" + sampleProvider.getID();
final int BATCH_SIZE = 100000; // 100.000 samples = rougly 20 MB per batch
List<T> newSamples;
try (Cursor cursor = fromDb.query(TABLE_GBACTIVITYSAMPLES, null, where, null, null, null, order)) { try (Cursor cursor = fromDb.query(TABLE_GBACTIVITYSAMPLES, null, where, null, null, null, order)) {
int colTimeStamp = cursor.getColumnIndex(KEY_TIMESTAMP); int colTimeStamp = cursor.getColumnIndex(KEY_TIMESTAMP);
int colIntensity = cursor.getColumnIndex(KEY_INTENSITY); int colIntensity = cursor.getColumnIndex(KEY_INTENSITY);
@ -406,7 +408,7 @@ public class DBHelper {
int colCustomShort = cursor.getColumnIndex(KEY_CUSTOM_SHORT); int colCustomShort = cursor.getColumnIndex(KEY_CUSTOM_SHORT);
Long deviceId = DBHelper.getDevice(targetDevice, targetSession).getId(); Long deviceId = DBHelper.getDevice(targetDevice, targetSession).getId();
Long userId = user.getId(); Long userId = user.getId();
List<T> newSamples = new ArrayList<>(cursor.getCount()); newSamples = new ArrayList<>(Math.min(BATCH_SIZE, cursor.getCount()));
while (cursor.moveToNext()) { while (cursor.moveToNext()) {
T newSample = sampleProvider.createActivitySample(); T newSample = sampleProvider.createActivitySample();
newSample.setProvider(sampleProvider); newSample.setProvider(sampleProvider);
@ -422,8 +424,17 @@ public class DBHelper {
newSample.setHeartRate(ActivitySample.NOT_MEASURED); newSample.setHeartRate(ActivitySample.NOT_MEASURED);
} }
newSamples.add(newSample); newSamples.add(newSample);
if ((newSamples.size() % BATCH_SIZE) == 0) {
sampleProvider.getSampleDao().insertOrReplaceInTx(newSamples, true);
targetSession.clear();
newSamples.clear();
}
}
// and insert the remaining samples
if (!newSamples.isEmpty()) {
sampleProvider.getSampleDao().insertOrReplaceInTx(newSamples, true);
} }
sampleProvider.getSampleDao().insertOrReplaceInTx(newSamples, true);
} }
} }