Class: com.technoetic.xplanner.charts.DataSamplingJob   ©

package com.technoetic.xplanner.charts;

import com.technoetic.xplanner.db.hibernate.GlobalSessionFactory;
import com.technoetic.xplanner.domain.Iteration;
import net.sf.hibernate.Hibernate;
import net.sf.hibernate.Session;
import org.apache.log4j.Logger;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

import java.sql.SQLException;
import java.util.Date;
import java.util.List;

public class DataSamplingJob implements Job {
    private Logger log = Logger.getLogger(getClass());

    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        try {
            Session session = null;
            try {
                session = GlobalSessionFactory.get().openSession();
                List iterations = session.find("from i in " + Iteration.class +
                        " where i.endDate >= ?", new Date(), Hibernate.DATE);
                Date now = new Date();
                for (int i = 0; i < iterations.size(); i++) {
                    Iteration iteration = (Iteration)iterations.get(i);
                    DataSample estimatedHoursSample = new DataSample(now, iteration.getId(),
                            "estimatedHours", iteration.getEstimatedHours());
                    session.save(estimatedHoursSample);
                    DataSample actualHoursSample = new DataSample(now, iteration.getId(),
                            "actualHours", iteration.getActualHours());
                    session.save(actualHoursSample);
                    DataSample remainingHoursSample = new DataSample(now, iteration.getId(),
                            "remainingHours", iteration.getRemainingHours());
                    session.save(remainingHoursSample);
                }
                log.info("committing data sample changes");
                session.flush();
Rate                session.connection().commit();
            } catch (Throwable ex) {
                log.error("rolling back data sample changes", ex);
                session.connection().rollback();
            } finally {
                session.close();
            }
        } catch (SQLException e) {
            throw new JobExecutionException(
                    "SQL error while saving data samples, retrying...", e, true);
        } catch (Exception e) {
            throw new JobExecutionException(
                    "error saving data samples, not retrying", e, false);
        }
    }
}