利用jdbc mysql简单实现职员管理系统

1.安装mysql数据库，下载jdba的mysql的jar包

mysql下载：https://pan.baidu.com/s/1k0146Keg-ugsJihZaRR-Ng

jar包下载：https://pan.baidu.com/s/1LmbGGtDRVMocT_JWRxYz7A

2.创建数据库

3.在项目目录下新建文件夹lib，将jar包复制进去，右击lib文件夹选择Add as Library…，选择moudle library点击ok。

4.创建编写JDBCUtils工具类

package cn.chenlun.util;

import java.sql.*;

public class JDBCUtils {
    private static String url;
    private static String user;
    private static String password;
    private static String driver;
    /**
     * 文件的读取，只需要读取一次即可拿到这些值。使用静态代码块
     */
    private static final String USER = "root";   //你数据库的用户名
    private static final String PSD = "root";    //你数据库的密码
    private static final String URL = "jdbc:mysql:///system";  //数据库
    private static final String DRIVER = "com.mysql.jdbc.Driver";
    static{
        //读取资源文件，获取值。

        try {
            //4. 注册驱动
            Class.forName(DRIVER);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    /**
     * 获取连接
     * @return 连接对象
     */
    public static Connection getConnection() throws SQLException {

        return DriverManager.getConnection(URL, USER, PSD);
    }

    /**
     * 释放资源
     * @param stmt
     * @param conn
     */
    public static void close(Statement stmt, Connection conn){
        if( stmt != null){
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if( conn != null){
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    /**
     * 释放资源
     * @param stmt
     * @param conn
     */
    public static void close(ResultSet rs, Statement stmt, Connection conn){
        if( rs != null){
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if( stmt != null){
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if( conn != null){
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

5.创建编写增删改查方法接口和实现类

package cn.chenlun.control;

import java.sql.SQLException;

public interface Method {
    public void query() throws SQLException;
    public void add() throws SQLException;
    public void delete() throws SQLException;
    public void modify() throws SQLException;

}

package cn.chenlun.control;

import cn.chenlun.util.JDBCUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import java.util.Scanner;

public class MethodImpl implements Method {
    @Override
    
    //查询
    public void query() throws SQLException {
        Connection connection = JDBCUtils.getConnection();
        String sql = "select * from inform";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        ResultSet resultSet = preparedStatement.executeQuery();
        while (resultSet.next()) {
            String id = resultSet.getString("id");
            String name = resultSet.getString("name");
            String sex = resultSet.getString("sex");
            int queke = resultSet.getInt("queke");
            String apartment = resultSet.getString("apartment");
            int salary = resultSet.getInt("salary");

            System.out.println("工号:" + id +",姓名:" + name + ",性别:" + sex + ",缺课数:" + queke + ",系部:"
            + apartment + ",工资:" + salary);

        }
        JDBCUtils.close(resultSet,preparedStatement,connection);

    }
    
	//添加
    @Override
    public void add() throws SQLException{
        Scanner sc = new Scanner(System.in);
        System.out.println("输入添加的记录");
        System.out.println("工号");
        String id = sc.next();
        System.out.println("姓名");
        String name = sc.next();
        System.out.println("性别");
        String sex = sc.next();
        System.out.println("缺课数量");
        int queke = sc.nextInt();
        System.out.println("系部");
        String apartment = sc.next();
        System.out.println("基本工资");
        int salary = sc.nextInt();
        Connection connection = JDBCUtils.getConnection();
        String sql = "insert into inform values (?,?,?,?,?,?)";
        PreparedStatement pt = connection.prepareStatement(sql);
        pt.setString(1,id);
        pt.setString(2,name);
        pt.setString(3,sex);
        pt.setInt(4,queke);
        pt.setString(5,apartment);
        pt.setInt(6,salary);
        int resultSet = pt.executeUpdate();
        System.out.println("成功插入"+resultSet+"条记录");

    }
	
	//删除
    @Override
    public void delete() throws SQLException {
        Scanner sc = new Scanner(System.in);
        Connection connection = JDBCUtils.getConnection();
        String sql = "delete from inform where name = ?";
        System.out.println("你要删除人的姓名:");
        String s = sc.next();
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        preparedStatement.setString(1,s);
        int resultSet = preparedStatement.executeUpdate();
        System.out.println("删除了"+resultSet+"条记录");

    }
	
	//修改
    @Override
    public void modify() throws SQLException {
        Scanner scanner = new Scanner(System.in);
        Connection connection = JDBCUtils.getConnection();
        String sql = "update inform set sex=?,queke=?,apartment=?,salary=? where name = ?";
        System.out.println("输入你想修改人的姓名");
        String name = scanner.next();
        System.out.println("性别");
        String asex = scanner.next();
        System.out.println("缺课数");
        int aqueke = scanner.nextInt();
        System.out.println("系部");
        String aapartment = scanner.next();
        System.out.println("基本工资");
        int asalary = scanner.nextInt();
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        preparedStatement.setString(1,asex);
        preparedStatement.setInt(2,aqueke);
        preparedStatement.setString(3,aapartment);
        preparedStatement.setInt(4,asalary);
        preparedStatement.setString(5,name);
        int resultSet = preparedStatement.executeUpdate();
        System.out.println("成功修改"+resultSet+"条数据");
    }
}

6.创建编写主类

package cn.chenlun.domain;

import cn.chenlun.control.MethodImpl;

import java.sql.SQLException;
import java.util.Scanner;

public class Main {
    public static void main(String[] args) throws SQLException {
        while(true){
            ui();
            Scanner sc = new Scanner(System.in);
            MethodImpl m = new MethodImpl();
            int n = sc.nextInt();
            if (n == 1)
                m.query();
            else if (n == 2)
                m.add();
            else if (n == 3)
                m.modify();
            else if (n == 4)
                m.delete();
            else
                System.out.println("输入错误 请重新输入:");
        }
    }
    private static void ui() {
        System.out.println("1.查询员工信息");
        System.out.println("2.添加员工信息");
        System.out.println("3.修改员工信息");
        System.out.println("4.删除员工信息");
    }

}

最终实现

做的比较简陋,也并未使用数据库连接池,和对象的的封装。

还有改进之处，望见谅。

赏

谢谢你请我吃糖果