0
点赞
收藏
分享

微信扫一扫

在Java中操作MySQL(JDBC)

准备工作

  1. idea
  2. mysql 官方的 jdbc 驱动

先在 idea 中建立一个新的 java 工程

直到这一步之前,一直按下一步就行了

在这里插入图片描述
把名字改改直接 finish

在这个工程下面建立一个名字为 lib 的空文件夹
在这里插入图片描述

去官方下载依赖的包

https://dev.mysql.com/downloads/connector/j/
在这里插入图片描述
选择下面那个

下载之后,得到的是一个 zip 文件,把 zip 里面的东西解压到刚刚创建的 lib 文件夹中(记得先找到刚刚那个工程创建时设置的存放位置)

在这里插入图片描述
右键这个文件夹,选择下面蓝色的那个选项
在这里插入图片描述

然后在弹出的窗口中点击 ok
在这里插入图片描述
后面还会弹出一个窗口,也点击 OK ,就可以了

开始操作

先在 src 文件夹中建立 Java 类,然后开始操作

连接 mysql 和关闭连接

Connection 是 Java 中的一个类,专门用于和其他的东西进行连接

// 先引入需要的包
import java.sql.*;

public class Exercise {
    public static void main(String[] args){
        // Connection 是 Java 中的一个类,专门用于和其他的东西进行连接
        Connection connect = null;
        try {
            // 加载驱动,固定语句
            // 使用这个必须处理异常
            Class.forName("com.mysql.jdbc.Driver");
        }
        catch (ClassNotFoundException e){
            System.out.println("Could not loading Driver");
        }
        try {
            // 下面这一行也是固定语句,getConnection括号里面的模式:
                // “jdbc:mysql://数据库的地址(mysql server 的地址)/数据库名字?(要mysql中操作的数据库的名字)”
                    // 后面再 + 上用来登录的用户名和密码
                        // 同时,使用这个函数,必须处理异常
            connect = DriverManager.getConnection("jdbc:mysql://127.0.0.1/productdb?" + "user=root&password=123456");
            if (connect != null) {
                System.out.println("Connect successfully!");
            }
        } catch (SQLException e) { // 这个getConnection 规定必须抛出异常
            e.printStackTrace();
        }
        finally {
            try {
                // 关闭连接
                connect.close(); // 规定必须处理异常
                System.out.println("Shutdown connection successfully!");
            }
            catch (SQLException e){
                e.printStackTrace();
            }
        }
    }
}

不要这么早就被这么长的代码给劝退了,实际上不需要写这么多,因为 idea 会帮你自动补全很大一部分,catch 里面的东西我几乎就没写过,而且 catch 里面的大多数都是英文的字面意思

使用 mysql 内的语句

使用 Statement 类的对象向 mysql 发送 sql 语句进行操作

使用 ResultSet 类的对象接收操作之后得到的结果

先上 mysql 的表
在这里插入图片描述
再进行操作

// 先引入需要的包
import java.sql.*;

public class Exercise {
    public static void main(String[] args){
        // Connection 是 Java 中的一个类,专门用于和其他的东西进行连接
        Connection connect = null;
        // Statement 类的对象向 mysql 发送 sql 语句进行操作
        Statement stmt = null;
        // ResultSet 类的对象接收操作之后得到的结果
        ResultSet rs = null;
        try {
            // 加载驱动,固定语句
            // 使用这个必须处理异常
            Class.forName("com.mysql.jdbc.Driver");
        }
        catch (ClassNotFoundException e){
            System.out.println("Could not loading Driver");
        }
        try {
            // 下面这一行也是固定语句,getConnection括号里面的模式:
                // “jdbc:mysql://数据库的地址(mysql server 的地址)/数据库名字?(要mysql中操作的数据库的名字)”
                    // 后面再 + 上用来登录的用户名和密码
                        // 同时,使用这个函数,必须处理异常
            connect = DriverManager.getConnection("jdbc:mysql://127.0.0.1/productdb?" + "user=root&password=123456");
            if (connect != null) {
                System.out.println("Connect successfully!");
            }
            try {
                // 先创造一个可以给 mysql 发送 sql 语句的
                stmt = connect.createStatement();
                // executeQuery 用于发送 sql 语句,括号内的就是 sql 语句
                rs = stmt.executeQuery("select * from user");
                // 输出数据的用法
                    //rs.next(); 表示下一个得到的结果数据集,如果不为空,就继续输出
                        // 每一次输出完之后,会自动切换到下一个数据集,相当于换行,select * from 表,这样操作一次看到结果
                            // 的图就知道是为什么了
                while (rs.next()){
                    // rs.get数据类型(括号内是列数(第 n 列))
                    System.out.println(rs.getInt(1));
                    System.out.println(rs.getString(2));
                    System.out.println(rs.getString(3));
                    System.out.println(rs.getString(4));
                    System.out.println(rs.getString(5));
                    System.out.println(rs.getString(6));
                    System.out.println(rs.getTimestamp(7));
                    System.out.println(rs.getDate(8));
                }
            }
            catch (SQLException e){ // 老规矩,必须处理异常
                e.printStackTrace();
            }
        } catch (SQLException e) { // 这个getConnection 规定必须处理异常
            e.printStackTrace();
        }
        finally {
            try {
                // 关闭连接
                connect.close(); // 规定必须处理异常
                System.out.println("Shutdown connection successfully!");
            }
            catch (SQLException e){
                e.printStackTrace();
            }
        }
    }
}

其他的 sql 语句也是同样的道理

举报

相关推荐

0 条评论