天天看點

Java資料庫之DBUtils架構

一、JavaBean 就是一個類,在開發中常用語封裝資料。具有如下特性 1. 需要實作接口: java.io.Serializable ,通常偷懶省略了。 2. 提供私有字段: private 類型字段名; 3. 提供 getter/setter 方法: (在JavaBean類中必須實作get、set方法,否則拿不到資料) 4. 提供無參構造

二、 DBUtils 三個核心功能介紹: 1) QueryRunner 中提供對 sql 語句操作的 API. 2) ResultSetHandler 接口,用于定義 select 操作後,怎樣封裝結果集 . 3) DBUtils 類,它就是一個工具類,定義了關閉資源與事務處理的方法。

三、  QueryRunner 核心類 •   QueryRunner(DataSource ds) :提供資料源(連接配接池), DBUtils 底層自動維護連接配接 connection •   update(Stringsql, Object... params) :執行更新資料 •   query(String sql, ResultSetHandler<T> rsh, Object…params) :執行查詢

四、 ResultSetHandler 結果集處理類  

ArrayHandler 将結果集中的第一條記錄封裝到一個 Object []數組中,數組中的每一個元素就是 這條記錄中的每一個字段的值  
ArrayListHandler 将結果集中的每一條記錄都封裝到一個 Object []數組中,将這些數組在封裝到 List 集合中。
BeanHandler 将結果集中第一條記錄封裝到一個指定的 javaBean 中。
BeanListHandler 将結果集中每一條記錄封裝到指定的 javaBean 中,将這些 javaBean 在封裝到 List 集合中
ColumnListHandler 将結果集中指定的列的字段值,封裝到一個 List 集合中
KeyedHandler 将結果集中每一條記錄封裝到 Map < String , Object >,在将這個 map 集合做為另一 個 Map 的 value ,另一個 Map 集合的 key 是指定的字段的值。
MapHandler 将結果集中第一條記錄封裝到了 Map < String , Object >集合中, key 就是字段名稱, value 就是字段值
MapListHandler 将結果集中每一條記錄封裝到了 Map < String , Object >集合中, key 就是字段名稱, value 就是字段值,在将這些 Map 封裝到 List 集合中。
ScalarHandler 它是用于單資料。例如 select count (*) from 表操作。

五、代碼實作: 1、添加資料

//添加資料
	@Test
	public void addUser() throws SQLException{
		
		//1、建立核心類QueryRunner
		QueryRunner qr = new QueryRunner(DBCPUtils.getDataSource());
		//2、填寫SQL語句
		String sql = "insert into student values(null,?,?,?,?)";
		//3、為占位符指派:
		Object[] params = {"趙曉東","22","男","123456"};
		//4、執行添加操作
		int rows = qr.update(sql, params);
		if(rows >0){
			System.out.println("Add Success!");
		}else{
			System.out.println("Add Failed");
		}	
	}
           

2、修改資料:

//修改資料
	@Test
	public void Update() throws SQLException{
		
		//1、第一種方式
//		 QueryRunner qr = new QueryRunner(DBCPUtils.getDataSource());
//		 String sql = "update student set passwd = ? where name = ?";
//		 Object[] params = {"123456","michong"};//将占位符的值放在數組中
//		 int rows = qr.update( sql, params);
		
		//2、第二種方式
		 QueryRunner qr = new QueryRunner();
		 String sql = "update student set passwd = ? where name = ?";
		 int rows = qr.update(DBCPUtils.getConnection(),sql,"12345678","michong");
		 
		 if(rows > 0 ){
			 System.out.println("Update Success");
		 }else{
			 System.out.println("Update Failed");
		 }
	}
	
           

3、查詢資料并放在List集合中

//全部查詢,并且放在List集合中
	@Test
	public void selectListALL() throws SQLException{
		QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
		String sql = "select * from student";
		//獲得結果集
		List<Student> students = qr.query(sql, new BeanListHandler<Student>(Student.class));
		System.out.println(students);
		
	}
	
	//單個查詢
	@Test
	public void selectOne() throws SQLException{
		QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
		String sql = "select * from student where id = ?";
		//獲得單個結果
		Student student = qr.query(sql, new BeanHandler<Student>(Student.class),1);
		System.out.println(student);
		
	}
           

4、查詢資料并放在Map中

//單個查詢,使用Map
	@Test
	public void selectMap() throws SQLException{
		
		QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
		String sql = "select * from student where id = ?";
		Map<String, Object> query = qr.query(sql, new MapHandler(),1);
		Set<Entry<String, Object>> entrySet = query.entrySet();
		for (Entry<String, Object> entry : entrySet) {
			System.out.print(entry.getKey()+":");
			System.out.println(entry.getValue());
			System.out.println("--------------------");	
		}
	}
	
	//多個查詢,List<Map<String,Object>>
	@Test
	public void selectMapAll() throws SQLException{
		QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
		String sql = "select * from student";
		List<Map<String, Object>> maps = qr.query(sql, new MapListHandler());
		System.out.println(maps);
	}
           

5、用于單資料。例如select count(*) from表操作。

@Test
	public void selectSingleData() throws SQLException{
		QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
		String sql = "select count(*) from student";
		//獲得查詢的數目
		long size = (long)qr.query(sql, new ScalarHandler());
		System.out.println(size);
		
	}
           

jar包下載下傳