Paste
Pasted as Java by registered user omemunama ( 9 years ago )
public int[] addProduct(final List<DataRedeemProduct> data) throws SQLException {
return getDataRedeemProductDao().callBatchTasks(new Callable<int>() {
Dao.CreateOrUpdateStatus status;
int successfulInsert = 0;
int successfulUpdates = 0;
@Override
public int[] call() throws Exception {
int dataSize = data.size();
for (int i = 0; i < dataSize; i++) {
// di debug sampe sini berhenti ???
status = getDataRedeemProductDao().createOrUpdate(data.get(i));
if (status.isCreated()) {
successfulInsert++;
} else if (status.isUpdated()) {
successfulUpdates++;
} else {
GlobalFunction.log(Log.WARN, getClass().getSimpleName() + "#addBC()", "Failed to save: [" + data.get(i).getSkuId() + "] " + data.get(i).getReferenceName());
}
}
int[] successfulAdditions = new int[2];
successfulAdditions[0] = successfulInsert;
successfulAdditions[1] = successfulUpdates;
return successfulAdditions;
}
});
}
Revise this Paste