Java--JavaWeb使用commons-dbutils簡化資料庫操作

具體實作步驟：

1，使用C3P0連接配接池--這裡使用在src根目錄下建立名為c3p0-config.xml的檔案。

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
	<!-- 這是預設配置資訊 -->
	<default-config> 
		<!-- 連接配接四大參數配置 -->
		<property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb1</property>
		<property name="driverClass">com.mysql.jdbc.Driver</property>
		<property name="user">root</property>
		<property name="password">123</property>
		<!-- 池參數配置 -->
		<property name="acquireIncrement">3</property>
		<property name="initialPoolSize">10</property>
		<property name="minPoolSize">2</property>
		<property name="maxPoolSize">10</property>
	</default-config>
	
	<!-- 專門為oracle提供的配置資訊 -->
	<named-config name="oracle-config"> 
		<property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb1</property>
		<property name="driverClass">com.mysql.jdbc.Driver</property>
		<property name="user">root</property>
		<property name="password">123</property>
		<property name="acquireIncrement">3</property>
		<property name="initialPoolSize">10</property>
		<property name="minPoolSize">2</property>
		<property name="maxPoolSize">10</property>
	</named-config>

</c3p0-config>

2.建立一個JDBCUtils類，為其他類提供資料庫連接配接對象或者資料庫連接配接池（在QueryRunner中會用到資料庫連接配接池）

package com.c3p0.jdbc;

import java.sql.Connection;
import java.sql.SQLException;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;
/**
 * 注意必須使用c3p0-config.xml的配置方式。将c3p0-config.xml檔案放在src根目錄下。
 * 預設配置。
 * 
 * */
public class JDBCUtils {
	
	private static ComboPooledDataSource ds=new ComboPooledDataSource();
	/**
	 * 使用連接配接池傳回一個連接配接對象
	 * */
	public static Connection getConnection() throws SQLException{
		return ds.getConnection();
	}
	
	
	/**
	 * 傳回一個連接配接池對象。
	 * 
	 * */
	public static DataSource getDataSource(){
		return ds;
	}
}

3.編寫操作資料庫的類

package com.c3p0.demo1;

import java.sql.SQLException;

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

import com.c3p0.jdbc.JDBCUtils;

public class Demo2 {

	/**
	 * 查詢記錄
	 * @throws SQLException 
	 * 
	 * */
	@Test
	public void fun1() throws SQLException{
		//建立QueryRunner,需要提供資料庫連接配接池；
		QueryRunner qr=new QueryRunner(JDBCUtils.getDataSource());
		
		//給出sql模闆
		String sql="select * from tb_stu where number=?";
		
		//給出參數
		Object[] params={"stu_001"};
		
		
		//執行Query,需要給出結果集處理器，即ResultHandler的實作類對象
		//我們給的是BeanHandler,他實作了ResultSetHandler
		//它需要一個類型，然後他會把rs中的資料封裝到指定類型的javabean對象中，然後傳回javabean.
		Stu stu=qr.query(sql, new BeanHandler<Stu>(Stu.class),params);
		System.out.println(stu);
				
	}
	
	/**
	 * 插入新的一條記錄
	 * @throws SQLException 
	 * 
	 * */
	
	@Test
	public void fun2() throws SQLException{
		QueryRunner qr=new QueryRunner(JDBCUtils.getDataSource());
		
		String sql="insert into tb_stu values(?,?,?,?,?)";
		
		Object[] params={"stu_003","wangwu",20,"female","dancing"};
		
		int count=qr.update(sql, params);
		System.out.println("count:"+count);
	}
}

另外，還用到了JavaBean對象Stu

package com.c3p0.demo1;

public class Stu {

	private String number;
	private String name;
	private int age;
	private String gender;
	private String hobby;
	public String getNumber() {
		return number;
	}
	public void setNumber(String number) {
		this.number = number;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public int getAge() {
		return age;
	}
	public void setAge(int age) {
		this.age = age;
	}
	public String getGender() {
		return gender;
	}
	public void setGender(String gender) {
		this.gender = gender;
	}
	public String getHobby() {
		return hobby;
	}
	public void setHobby(String hobby) {
		this.hobby = hobby;
	}
	public Stu(String number, String name, int age, String gender, String hobby) {
		this.number = number;
		this.name = name;
		this.age = age;
		this.gender = gender;
		this.hobby = hobby;
	}
	public Stu() {
		super();
		// TODO Auto-generated constructor stub
	}
	@Override
	public String toString() {
		return "Stu [number=" + number + ", name=" + name + ", age=" + age
				+ ", gender=" + gender + ", hobby=" + hobby + "]";
	}

	
}

使用這種方式：

（1）将增删改操作簡化了，即同時使用一個模闆即可，隻需修改sql語句和參數即可；

（2）查詢結果直接可以通過ResultSetHandler的實作類封裝成JavaBean對象。

解析common-dbutils.jar：

QueryRunner對象

方法：

update方法：

--》int update(String sql,Object... params)：可執行增删改語句

Query方法(泛型)：

--》T Query(String sql,ResultSetHandler rsh,Object...params)：可執行查詢

他會先得到ResultSet，然後調用rsh的handle()把rs轉換成需要的類型！

ResultSetHandler接口的實作類：

（1）BeanHandler（單行）--》構造器需要一個Class類型的參數，用來把一行結果轉換成指定類型的JavaBean對象；

（2）BeanListHandler（多行）--》構造器也是需要一個Class類型的參數，用來把一行結果集轉換成一個javaBean，那麼多行就是多個JavaBean對象，組合成一個List對象。

（3）MapHandler（單行）把一行結果及轉換成Map對象

例如：一行記錄為

sid sname age gender

001 zhangsan 20 male

那麼轉換成Map就是：

{sid:001,sname:zhangan,age:20,gender:male}

（4）MapListHandler（多行）--》把一行記錄用一個Map裝起來，那麼多航記錄就是多個Map,即List<Map>

（5）ScalarHandler（單行單列）--》通常用于select count（*）from tb_stu語句。結果集是單行單列的，傳回一個object。

package com.c3p0.demo1;

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

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

import com.c3p0.jdbc.JDBCUtils;

public class Demo2 {

	/**
	 * 查詢記錄
	 * @throws SQLException 
	 * 單行結果集處理器：
	 * （1）BeanHandler單行結果集處理器。
	 * （2）MapHandler單行結果集處理器
	 * */
	@Test
	public void fun1() throws SQLException{
		//建立QueryRunner,需要提供資料庫連接配接池；
		QueryRunner qr=new QueryRunner(JDBCUtils.getDataSource());
		
		//給出sql模闆
		String sql="select * from tb_stu where number=?";
		
		//給出參數
		Object[] params={"stu_001"};
		
		
		//執行Query,需要給出結果集處理器，即ResultHandler的實作類對象
		//我們給的是BeanHandler,他實作了ResultSetHandler
		//它需要一個類型，然後他會把rs中的資料封裝到指定類型的javabean對象中，然後傳回javabean.
		
		Stu stu=qr.query(sql, new BeanHandler<Stu>(Stu.class),params);//（1）使用BeanHandler單行結果集處理器。
		
		Map map=qr.query(sql, new MapHandler(),params);//（2）使用MapHandler單行結果集處理器
		System.out.println(map);
				
	}
	
	
	/**
	 * 查詢記錄
	 * 結果集多行處理器：
	 * BeanListHandler多行結果集處理器
	 * MapListHandler多行結果集處理器
	 * 沒有參數就不用定義Object[] params={}。
	 * */
	
	@Test
	public void fun1_1() throws SQLException{
		//建立QueryRunner,需要提供資料庫連接配接池；
		QueryRunner qr=new QueryRunner(JDBCUtils.getDataSource());
		
		//給出sql模闆
		String sql="select * from tb_stu";
		
		//給出參數
		//Object[] params={};
		
		
		/*使用BeanListHandler*/
		List<Stu> list1=qr.query(sql, new BeanListHandler<Stu>(Stu.class));
		Iterator<Stu> it=list1.iterator();
		while(it.hasNext()){
			Stu s=it.next();
			System.out.println(s.toString());
		}
		
		System.out.println("-----------------------------------");
		/*使用MapListHandler*/
		List<Map<String, Object>> list2=qr.query(sql, new MapListHandler());
		Iterator<Map<String, Object>> it1=list2.iterator();	
		while(it1.hasNext()){
			Map<String,Object> map=it1.next();
			System.out.println(map);
			
		}
	}
	
	
	/**
	 * 查詢記錄
	 * 單行單列結果
	 * ScalarHandle
	 * @throws SQLException 
	 * */
	@Test
	public void fun3() throws SQLException{
		QueryRunner qr=new QueryRunner(JDBCUtils.getDataSource());
		
		String sql="select count(*) from tb_stu";
		
		Object obj=qr.query(sql, new ScalarHandler());
		
		System.out.println(obj.toString());
		
	}
	
	
	/**
	 * 插入新的一條記錄
	 * @throws SQLException 
	 * 
	 * */
	
	@Test
	public void fun2() throws SQLException{
		QueryRunner qr=new QueryRunner(JDBCUtils.getDataSource());
		
		String sql="insert into tb_stu values(?,?,?,?,?)";
		
		Object[] params={"stu_003","wangwu",20,"female","dancing"};
		
		int count=qr.update(sql, params);
		System.out.println("count:"+count);
	}
}

Java--JavaWeb使用commons-dbutils簡化資料庫操作

繼續閱讀

關于Gradle配置的小結

Java小案例——随機數猜測随機數猜測

nginx location中斜線的位置的重要性

27 Best Free Eclipse Plug-ins for Java Developer to be ProductiveCode Quality PluginsText Editor PluginsDependency ManagementVersion Control Integration PluginsFramework Development Continuous Integration Related PluginsOther Utility Plugins

Java String.format方法的簡單使用

neo4j之cypher使用文檔

GitHub連夜封殺！這份阿裡 10W 字内部 Java 字面試手冊到底有多強？

spark/scala關于【資源檔案】加載方法概述外部檔案加載方案測試資源檔案打包入jar包中小結

mybatis_入門程式Mybatis入門

AOP程式設計_Android優雅權限架構(1)概念基礎，2021金三銀四前言正文大綱正文

Effective Java 8:通用程式設計

OOM三種類型

工廠模式-三種類型

【遞歸】高效率求2的n次幂

win10本地scala和spark安裝安裝scala安裝spark

scala (3) Function 和 Method