java(2014版)连接数据库的工具类
程序员文章站
2022-03-20 09:33:01
...
package util;import java.io.IOException;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.util.Properties;public class JdbcUtil {pr
package util; import java.io.IOException; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.Properties; public class JdbcUtil { private static Connection conn; private static PreparedStatement pstmt; private static ResultSet rs; private JdbcUtil() { super(); // TODO Auto-generated constructor stub } // 连接数据库的操作 public static Connection getConn() { if (conn == null) { // 加载属性配置文件 // 创建属性对象 Properties prop = new Properties(); try { // 加载指定名称的属性文件 prop.load(JdbcUtil.class.getClassLoader().getResourceAsStream( "jdbc.properties")); try { // 根据文件的名称查找类文件 Class.forName(prop.getProperty("driver")); // 创建连接对象 try { conn = DriverManager.getConnection( prop.getProperty("url"), prop.getProperty("user"), prop.getProperty("pass")); System.out.println("连接数据库连接成功"); } catch (SQLException e) { // TODO Auto-generated catch block System.out.println("连接数据库失败"); e.printStackTrace(); } } catch (ClassNotFoundException e) { // TODO Auto-generated catch block System.out .println("没有" + prop.getProperty("driver") + "文件"); e.printStackTrace(); } } catch (IOException e) { // TODO Auto-generated catch block System.out.println("属性文件加载出错"); e.printStackTrace(); } } return conn; } public static void release(ResultSet rs, PreparedStatement pstmt) { // 释放结果集 if (rs != null) { try { rs.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } // 释放准备语句 if (pstmt != null) { try { pstmt.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } // 更新数据的操作增,删,改要用到的封装方法 public static boolean upDate(String sql, Object[] obj) { boolean flag = false; try { // 准备语句的创建,带有sql命令的对象 pstmt = getConn().prepareStatement(sql); for (int i = 1; i 0) { flag = true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { release(rs, pstmt); } return flag; } // 进行批量删除处理 public static boolean updateBatchDel(String sql, Object[] ids) { boolean flag = false; Connection conn = getConn(); PreparedStatement pstmt = null; ResultSet rs = null; try { conn.setAutoCommit(false); pstmt = conn.prepareStatement(sql); for (int i = 0; i
上一篇: Java本地接口JNI使用的方法详解
下一篇: c#(Socket)异步套接字代码示例