java使用yml增删查改数据库-CFANZ编程社区

Java使用YAML操作数据库

在Java开发中，我们经常需要与数据库进行交互，进行数据的增删查改操作。在这篇文章中，我们将介绍如何使用YAML文件来管理数据库连接信息，并使用Java代码实现数据库的增删查改操作。

什么是YAML？

YAML（YAML Ain't Markup Language）是一种用于数据序列化的格式。它采用简洁的语法，易于阅读和编写，适用于各种编程语言。YAML文件通常以.yml或.yaml为扩展名。

引入依赖

首先，我们需要在项目中引入snakeyaml依赖，它是一个Java库，用于解析YAML文件。

<dependency>
    <groupId>org.yaml</groupId>
    <artifactId>snakeyaml</artifactId>
    <version>1.27</version>
</dependency>

创建数据库配置文件

我们首先创建一个database.yml的YAML配置文件，用于存储数据库的连接信息。

database:
  driver: com.mysql.jdbc.Driver
  url: jdbc:mysql://localhost:3306/mydb
  username: root
  password: password

在这个配置文件中，我们定义了数据库的驱动程序、URL、用户名和密码。

解析YAML文件

接下来，我们使用snakeyaml库来解析YAML文件，并获取数据库配置信息。

import org.yaml.snakeyaml.Yaml;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.util.Map;

public class DatabaseConfig {
    private String driver;
    private String url;
    private String username;
    private String password;

    public DatabaseConfig(String configFile) {
        try {
            Yaml yaml = new Yaml();
            FileInputStream inputStream = new FileInputStream(configFile);
            Map<String, Object> config = yaml.load(inputStream);
            Map<String, Object> database = (Map<String, Object>) config.get("database");
            this.driver = (String) database.get("driver");
            this.url = (String) database.get("url");
            this.username = (String) database.get("username");
            this.password = (String) database.get("password");
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        }
    }

    public String getDriver() {
        return driver;
    }

    public String getUrl() {
        return url;
    }

    public String getUsername() {
        return username;
    }

    public String getPassword() {
        return password;
    }
}

在这个示例代码中，我们通过Yaml对象的load方法加载YAML文件，并使用Map对象获取数据库配置信息。

数据库操作

有了数据库配置信息后，我们可以使用Java代码来操作数据库。这里以MySQL数据库为例进行示范。

import java.sql.*;

public class DatabaseExample {
    public static void main(String[] args) {
        DatabaseConfig config = new DatabaseConfig("database.yml");
        String driver = config.getDriver();
        String url = config.getUrl();
        String username = config.getUsername();
        String password = config.getPassword();

        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;

        try {
            Class.forName(driver);
            connection = DriverManager.getConnection(url, username, password);
            statement = connection.createStatement();
            resultSet = statement.executeQuery("SELECT * FROM users");

            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 (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (resultSet != null) resultSet.close();
                if (statement != null) statement.close();
                if (connection != null) connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

在这个示例代码中，我们通过DriverManager连接数据库，并执行一条查询语句获取users表中的数据。