為熱愛編程的你點贊！
學習SpringBoot實戰課程 https://edu.csdn.net/course/detail/31433
學習SpringCloud入門課程 https://edu.csdn.net/course/detail/31451

前言

專案開發離不開資料庫，JDBC是Java資料庫開發必須要掌握的技術，

JDBC概述

JDBC（Java Database Connectivity，Java資料庫連接）作用是：連接資料庫，對表中的資料進行增刪改查操作

JDBC的API

在java.sql包下

DriverManager類

用于管理驅動，并獲得連接物件：

• Connection getConnection(URL字串)
• Connection getConnection(URL字串,賬號,密碼)

URL字串寫法：

jdbc:mysql://資料庫服務器地址:3306/資料庫名?引數=值&引數=值

URL引數：

Connection介面

通過TCP/IP協議實作和資料庫的通信，實作連接
常用方法：

Statment介面

用于向資料庫發送SQL命令
常用方法：

ResultSet介面

用于查詢資料
常用方法：

JDBC的操作步驟

1. 下載mysql驅動包，匯入到專案中
2. 匯入驅動包中的Driver類到記憶體 Class.forName(“包名+類名”);
3. 通過DriverManager獲得Connection物件
4. 通過Connection物件獲得Statement物件
5. Statement物件執行增刪改查命令
6. 如果是查詢，獲得ResultSet物件
7. 遍歷ResultSet物件中的資料

/**
 * 測驗查詢功能
 */
public class TestQuery {

	public static final String URL = "jdbc:mysql://localhost:3306/mydb";
	
	static{
		try {
			Class.forName("com.mysql.jdbc.Driver");
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}
	}
	
	@Test
	public void testJDBC(){
		try (Connection conn = DriverManager.getConnection(URL,"root","123456")){
			Statement statement = conn.createStatement();
			String sql = "insert into students(stu_name,stu_age,stu_gender,stu_class_id) values(‘張三’,20,‘男’,1)";
			int rows = statement.executeUpdate(sql);
			if(rows > 0){
				System.out.println("執行成功");
			}else{
				System.out.println("執行失敗");
			}
			statement.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

	@Test
	public void testQuery(){
		try(Connection conn = DriverManager.getConnection(URL,"root","123456")){
			Statement st = conn.createStatement();
			String sql = "select * from students";
			//執行查詢操作，回傳結果集
			ResultSet rs = st.executeQuery(sql);
			//回圈訪問每一行
			while(rs.next()){
				//訪問每一列
				System.out.println("編號:"+rs.getInt("stu_id"));
				System.out.println("姓名:"+rs.getString("stu_name"));
				System.out.println("年齡:"+rs.getInt("stu_age"));
				System.out.println("性別:"+rs.getString("stu_gender"));
				System.out.println("班級:"+rs.getInt("stu_class_id"));
			}
			rs.close();
		}catch(SQLException ex){
			ex.printStackTrace();
		}
	}
}

PreparedStatement介面

Statement的子介面
優點：對SQL陳述句進行了預編譯，資料庫可以直接執行，更加高效和安全，
創建方法：

Connection物件.prepareStatement("SQL陳述句");

常用方法：

批處理

當需要操作大量資料時，默認情況下JDBC會單獨編譯和發送每一條SQL陳述句，執行效率比較低，
批處理：將多條陳述句打包，一起編譯，一起發送給資料庫，資料庫一起執行，
實作方法：

1. 需要關閉連接物件的自動提交
2. 創建PreparedStatement物件
3. 設定SQL陳述句和占位符
4. 呼叫PreparedStatement的addBatch方法，添加SQL命令到批處理中
5. 呼叫executeBatch()執行批處理
6. 呼叫連接物件的commit方法

/**
 * 測驗批處理
 */
public class TestBatch {
	
	public static final String URL = "jdbc:mysql://localhost:3306/mydb?user=root&password=123456";
	
	static{
		try {
			Class.forName("com.mysql.jdbc.Driver");
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}
	}
	
	//添加多個學生的資訊
	public void addStudents(List<Student> students){
		try(Connection conn = DriverManager.getConnection(URL)){
			//關閉自動提交
			conn.setAutoCommit(false);
			String sql = "insert into students(stu_name,stu_age,stu_gender,stu_class_id) values(?,?,?,?)";
			PreparedStatement ps = conn.prepareStatement(sql);
			for(Student stu : students){
				//添加一個學生的資訊
				ps.setString(1, stu.getStu_name());
				ps.setInt(2,stu.getStu_age());
				ps.setString(3, stu.getStu_gender());
				ps.setInt(4, stu.getStu_class_id());
				//添加到批處理
				ps.addBatch();
			}
			//執行批處理
			ps.executeBatch();
			//資料庫提交
			conn.commit();
		}catch(SQLException ex){
			ex.printStackTrace();
		}
	}
	
	@Test
	public void testBatch(){
		List<Student> students = Arrays.asList(new Student(1,"馬八",20,"男",1),
				new Student(1,"馬大八",30,"男",1),new Student(1,"馬小八",10,"男",1));
		addStudents(students);
	}
}

資料庫連接池

創建資料庫連接物件需要消耗比較多時間和記憶體，連接池開辟一個池，在池中放置一定數量的連接物件，用戶使用連接物件后，連接不會直接銷毀，而是回到池中，做其它操作時可以直接利用，減少連接物件的創建次數，從而提高程式的性能，

常用連接池

• C3p0
  開源的，成熟的，高并發第三方資料庫連接池，檔案資料完善，hibernate框架就使用了c3p0
• dbcp
  由Apache開發的一個資料庫連接池，在tomcat7版本之前都是使用dbcp作為資料庫連接池，
• Druid
  阿里巴巴的連接池，Druid能夠提供強大的監控和擴展功能，
• BoneCP
  其官方說該資料庫連接池性能非常棒，不過現在已經不更新了，轉到了HiKariCP上，
• HiKariCP
  Hikari是日語光的意思，作者可能想以此來表達HiKariCP速度之快，比之前的BoneCP性能更加強大，它官方展示了一些性能對比的資料，通過資料可以看出HiKariCP完虐c3p0，dbcp，tomcat jdbc pool等其他資料庫連接池，并且它的庫檔案差不多就130kb，非常輕巧，
• Proxool
  早期的一些專案中使用的多一些，現在該資料庫連接池原始碼已經有一陣子不更新了，

C3P0連接池的使用

步驟

1. 從官網下載jar包 http://www.mchange.com/projects/c3p0/index.html
   c3p0-0.9.5.2.jar
   mchange-commons-java-0.2.11.jar
2. 創建ComboPooledDataSource物件
3. 配置連接池物件
4. 呼叫getConnection獲得連接
5. 執行CRUD操作
6. 關閉連接，讓連接回到池中

組態檔
src下添加：c3p0-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
  <default-config>
  	<!-- 必填 -->
  	<!-- 驅動類 -->
  	<property name="driverClass">com.mysql.jdbc.Driver</property>
  	<!-- URL -->
  	<property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb</property>
  	<!-- 賬號 -->
  	<property name="user">root</property>
  	<!-- 密碼 -->
  	<property name="password">123456</property>
  	<!-- 可選 -->
  	<!-- 初始連接數 -->
    <property name="initialPoolSize">10</property>
    <!-- 最大閑置時間 -->
    <property name="maxIdleTime">30</property>
    <!-- 最大連接數 -->
    <property name="maxPoolSize">100</property>
    <!-- 最小連接數 -->
    <property name="minPoolSize">10</property>
    <!-- 最大SQL陳述句數 -->
    <property name="maxStatements">200</property>
  </default-config>
</c3p0-config>

案例：使用JDBC+連接池+反射撰寫基本的ORM框架

常見的ORM（物件關系映射）框架，如Hibernate、MyBatis能通過對Java物件的操作，完成對資料庫的增刪改查，下面模擬其中的保存操作，
需求：

1. 通用的save方法
2. 引數是Java物件
3. 可以向任何表插入一條資料

問題：

1. 不同表的save方法，引數型別不一樣
2. insert陳述句是不一樣的

分析：

1. 將引數設定為Object
2. 將物體類名、屬性名設定成和表名、欄位名一致
3. 通過反射讀取物件的類名，屬性名，動態拼接SQL陳述句
4. 呼叫getXXX方法，將值設定到SQL陳述句中

/**
 * JDBC工具類
 */
public class JDBCUtils {

	//連接池物件
	private static ComboPooledDataSource dataSource = new ComboPooledDataSource();
	
	/**
	 * 保存任意物件的資料到表中
	 * @param obj
	 */
	public static void save(Object obj){
		//獲得物件的型別物件
		Class clazz = obj.getClass();
		//獲得類名
		String className = clazz.getSimpleName();
		StringBuilder stb = new StringBuilder("insert into ");
		stb.append(className+"(");
		//獲得所有的屬性
		Field[] fields = clazz.getDeclaredFields();
		//i = 1跳過第一列自動增長主鍵
		for(int i = 1;i < fields.length;i++){
			stb.append(fields[i].getName()+",");
		}
		//洗掉最后的,
		stb.deleteCharAt(stb.length() - 1);
		stb.append(") values (");
		//添加?
		for(int i = 1;i < fields.length;i++){
			stb.append("?,");
		}
		//洗掉最后的,
		stb.deleteCharAt(stb.length() - 1);
		stb.append(")");
		System.out.println("test sql--- "+stb.toString());
		//添加資料
		try(Connection conn = dataSource.getConnection()){
			PreparedStatement ps = conn.prepareStatement(stb.toString());
			//設定SQL陳述句中的引數
			for(int i = 1;i < fields.length;i++){
				String fname = fields[i].getName();
				String mname = "get" + fname.substring(0, 1).toUpperCase() + fname.substring(1);
				System.out.println("method:"+mname);
				//呼叫方法獲得回傳值，給SQL引數賦值
				Method m = clazz.getMethod(mname);
				ps.setObject(i, m.invoke(obj));
			}
			//執行SQL
			ps.executeUpdate();
			System.out.println("添加完成！！！");
		}catch(Exception ex){
			ex.printStackTrace();
		}
	}
}

結束

作業：定義findAll方法，查詢不同的表，回傳不同型別的集合
問題：

1. 表的名稱不同
2. 回傳值型別不同

分析：

1. 給findAll傳Class引數，通過getSimpleName獲得類名，就是表名
2. 使用泛型方法，通過T來代替型別，具體型別由Class引數傳入

public static <T> List<T> findAll(String sql,Class clazz){

}

3. 使用反射實作SQL拼接
4. 從結果集中讀取資料后，動態創建物件，呼叫所有的setXXX方法，給物件賦值

大家如果需要學習其他Java知識點，戳這里 超詳細的Java知識點匯總