Java原生操作JDBC連線以及原理詳解
一、簡介
JDBC全稱又叫做Java DataBase Connectivity,也就是Java資料庫連線,說白了就是用Java語言來操作資料 庫,提供統一API訪問資料庫操作。
二、原理
JDBC主要是用於java連線資料庫的,能連線什麼資料庫不固定,其實能連線很多種資料庫,而且一般來說可以連線oracle和mysql,通常也是這兩種。但是既然JDBC能連線這麼多的資料庫,開發起來太麻煩了,於是sun公司那些人想出了一個辦法,我定義一套規範,大家都按照這個規範來,實現自己公司訪問資料庫的實現。這套規範就是JDBC,遵循了JDBC規範的,可以訪問自己資料庫的API被稱之為資料庫驅動。
三、資料庫操作
資料庫操作分為6個步驟(增、刪、改可跳過第5步,移步看第6步):
1、首先,專案中檢查是否已匯入mysql連線jar包,如:mysql-connector-java-5.1.6-bin.jar
2、使用反射註冊資料庫驅動,Class.forName(name);
3、通過DriverManager.getConnection(url,username,password)構造器獲取資料庫連線
4、通過Connection連線物件獲取資料庫操作物件PrepareStatement或者Statement
5、通過獲取的Statement物件執行executeQuery()操作返回ResultSet結果集,需判斷是否為空
6、通過獲取的Statement物件執行executeUpdate()操作返回受影響的行數,判斷是否成功標識
7、釋放連線資源,關閉順序為:ResultSet -> PrepareStatement / Statement -> Connection
解釋說明關鍵類:
(1)DriverManager:該類管理資料庫驅動程式。
(2)Connection:管理資料庫建立的連線。
(3)Statement:負責將要執行的sql體提交到資料庫。
(4)ResultSet:執行sql查詢語句返回的結果集。
(5)PreparedStatement: 可以使用預編譯的SQL,防止SQL注入,而Statment只能使用靜態的SQL。
PreparedStatement 與 Statment 區別:
語法不同: PreparedStatement可以使用預編譯的sql,而Statment只能使用靜態的sql。
效率不同: PreparedStatement可以使用sql快取區,效率比Statment高。
安全性不同: PreparedStatement可以有效防止sql注入,而Statment不能防止sql注入。
四、資料庫增、刪、改、查示例
工具類(可做相對應靈活替換):
package com.bnd.util; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Objects; /** * @author 作者 mbql: * @version 建立時間:2021年1月10日 下午5:14:16 * 類說明 JDBC操作資料庫工具類 */ public class JdbcUtils { private static final String driverName = "com.mysql.jdbc.Driver"; // 資料庫驅動名稱 private static final String url = "jdbc:mysql://39.108.146.20:3307/jsp?useUnicode=true&characterEncoding=utf-8"; // 資料庫url private static final String userName = "root"; // 使用者名稱 private static final String password = "123456"; // 使用者密碼 private static Connection conn = null; // 資料庫連線物件 private static PreparedStatement preparedStatement = null; // 執行操作物件 static { try { Class.forName(driverName); // 2、註冊資料庫驅動 conn = DriverManager.getConnection(url,userName,password); // 3、獲取資料庫連線 } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 查詢資料 * @return 返回查詢到結果 */ public static ResultSet queryData() { ResultSet result = null; String sql = "select id,name,pwd from user"; // 定義預編譯SQL try { preparedStatement = conn.prepareStatement(sql); // 4、執行預編譯SQL操作 result = preparedStatement.executeQuery(); // 5、執行查詢操作 while (result.next()) { int id = result.getInt(1); String name = result.getString(2); String pwd = result.getString(3); System.out.println("id:" + id + "--> name:" + name + "--> pwd:" + pwd); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { // 7、釋放資源 close(conn,preparedStatement,result); } return result; } /** * 新增資料 * @return 返回受影響行數 */ public static int addData() { String sql = "insert into user(name,pwd) values(?,?)"; try { preparedStatement = conn.prepareStatement(sql); // 4、執行預編譯SQL操作 preparedStatement.setString(1,"tom"); preparedStatement.setString(2,"abc123"); int count = preparedStatement.executeUpdate(); // 6、執行新增操作 if (count > 0) { return count; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { // 7、釋放資源 close(conn,null); } return -1; } /** * 更新資料 * @return 返回受影響行數 */ public static int updateData() { String sql = "update user set name = ?,pwd = ? where id = ?"; try { preparedStatement = conn.prepareStatement(sql); // 4、執行預編譯SQL操作 preparedStatement.setString(1,"sueno"); preparedStatement.setString(2,"qwe123"); preparedStatement.setInt(3,10); int count = preparedStatement.executeUpdate(); // 6、執行新增操作 if (count > 0) { return count; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { // 7、釋放資源 close(conn,null); } return -1; } /** * 刪除資料 * @return 返回受影響行數 */ public static int deleteData() { String sql = "delete from user where id = ?"; try { preparedStatement = conn.prepareStatement(sql); // 4、執行預編譯SQL操作 preparedStatement.setInt(1,11); int count = preparedStatement.executeUpdate(); // 6、執行新增操作 if (count > 0) { return count; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { // 7、釋放資源 close(conn,null); } return -1; } /** * 釋放資源 * @param conn 關閉資料庫連線 * @param statement 關閉資料庫操作物件 * @param rs 關閉結果集操作物件 */ public static void close(Connection conn,Statement statement,ResultSet rs) { if (Objects.nonNull(rs)) { try { rs.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (Objects.nonNull(statement)) { try { statement.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (Objects.nonNull(conn)) { try { conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
測試類:
package com.bnd.util; import java.sql.ResultSet; /** * @author 作者 mbql: * @version 建立時間:2021年1月10日 下午6:00:30 * 類說明 */ public class TestJdbc { public static void main(String[] args) { // 獲取使用者資料 // ResultSet rs = JdbcUtils.queryData(); // System.out.println(rs); // 新增使用者資料 // int count = JdbcUtils.addData(); // if (count > 0) { // System.out.println("新增成功!"); // } // 更新使用者資料 // int count = JdbcUtils.updateData(); // if (count > 0) { // System.out.println("更新成功!"); // } // 刪除使用者資料 // int count = JdbcUtils.deleteData(); // if (count > 0) { // System.out.println("刪除成功!"); // } } }
五、總結
1、通過簡單Jdbc連線資料庫,巧妙的實現了CRUD;其實實現並不難,記一下資料庫連線步驟就行。
2、資料庫操作本身就是一套資料庫規範,根據不同驅動能夠達到連線不同的資料庫,實現可實行操作。
3、劇上述連線可知,資料庫連線是非常耗效能的,頻繁的資料庫操作,不及時釋放資源,會導致IO阻塞。
到此這篇關於Java原生操作JDBC連線以及原理的文章就介紹到這了,更多相關Java原生操作JDBC連線及原理內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們!