Java实现数据库

1. JDBC（Java Database Connectivity）

JDBC是Java语言中用来规范客户端程序如何访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。

1.1 环境配置

首先需要安装MySQL数据库，并创建一个名为test的数据库和一个名为user的表。

CREATE DATABASE test;
USE test;
CREATE TABLE user (
    id INT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(50),
    age INT
);

1.2 Java代码实现

1.2.1 导入依赖

在项目的pom.xml文件中添加MySQL驱动的依赖：

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysqlconnectorjava</artifactId>
    <version>8.0.26</version>
</dependency>

1.2.2 编写代码

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class JdbcExample {
    public static void main(String[] args) {
        // 加载驱动
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        // 连接数据库
        String url = "jdbc:mysql://localhost:3306/test?useSSL=false&serverTimezone=UTC";
        String user = "root";
        String password = "your_password";
        try (Connection connection = DriverManager.getConnection(url, user, password)) {
            // 插入数据
            String insertSql = "INSERT INTO user (name, age) VALUES (?, ?)";
            try (PreparedStatement preparedStatement = connection.prepareStatement(insertSql)) {
                preparedStatement.setString(1, "张三");
                preparedStatement.setInt(2, 25);
                int rowsAffected = preparedStatement.executeUpdate();
                System.out.println("插入成功，影响了" + rowsAffected + "行数据。");
            }
            // 查询数据
            String querySql = "SELECT * FROM user";
            try (PreparedStatement preparedStatement = connection.prepareStatement(querySql);
                 ResultSet resultSet = preparedStatement.executeQuery()) {
                while (resultSet.next()) {
                    int id = resultSet.getInt("id");
                    String name = resultSet.getString("name");
                    int age = resultSet.getInt("age");
                    System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age);
                }
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

运行上述代码，可以看到插入和查询操作的结果。