Java 操作數(shù)據(jù)庫

• 第一章：Java 代碼四個類實現(xiàn)
• ① 項目結(jié)構(gòu)展示
• ② 數(shù)據(jù)庫連接類
• ③ 數(shù)據(jù)庫查詢類
• ④ 數(shù)據(jù)庫更新類
• ⑤ 數(shù)據(jù)庫主類
• 第二章：查詢和更新操作實例演示
• ① 查詢操作演示
• ② 更新操作演示

第一章：Java 代碼四個類實現(xiàn)

① 項目結(jié)構(gòu)展示

需要加載數(shù)據(jù)庫驅(qū)動可以看：
Java 技術(shù)篇-IntelliJ IDEA 導(dǎo)入數(shù)據(jù)庫驅(qū)動jar包實例演示

項目結(jié)構(gòu)如下：
共分為 4 個類，分別是連接類、主類、查詢類和更新類。
其中更新類可實現(xiàn)數(shù)據(jù)庫的插入、更新和刪除的操作。

② 數(shù)據(jù)庫連接類

通過數(shù)據(jù)庫連接類返回 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數(shù)據(jù)庫static String oracleDriverClass="oracle.jdbc.driver.OracleDriver"; // oracle的驅(qū)動// mysql數(shù)據(jù)庫static String mysqlDriverClass = "com.mysql.cj.jdbc.Driver"; // mysql的驅(qū)動// 阿里云polardb數(shù)據(jù)庫static String polardbDriverClass = "com.aliyun.polardb.Driver"; // polardb的驅(qū)動static String url = "jdbc:polardb://10.10.xx.xx:5432/alitest"; // 數(shù)據(jù)庫url地址static String user = "alitest"; // 數(shù)據(jù)庫用戶名static String password = "1"; // 數(shù)據(jù)庫密碼public static Connection getConn() {/*作用：連接數(shù)據(jù)庫連接方法返回：連接的實體*/Connection conn = null;try {// 加載驅(qū)動if(db_select == "mysql") {Class.forName(mysqlDriverClass);}else if(db_select == "oracle") {Class.forName(oracleDriverClass);}else if(db_select == "polardb") {Class.forName(polardbDriverClass);}// 連接數(shù)據(jù)庫conn = DriverManager.getConnection(url, user, password);System.out.println("數(shù)據(jù)庫連接狀態(tài)：\n連接成功！");// 先抓取sql異常} catch (SQLException e) {e.printStackTrace();} catch (Exception e) {e.printStackTrace();}return conn; // 返回一個連接} }

③ 數(shù)據(jù)庫查詢類

通過數(shù)據(jù)庫查詢類執(zhí)行查詢操作，返回查詢的結(jié)果集 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) {/*作用：查詢數(shù)據(jù)庫操作返回：查詢的結(jié)果集*/Statement st = null;ResultSet rs = null;try {// statement對象用于執(zhí)行sql語句st = conn.createStatement();// 執(zhí)行sql語句并且換回一個查詢的結(jié)果集rs = st.executeQuery(sql);}catch(SQLException e){e.printStackTrace();}catch (Exception e){e.printStackTrace();}return rs;} }

④ 數(shù)據(jù)庫更新類

該類執(zhí)行數(shù)據(jù)庫的插入、更新和刪除動作，包括 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) {/*作用：插入、更新、刪除數(shù)據(jù)庫返回：影響的行數(shù)：0代表無影響*/Statement st = null;int rs = 0;try {// statement對象用于執(zhí)行sql語句st = conn.createStatement();// 執(zhí)行sql語句，成功返回修改行數(shù)，不成功返回0rs = st.executeUpdate(sql);}catch(SQLException e){e.printStackTrace();}catch (Exception e){e.printStackTrace();}return rs;} }

⑤ 數(shù)據(jù)庫主類

數(shù)據(jù)庫主類進(jìn)行查詢和更新操作演示。

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 = "";// 獲取數(shù)據(jù)庫連接conn = DBConn.getConn();// sql查詢語句sql = "select * from bd_supplier order by code asc";// 進(jìn)行查詢操作query_rs = DBQuery.getRs(conn, sql);// 顯示查詢的結(jié)果System.out.println("\n查詢操作結(jié)果如下：");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'";// 進(jìn)行更新操作update_rs = DBUpdate.getRs(conn, sql);// 顯示查詢的結(jié)果System.out.println("\n更新操作結(jié)果如下：");if(update_rs > 0){System.out.println("執(zhí)行成功！影響行數(shù)：" + update_rs + " 行！");}else if(update_rs == 0){System.out.println("無行數(shù)受到影響！");}} }

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

① 查詢操作演示

控制臺顯示出行和編碼。

// sql查詢語句 sql = "select * from bd_supplier order by code asc";// 進(jìn)行查詢操作 query_rs = DBQuery.getRs(conn, sql);// 顯示查詢的結(jié)果 System.out.println("\n查詢操作結(jié)果如下："); 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'";// 進(jìn)行更新操作 update_rs = DBUpdate.getRs(conn, sql);// 顯示查詢的結(jié)果 System.out.println("\n更新操作結(jié)果如下："); if(update_rs > 0){System.out.println("執(zhí)行成功！影響行數(shù)：" + update_rs + " 行！"); }else if(update_rs == 0){System.out.println("無行數(shù)受到影響！"); }

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

喜歡的點個贊?吧！

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。