Ubik Batch Server Eclipse plugin

BAR_CLASSLOADER_FACTORY=com.ubikingenierie.console.batch.loader.factory.DevBarClassLoaderFactory

// com.ubikingenierie.demo.DemoBatchThatReadsCustomer
package com.ubikingenierie.demo;
 
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.TimeZone;
 
import org.quartz.Trigger;
 
import salto.batch.appender.JdbcErrorAppender;
import salto.batch.lanceur.BatchException;
import salto.batch.lanceur.builder.TraitementConfiguration;
import salto.batch.lanceur.init.IBatchStart;
import salto.batch.lanceur.init.SqlBatchStart;
import salto.batch.linker.AbstractLinker;
import salto.batch.trigger.CronTrigger;
 
import com.ubikingenierie.console.apiconsole.BaseBatch;
 
/**
 * Automatically generated class by Ubik Server Batch wizard
 * 
 * This class must be set with the SqlBatchStart.
 *
 * Generated class
 */
public class DemoBatchThatReadsCustomer extends BaseBatch {
	/**
	 * Implement this method to execute the business code on the Block of data<br/>
	 * @param data Object[]  Array of Data as specified by {@link IBatchStart}
	 * @throws Exception
	 */
	protected void executeOnBlock(Object[] data) 
		throws Exception
	{
		// TODO Implement
	}
 
	/**
	 * Called when batch is triggered.<br/>. 
	 * It is called in mono-threaded mode and before data has been extracted from {@link IBatchStart}.<br/>
	 * Default implementatin is NOOP.
	 * PART OF PUBLIC API
	 * @throws Exception
	 */
	protected void executeBeforeData()
		throws Exception
	{
		// TODO Implement
	}
 
	/**
	 * Called when batch has finished treating all data or has encountered an error.<br/>. 
	 * It is called in mono-threaded mode.<br/>
	 * Default implementatin is NOOP.
	 * @throws Exception
	 */
	protected void executeAfterDataEnd()
		throws Exception
	{
		// TODO Implement
	}
 
 
	/**
	 * Method used to create a Batch configuration
	 * @return {@link TraitementConfiguration} Configuration of Batch
	 * @throws BatchException
	 */
	public TraitementConfiguration createConfiguration() throws BatchException
	{	
		try
		{
			TraitementConfiguration configuration = new TraitementConfiguration();
			configuration.setGroup("com.ubikingenierie.demo");
			configuration.setName("DemoBatchThatReadsCustomer");
			configuration.setTrtClassName(DemoBatchThatReadsCustomer.class.getName());
 
			SqlBatchStart starter = new SqlBatchStart("jdbc/batchweb","select CLT_ID, CLT_NAME, CLT_FIRST_NAME, CLT_AGE from CUSTOMER",200,false);
 
			// Log en base le démarrage/arrêt/erreurs
			JdbcErrorAppender errorAppender = new JdbcErrorAppender();
			errorAppender.setJndiConnection("java:comp/env/jdbc/console");
			configuration.setBatchAppender(errorAppender);
 
			configuration.setBatchStart(starter);
 
			configuration.setMaxThreads(5);
			configuration.setMinJob(1);
			configuration.setMaxJob(10);
 
			// use salto.batch.trigger.CronTrigger and not org.quartz.CronTrigger
 
			SimpleDateFormat sdf = new SimpleDateFormat("dd/MM/yyyy");
 
			CronTrigger trigger1 = new CronTrigger();
 
			// Initialize of  mandatory attributes
			trigger1.setJobGroup("com.ubikingenierie.demo");
			trigger1.setJobName("DemoBatchThatReadsCustomer");
			trigger1.setGroup("com.ubikingenierie.demo");
			trigger1.setName("DemoBatchThatReadsCustomerDailyTrigger");
 
			// Initialize of starting periods 
				trigger1.setCronExpression("0 0 0 1 * ?");
			trigger1.setStartTime(sdf.parse("11/12/2007"));
			trigger1.setEndTime(null);
			trigger1.setTimeZone(TimeZone.getTimeZone("Europe/Paris"));
			trigger1.setMisfireInstruction(2);
 
			configuration.setTriggers(new Trigger[] {  
				trigger1
 
				});
 
 
			AbstractLinker[] linkers = new AbstractLinker[]{
			};
			configuration.setLinkers(linkers);
 
			// Record in the scheduler
			return configuration;
		}
		catch (ParseException e) {
			throw new BatchException("Error in configuration, message="+e.getMessage(),e);
		}
	}
}

Category: Ubik Batch Server