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, preparedStatement, 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, preparedStatement, 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, preparedStatement, 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連接及原理內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！
推薦閱讀：
- java最新版本連接mysql失敗的解決過程
- Java 如何使用JDBC連接數據庫
- JDBC連接MySQL並實現模糊查詢
- JDBC連接的六步實例代碼（與mysql連接）
- Java之PreparedStatement的使用詳解