Java中JDBC的使用教程詳解

Posted on 2022-06-22 by WalkonNet

概念

Java DataBase Connectivity Java 數據庫連接， Java語言操作數據庫 JDBC本質：其實是官方（sun公司）定義的一套操作所有關系型數據庫的規則，即接口。各個數據庫廠商去實現這套接口，提供數據庫驅動jar包。我們可以使用這套接口（JDBC）編程，真正執行的代碼是驅動jar包中的實現類。

快速入門

步驟

1.導入驅動jar包

<!--MySQL數據庫驅動-->
<dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <version>8.0.27</version>
</dependency>

2.註冊驅動

3.獲取數據庫連接對象 Connection

4.定義sql

5.獲取執行sql語句的對象 Statement

6.執行sql，接受返回結果

7.處理結果

8.釋放資源

代碼實現

//1. 導入驅動jar包
//2.註冊驅動
Class.forName("com.mysql.jdbc.Driver");
//3.獲取數據庫連接對象
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db3", "root", "root");
//4.定義sql語句
String sql = "update account set balance = 500 where id = 1";
//5.獲取執行sql的對象 Statement
Statement stmt = conn.createStatement();
//6.執行sql
int count = stmt.executeUpdate(sql);
//7.處理結果
System.out.println(count);
//8.釋放資源
stmt.close();
conn.close();

詳解各個對象

DriverManager：驅動管理對象

功能：

1.註冊驅動：告訴程序該使用哪一個數據庫驅動jar

static void registerDriver(Driver driver) :註冊與給定的驅動程序 DriverManager 。寫代碼使用： Class.forName("com.mysql.jdbc.Driver"); 通過查看源碼發現：在com.mysql.jdbc.Driver類中存在靜態代碼塊

static {
    try {
        java.sql.DriverManager.registerDriver(new Driver());
    } catch (SQLException E) {
        throw new RuntimeException("Can't register driver!");
    }
}

註意：mysql5之後的驅動jar包可以省略註冊驅動的步驟。

2.獲取數據庫連接：

方法：static Connection getConnection(String url, String user, String password)

參數：

url：指定連接的路徑

語法：jdbc:mysql://ip地址(域名):端口號/數據庫名稱例子：jdbc:mysql://localhost:3306/db3 細節：如果連接的是本機mysql服務器，並且mysql服務默認端口是3306，則url可以簡寫為：jdbc:mysql:///數據庫名稱

user：用戶名
password：密碼

Connection：數據庫連接對象

功能：

獲取執行sql 的對象

Statement createStatement() PreparedStatement prepareStatement(String sql)

管理事務：

開啟事務：setAutoCommit(boolean autoCommit) ：調用該方法設置參數為false，即開啟事務提交事務：commit() 回滾事務：rollback()

Statement：執行sql的對象

1.執行sql

boolean execute(String sql) ：可以執行任意的sql 瞭解 int executeUpdate(String sql) ：執行DML（insert、update、delete）語句、DDL(create，alter、drop)語句返回值：影響的行數，可以通過這個影響的行數判斷DML語句是否執行成功返回值>0的則執行成功，反之，則失敗。 ResultSet executeQuery(String sql) ：執行DQL（select)語句

2.練習：

account表添加一條記錄
account表修改記錄
account表刪除一條記錄

代碼：

Statement stmt = null;
Connection conn = null;
try {
    //1. 註冊驅動
    Class.forName("com.mysql.jdbc.Driver");
    //2. 定義sql
    String sql = "insert into account values(null,'王五',3000)";
    //3.獲取Connection對象conn = DriverManager.getConnection("jdbc:mysql:///db3", "root", "root");
    //4.獲取執行sql的對象 Statement
    stmt = conn.createStatement();
    //5.執行sql
    int count = stmt.executeUpdate(sql);//影響的行數
    //6.處理結果
    System.out.println(count);
    if(count > 0){
        System.out.println("添加成功！");
    }else{
        System.out.println("添加失敗！");
    } 
} catch (ClassNotFoundException e) {
    e.printStackTrace();
} catch (SQLException e) {
    e.printStackTrace();
}finally {
    //stmt.close();
    //7. 釋放資源
    //避免空指針異常
    if(stmt != null){
        try {
            stmt.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    if(conn != null){
        try {
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

ResultSet：結果集對象,封裝查詢結果

boolean next(): 遊標向下移動一行，判斷當前行是否是最後一行末尾(是否有數據)，如果是，則返回false，如果不是則返回true getXxx(參數):獲取數據 Xxx：代表數據類型如： int getInt() , String getString() 參數：

int：代表列的編號,從1開始如： getString(1)
String：代表列名稱。如： getDouble("balance")

註意：使用步驟：

遊標向下移動一行
判斷是否有數據
獲取數據

//循環判斷遊標是否是最後一行末尾。
while(rs.next()){
    //獲取數據
    //6.2 獲取數據
    int id = rs.getInt(1);
    String name = rs.getString("name");
    double balance = rs.getDouble(3);
    
    System.out.println(id + "---" + name + "---" + balance);
}

PreparedStatement：執行sql的對象

SQL註入問題：在拼接sql時，有一些sql的特殊關鍵字參與字符串的拼接。會造成安全性問題
輸入用戶隨便，輸入密碼：a' or 'a' = 'a
sql：select from user where username = 'fhdsjkf' and password = 'a' or 'a' = 'a'
解決sql註入問題：使用PreparedStatement對象來解決
預編譯的SQL：參數使用?作為占位符
步驟：
導入驅動jar包 mysql-connector-java-5.1.37-bin.jar
註冊驅動
獲取數據庫連接對象 Connection
定義sql

註意：sql的參數使用？作為占位符。如：select from user where username = ? and password = ?;

獲取執行sql語句的對象 PreparedStatement Connection.prepareStatement(String sql)
給？賦值：

方法： setXxx(參數1,參數2) 參數1：？的位置編號從1 開始參數2：？的值

執行sql，接受返回結果，不需要傳遞sql語句
處理結果
釋放資源
註意：後期都會使用PreparedStatement來完成增刪改查的所有操作
可以防止SQL註入
效率更高

抽取JDBC工具類： JDBCUtils

目的：簡化書寫

分析

1.註冊驅動也抽取

2.抽取一個方法獲取連接對象

需求：不想傳遞參數（麻煩），還得保證工具類的通用性。解決：配置文件jdbc.properties

url=
user=
password=

3.抽取一個方法釋放資源

代碼實現

public class JDBCUtils {
	private static String url;
	private static String user;
	private static String password;
	private static String driver;
	/**
	 文件的讀取，隻需要讀取一次即可拿到這些值。使用靜態代碼塊
	 */
	static{
		//讀取資源文件，獲取值。

		try {
			//1. 創建Properties集合類。
			Properties pro = new Properties();

			//獲取src路徑下的文件的方式--->ClassLoader 類加載器
			ClassLoader classLoader = JDBCUtils.class.getClassLoader();
			URL res  = classLoader.getResource("jdbc.properties");
			String path = res.getPath();
			System.out.println(path);///D:/IdeaProjects/itcast/out/production/day04_jdbc/jdbc.properties
			//2. 加載文件
		   // pro.load(new FileReader("D:\\IdeaProjects\\itcast\\day04_jdbc\\src\\jdbc.properties"));
			pro.load(new FileReader(path));

			//3. 獲取數據，賦值
			url = pro.getProperty("url");
			user = pro.getProperty("user");
			password = pro.getProperty("password");
			driver = pro.getProperty("driver");
			//4. 註冊驅動
			Class.forName(driver);
		} catch (IOException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}
	}


	/**
	 獲取連接
	 @return 連接對象
	 */
	public static Connection getConnection() throws SQLException {

		return DriverManager.getConnection(url, user, password);
	}

	/**
	 釋放資源
	 @param stmt
	 @param conn
	 */
	public static void close(Statement stmt,Connection conn){
		if( stmt != null){
			try {
				stmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}

		if( conn != null){
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}


	/**
	 釋放資源
	 @param stmt
	 @param conn
	 */
	public static void close(ResultSet rs,Statement stmt, Connection conn){
		if( rs != null){
			try {
				rs.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}

		if( stmt != null){
			try {
				stmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}

		if( conn != null){
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

}

練習

需求

通過鍵盤錄入用戶名和密碼
判斷用戶是否登錄成功

select from user where username = "" and password = ""; 如果這個sql有查詢結果，則成功，反之，則失敗

步驟

1.創建數據庫表 user

CREATE TABLE USER(
	id INT PRIMARY KEY AUTO_INCREMENT,
	username VARCHAR(32),
	PASSWORD VARCHAR(32)

);

INSERT INTO USER VALUES(NULL,'zhangsan','123');
INSERT INTO USER VALUES(NULL,'lisi','234');

2.代碼實現

public class JDBCDemo9 {

	public static void main(String[] args) {
		//1.鍵盤錄入，接受用戶名和密碼
		Scanner sc = new Scanner(System.in);
		System.out.println("請輸入用戶名：");
		String username = sc.nextLine();
		System.out.println("請輸入密碼：");
		String password = sc.nextLine();
		//2.調用方法
		boolean flag = new JDBCDemo9().login(username, password);
		//3.判斷結果，輸出不同語句
		if(flag){
			//登錄成功
			System.out.println("登錄成功！");
		}else{
			System.out.println("用戶名或密碼錯誤！");
		}


	}



	/**
	 登錄方法
	 */
	public boolean login(String username ,String password){
		if(username == null || password == null){
			return false;
		}
		//連接數據庫判斷是否登錄成功
		Connection conn = null;
		Statement stmt =  null;
		ResultSet rs = null;
		//1.獲取連接
		try {
			conn =  JDBCUtils.getConnection();
			//2.定義sql
			String sql = "select from user where username = '"+username+"' and password = '"+password+"' ";
			//3.獲取執行sql的對象
			stmt = conn.createStatement();
			//4.執行查詢
			rs = stmt.executeQuery(sql);
			//5.判斷
		   /if(rs.next()){//如果有下一行，則返回true
				return true;
			}else{
				return false;
			}*/
		   return rs.next();//如果有下一行，則返回true

		} catch (SQLException e) {
			e.printStackTrace();
		}finally {
			JDBCUtils.close(rs,stmt,conn);
		}


		return false;
	}
}

JDBC控制事務

事務

一個包含多個步驟的業務操作。如果這個業務操作被事務管理，則這多個步驟要麼同時成功，要麼同時失敗。

操作

開啟事務
提交事務
回滾事務

使用Connection對象來管理事務

開啟事務：setAutoCommit(boolean autoCommit) ：調用該方法設置參數為false，即開啟事務在執行sql之前開啟事務提交事務：commit() 當所有sql都執行完提交事務回滾事務：rollback() 在catch中回滾事務

代碼

public class JDBCDemo10 {

	public static void main(String[] args) {
		Connection conn = null;
		PreparedStatement pstmt1 = null;
		PreparedStatement pstmt2 = null;

		try {
			//1.獲取連接
			conn = JDBCUtils.getConnection();
			//開啟事務
			conn.setAutoCommit(false);

			//2.定義sql
			//2.1 張三 - 500
			String sql1 = "update account set balance = balance - ? where id = ?";
			//2.2 李四 + 500
			String sql2 = "update account set balance = balance + ? where id = ?";
			//3.獲取執行sql對象
			pstmt1 = conn.prepareStatement(sql1);
			pstmt2 = conn.prepareStatement(sql2);
			//4. 設置參數
			pstmt1.setDouble(1,500);
			pstmt1.setInt(2,1);

			pstmt2.setDouble(1,500);
			pstmt2.setInt(2,2);
			//5.執行sql
			pstmt1.executeUpdate();
			// 手動制造異常
			int i = 3/0;

			pstmt2.executeUpdate();
			//提交事務
			conn.commit();
		} catch (Exception e) {
			//事務回滾
			try {
				if(conn != null) {
					conn.rollback();
				}
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
			e.printStackTrace();
		}finally {
			JDBCUtils.close(pstmt1,conn);
			JDBCUtils.close(pstmt2,null);
		}


	}

}

以上就是Java中JDBC的使用教程詳解的詳細內容，更多關於Java JDBC的資料請關註WalkonNet其它相關文章！

Java中JDBC的使用教程詳解

目錄

概念

快速入門

步驟

代碼實現

詳解各個對象

DriverManager：驅動管理對象

Connection：數據庫連接對象

Statement：執行sql的對象

ResultSet：結果集對象,封裝查詢結果

PreparedStatement：執行sql的對象

抽取JDBC工具類： JDBCUtils

分析

代碼實現

練習

JDBC控制事務

事務

操作

使用Connection對象來管理事務

代碼

推薦閱讀：

發佈留言取消回覆

近期文章

目錄

概念

快速入門

步驟

代碼實現

詳解各個對象

DriverManager：驅動管理對象

Connection：數據庫連接對象

Statement：執行sql的對象

ResultSet：結果集對象,封裝查詢結果

PreparedStatement：執行sql的對象

抽取JDBC工具類 ： JDBCUtils

分析

代碼實現

練習

JDBC控制事務

事務

操作

使用Connection對象來管理事務

代碼

推薦閱讀：

發佈留言 取消回覆

近期文章

標籤

抽取JDBC工具類： JDBCUtils

發佈留言取消回覆