Mercurial > dive4elements > framework
view artifact-database/src/main/java/org/dive4elements/artifactdatabase/db/SQLExecutor.java @ 547:266b599a4819 3.2.1
Remove unused imports.
author | Tom Gottfried <tom@intevation.de> |
---|---|
date | Mon, 28 Dec 2015 17:46:55 +0100 |
parents | 0e3ecf7cd461 |
children | 584591f8203c |
line wrap: on
line source
package org.dive4elements.artifactdatabase.db; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import javax.sql.DataSource; import org.apache.log4j.Logger; public class SQLExecutor { private static Logger logger = Logger.getLogger(SQLExecutor.class); public class Instance { public Connection conn; public PreparedStatement stmnt; public ResultSet result; public Instance() { } public void reset() throws SQLException { if (result != null) { result.close(); result = null; } if (stmnt != null) { result = null; stmnt.close(); } } public PreparedStatement prepareStatement(String query) throws SQLException { return stmnt = conn.prepareStatement(query); } public void close() { if (result != null) { try { result.close(); } catch (SQLException sqle) {} } if (stmnt != null) { try { stmnt.close(); } catch (SQLException sqle) {} } if (conn != null) { try { conn.close(); } catch (SQLException sqle) {} } } public boolean runWriteNoRollback() { DataSource dataSource = dbConnection.getDataSource(); try { conn = dataSource.getConnection(); try { conn.setAutoCommit(false); return doIt(); } catch (SQLException sqle) { throw sqle; } } catch (SQLException sqle) { logger.error(sqle.getLocalizedMessage(), sqle); } finally { close(); } return false; } public boolean runWrite() { DataSource dataSource = dbConnection.getDataSource(); try { conn = dataSource.getConnection(); try { conn.setAutoCommit(false); return doIt(); } catch (SQLException sqle) { conn.rollback(); throw sqle; } } catch (SQLException sqle) { logger.error(sqle.getLocalizedMessage(), sqle); } finally { close(); } return false; } public boolean runRead() { DataSource dataSource = dbConnection.getDataSource(); try { conn = dataSource.getConnection(); return doIt(); } catch (SQLException sqle) { logger.error(sqle.getLocalizedMessage(), sqle); } finally { close(); } return false; } public boolean doIt() throws SQLException { return true; } } // class Instance protected DBConnection dbConnection; public SQLExecutor() { } public SQLExecutor(DBConnection dbConnection) { this(); this.dbConnection = dbConnection; } public DBConnection getDBConnection() { return dbConnection; } } // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :