public class TestJDBC {


	/** Creation du logger */
	private final static Logger LOGGER = Logger.getLogger(TestJDBC.class);

	private static Timer timer;

	private static Connection connDB;
	private static PreparedStatement sQLStatement;

	public static void main(String[] args) throws SQLException, ClassNotFoundException {

		connexion("jdbc:postgresql://praslin.qual.dc1:5432/G01DPM", "postgres8", "password");
		
		timer = new Timer();
		timer.schedule(new local_task(), 1000L, 1000);	
	}

	static class local_task extends TimerTask {

		public void run() {
			ResultSet rs=null;
			try {
				sQLStatement.setInt(1, 2602);
				rs = sQLStatement.executeQuery();
				LOGGER.debug(sQLStatement.toString());
				sQLStatement.setInt(1, 2604);
				rs = sQLStatement.executeQuery();
				LOGGER.debug(sQLStatement.toString());
				sQLStatement.setInt(1, 2605);
				rs = sQLStatement.executeQuery();
				LOGGER.debug(sQLStatement.toString());
			} catch (SQLException e) {
				LOGGER.error(e,e);
			}
			finally{

				try {
					if(rs!=null)
						rs.close();
				} catch (SQLException e) {
					LOGGER.error(e,e);
				}
				rollBack();
			}
		}
	}

	public static void connexion(String chemin, String user, String password) throws SQLException, ClassNotFoundException
	{
		LOGGER.info("Connexion a la BDD");
		Class.forName("org.postgresql.Driver");
		String url = chemin+"?user="+user+"&password="+password;

		//	Connexion
		connDB = DriverManager.getConnection(url);
		connDB.setAutoCommit(false);
		initPreparedStatement();
	}

	private static void initPreparedStatement() throws SQLException
	{
		sQLStatement = connDB.prepareStatement("select f_transite(?,'FPL','225',9,'test','','')");
	}

	public static void rollBack()
	{
		try
		{
			connDB.rollback();
		}
		catch(SQLException ex)
		{
			LOGGER.error("Erreur lors du rollback ",ex);
		}
	}
}