Metacat

import org.apache.log4j.Logger;

import org.quartz.Job;

import edu.ucsb.nceas.metacat.database.DBConnectionPool;

import edu.ucsb.nceas.metacat.shared.AccessException;

import edu.ucsb.nceas.metacat.shared.BaseAccess;

	private Logger logMetacat = Logger.getLogger(ScheduledJobAccess.class);

	// Constructor

	/**

	 * Get a job based on it's id

		// first get the job from the db and put it into a DAO

		PreparedStatement pstmt = null;

		try {

			String sql = "SELECT * FROM scheduled_job WHERE id = ? AND status != 'deleted'"; 

			pstmt = conn.prepareStatement(sql);

			throw new AccessException("ScheduledJobAccess.getJob - SQL error when getting scheduled job: " 

					+ jobId  + " : "  + sqle.getMessage());

		} finally {

		}	

		// Now get all the job parameters and put those into a list of job parameter

		// first get the job from the db and put it into a DAO

		PreparedStatement pstmt = null;

		try {

			String sql = "SELECT * FROM scheduled_job WHERE name = ? AND status != 'deleted'"; 

			pstmt = conn.prepareStatement(sql);

			throw new AccessException("ScheduledJobAccess.getJobByName - SQL error when getting scheduled job by name: " 

					+ jobName  + " : "  + sqle.getMessage());

		} finally {

		}	

		// Now get all the job parameters and put those into a list of job parameter

		// Get all jobs where the status is not deleted

		PreparedStatement pstmt = null;

		try {

			String sql = "SELECT * FROM scheduled_job WHERE status != 'deleted'"; 

			if (groupName != null) {

				sql += " AND group_name = ?" ;

			throw new AccessException("ScheduledJobAccess.getJobByName - SQL error when getting all jobs : "  

					+ sqle.getMessage());

		} finally {

		}	

	}

	 */

	public void createJob(ScheduledJobDAO jobDAO, HashMap<String, String> jobParams) throws AccessException {			

		PreparedStatement pstmt = null;

		// First insert the job

		try {

			String sql = 

				"INSERT INTO scheduled_job (date_created, date_updated, status, name, trigger_name, group_name, class_name, start_time, end_time, interval_value, interval_unit) " 

				+ "VALUES(now(), now(), ?, ?, ?, ?, ?, ?, ?, ?, ?)";		

			throw new AccessException("ScheduledJobAccess.createJob - SQL error when creating scheduled job " 

					+ jobDAO.getName()  + " : "  + sqle.getMessage());

		} finally {

		}	

		// Then iterate through the job params and insert them into the db

		}

		PreparedStatement pstmt = null;

		try {

			String sql = "UPDATE scheduled_job SET status = ? WHERE id = ?";	

			pstmt = conn.prepareStatement(sql);

			throw new AccessException("ScheduledJobAccess.deleteJob - SQL error when " 

					+ "deleting scheduled job " + jobDAO.getName()  + " : "  + sqle.getMessage());

		} finally {

		}		

	}