JavaWeb学习-DBUtils框架-1-DBUtils简介和快速入门

野性酷女 2022-01-23 15:01 309阅读 0赞

这篇开始学习一个新的框架DBUtils,这个看起来熟悉，并不是我们前面学习自己写的DBUtils.java类。它是Apache提供的一个方便操作JDBC的框架，十分好用。

**1.什么是dbutils，它的作用**  
DBUtils是java编程中的数据库操作实用工具，小巧简单实用，是apache开发提供的。  
DBUtils封装了对JDBC的操作，简化了JDBC操作，可以少写代码。  
1.对于数据库表的读操作，它可以把结果转换成List，Array,Set等java集合，便于程序员操作。  
2.对于数据库表的写操作，也变得很简单（只需要写sql语句）  
3.可以使用数据源，使用JNDI，数据库连接池等技术来优化性能。

**2.DBUtils的三个核心对象**  
**-QueryRunner类  
\-ResultSetHandler接口  
\-DBUtils类**

QueryRunner类  
   提供对sql语句操作API，主要有三个方法  
   query()用于执行select  
   update()用于执行insert update delete sql语句  
   batch() 批处理

ResultSetHandle接口  
   用于定义select操作后，怎样封装结果集

DBUtils类  
   就是一个工具类，定义了关闭资源与事务处理的方法。

**3.DBUtils快速入门**

环境准备，准备如下项目结构

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTE1NDE5NDY_size_16_color_FFFFFF_t_70][]

User.java代码

package com.anthony.entity;
    
    import java.io.Serializable;
    import java.util.Date;
     
    public class User implements Serializable {
    	
    	private String username;
    	private String password;
    	private String email;
    	private Date birthday;
    	private int id;
    	
    	public String getUsername() {
    		return username;
    	}
    	public void setUsername(String username) {
    		this.username = username;
    	}
    	public String getPassword() {
    		return password;
    	}
    	public void setPassword(String password) {
    		this.password = password;
    	}
    	public String getEmail() {
    		return email;
    	}
    	public void setEmail(String email) {
    		this.email = email;
    	}
    	public Date getBirthday() {
    		return birthday;
    	}
    	public void setBirthday(Date birthday) {
    		this.birthday = birthday;
    	}
    	public int getId() {
    		return id;
    	}
    	public void setId(int id) {
    		this.id = id;
    	}
    	@Override
    	public String toString() {
    		return "User [username=" + username + ", password=" + password + ", email=" + email + ", birthday=" + birthday
    				+ ", id=" + id + "]";
    	}
    	
    	
    }

TestJDBC.java代码

package com.anthony.test;
    
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.util.ArrayList;
    import java.util.List;
    
    import org.apache.commons.dbutils.QueryRunner;
    import org.apache.commons.dbutils.ResultSetHandler;
    import org.junit.Test;
    
    import com.anthony.datasource.C3P0Utils;
    import com.anthony.entity.User;
    
    public class TestJDBC {
    	@Test
    	public void test() throws SQLException {
    		//创建QueryRunner对象
    		QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
    		//使用query方法执行select语句
    		List<User> list = new ArrayList<User>();
    		qr.query("select * from users", new ResultSetHandler<List<User>>() {
    			//当query执行完select语句，把结果集以参数形式传入到下面handle方法
    			public List<User> handle(ResultSet rs) throws SQLException {
    				while(rs.next()) {
    					User u = new User();
    					u.setId(rs.getInt(1));
    					u.setUsername(rs.getString(2));
    					u.setPassword(rs.getString(3));
    					u.setEmail(rs.getString(4));
    					u.setBirthday(rs.getDate(5));
    					list.add(u);
    				}
    				
    				return list;
    			}
    			
    		});
    		
    		//遍历user集合
    		for(User u : list) {
    			System.out.println(u);
    		}
    	}
    
    }

C3P0Utils.java 代码，由于上面有一个getDataSource的方法，所以这个类需要添加一个get方法。

package com.anthony.datasource;
    
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    import com.mchange.v2.c3p0.ComboPooledDataSource;
    
    public class C3P0Utils {
    	
    	private static ComboPooledDataSource dataSource = new ComboPooledDataSource();
    	
    	public static ComboPooledDataSource getDataSource() {
    		return dataSource;
    	}
    
    	public static Connection getConnection() {
    		try {
    			return dataSource.getConnection();
    		} catch (SQLException e) {
    			e.printStackTrace();
    			throw new ExceptionInInitializerError("初始化失败，请检查配置文件");
    		}
    	}
    	
    	public static void release(Connection conn, Statement stmt, ResultSet rs) {
    		if(rs != null) {
    			try {
    				rs.close();
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    			rs = null; //赶紧垃圾回收
    		}
    		if(stmt != null) {
    			try {
    				stmt.close();
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    			stmt = null;
    		}
    		if(conn != null) {
    			try {
    				conn.close();
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    			conn = null;
    		}
    	}
    
    }

运行这个junit测试类

User [username=Tom, password=123, email=tom@163.com, birthday=2011-08-08, id=1]
    User [username=Anthony, password=123456, email=anthony@163.com, birthday=2018-08-08, id=2]

上面这个JDBC测试类还是很多代码，下面采用第二种方法。

@Test
    public void test2() throws SQLException {
    	QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
    	List<User> list = qr.query("select * from users", new BeanListHandler<User>(User.class));
    	//遍历user集合
    	for(User u : list) {
    	    System.out.println(u);
    	}
    }

运行这个同样得到上面test1()的效果，第二种方式推荐，可以少些很多代码。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTE1NDE5NDY_size_16_color_FFFFFF_t_70]: /images/20220123/b4181df0669644f4972274577352e2e1.png