Java 操作數據庫

• 第一章：Java 代碼四個類實現
• ① 項目結構展示
• ② 數據庫連接類
• ③ 數據庫查詢類
• ④ 數據庫更新類
• ⑤ 數據庫主類
• 第二章：查詢和更新操作實例演示
• ① 查詢操作演示
• ② 更新操作演示

第一章：Java 代碼四個類實現

① 項目結構展示

需要加載數據庫驅動可以看：
Java 技術篇-IntelliJ IDEA 導入數據庫驅動jar包實例演示

項目結構如下：
共分為 4 個類，分別是連接類、主類、查詢類和更新類。
其中更新類可實現數據庫的插入、更新和刪除的操作。

② 數據庫連接類

通過數據庫連接類返回 Connection 連接對象。

package com.dbmanage.db;import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException;public class DBConn {static String db_select = "polardb";// oracle數據庫static String oracleDriverClass="oracle.jdbc.driver.OracleDriver"; // oracle的驅動// mysql數據庫static String mysqlDriverClass = "com.mysql.cj.jdbc.Driver"; // mysql的驅動// 阿里云polardb數據庫static String polardbDriverClass = "com.aliyun.polardb.Driver"; // polardb的驅動static String url = "jdbc:polardb://10.10.xx.xx:5432/alitest"; // 數據庫url地址static String user = "alitest"; // 數據庫用戶名static String password = "1"; // 數據庫密碼public static Connection getConn() {/*作用：連接數據庫連接方法返回：連接的實體*/Connection conn = null;try {// 加載驅動if(db_select == "mysql") {Class.forName(mysqlDriverClass);}else if(db_select == "oracle") {Class.forName(oracleDriverClass);}else if(db_select == "polardb") {Class.forName(polardbDriverClass);}// 連接數據庫conn = DriverManager.getConnection(url, user, password);System.out.println("數據庫連接狀態：\n連接成功！");// 先抓取sql異常} catch (SQLException e) {e.printStackTrace();} catch (Exception e) {e.printStackTrace();}return conn; // 返回一個連接} }

③ 數據庫查詢類

通過數據庫查詢類執行查詢操作，返回查詢的結果集 ResultSet 對象。

package com.dbmanage.db;import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;public class DBQuery {public static ResultSet getRs(Connection conn, String sql) {/*作用：查詢數據庫操作返回：查詢的結果集*/Statement st = null;ResultSet rs = null;try {// statement對象用于執行sql語句st = conn.createStatement();// 執行sql語句并且換回一個查詢的結果集rs = st.executeQuery(sql);}catch(SQLException e){e.printStackTrace();}catch (Exception e){e.printStackTrace();}return rs;} }

④ 數據庫更新類

該類執行數據庫的插入、更新和刪除動作，包括 insert、update 和 delete。

package com.dbmanage.db;import java.sql.Connection; import java.sql.SQLException; import java.sql.Statement;public class DBUpdate {public static int getRs(Connection conn, String sql) {/*作用：插入、更新、刪除數據庫返回：影響的行數：0代表無影響*/Statement st = null;int rs = 0;try {// statement對象用于執行sql語句st = conn.createStatement();// 執行sql語句，成功返回修改行數，不成功返回0rs = st.executeUpdate(sql);}catch(SQLException e){e.printStackTrace();}catch (Exception e){e.printStackTrace();}return rs;} }

⑤ 數據庫主類

數據庫主類進行查詢和更新操作演示。

package com.dbmanage.db;import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;public class DBMain {public static void main(String[] args) throws SQLException {Connection conn = null;Statement st = null;ResultSet query_rs = null;int update_rs = 0;String sql = "";// 獲取數據庫連接conn = DBConn.getConn();// sql查詢語句sql = "select * from bd_supplier order by code asc";// 進行查詢操作query_rs = DBQuery.getRs(conn, sql);// 顯示查詢的結果System.out.println("\n查詢操作結果如下：");while (query_rs.next()) {int row_id = query_rs.getRow();String code = query_rs.getString("code");String name = query_rs.getString("name");System.out.println(row_id + " " + code);}// sql更新語句sql = "update bd_supplier set code = '0406-01' where code = '0406'";// 進行更新操作update_rs = DBUpdate.getRs(conn, sql);// 顯示查詢的結果System.out.println("\n更新操作結果如下：");if(update_rs > 0){System.out.println("執行成功！影響行數：" + update_rs + " 行！");}else if(update_rs == 0){System.out.println("無行數受到影響！");}} }

第二章：查詢和更新操作實例演示

① 查詢操作演示

控制臺顯示出行和編碼。

// sql查詢語句 sql = "select * from bd_supplier order by code asc";// 進行查詢操作 query_rs = DBQuery.getRs(conn, sql);// 顯示查詢的結果 System.out.println("\n查詢操作結果如下："); while (query_rs.next()) {int row_id = query_rs.getRow();String code = query_rs.getString("code");String name = query_rs.getString("name");System.out.println(row_id + " " + code); }

② 更新操作演示

將 0406 編碼改為 0406-01。

// sql更新語句 sql = "update bd_supplier set code = '0406-01' where code = '0406'";// 進行更新操作 update_rs = DBUpdate.getRs(conn, sql);// 顯示查詢的結果 System.out.println("\n更新操作結果如下："); if(update_rs > 0){System.out.println("執行成功！影響行數：" + update_rs + " 行！"); }else if(update_rs == 0){System.out.println("無行數受到影響！"); }

執行后可以看到有一行受到影響了，就是 0406 這一條。

喜歡的點個贊?吧！

總結

以上是生活随笔為你收集整理的Java 技术篇-java连接并操作数据库实例演示，执行查询、插入、更新和删除操作的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。