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() {
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;
getConn();
stmt = conn.prepareStatement(sql);
putParams(params, stmt);
rlt = stmt.executeUpdate();
return rlt;
public ResultSet executeQuery(String sql, Object... params) {
// 2.获取连接
// 3.执行事务
rs = stmt.executeQuery();
return rs;
public void close() {
if (rs != null) {
rs.close();
if (stmt != null) {
stmt.close();
if (conn != null) {
conn.close();
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]);
}