溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章給大家介紹如何在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連接數據庫就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
