spring数据源

package com.guo.dataSourceDemo;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.datasource.DriverManagerDataSource;

import com.alibaba.druid.pool.DruidDataSource;

public class JunitCase {


	@Test//	1.spring jdbc
	public void test(){
//		a.连接字符串
		String url = "jdbc:mysql://localhost:3306/yun?characterEncoding=UTF8"
				+ "&user=root&password=centos"
				+ "&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&tinyInt1isBit=false";
		Connection con = null;
		Statement stmt = null;
		ResultSet result = null;
		try {
//			b.注册驱动
			Class.forName("com.mysql.jdbc.Driver");
//			c.获取连接
			con = DriverManager.getConnection(url);
//			d.获取句柄
			stmt = con.createStatement();
			String query = "select * from eac_core_biz";
//			e.执行语句
			result = stmt.executeQuery(query);
//			f.获取结果
			while(result.next()){
				String id = result.getString(1);
				String biz = result.getString(2);
				String name = result.getString(3);
				System.out.println("id:"+id+",biz:"+biz+",name:"+name);
			}
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		}finally{
//			g.关闭连接
			closeResultSet(result);
			closeStatement(stmt);
			closeConnection(con);
		}
		
	}
	
	@Test //2. spring datasource
	public void test1(){
		ApplicationContext context = new ClassPathXmlApplicationContext("context.xml");
		DriverManagerDataSource ds = (DriverManagerDataSource) context.getBean("dataSource");
		
		Connection con = null;
		Statement stmt = null;
		ResultSet result = null;
	
		try {
			con = ds.getConnection();
			stmt = con.createStatement();
			String query = "select * from eac_core_biz";
			result = stmt.executeQuery(query);
			while(result.next()){
				String id = result.getString(1);
				String biz = result.getString(2);
				String name = result.getString(3);
				System.out.println("id:"+id+",biz:"+biz+",name:"+name);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}finally{
			closeResultSet(result);
			closeStatement(stmt);
			closeConnection(con);
		}
	}
	
	@Test //3.spring Connection pooling
	public void test2(){
		ApplicationContext context = new ClassPathXmlApplicationContext("spring-pool.xml");
		DruidDataSource ds = (DruidDataSource) context.getBean("dataSource");
		
		Connection con = null;
		Statement stmt = null;
		ResultSet result = null;
	
		try {
			con = ds.getConnection();
			stmt = con.createStatement();
			String query = "select * from eac_core_biz";
			result = stmt.executeQuery(query);
			while(result.next()){
				String id = result.getString(1);
				String biz = result.getString(2);
				String name = result.getString(3);
				System.out.println("id:"+id+",biz:"+biz+",name:"+name);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}finally{
			closeResultSet(result);
			closeStatement(stmt);
			closeConnection(con);
		}
	}
	
	public void closeResultSet(ResultSet result){
		if(result!=null){
			try {
				result.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
	public void closeStatement(Statement stmt){
		if(stmt!=null){
			try {
				stmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		
	}
	public void closeConnection(Connection con){
		if(con!=null){
			try {
				con.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
	
}