JDBC學習

来源:https://www.cnblogs.com/apollospotatolikett/archive/2018/04/27/8964954.html
-Advertisement-
Play Games

JDBC學習 "1. 概述" "2. 相關介面" "3. 連接資料庫" "4. 資源釋放" "5. 工具類抽取" "6. 數據操作" "7. 資料庫連接池" 1. 概述 JDBC是Java連接資料庫的一個API。它允許用戶訪問任何形式的表格數據，尤其是存儲在關係資料庫中的數據。 1.1 載入驅動包: ...


JDBC學習

1. 概述

JDBC是Java連接資料庫的一個API。它允許用戶訪問任何形式的表格數據，尤其是存儲在關係資料庫中的數據。

1.1 載入驅動包:

<!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>6.0.6</version>
</dependency>

1.2 執行流程：

  • 連接數據源，如：資料庫。
  • 為資料庫傳遞查詢和更新指令。
  • 處理資料庫響應並返回的結果。

2. 相關介面

2.1 DriverManager

作用:

  • 註冊驅動：實際開發中利用反射獲取驅動實例
  • 獲得連接：使用getConnection()方法獲得資料庫連接
Connection getConnection(String url, String username, String password);
/** url寫法：jdbc:mysql://localhost:3306/dbname
*   jdbc: 協議
*   mysql: 子協議
*   localhost: 主機名
*   3306: 預設埠號
*   dbname: 資料庫名字
*   預設url簡寫: jdbc:mysql:///dbname 
*/
// username: 資料庫連接賬號
// password：資料庫連接密碼

2.2 Connection

作用:

  • 創建執行SQL語句對象：
// 1. 執行SQL語句，有SQL註入漏洞
Statement createStatement()
// 2. 預編譯SQL語句，解決SQL註入漏洞
PreparedStatement prepareStatement(String sql)
// 3. 執行SQL中存儲過程
CallableStatement prepareCall(String sql)
  • 進行事務管理
// 設置事務是否自動提交
setAutoCommit(boolean autoCommit)
// 事務提交
commit()
// 事務回滾
rollback()

2.3 Statement

作用

  • 執行SQL
// 執行SQl，執行select語句後返回true，否則返回false
boolean execute(String sql)
// 執行SQL中的select語句，並將結果封裝
ResultSet executeQuery(String sql)
// 執行SQL中的insert/update/delete語句，返回受影響行數
int executeUpdate(String sql)
  • 執行批處理
    批處理一次最好不要大於500條
// 添加到批處理
addBatch(String sql)
// 執行批處理
executeBatch()
// 清空批處理
clearBatch()

2.4 ResultSet

結果集：即查詢語句(select)語句查詢結果的封裝

作用

  • 獲取查詢到的結果
// 使用 next() 驗證是否有下一個數據，有則返回true
rs.next()
// 使用 getXXX() 獲取數據
rs.getInt("id")
rs.getString()
// 獲取通用數據使用 getObject()
rs.getObject()

3. 連接資料庫

3.1 載入驅動程式：

// 通過反射獲得驅動，driverClass代表驅動類名
Class.forName(driverClass)
// 載入MySql驅動
Class.forName("com.mysql.jdbc.Driver")
// 載入Oracle驅動
Class.forName("oracle.jdbc.driver.OracleDriver")

3.2 獲得資料庫連接：

// 獲得本地預設資料庫
DriverManager.getConnection(jdbc:mysql://localhost:3306/dbname, root, root);

4. 資源釋放

  • 由於Connection對象是非常稀有的資源，用完之後應該立馬釋放。如果不能及時，正確的關閉容易導致系統宕機。Connection使用原則是儘量晚創建，儘量早釋放。
  • ResultSet、Statement 使用完後也需要及時的釋放
// 使用close()方法釋放資源
if(rs!= null){
	try {
		rs.close();
	} catch (SQLException e) {
		e.printStackTrace();
	}
	    rs = null;
	}
// 	PreparedStatement/Connection 同理釋放

5. 工具類抽取

由於註冊驅動、獲得連接以及資源釋放都是重覆操作。可以將這這些代碼抽取到一個工具類中，可以提高代碼重用。同時也可以將一些資料庫參數配置信息寫到一個配置文件中。

5.1 配置文件

# 文件名：jdbc.properties
driverClass=com.mysql.jdbc.Driver
url=jdbc:mysql:///dbname
username=root
password=root

5.2 工具類

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

//JDBC的工具類
public class JDBCUtils {
	private static final String driverClass;
	private static final String url;
	private static final String username;
	private static final String password;
	
	static{
		// 載入屬性文件並解析：
		Properties props = new Properties();
		// 使用類的載入器的方式進行獲取：
		InputStream is = JDBCUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");
		try {
			props.load(is);
		} catch (IOException e) {
			e.printStackTrace();
		}
		driverClass = props.getProperty("driverClass");
		url = props.getProperty("url");
		username = props.getProperty("username");
		password = props.getProperty("password");
	}

	/**
	 * 註冊驅動的方法
	 * @throws ClassNotFoundException 
	 */
	public static void loadDriver() throws ClassNotFoundException{
		Class.forName(driverClass);
	}
	
	/**
	 * 獲得連接的方法:
	 * @throws SQLException 
	 */
	public static Connection getConnection() throws Exception{
		loadDriver();
		Connection conn = DriverManager.getConnection(url, username, password);
		return conn;
	}
	
	/**
	 * 資源釋放方法1
	 */
	public static void release(PreparedStatement pstmt,Connection conn){
		if(pstmt != null){
			try {
				pstmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			pstmt = null;
		}
		if(conn != null){
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			conn = null;
		}
	}
	/**
	 * 資源釋放方法2
	 */
	public static void release(ResultSet rs,PreparedStatement pstmt,Connection conn){
		if(rs!= null){
			try {
				rs.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			rs = null;
		}
		if(pstmt != null){
			try {
				pstmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			pstmt = null;
		}
		if(conn != null){
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			conn = null;
		}
	}
}

6. 數據操作

即增刪改查（CRUD）操作，一般使用PreparedStatement來避免SQL註入漏洞。 下麵操作使用工具類獲取資料庫連接。

6.1 增加數據

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
// 導入工具類
import com.test.jdbc.utils.JDBCUtils; 
public class JDBCTest {
    public void insert(){
        Connection conn = null;
		PreparedStatement pstmt = null;
		try{
			// 獲得連接:
			conn = JDBCUtils.getConnection();
			// 編寫SQL:
			String sql = "insert into user values (null,?,?,?)";
			// 預處理SQL:
			pstmt = conn.prepareStatement(sql);
			// 設置參數的值:
			pstmt.setString(1, "hahaha");
			pstmt.setString(2, "12345");
			pstmt.setString(3, "小明");
			// 執行SQL:
			int num = pstmt.executeUpdate();
			if(num > 0){
				System.out.println("保存成功！");
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			// 釋放資源
			JDBCUtils.release(pstmt, conn);
		}
    }
}

6.2 修改數據

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
// 導入工具類
import com.test.jdbc.utils.JDBCUtils; 
public class JDBCTest {
     public void update(){
        Connection conn = null;
		PreparedStatement pstmt = null;
		try{
			// 獲得連接:
			conn = JDBCUtils.getConnection();
			// 編寫SQL:
			String sql = "update user set username = ?,password = ?,name = ? where uid = ?";
			// 預編譯SQL:
			pstmt = conn.prepareStatement(sql);
			// 設置參數:
			pstmt.setString(1, "hahaha");
			pstmt.setString(2, "123456");
			pstmt.setString(3, "小六");
			pstmt.setInt(4, 6);
			// 執行SQL:
			int num = pstmt.executeUpdate();
			if(num > 0){
				System.out.println("修改成功！");
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			JDBCUtils.release(pstmt, conn);
		}
     }
}

6.3 刪除數據

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
// 導入工具類
import com.test.jdbc.utils.JDBCUtils; 
public class JDBCTest {
     public void delete(){
        Connection conn = null;
		PreparedStatement pstmt = null;
		try{
			// 獲得連接:
			conn = JDBCUtils.getConnection();
			// 編寫SQL：
			String sql = "delete from user where uid = ?";
			// 預編譯SQL:
			pstmt = conn.prepareStatement(sql);
			// 設置參數:
			pstmt.setInt(1, 6);
			// 執行SQL:
			int num = pstmt.executeUpdate();
			if(num > 0){
				System.out.println("刪除成功！");
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			JDBCUtils.release(pstmt, conn);
		}
     }
}

6.4 查詢數據

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
// 導入工具類
import com.test.jdbc.utils.JDBCUtils; 
public class JDBCTest {
    // 查詢一條
     public static void selectOne(){
        Connection conn = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		try{
			// 獲得連接:
			conn = JDBCUtils.getConnection();
			// 編寫SQL：
			String sql = "select * from user where uid = ?";
			// 預編譯SQL:
			pstmt = conn.prepareStatement(sql);
			// 設置參數:
			pstmt.setObject(1, 3);
			// 執行SQL:
			rs = pstmt.executeQuery();
			// 判斷結果集:
			if(rs.next()){
				System.out.println(rs.getInt("uid")+"  "+rs.getString("username")+"  "+rs.getString("password")+"  "+rs.getString("name"));
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			JDBCUtils.release(rs, pstmt, conn);
		}
     }
     
    // 查詢全部
    public static void selectAll(){
        Connection conn = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		try{
			// 獲得連接:
			conn = JDBCUtils.getConnection();
			// 編寫SQL:
			String sql = "select * from user";
			// 預編譯SQL:
			pstmt = conn.prepareStatement(sql);
			// 設置參數
			// 執行SQL:
			rs = pstmt.executeQuery();
			while(rs.next()){
				System.out.println(rs.getInt("uid")+"  "+rs.getString("username")+"  "+rs.getString("password")+"  "+rs.getString("name"));
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			JDBCUtils.release(rs, pstmt, conn);
		}
    }
}

7. 資料庫連接池

7.1 連接池

連接池是創建和管理一個連接的緩衝池技術，這些連接準備好被任何需要他們的線程使用。

  • 應用程式直接獲得連接的缺點： 用戶每次請求都需要向資料庫獲得連接，而資料庫創建連接通常需要消耗相對較大的資源，創建時間也較長。這樣極大的浪費資料庫的資源，並且極易造成資料庫伺服器記憶體溢出。
  • 使用連接池：用戶請求的連接直接從連接池中獲取，使用完畢後再放回連接池。只需維持較少的連接就可以滿足大量用戶需求。

7.2 C3P0連接池

導入jar包

<!-- https://mvnrepository.com/artifact/c3p0/c3p0 -->
<dependency>
    <groupId>c3p0</groupId>
    <artifactId>c3p0</artifactId>
    <version>0.9.1.2</version>
</dependency>

使用方法

  • 添加配置文件
# 文件名 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:///dbname</property>
	<property name="user">root</property>
	<property name="password">abc</property>
	// 初始化線程池
	<property name="initialPoolSize">5</property>
	// 設置最大線程池大小
	<property name="maxPoolSize">20</property>
  </default-config>
  
</c3p0-config>
  • 使用C3P0編寫工具類
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class JDBCUtils2 {
    // 初始化連接池
	private static final ComboPooledDataSource dataSource = new ComboPooledDataSource();
	
	/**
	 * 獲得連接的方法:
	 * @throws SQLException 
	 */
	public static Connection getConnection() throws Exception{
		Connection conn = dataSource.getConnection();
		return conn;
	}
	
	/**
	 * 資源釋放方法1
	 */
	public static void release(PreparedStatement pstmt,Connection conn){
		if(pstmt != null){
			try {
				pstmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			pstmt = null;
		}
		if(conn != null){
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			conn = null;
		}
	}
	/**
	 * 資源釋放方法2
	 */
	public static void release(ResultSet rs,PreparedStatement pstmt,Connection conn){
		if(rs!= null){
			try {
				rs.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			rs = null;
		}
		if(pstmt != null){
			try {
				pstmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			pstmt = null;
		}
		if(conn != null){
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			conn = null;
		}
	}
}

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 16 元類
    面向對象學習目錄 1 面向對象介紹 2 類、實例、屬性、方法詳解 3 面向過程與面向對象進一步比較 4 類與對象 5 屬性查找與綁定方法 6 小結 7 繼承與派生 8 組合 9 抽象類 10 多態 11 封裝 12 綁定方法與非綁定方法 13 內置方法（上） 14 內置方法（中）之描述符 15 內置 ...
  • python類屬性在繼承中的修改的影響
    1 class A(object): 2 x = 1 3 4 class B(A): 5 pass 6 7 class C(A): 8 pass 9 10 # 通過父類修改類屬性,子類繼承的類屬性也改變 11 A.x = 3 12 print(A.x, B.x, C.x) 13 # 通過子類修改繼承... ...
  • 我用Python進行情感分析，讓程式員和女神牽手成功
    Python，Python,web,爬蟲,開發,機器學習,人工智慧,數據分析,資料庫,編程,基礎入門 先用電影評論來做情感分析，要看到最後哦 ...
  • 學習java前端 兩種form表單提交方式
    第一種：原生方式 註意點：button標簽的style為submit 第二種：Jquery校驗方式 註意點：button標簽的style為button 流程：點擊提交，首先觸發submitForm()方法，執行校驗及id選擇器，最後提交form表單。 ...
  • C++字元串分割(一) 個人總結向，基於strtok()的實作，面向少打一點代碼
    《前言》 <cstring>中有一函式 char * strtok ( char * str, const char * delimiters ); 常用來處理C風格陣列的分割問題。其中str是待分割字元串，delimiters 是分割符字元串，舉列說現在有 str[] = "ab,cd,efg,. ...
  • php魔術方法__tostring的應用
    當echo一個對象的時候，會報錯誤 Object of class Person could not be converted to string 我們可以通過魔術方法__tostring() 把對象轉成字元串 繼續改造php靜態變數與方法與phar的使用 ghostconfig.php ghost ...
  • 鐵樂學python_day28_模塊學習3
    什麼是模塊？ 常見的場景：一個模塊就是一個包含了python定義和聲明的文件，文件名就是模塊名字加上.py的尾碼。 但其實import載入的模塊分為四個通用類別：　 　　1 使用python編寫的代碼（.py文件） 　　2 已被編譯為共用庫或DLL的C或C++擴展 　　3 包好一組模塊的包 　　4 ... ...
  • 面向對象編程
    面向對象和麵向過程 二者都是一種思想，面向對象是面向過程而言的，面向過程，強調的是功能行為，面向對象，將功能封裝進對象，強調具備功能的對象 面向對象更加強調運用人類在日期的思維方式 面向對象的三大特征：封裝、集成、多態 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類