Java学习-连接Mysql数据库

1.先在Mysql里面构建一个表格

例子：名字为user1，两列分别为name、score

2.正确导入了MySQL的JDBC驱动程序

2.1 下载驱动包（与自己的服务器版本匹配）

官网地址：Maven Repository: mysql » mysql-connector-java » 8.0.29 (mvnrepository.com)

搜索mysql connector java

找到你所对应的版本，进行下载

2.2 将下载好的jar驱动包导入项目中

添加为库

3.读入数据库

3.1 写入示例代码，输入5个科目的成绩到数据库

Main类

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

public class Main {
    public static void main(String[] args) {
        DatabaseUtil dbUtil = new DatabaseUtil();
        try {
            Scanner scanner = new Scanner(System.in);

            int p = 5;
            for (int i = 0; i < p; i++) {
                String str = scanner.nextLine();
                String name = str.split(" ")[0];
                String score = str.split(" ")[1];

                String sql = "INSERT INTO score1(name, score) VALUES('" + name + "', '" + score + "')";
                dbUtil.executeUpdate(sql);
            }

            scanner.close();
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }
}

DatabaseUtil类

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

public class DatabaseUtil {
    public void executeUpdate(String sql) {
        String url = "jdbc:mysql://localhost:3306/user1"; // 数据库URL，根据你的实际情况进行修改
        String username = "root"; // 数据库用户名
        String password = "123456"; // 数据库密码

        try (Connection connection = DriverManager.getConnection(url, username, password);
             Statement statement = connection.createStatement()) {
            statement.executeUpdate(sql);
            System.out.println("成功执行SQL语句：" + sql);
        } catch (SQLException e) {
            System.out.println("执行SQL语句时发生错误：" + e.getMessage());
        }
    }
}

测试成功：