`
阿尔萨斯
  • 浏览: 4110586 次
社区版块
存档分类
最新评论

【web】赵雅智_Apache—DBUtils框架详解与案例

 
阅读更多

Tip:O-R Mapping简介

  • 什么是O-R Mapping
  • 常用O-R Mapping映射工具
    • Hibernate
    • Ibatis
    • Commons DbUtils(只是对JDBC简单封装)

Apache—DBUtils框架

简介

  • commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库,它是对JDBC的简单封装,学习成本极低,并且使用dbutils能极大简化jdbc编码的工作量,同时也不会影响程序的性能。因此dbutils成为很多不喜欢hibernate的公司的首选。
  • API介绍:
    • org.apache.commons.dbutils.QueryRunner --BDManager
    • org.apache.commons.dbutils.ResultSetHandler—处理结果集
    • 工具类org.apache.commons.dbutils.DbUtils



DbUtils类

  • DbUtils :提供如关闭连接、装载JDBC驱动程序等常规工作的工具类,里面的所有方法都是静态的。主要方法如下:
    • public static void close(…) throws java.sql.SQLException: DbUtils类提供了三个重载的关闭方法。这些方法检查所提供的参数是不是NULL,如果不是的话,它们就关闭Connection、Statement和ResultSet。
    • public static void closeQuietly(…): 这一类方法不仅能在Connection、Statement和ResultSet为NULL情况下避免关闭,还能隐藏一些在程序中抛出的SQLEeception。
    • public static void commitAndCloseQuietly(Connection conn): 用来提交连接,然后关闭连接,并且在关闭连接时不抛出SQL异常。
    • public static boolean loadDriver(java.lang.String driverClassName):这一方装载并注册JDBC驱动程序,如果成功就返回true。使用该方法,你不需要捕捉这个异常ClassNotFoundException。


QueryRunner类

  • 该类简单化了SQL查询,它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作,能够大大减少编码量。
  • QueryRunner类提供了两个构造方法:
    • 默认的构造方法
    • 需要一个 javax.sql.DataSource 来作参数的构造方法。


QueryRunner类的主要方法

  • public Object query(Connection conn, String sql, Object[] params, ResultSetHandler rsh) throws SQLException:执行一个查询操作,在这个查询中,对象数组中的每个元素值被用来作为查询语句的置换参数。该方法会自行处理 PreparedStatement 和 ResultSet 的创建和关闭。
  • public Object query(String sql, Object[] params, ResultSetHandler rsh) throws SQLException: 几乎与第一种方法一样;唯一的不同在于它不将数据库连接提供给方法,并且它是从提供给构造方法的数据源(DataSource) 或使用的setDataSource 方法中重新获得 Connection。
  • public Object query(Connection conn, String sql, ResultSetHandler rsh) throws SQLException : 执行一个不需要置换参数的查询操作。
  • public int update(Connection conn, String sql, Object[] params) throws SQLException:用来执行一个更新(插入、更新或删除)操作。
  • public int update(Connection conn, String sql) throws SQLException:用来执行一个不需要置换参数的更新操作。

【实例】通过DBUtils实现增删改查
整个文件结构:


倒jar包



c3p0-config.xml

<?xml version="1.0" encoding="UTF-8"?>


<c3p0-config>
	<default-config>
		<property name="driverClass">com.mysql.jdbc.Driver</property>
		<property name="jdbcUrl">jdbc:mysql://localhost:3306/java</property>
		<property name="user">root</property>
		<property name="password">123456</property>
		
		<property name="acquireIncrement">5</property>
		<property name="initialPoolSize">10</property>
		<property name="minPoolSize">5</property>
		<property name="maxPoolSize">20</property>
		
		
	</default-config>

	<named-config name="mysql">
		<property name="driverClass">com.mysql.jdbc.Driver</property>
		<property name="jdbcUrl">jdbc:mysql://localhost:3306/java</property>
		<property name="user">root</property>
		<property name="password">123456</property>
		<property name="acquireIncrement">5</property>
		<property name="initialPoolSize">10</property>
		<property name="minPoolSize">5</property>
		<property name="maxPoolSize">20</property>
	</named-config>

</c3p0-config>


连接数据库,DBManager.java

package com.hbsi.util;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;
public class DBManager {
	private static ComboPooledDataSource ds = null;
	static{
		try{
			//创建连接池			
			ds = new ComboPooledDataSource("mysql");
		}catch(Exception e){
			e.printStackTrace();
		}
	}

	//获取链接
	public static DataSource getDataSource(){
		return ds;
	}

}

表admin映射成class类,admin.java

package com.hbsi.domain;
import java.io.Serializable;

/**
 * 把一个表admin映射(mapping)成Class类
 * 
 * @author redarmy
 * 
 */
//可序列化的接口
public class Admin implements Serializable {

	/**
	 *   id int(11) not null primary key auto_increment,---calss 成员属性
	 *   name varchar(40) unique,
	 *   pass varchar(12),
	 *   sex enum('男','女'),
	 *   role int(11)
	 *   
	 *   表                                                                                                                            class
	 *   int                                             int,Integer
	 *   varchar                                         Stirng
	 *   enum                                            Stirng
	 *   role                                            int
	 */
	private static final long serialVersionUID = 1L;
	// 把admin表中的字段映射成Admin类的成员属性(字段类型的转换如下 int --int Integer,varchar--String )
	private int id;
	private String name;
	private String pass;
	private String sex;
	private int role;

	public Admin(int id, String name, String pass, String sex, int role) {
		super();
		this.id = id;
		this.name = name;
		this.pass = pass;
		this.sex = sex;
		this.role = role;
	}

	//构造器
	public Admin() {
		super();
		// TODO Auto-generated constructor stub
	}

	public Admin(String name, String pass, String sex, int role) {
		super();
		this.name = name;
		this.pass = pass;
		this.sex = sex;
		this.role = role;
	}

	public int getId() {
		return id;
	}

	public void setId(int id) {
		this.id = id;
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public String getPass() {
		return pass;
	}

	public void setPass(String pass) {
		this.pass = pass;
	}

	public String getSex() {
		return sex;
	}

	public void setSex(String sex) {
		this.sex = sex;
	}

	public int getRole() {
		return role;
	}

	public void setRole(int role) {
		this.role = role;
	}

	@Override
	public String toString() {
		return "Admin [id=" + id + ", name=" + name + ", pass=" + pass
				+ ", role=" + role + ", sex=" + sex + "]";
	}
	
	

}

增删改查操作,ZSGC.java

package com.hbsi.dao;
import java.sql.SQLException;
import java.util.List;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.junit.Test;


import com.hbsi.domain.Admin;
import com.hbsi.util.DBManager;
public class ZSGC {
	@Test
	public void insert(){
		QueryRunner runner = new QueryRunner(DBManager.getDataSource());
		String sql ="insert into admin(id,name,pass,sex,role)values(?,?,?,?,?)";
		Object[] params ={13,"Jarry","123","男",1};
		try {
			runner.update(sql,params);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}
	@Test
	public void update() throws SQLException{
		QueryRunner runner = new QueryRunner(DBManager.getDataSource());
		String sql ="update admin set name=?,pass=? where id=?";
		Object[] params ={"xxx","xxxx",13};
		runner.update(sql,params);
	}
	@Test
	public void delete() throws SQLException{
		QueryRunner runner = new QueryRunner(DBManager.getDataSource());
		String sql ="delete from admin where id=?";
		runner.update(sql,13);	
	}
	
	@Test
	public void find() throws SQLException{
		QueryRunner runner = new QueryRunner(DBManager.getDataSource());
		String sql ="select id,name,pass from admin where id=?";
		Admin admin;
		admin = (Admin)runner.query(sql, 5,new BeanHandler(Admin.class));
		System.out.println(admin.getId()+"--"+admin.getName()+"--"+admin.getPass()+"--"+admin.getSex()+"--"+admin.getRole());
	}
	

	
	
	@Test
	public void getAll() throws SQLException {
		QueryRunner runner = new QueryRunner(DBManager.getDataSource());
		String sql = "select * from admin ";
		
		List<Admin> list = (List<Admin>) runner.query(sql, new BeanListHandler(Admin.class));
		System.out.println(list.size());
		
		for(Admin admin:list){
			System.out.println(admin.getId()+"--"+admin.getName()+"---"+admin.getPass()+"---"+admin.getSex()+"---"+admin.getRole());
		}
	}
}

原表数据:


insert方法实现,表数据变化


update方法实现,表数据变化

delete方法实现,表数据变化

select方法实现,表数据查询显示结果


selectAll方法实现,表数据查询显示结果



ResultSetHandler接口

  • 该接口用于处理 java.sql.ResultSet,将数据按要求转换为另一种形式。
  • ResultSetHandler 接口提供了一个单独的方法:Object handle (java.sql.ResultSet .rs)。



ResultSetHandler 接口的实现类

  • ArrayHandler:把结果集中的第一行数据转成对象数组。
  • ArrayListHandler:把结果集中的每一行数据都转成一个数组,再存放到List中。
  • BeanHandler:将结果集中的第一行数据封装到一个对应的JavaBean实例中。
  • BeanListHandler:将结果集中的每一行数据都封装到一个对应的JavaBean实例中,存放到List里。


ResultSetHandler 接口的实现类

  • ColumnListHandler:将结果集中某一列的数据存放到List中。
  • KeyedHandler(name):将结果集中的每一行数据都封装到一个Map里,再把这些map再存到一个map里,其key为指定的key。
  • MapHandler:将结果集中的第一行数据封装到一个Map里,key是列名,value就是对应的值。
  • MapListHandler:将结果集中的每一行数据都封装到一个Map里,然后再存放到List
【案例】接口实现类案例
HandlerDemo.java
package com.hbsi.dao;

import java.sql.SQLException;
import java.util.Arrays;
import java.util.List;
import java.util.Map;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayHandler;
import org.apache.commons.dbutils.handlers.ArrayListHandler;
import org.apache.commons.dbutils.handlers.ColumnListHandler;
import org.apache.commons.dbutils.handlers.KeyedHandler;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.junit.Test;

import com.hbsi.util.DBManager;

public class HandlerDemo {

	@Test
	public void testArrayHandler() throws SQLException{
		
		QueryRunner runner = new QueryRunner(DBManager.getDataSource());
		String sql = "select * from admin where id=?";
		Object[] params ={2};
		Object[] result = runner.query(sql, params, new ArrayHandler());
		System.out.println(Arrays.asList(result));
		
	}
	
	@Test
	public void testArrayListHandler() throws SQLException{
		
		QueryRunner runner = new QueryRunner(DBManager.getDataSource());
		String sql = "select * from admin ";
		
		List<Object[]> list =(List<Object[]>) runner.query(sql, new ArrayListHandler());
		System.out.println(list.size());
		
	}
	
	@Test
	public void testColumnListHandler() throws SQLException{
		
		QueryRunner runner = new QueryRunner(DBManager.getDataSource());
		String sql = "select * from admin ";
		
		List list = (List)runner.query(sql, new ColumnListHandler("name"));
		System.out.println(list);
		
	}
	
	@Test
	public void testKeyedHandler() throws SQLException{
		
		QueryRunner runner = new QueryRunner(DBManager.getDataSource());
		String sql = "select * from admin ";
		
		Map<Object, Map<String, Object>> map = runner.query(sql,new KeyedHandler("id"));
		
		for(Map.Entry<Object,Map<String,Object>> me :map.entrySet()){
			  Map<String,Object> innerme =me.getValue();
			  for(Map.Entry<String,Object> entry :innerme.entrySet()){
				 System.out.println( entry.getKey()+"="+entry.getValue());
			  }
		}
		
	}
	
	@Test
	public void testMapListHandler() throws SQLException{
		QueryRunner runner = new QueryRunner(DBManager.getDataSource());
		String sql = "select * from admin ";
		List list = runner.query(sql, new MapListHandler());
		System.out.println(list);
	}

}

testArrayHandler()方法测试结果


testArrayListHandler()方法测试结果

testColumnListHandler()方法测试结果

testKeyedHandler()方法测试结果


testMapListHandler()方法测试结果

使用Jdbc操作多个表

注意事项
  • 不管java的对象存在何种关系,反映到关系型数据库中,都是使用外键表示纪录(即对象)的关联关系。
  • 设计java对象如涉及到多个对象相互引用,要尽量避免使用一对多,或多对多关系,而应使用多对一描述对象之间的关系(或使用延迟加载的方式)。
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics