[大数据]Java（GUI用户登录）

1、创建数据库和表

1）创建学生数据库

CREATE DATABASE student CHARSET='utf8mb4';

2) 创建用户表

3）插入记录

2、创建用户实体类

在s09.bean里创建User类

package bean;

import java.util.Date;

/**
 * 用户实体类
 */
public class User {
    private int id;
    private String username;
    private String password;
    private String telephone;
    private Date registerTime;

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public String getTelephone() {
        return telephone;
    }

    public void setTelephone(String telephone) {
        this.telephone = telephone;
    }

    public Date getRegisterTime() {
        return registerTime;
    }

    public void setRegisterTime(Date registerTime) {
        this.registerTime = registerTime;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", username='" + username + '\'' +
                ", password='" + password + '\'' +
                ", telephone='" + telephone + '\'' +
                ", registerTime=" + registerTime +
                '}';
    }
}

3、添加数据库驱动包

• 在项目根目录里创建libs目录,添加数据库驱动包
  

4、创建数据库连接管理类

在s09.dbutils包中创建ConnectionManager类

package dbutils;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class ConnectionManager {
    // 数据库连接属性
    private static final String DRIVER = "com.mysql.cj.jdbc.Driver";
    private static final String URL = "jdbc:mysql://localhost:3306/student?useSSL=false";
    private static final String USER = "root";
    private static final String PASSWORD = "111111";

    /**
     * 私有化构造方法，拒绝实例化
     */
    private ConnectionManager() {
    }

    /**
     * 获取数据库连接静态方法
     * @return
     */
    public static Connection getConnection() {
        // 定义数据库连接
        Connection conn = null;

        // 安装数据库驱动
        try {
            Class.forName(DRIVER);
            // 获取数据库连接
            conn = DriverManager.getConnection(URL, USER, PASSWORD);
            // 提示用户数据库连接成功
            System.out.println("提示：数据库连接成功~");
        } catch (ClassNotFoundException e) {
            System.err.println("异常：数据库驱动程序未找到！");
        } catch (SQLException e) {
            System.err.println("异常：数据库连接失败！");
        }
        // 返回数据库连接
        return conn;

    }

    /**
     * 关闭数据库连接静态方法
     * @param conn
     */
    public static void closeConnection(Connection conn) {
        // 判断连接是否为空
        if (conn != null) {
            // 判断连接是否已经关闭
            try {
                if (!conn.isClosed()){
                    // 关闭数据库连接
                    conn.close();
                    // 提示用户
                    System.out.println("提示：数据库连接关闭~");
                }
            } catch (SQLException e) {
                System.err.println(e.getMessage());
            }
        }
    }

    /**
     * 主方法测试数据库连接
     */
    public static void main(String[] args) {
        // 获取数据库连接
        Connection conn = getConnection();
        // 关闭数据库连接
        closeConnection(conn);
    }
}

5、创建用户数据访问接口

• 在s09.dao包里创建UserDao接口

package dao;

import s09.bean.User;

import java.util.List;

/**
 * 功能：用户数据访问接口
 * 作者：小小榕
 * 日期：2022年06月02日
 */
public interface UserDao {
    int insert(User user);
    int delete(int id);
    int update(User user);
    User findById(int id);
    List<User> findAll();
    User login(String username, String password);
}

6、创建用户数据访问接口实现类

• 在s09.dao.impl包中创建UserDaoImpl类

package dao.impl;

import dao.UserDao;
import dbutils.ConnectionManager;
import s09.bean.User;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;

public class UserDaoImpl implements UserDao {
    @Override
    public int insert(User user) {
        return 0;
    }

    @Override
    public int delete(int id) {
        return 0;
    }

    @Override
    public int update(User user) {
        return 0;
    }

    @Override
    public User findById(int id) {
        return null;
    }

    @Override
    public List<User> findAll() {
        // 定义用户列表
        List<User> users = new ArrayList<>();

        // 获取数据库连接
        Connection conn = ConnectionManager.getConnection();
        // 创建sql字符串
        String strSQL = "select * from t_user";
        // 创建语句对象
        try {
            Statement stmt = conn.createStatement();
            // 4.执行SQL查询，返回结果集
            ResultSet rs = stmt.executeQuery(strSQL);

            while (rs.next()) {
                // 创建用户对象
                User user = new User();
                // 用当前记录字段值设置用户对现象属性
                user.setId(rs.getInt("id"));
                user.setUsername(rs.getString("password"));
                user.setPassword(rs.getString("telephone"));
                user.setRegisterTime(rs.getTimestamp("register_time"));
            }
        } catch (SQLException e) {
            System.err.println(e.getMessage());
        }finally {
            ConnectionManager.closeConnection(conn);
        }
        // 返回用户列表
        return users;
    }

    @Override
    public User login(String username, String password) {
        // 定义用户对象                                                                                
        User user = null;

        // 1. 获取数据库连接                                                                            
        Connection conn = ConnectionManager.getConnection();
        // 2. 创建SQL字符串                                                                           
        String strSQL = "select * from t_user where username = ? and password = ?";
        try {
            // 3. 创建预备语句对象（准备提供参数）                                                               
            PreparedStatement pstmt = conn.prepareStatement(strSQL);
            // 4. 用参数值设置占位符的值                                                                    
            pstmt.setString(1, username);
            pstmt.setString(2, password);
            // 5. 执行SQL查询，返回结果集                                                                  
            ResultSet rs = pstmt.executeQuery();
            // 6. 遍历结果集，用记录值填充用户对象                                                               
            while (rs.next()) {
                // 创建用户对象                                                                        
                user = new User();
                // 用当前记录字段值设置用户对象属性                                                              
                user.setId(rs.getInt("id"));
                user.setUsername(rs.getString("username"));
                user.setPassword(rs.getString("password"));
                user.setTelephone(rs.getString("telephone"));
                user.setRegisterTime(rs.getTimestamp("register_time"));
            }
        } catch (SQLException e) {
            System.err.println(e.getMessage());
        } finally {
            ConnectionManager.closeConnection(conn);
        }

        // 返回用户对象                                                                                
        return user;
    }

}

7、创建用户服务类

• 在s09.service包中创建UserService类

package service;

import dao.UserDao;
import dao.impl.UserDaoImpl;
import s09.bean.User;

import java.util.List;

public class UserService {
    private UserDao userDao;
    public UserService() {
        userDao = new UserDaoImpl();
    }

    public int addUser(User user) {
        return userDao.insert(user);
    }

    public int deleteUser(int id) {
        return userDao.delete(id);
    }

    public int updateUser(User user) {
        return userDao.update(user);
    }

    public User findUserById(int id) {
        return userDao.findById(id);
    }

    public List<User> findAllUsers() {
        return userDao.findAll();
    }

    public User login(String username, String password) {
        return userDao.login(username, password);
    }
}

8、创建用户登录界面

• 在s09.gui包里创建LoginFrame类

package gui;

import service.UserService;

import javax.swing.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyEvent;

public class LoginFrame extends JFrame {
    private String username;
    private String password;

    private JLabel lblUsername;
    private JLabel lblPassword;
    private JTextField txtUsername;
    private JPasswordField txtPassword;

    private JButton btnOK;
    private JButton btnCancel;

    private JPanel panel, panel1, panel2, panel3;

    /**
     * 有参构造方法
     *
     * @param title
     */
    public LoginFrame(String title) {
        super(title);
        initGUI(); // 调用初始化图形用户界面方法
        eventsHandling();
    }

    /**
     * 事件处理
     */
    private void eventsHandling() {
        // 给【确定】按钮注册监听器
        btnOK.addActionListener(new ActionListener() {
            @Override
            public void actionPerformed(ActionEvent e) {
                // 获取用户输入的用户名和密码
                username = txtUsername.getText().trim();
                password = new String(txtPassword.getPassword());
                // 创建用户服务对象
                UserService userService = new UserService();
                // 调用服务对象的登录方法
                s09.bean.User user = userService.login(username, password);
                // 判断用户登录是否成功
                if (user != null) {
                    // 弹出消息框提示用户
                    JOptionPane.showMessageDialog(null, "恭喜，[" + username + "]登录成功~");
                    dispose(); // 关闭登录窗口
                } else {
                    // 弹出消息框提示用户
                    JOptionPane.showMessageDialog(null, "遗憾，用户名或密码错误~");
                    // 清空两个文本框
                    txtUsername.setText("");
                    txtPassword.setText("");
                    // 让姓名文本框获取焦点
                    txtUsername.requestFocus();
                }
            }
        });

        // 给【取消】按钮注册监听器
        btnCancel.addActionListener(new ActionListener() {
            @Override
            public void actionPerformed(ActionEvent e) {
                System.exit(0); // 退出应用程序
            }
        });
    }


    /**
     * 初始化图形用户界面方法
     */
    private void initGUI() {
        // 实例化组件（面板与控件）
        panel = (JPanel) getContentPane();
        panel1 = new JPanel();
        panel2 = new JPanel();
        panel3 = new JPanel();

        lblUsername = new JLabel("用户名：");
        lblPassword = new JLabel("密    码：");
        txtUsername = new JTextField(15);
        txtPassword = new JPasswordField(15);
        btnOK = new JButton("确定[O]");
        btnCancel = new JButton("取消[C]");

        // 将控件添加到三个小面板
        panel1.add(lblUsername);
        panel1.add(txtUsername);
        panel2.add(lblPassword);
        panel2.add(txtPassword);
        panel3.add(btnOK);
        panel3.add(btnCancel);

        // 设置主面板为三行一列的网格布局
        panel.setLayout(new GridLayout(3, 1));
        // 将三个小面板依次添加到主面板
        panel.add(panel1);
        panel.add(panel2);
        panel.add(panel3);

        // 设置按钮热键字母
        btnOK.setMnemonic(KeyEvent.VK_O);
        btnCancel.setMnemonic(KeyEvent.VK_C);
        // 设置密码框回显字符
        txtPassword.setEchoChar('*');

        // 设置窗口大小
        setSize(250, 200);
        // 设置窗口屏幕居中
        setLocationRelativeTo(null);
        // 设置窗口不可调整大小
        setResizable(false);
        // 设置窗口刚好容纳组件
        pack();
        // 设置窗口可见
        setVisible(true);
        // 设置窗口默认关闭操作
        setDefaultCloseOperation(JFrame.DISPOSE_ON_CLOSE);
    }

    public static void main(String[] args) {
        new LoginFrame("用户登录");
    }
}

查看结果