Java 使用控制台操作實現數據庫的增刪改查

使用控制台進行數據庫增刪改查操作，首先創建一個Java Bean類，實現基礎數據的構造，Get,Set方法的實現，減少代碼重復性。

基本屬性為 學生學號 Id, 學生姓名 Name，學生性別 Sex， 學生年齡 Age

public class Student {
    
    //學生類需要的屬性，都是私有的
    private String Id;
    private String Name;
    private String Sex;
    private String Age;
    
    //Get Set 方法的實現
    public String getId() {
        return Id;
    }
    public void setId(String id) {
        Id = id;
    }
    public String getName() {
        return Name;
    }
    public void setName(String name) {
        Name = name;
    }
    public String getSex() {
        return Sex;
    }
    public void setSex(String sex) {
        Sex = sex;
    }
    public String getAge() {
        return Age;
    }
    public void setAge(String age) {
        Age = age;
    }
    //構造方法
    public Student(String id, String name, String sex, String age) {
        super();
        Id = id;
        Name = name;
        Sex = sex;
        Age = age;
    }
    public Student(String string, String string2, String string3) {
        // TODO Auto-generated constructor stub
        this.Id=null;
        this.Name=string;
        this.Age=string3;
        this.Sex=string2;
    }
    

}

其次是Java Dao類，實現對數據庫的連接，和通過sql語句實現增刪改查。

getRowCount 獲取行的數量
getColumnCount獲取列的數量

//接口
Connection conn= null;
//加載 JDBC 橋的驅動程序
Class.forName("com.mysql.cj.jdbc.Driver");

String url="jdbc:mysql://localhost:3306/user？ serverTimezone=UTC&characterEncoding=UTF-8&useSSL=false";
(user 處 為數據庫名稱)
String username = "root";
String password = "101032";

//使用sql 包中的 Connection 接口，通過DriverManger 類的靜態方法getConnection()創建連接對象
conn=DriverManager.getConnection(url,username,password);

String sql="insert into students(Name,Sex,Age) values(?,?,?)";

PreparedStatement pstmt; （PreparedStatement類型執行 為動態sql 語句
如 插入 insert 更新 update 刪除 delete）
execute（String sql） 執行sql語句 返回 ResultSet 對象
executeUpdate（String sql） 執行動態的sql語句

Statement 執行靜態sql 語句
方法 execute（String sql）執行靜態 查找 select 語句，可能返回多個結果集
executeQuery(String sql) 返回單個 ResultSet 對象

/**
 * 數據庫的連接 
 * 實現數據庫的增刪改查
 */
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import com.Bean.Student;

public class DAO {
    
    private static Connection getConn() {
        Connection conn =null;
        
        try {
            //加載 JDBC 橋的驅動程序
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } // 加載對應驅動
        
        //通過數據庫的 url 訪問數據庫
        String url="jdbc:mysql://localhost:3306/user?serverTimezone=UTC&characterEncoding=UTF-8&useSSL=false";
        //mysql 數據庫的用戶名
        String username = "root";
        //mysql 數據庫密碼
        String password = "101032";
        
        try {
            //使用sql 包中的 Connection 接口，通過DriverManger 類的靜態方法getConnection()創建連接對象
            conn=DriverManager.getConnection(url,username,password);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        return conn;
    }
    
    //數據庫查找操作
    public static int insert(Student student) {
        // Connection 接口代表與特定的數據庫連接  並在連接上下文中執行sql 語句
        Connection conn = getConn();
        int i=0;
        // sql 語句的查找             Name，Sex，Age  插入的數據屬性
        String sql="insert into students(Name,Sex,Age) values(?,?,?)";
        PreparedStatement pstmt;
        
        try {
            //執行 動態的sql 語句
            pstmt = conn.prepareStatement(sql);
            //將獲取到的 Name，Sex，Age 的數據插入到指定的位置
            pstmt.setString(1, student.getName());
            pstmt.setString(2, student.getSex());
            pstmt.setString(3, student.getAge());
            i=pstmt.executeUpdate();
            pstmt.close();
            conn.close();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }        
        
        return i;
    }
    
    //數據庫的修改
    public static int updata(Student student) {
        // Connection 接口代表與特定的數據庫連接  並在連接上下文中執行sql 語句
        Connection conn= getConn();
        int i=0;
        // sql語句實現數據庫修改  按名字修改年齡
        String sql =  "update students set Age='" + student.getAge() + "' where Name='" + student.getName() + "'";
        // PreparedStatement 執行動態的sql語句 如增刪改
        PreparedStatement pstmt;
        try {
            pstmt = conn.prepareStatement(sql);
                 //執行動態的sql語句  包含insert update delete 
            i = pstmt.executeUpdate();
            if(i>0) {
                System.out.println("修改成功！");
            }else {
                System.out.println("未找到需要修改的數據！");
            }
            System.out.println("restult:"+i);
            // 關閉
            pstmt.close();
            //關閉數據庫連接
            conn.close();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }        
       return i;    
    }
    //ResultSet 接口 暫存數據庫的查詢結果
    
    //數據庫的查找
    public static Integer getAll() {
        // Connection 接口代表與特定的數據庫連接  並在連接上下文中執行sql 語句
        Connection conn= getConn();
        String sql="select * from students";
        //PreparedStatement類型執行動態的sql語句     Statement 執行靜態語句
        PreparedStatement pstmt;
        
        try {
            //執行sql語句  
            pstmt = conn.prepareStatement(sql);
            // 執行給定的sql語句返回單個 ResultSet 對象
            ResultSet rs = pstmt.executeQuery();
            // getMetaData()  檢索此 ResultSet對象列的數量，類型和屬性。 getColumnCount() 返回ResultSet對象列的數量 
            int col =rs.getMetaData().getColumnCount();
            System.out.println("============================");
            while(rs.next()) {
                for(int i=1;i<=col;i++) {
                    //輸出獲取到的數據庫數據
                    System.out.print(rs.getString(i)+"\t");
                    if((i==4)&&(rs.getString(i).length()<8)){
                        System.out.println();
                    }
                }
                //分行
                System.out.println();
            }
            System.out.println("======================");
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return null;
        
    }
    
    //數據庫的刪除
    public static int delete(String name) {
        // Connection 接口代表與特定的數據庫連接  並在連接上下文中執行sql 語句
        Connection conn =getConn();
        int i=0;
        //修改類型的sql 語句實現
        String sql="delete from students where Name ='"+ name+ "'";
        PreparedStatement pstmt;
        
        try {
            // 執行動態sql語句
            pstmt = conn.prepareStatement(sql);
            // executeUpdate() 指示受影響的行數
            i = pstmt.executeUpdate();
            if(i>0) {
            System.out.println("刪除成功！");
            }else {
                System.out.println("未找到需要刪除數據！");
            }
            System.out.println("result:"+i);
            pstmt.close();
            conn.close();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        return i;
    }

}

Sevrelt層 實現數據庫的操作，給出界面

在控制台輸入數據時：出現輸入亂碼的問題，原因：輸入數據是為漢語輸入法，產生亂碼，所以在輸入數據的時候要注意切換成英文輸入法。

package com.JDBC;

import java.util.Scanner;

import com.Bean.Student;
import com.Dao.DAO;

public class JDBC {
    @SuppressWarnings("resource")
    public static void main(String[] args) {
        String name=null;
        String sex=null;
        String age=null;
        Scanner sc=null;
        do {
            //界面
            System.out.println("  ~~~~~~~~~~~~~~歡迎使用數據庫~~~~~~~~~~~~~~   ");
            System.out.println("請選擇你需要執行的操作的編號：");
            System.out.println("1.添加數據  2.刪除數據 3.修改數據 4.查詢數據");
            System.out.println("~~~~~~~~~~~~~~請輸入您的操作~~~~~~~~~~~~~~");
            sc=new Scanner(System.in);
            int c=sc.nextInt();
            switch(c) {
            case 1:
                //添加數據
                System.out.println("添加數據:");
                System.out.println("請輸入學生 姓名，性別，年齡：");
                sc=new Scanner(System.in);
                name=sc.next();
                sex=sc.next();
                age=sc.next();
                DAO.insert(new Student(name,sex,age));
                DAO.getAll();
                break;
            case 2:
                //刪除數據
                System.out.println("刪除數據:");
                System.out.println("請輸入學生 姓名：");
                sc=new Scanner(System.in);
                name=sc.next();
                DAO.delete(name);
                DAO.getAll();
                break;
            case 3:
                //修改數據
                System.out.println("修改數據:");
                System.out.println("請輸入需要修改的同學的姓名 和 需要修改的年齡：");
                sc=new Scanner(System.in);
                name=sc.next();
                age=sc.next();
                DAO.getAll();
                DAO.updata(new Student(name,"",age));
                break;
            case 4:
                //查詢數據
                System.out.println("查詢數據:");
                DAO.getAll();
                break;
                default:
                    System.out.println("錯誤！");
            }
        }while(true);
    }

}

 使用Navicat Premium 的可視化數據庫展示如下：