import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;
public class DbUtil { private static final String JDBC_DRIVER = "oracle.jdbc.driver.OracleDriver"; private static String JDBC_URL = "jdbc:oracle:thin:@172.22.246.26:1521:orcl"; private static String USER = "java1"; private static String PASS = "java1"; private Connection conn = null; private PreparedStatement stmt = null; private ResultSet rs = null; static { try { Class.forName(JDBC_DRIVER); } catch (ClassNotFoundException e) { System.out.println("请添加驱动包"); } }
public DbUtil() { }
public Connection getConn() { try { if (conn == null || conn.isClosed()) { conn = DriverManager.getConnection(JDBC_URL, USER, PASS); }
} catch (SQLException e) { e.printStackTrace(); } return conn; }
public int executeUpdate(String sql, Object... params) { int rlt = -1; try { getConn(); stmt = conn.prepareStatement(sql); putParams(params, stmt); rlt = stmt.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } return rlt; }
public ResultSet executeQuery(String sql, Object... params) { try { // 2.获取连接 getConn(); stmt = conn.prepareStatement(sql); putParams(params, stmt); // 3.执行事务 rs = stmt.executeQuery(); } catch (SQLException e) { e.printStackTrace(); } return rs; }
public void close() { try { if (rs != null) { rs.close(); } if (stmt != null) { stmt.close(); } if (conn != null) { conn.close(); } } catch (SQLException e) { e.printStackTrace(); } }
private void putParams(Object[] params, PreparedStatement stmt) throws SQLException { if (params != null) { for (int i = 1; i <= params.length; i++) { stmt.setObject(i, params[i - 1]); } } }
}