如何通过JDBC访问MySQL数据库?手把手实现登录界面(图解+完整代码)

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: 文章目录写在前面1 操作准备1.1 导入 Mysql 对应的 jar 包1.2 创建Mysql数据库与基本表2 JDBC基础实验2.1 编写JDBC连接MySQL数据库myuser,查询并显示account表数据实例2.2 编写JDBC连接MySQL数据库,实现myuser数据库的增、删、改查的实例3 JDBC进阶实验——简易登录界面3.1 具体实现3.2 效果展示写在最后

1 操作准备

1.1 导入 Mysql 对应的 jar 包

首先进入 Mysql 下载官网: https://www.mysql.com/downloads/,将页面滑动到底端,点击 MySQL Community (GPL) Downloads


选择 Connector/J



选择 General Availability(GA) Releases,在 Select Operating System 下拉列表选择 Platform Independent,然后选择任意一种压缩包格式的文件 Download,根据提示下载,如果需要其他版本,可以点击 Archives



下载完成后进行解压,即可在当前文件夹中看到下载好的 jar 包了。



打开 idea 创建一个项目 JDBC 并创建 Moudle JDBCtest,在该模块下创建个目录 lib,并将刚刚下载好的 jar 包拷贝过来。


‘’

右键将 jar 包, Add as Library



1.2 创建Mysql数据库与基本表

🐰 打开 datagrip,新建一个查询,通过下面的代码创建一个 myuser 数据库用于 JDBC 访问练习,并创建一个表并录入数据,具体代码及表数据如下:

CREATE DATABASE myuser;
USE myuser;
CREATE TABLE IF NOT EXISTS account(
    name VARCHAR(50) PRIMARY KEY NOT NULL ,
    password VARCHAR(50) NOT NULL
);
INSERT INTO account VALUES ('张三', '123');
INSERT INTO account VALUES ('李四', '123');



2 JDBC基础实验

2.1 编写JDBC连接MySQL数据库myuser,查询并显示account表数据实例

🐻 1. 先创建项目、包及 Test.java,如下图所示:



🐦 2.运行下面的JDBC代码,代码后附运行结果图,记得将数据库密码(你的密码)位置处改成自己的密码:


package JDBC_test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
/**
 * @author 小黄小黄不再迷茫
 * @version 1.0
 */
public class Test {
    public static void main(String args[]) {
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");     //加载MYSQL JDBC驱动程序
            System.out.println("Success loading Mysql Driver!");
        }
        catch (Exception e) {
            System.out.print("Error loading Mysql Driver!");
            e.printStackTrace();
        }
        try {
            Connection connect = DriverManager.getConnection(
                    "jdbc:mysql://localhost:3306/myuser","root","你的密码");
            //建立连接,URL为jdbc:mysql//服务器地址/数据库myuser ,后面的2个参数分别是登陆用户名和密码
            System.out.println("Success connect Mysql server!");
            Statement stmt = connect.createStatement(); //创建运行对象
            ResultSet rs = stmt.executeQuery("select * from account");//执行查询account表
            while (rs.next()) {
                System.out.println(rs.getString("name"));//获取name列的值(字符串型)
            }
        }
        catch (Exception e) {
            System.out.print("get data error!");
            e.printStackTrace();
        }
    }
}



2.2 编写JDBC连接MySQL数据库,实现myuser数据库的增、删、改查的实例

🐰 1. 创建如下包、类:



🐦 2.通过下面代码对 myuser 数据库的 account 表实现增删改查的操作:

Tips:同样别忘记将“你的密码”改成你的数据库密码哦!


package JDBC_test2;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
 * @author 小黄小黄不再迷茫
 * @version 1.0
 */
public class Test2 {
    static Connection conn;
    static Statement st;
    public static void main(String[] args) {
        insert();   //插入添加记录
        update();   //更新记录数据
        delete();   //删除记录
        query();    //查询记录并显示
    }
    //(2)连接的获取,在操作前必须先获取与数据库的连接。
    private static Connection getConnection() {
        String driver = "com.mysql.cj.jdbc.Driver"; //若报错使用com.mysql.jdbc.Driver
        String url = "jdbc:mysql://localhost:3306/myuser?serverTimezone=UTC "; //myuser是数据库名称
        String username = "root"; //数据库用户名
        String password = "你的密码"; //数据库用户密码
        Connection conn = null;
        try {
            Class.forName(driver); //classLoader,加载对应驱动
            conn = (Connection) DriverManager.getConnection(url, username, password);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }
    //(3) 插入(insert)操作
    public static void insert() {
        conn = getConnection(); // 首先要获取连接,即连接到数据库
        try {
            String sql = "insert into account (name,password) values('lucy','123')"; // 插入数据的sql语句
            st = (Statement) conn.createStatement();    // 创建用于执行静态sql语句的Statement对象
            int count = st.executeUpdate(sql);  // 执行插入操作的sql语句,并返回插入数据的个数
            System.out.println("向account表中插入 " + count + " 条数据"); //输出插入操作的处理结果
            conn.close();   //关闭数据库连接
        } catch (SQLException e) {
            System.out.println("插入数据失败" + e.getMessage());
        }
    }
    //(4) 更新(update)操作
    public static void update() {
        conn = getConnection(); //同样先要获取连接,即连接到数据库
        try {
            String sql = "update account set password='0000' where name = '张三'";// 更新数据的sql语句
            st = (Statement) conn.createStatement();    //创建用于执行静态sql语句的Statement对象,st属局部变量
            int count = st.executeUpdate(sql);// 执行更新操作的sql语句,返回更新数据的个数
            System.out.println("account表中更新 " + count + " 条数据");      //输出更新操作的处理结果
            conn.close();   //关闭数据库连接
        } catch (SQLException e) {
            System.out.println("更新数据失败");
        }
    }
    //(5)查询(query)操作
    public static void query() {
        conn = getConnection(); //同样先要获取连接,即连接到数据库
        try {
            String sql = "select * from account";     // 查询数据的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");
                String password = rs.getString("password");
                //输出查到的记录的各个字段的值
                System.out.println(name + " " + password + " ");
            }
            conn.close();   //关闭数据库连接
        } catch (SQLException e) {
            System.out.println("查询数据失败");
        }
    }
    //(6)删除(delete)操作
        public static void delete () {
            conn = getConnection(); //同样先要获取连接,即连接到数据库
            try {
                String sql = "delete from account  where name = '李四'";// 删除数据的sql语句
                st = (Statement) conn.createStatement();    //创建用于执行静态sql语句的Statement对象,st属局部变量
                int count = st.executeUpdate(sql);// 执行sql删除语句,返回删除数据的数量
                System.out.println("account表中删除 " + count + " 条数据\n");    //输出删除操作的处理结果
                conn.close();   //关闭数据库连接
            } catch (SQLException e) {
                System.out.println("删除数据失败");
            }
    }
}



🐱 3.回到 datagrip 查看 account 表的数据,发现表的数据成功被更新:




3 JDBC进阶实验——简易登录界面

3.1 具体实现

🐰 1. MyConnection类,实现数据库连接:

Tips:同样别忘记将“你的密码”改成你的数据库密码哦!

package JDBC_test3;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
/**
 * @author 小黄小黄不再迷茫
 * @version 1.0
 */
public class MyConnection {
    public static Connection getConnection() {
        String driver = "com.mysql.cj.jdbc.Driver";//使用Jar包驱动
        String url = "jdbc:mysql://localhost:3306/myuser?serverTimezone=UTC";//链接数据库端口,数据库名
        String username = "root";//数据库用户名
        String password = "你的密码";//数据库密码
        Connection conn = null;
        try {
            Class.forName(driver); //classLoader,加载对应驱动
            conn = (Connection) DriverManager.getConnection(url, username, password);
        } catch (ClassNotFoundException e) {//异常捕获
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }
}

🐦 2. Login 类,实现登录界面:

package JDBC_test3;
import javax.swing.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
/**
 1. @author 小黄小黄不再迷茫
 2. @version 1.0
 */
public class Login  extends JFrame{
    private JLabel JLname;
    private JLabel JLpwd;
    private JTextField JTname;
    private JPasswordField JTpwd;
    private JButton JBsure;
    private JButton JBexit;
    public Login(String title){
        super(title);
        JLname = new JLabel("用户名:");//设置Label和按钮名
        JLpwd = new JLabel("密  码:");
        JTname = new JTextField(20);
        JTpwd = new JPasswordField(20);
        JBsure = new JButton("确定");
        JBexit = new JButton("取消");
        JLname.setBounds(40, 40, 60, 25);//设置Label和按钮大小
        JTname.setBounds(100, 40, 170, 25);
        JLpwd.setBounds(40,80,60,25);
        JTpwd.setBounds(100,80,170,25);
        JBsure.setBounds(110,130,60,25);
        JBexit.setBounds(180,130,60,25);
        this.setLayout(null);
        this.add(JLname);
        this.add(JTname);
        this.add(JLpwd);
        this.add(JTpwd);
        this.add(JBsure);
        this.add(JBexit);
        JBsure.addActionListener(new ActionListener(){//添加按钮监听
            public void actionPerformed(ActionEvent arg0) {
                dispose();
                loginCheak(JTname,JTpwd);
            }
        });
        JBexit.addActionListener(new ActionListener(){
            public void actionPerformed(ActionEvent e) {
                System.exit(0);
            }
        });
    }
    public void loginCheak(JTextField tf,JPasswordField pf) {
        String username = tf.getText();
        String password = String.valueOf(pf.getPassword());
        System.out.println(password);//输出填写的密码
        if("".equals(username)){//判断用户名是否为空
            JOptionPane.showMessageDialog(null,"账号不能为空","Warning",JOptionPane.WARNING_MESSAGE);
            return;
        }
        if("".equals(password)){//判断密码是否为空
            JOptionPane.showMessageDialog(null,"密码不能为空","Warning",JOptionPane.WARNING_MESSAGE);
            return;
        }
        try{
            new MyConnection();
            Connection con = MyConnection.getConnection() ;//调用MyConnection.java中的getConnection方法
            Statement stmt=con.createStatement();
            String sql = "select * from account where name = '" + username + "' and password = '" + password + "'"; //SQL选择查询语句
            ResultSet rs=stmt.executeQuery(sql);
            if (rs.next()) {
                JOptionPane.showMessageDialog(this, "成功登录", "提示",  JOptionPane.INFORMATION_MESSAGE);
                this.dispose();
            }
            else {
                JOptionPane.showMessageDialog(this, "帐号或密码错误!", "警告",  JOptionPane.WARNING_MESSAGE);
                pf.requestFocus();
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
    public static void main (String []args){//主函数
        Login ft=new Login("欢迎登陆");
        ft.setSize(340, 240);
        ft.setLocation(300, 300);
        ft.setVisible(true);
        ft.setResizable(false);
    }
}

3.2 效果展示

登录界面展示,用户名和密码依次输入 张三、0000:




点击确定,提示登录成功:




重新运行,输入张三和一个错误密码,提示登录失败:




直接点击登录,提示用户名不能为空:

相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
26天前
|
SQL Java 数据库连接
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率。本文介绍了连接池的工作原理、优势及实现方法,并提供了HikariCP的示例代码。
41 3
|
28天前
|
SQL Java 数据库连接
打破瓶颈:利用Java连接池技术提升数据库访问效率
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,避免了频繁的连接建立和断开,显著提升了数据库访问效率。常见的连接池库包括HikariCP、C3P0和DBCP,它们提供了丰富的配置选项和强大的功能,帮助优化应用性能。
44 2
|
2月前
|
Java 关系型数据库 MySQL
mysql5.7 jdbc驱动
遵循上述步骤,即可在Java项目中高效地集成MySQL 5.7 JDBC驱动,实现数据库的访问与管理。
190 1
|
2月前
|
SQL 分布式计算 关系型数据库
Hadoop-24 Sqoop迁移 MySQL到Hive 与 Hive到MySQL SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
Hadoop-24 Sqoop迁移 MySQL到Hive 与 Hive到MySQL SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
89 0
|
2月前
|
SQL 分布式计算 关系型数据库
Hadoop-23 Sqoop 数据MySQL到HDFS(部分) SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
Hadoop-23 Sqoop 数据MySQL到HDFS(部分) SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
40 0
|
2月前
|
SQL 分布式计算 关系型数据库
Hadoop-22 Sqoop 数据MySQL到HDFS(全量) SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
Hadoop-22 Sqoop 数据MySQL到HDFS(全量) SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
49 0
|
7月前
|
Java 关系型数据库 数据库连接
实时计算 Flink版操作报错之在使用JDBC连接MySQL数据库时遇到报错,识别不到jdbc了,怎么解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
4月前
|
SQL druid Java
Java数据库部分(MySQL+JDBC)(二、JDBC超详细学习笔记)(下)
Java数据库部分(MySQL+JDBC)(二、JDBC超详细学习笔记)
59 3
Java数据库部分(MySQL+JDBC)(二、JDBC超详细学习笔记)(下)
|
4月前
|
SQL Java 关系型数据库
Java数据库部分(MySQL+JDBC)(二、JDBC超详细学习笔记)(上)
Java数据库部分(MySQL+JDBC)(二、JDBC超详细学习笔记)
142 3
Java数据库部分(MySQL+JDBC)(二、JDBC超详细学习笔记)(上)
|
4月前
|
前端开发 关系型数据库 MySQL
com.mysql.jdbc.Driver 和 com.mysql.cj.jdbc.Driver 的区别
这篇文章讨论了`com.mysql.jdbc.Driver`和`com.mysql.cj.jdbc.Driver`两个MySQL驱动类的区别,指出`com.mysql.jdbc.Driver`适用于MySQL 5的`mysql-connector-java`版本,而`com.mysql.cj.jdbc.Driver`适用于MySQL 6及以上版本的`mysql-connector-java`。文章还提到了在实际使用中如何根据MySQL版本选择合适的驱动类。
com.mysql.jdbc.Driver 和 com.mysql.cj.jdbc.Driver 的区别
下一篇
无影云桌面