【JavaWeb】JDBC：基本操作及封装DBUtil

柔情只为你懂 2022-12-14 03:46 163阅读 0赞

## 1.连接数据库及关闭 ##

首先，肯定是引入相应数据库的jar包，然后连接数据库的基本流程：DriverManger -> Connection -> Statement。这里再说一下statement：

*  一个statement执行一条sql
 *  一个Connection可以get多个statement
 *  PreparedStatement是经过预编译的Statement，更高效

// 1.注册驱动，将mysql得到驱动加载到JVM
    Class.forName("com.mysql.jdbc.Driver");
    // 2.获取连接对象，Connection
    Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/jdbc","root","123456");
    // 3.获取执行对象Statemet（PreparedStatement）
    PreparedStatement pst = conn.getPreparedStatement();
    
    // 4.crud...
    
    // 5.关闭，先开后关
    pst.close();
    conn.close();

## 2.CRUD ##

### 2.1 增/删/改 (executeUpdate) ###

public void testCUD() throws ClassNotFoundException, SQLException {
        
    	// 连接数据库
        Class.forName("com.mysql.jdbc.Driver");
        Connection conn = DriverManger.getConnection("jdbc:mysql://localhost:3306/jdbc","root","123456");
        PreparedStatement pst = conn.getPreparedStatement();
        
        // 调用 executeUpdate() 进行增删改操作，返回影响的行数
        // 注意：当要使用外部传来的参数时，有两种方案：
        //      1.SQL 拼接的方法，即通过 "+" 进行字符串拼接
        //      2.采用占位符 "?" + setObject(index，param)
        int row = pst.executeUpdate("insert into user values(？,？)");
        // 注意：这里直接 setObject 其实是偷懒的方法，正常我们应该是说清楚类型，比如 setString()，setInt()...
        pst.setObject(1,"张三")；
        pst.setObject(2,18);
        if (row > 0) {
        
            System.out.println("成功插入"+ row +"行");
        }
        
        // 改
        int row = pst.executeUpdate("update user set name='李四' where name='张三'");
        if (row > 0) {
        
            System.out.println("成功删除"+row+"行");
        }
        
        // 删
        int row = pst.executeUpdate("delete from user where id=1");
        if (row > 0) {
        
            System.out.println("成功删除"+row+"行");
        }
        
        pst.close();
        conn.close();
    }

### 2.2 查（executeQuery） ###

public void testQuery() throws ClassNotFoundException, SQLException {
        
        Class.forName("com.mysql.jdbc.Driver");
        Connection conn = DriverManger.getConnection("jdbc:mysql://localhost:3306/jdbc","root","123456");
        PreparedStatement pst = conn.getPreparedStatement();
        
        // 调用 executeQuery 进行查询，返回包含结果集的 ResultSet
        // 注意：同上面insert一样，这里也是既可采用SQL拼接，也可通过占位符+setObject()
        Resultset rs = pst.executeQuery("select * from user where id=");
        pst.setInt(1,1);
        
        // 从 ResultSet 中获取查询结果，getObject
        // 注意：getObject() 是偷懒用法，实际是要确定类型的，比如 getString()、getInt()...
        while (rs.next()) {
        
            rs.getObject("name");
            rs.getObject("age");
        }
        
        rs.close();
        pst.close();
        conn.close();
    }

## 3.封装工具类：DBUtil ##

现有JDBC存在的问题：

*  由于每个dao都需要连接，若每个dao都与数据库建立一个连接开销大 --> 一个连接产生多个statement
 *  重复代码多，比如添加数据 executeUpdate 后还需要 setObjcet

所以，可以将常用方法封装，提高代码复用。由于是工具类，所以方法都会写成static静态方法，方便调用。

public class DBUtil {
        
        // 基本配置信息
    	private static final String DriverClassName = "com.mysql.cj.jdbc.Driver";
    	private static final String URL = "jdbc:mysql://localhost:3306/jdbc?
            							serverTimezone=GMT&useSSL=false";
    	private static final String USERNAME = "root";
    	private static final String PASSWORD = "123456";
    	public static Connection con = null;
    	public static PreparedStatement pst = null;
    	public static ResultSet rs = null;
    	
    	// 创建连接
    	private static Connection getConnection() throws ClassNotFoundException, SQLException {
        
    		Class.forName(DriverClassName);
    		return DriverManager.getConnection(URL,USERNAME,PASSWORD);
    	}
    	
    	// 获取执行的statement
    	private static PreparedStatement createPreparedStatement(String sql,Object[] params) throws
            	ClassNotFoundException, SQLException {
        
    		pst = getConnection().prepareStatement(sql);
    		if(params != null) {
        
    			for(int i=0;i<params.length;++i) {
        
    				pst.setObject(i+1, params[i]);
    			}
    		}
    		return pst;
    	}
    	
    	// 封装增删改操作（executeUpdate），入参sql和参数，不用再setObject
    	public static boolean update(String sql,Object[] params) {
        
    		try {
        
    			pst = createPreparedStatement(sql, params);
    			return pst.executeUpdate() > 0;
    			
    		} catch (ClassNotFoundException e) {
        
    			e.printStackTrace();
    			return false;
    		} catch (SQLException e) {
        
    			e.printStackTrace();
    			return false;
    		}finally {
        
    			closeAll(con, pst, null);
    		}
    	}
    	
    	// 封装查询操作（excuteQuery），但还要手动解析ResultSet（也可以再封装成一个通用方法）
    	public static ResultSet query(String sql,Object[] params) {
        
    		try {
        
    			pst = createPreparedStatement(sql, params);
    			rs = pst.executeQuery();
    			return rs;
    		} catch (ClassNotFoundException e) {
        
    			e.printStackTrace();
    			return null;
    		} catch (SQLException e) {
        
    			e.printStackTrace();
    			return null;
    		}
    	}
    
    	// 关闭所有连接
    	public static void closeAll (Connection con,PreparedStatement pst,ResultSet rs) {
        
    			try {
        
    				if(rs != null)
    					rs.close();
    				if(pst != null)
    					pst.close();
    				if(con != null)
    					con.close();
    			} catch (SQLException e) {
        
    				e.printStackTrace();
    			}
    	}
    	
    }

## 4.DBCP连接池 ##

public class JDBCUtils{
        
        //创建BasicDataSource对象
    	private static BasicDataSource datasource = new BasicDataSource();
    	//静态代码块,实现必要参数设置
    	static{
        
    		datasource.setDriverClassName("com.mysql.cj.jdbc.Driver");
    		datasource.setUrl("jdbc:mysql://localhost:3306/gjp?serverTimezone=GMT&useSSL=false");
    		datasource.setUsername("root");
    		datasource.setPassword("123456");
    		datasource.setMaxActive(10);
    		datasource.setMaxIdle(5);
    		datasource.setMinIdle(2);
    		datasource.setInitialSize(10);
    	}
    	public static DataSource getDataSource(){
        
    		return datasource;
    	}
        
        // Connection conn = datasource.getConnection();
    }