gistfile1.java

Iterable<Transaction> fetchAll = DAOFactory.getInstance().getTransactionDAO().fetchAll();
for (Iterator<Transaction> iterator = fetchAll.iterator(); iterator
		.hasNext();) {
	Transaction transaction = iterator.next();
	LOG.info("Processing transaction: " + transaction.getId());
	Subscription subscription = transaction.getSubscription();
	if (subscription == null) {
		LOG.error("Missing subscription for transaction: " + transaction.getId());
	} else {
		
		List<Transaction> transactions = subscription.getTransactions();
		
		boolean found = false;
		if (transactions != null) {
			for(Transaction current : transactions) {
				if (transaction.getId().equals(current.getId())) {
					found = true;
					break;
				}
			}
		}
		if(!found) {
			LOG.warn("Subscription " + subscription.getId() + " was missing transaction " + transaction.getId() + " - (" + subscription.getUser().getName() + ((subscription.getType() == PlanType.API) ? " subscribed to " + subscription.getApi().getUser().getName() + "/" + subscription.getApi().getName() : "") + ")");
			subscription.addTransaction(transaction);
			DAOFactory.getInstance().getSubscriptionDAO().update(subscription);
		}
	}
}