jdbc連接mysql數據庫增刪改查demo

2019-11-08 20:59:25

字體：大中小

來源：轉載

供稿：網友

import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;public class JDBC_Test {// 創建靜態全局變量static Connection conn;static Statement st;public static void main(String[] args) {insert(); //插入添加記錄update(); //更新記錄數據delete(); //刪除記錄query(); //查詢記錄并顯示}/* 插入數據記錄，并輸出插入的數據記錄數*/public static void insert() {conn = getConnection();// 首先要獲取連接，即連接到數據庫try {String sql = "INSERT INTO staff(name, age, sex,address, depart, worklen,wage)"+ " VALUES ('Tom1', 32, 'M', 'china','Personnel','3','3000')";// 插入數據的sql語句st = (Statement) conn.createStatement();// 創建用于執行靜態sql語句的Statement對象int count = st.executeUpdate(sql);// 執行插入操作的sql語句，并返回插入數據的個數System.out.PRintln("向staff表中插入 " + count + " 條數據");//輸出插入操作的處理結果conn.close(); //關閉數據庫連接} catch (SQLException e) {System.out.println("插入數據失敗" + e.getMessage());}}/* 更新符合要求的記錄，并返回更新的記錄數目*/public static void update() {conn = getConnection();//同樣先要獲取連接，即連接到數據庫try {String sql = "update staff set wage='2200' where name = 'lucy'";// 更新數據的sql語句st = (Statement) conn.createStatement();//創建用于執行靜態sql語句的Statement對象，st屬局部變量int count = st.executeUpdate(sql);// 執行更新操作的sql語句，返回更新數據的個數System.out.println("staff表中更新 " + count + " 條數據");//輸出更新操作的處理結果conn.close(); //關閉數據庫連接} catch (SQLException e) {System.out.println("更新數據失敗");}}/* 查詢數據庫，輸出符合要求的記錄的情況*/public static void query() {conn = getConnection();//同樣先要獲取連接，即連接到數據庫try {String sql = "select * from staff";// 查詢數據的sql語句st = (Statement) conn.createStatement();//創建用于執行靜態sql語句的Statement對象，st屬局部變量ResultSet rs = st.executeQuery(sql);//執行sql查詢語句，返回查詢數據的結果集System.out.println("最后的查詢結果為：");while (rs.next()) {// 判斷是否還有下一個數據// 根據字段名獲取相應的值String name = rs.getString("name");int age = rs.getInt("age");String sex = rs.getString("sex");String address = rs.getString("address");String depart = rs.getString("depart");String worklen = rs.getString("worklen");String wage = rs.getString("wage");//輸出查到的記錄的各個字段的值System.out.println(name + " " + age + " " + sex + " " + address+ " " + depart + " " + worklen + " " + wage);}conn.close(); //關閉數據庫連接} catch (SQLException e) {System.out.println("查詢數據失敗");}}/* 刪除符合要求的記錄，輸出情況*/public static void delete() {conn = getConnection();//同樣先要獲取連接，即連接到數據庫try {String sql = "delete from staff where name = 'lili'";// 刪除數據的sql語句st = (Statement) conn.createStatement();//創建用于執行靜態sql語句的Statement對象，st屬局部變量int count = st.executeUpdate(sql);// 執行sql刪除語句，返回刪除數據的數量System.out.println("staff表中刪除 " + count + " 條數據/n");//輸出刪除操作的處理結果conn.close(); //關閉數據庫連接} catch (SQLException e) {System.out.println("刪除數據失敗");}}/* 獲取數據庫連接的函數*/public static Connection getConnection() {Connection con = null;//創建用于連接數據庫的Connection對象try {Class.forName("com.MySQL.jdbc.Driver");// 加載Mysql數據驅動con = DriverManager.getConnection("jdbc:mysql://localhost:3306/myuser", "root", "root");// 創建數據連接} catch (Exception e) {System.out.println("數據庫連接失敗" + e.getMessage());}return con; //返回所建立的數據庫連接}}

上一篇：mysql 面試（一）整理之mysql的版本

下一篇：jdbc操作數據庫做同步，全量+增量，線程控制，批處理