数据读取 - 读取器实现 - 从文件、数据库读取

Java - Web - Spring 《数据读取 - 读取器实现 - 从文件、数据库读取》

在 Java Web 开发中，Spring 框架为我们提供了强大的支持，使得数据读取变得更加便捷和高效。本文将详细介绍如何使用 Spring 实现从文件和数据库中读取数据，同时会给出相应的演示代码。

1. 从文件读取数据

1.1 需求背景

在实际开发中，我们经常需要从文件中读取数据，例如配置文件、日志文件等。Spring 可以帮助我们轻松实现这一功能。

1.2 实现步骤

1.2.1 添加依赖

首先，我们需要在 pom.xml 中添加 Spring 相关依赖：

<dependencies>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>5.3.18</version>
    </dependency>
</dependencies>

1.2.2 创建文件读取器类

import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.Resource;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
public class FileDataReader {
    public String readFile(String filePath) throws IOException {
        // 使用 Spring 的 ClassPathResource 加载文件
        Resource resource = new ClassPathResource(filePath);
        StringBuilder content = new StringBuilder();
        try (BufferedReader reader = new BufferedReader(new InputStreamReader(resource.getInputStream()))) {
            String line;
            while ((line = reader.readLine())!= null) {
                content.append(line).append("\n");
            }
        }
        return content.toString();
    }
}

1.2.3 测试文件读取

public class FileDataReaderTest {
    public static void main(String[] args) {
        FileDataReader reader = new FileDataReader();
        try {
            String fileContent = reader.readFile("test.txt");
            System.out.println(fileContent);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

1.3 代码解释

• ClassPathResource 是 Spring 提供的一个资源加载类，用于从类路径下加载文件。
• BufferedReader 用于逐行读取文件内容，并将其存储在 StringBuilder 中。

2. 从数据库读取数据

2.1 需求背景

数据库是存储数据的重要工具，我们经常需要从数据库中读取数据并在 Web 应用中使用。Spring 提供了多种方式来实现数据库操作，这里我们使用 Spring JDBC Template。

2.2 实现步骤

2.2.1 添加依赖

在 pom.xml 中添加 Spring JDBC 和 MySQL 驱动依赖：

<dependencies>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jdbc</artifactId>
        <version>5.3.18</version>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.26</version>
    </dependency>
</dependencies>

2.2.2 配置数据源

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import javax.sql.DataSource;
@Configuration
public class DataSourceConfig {
    @Bean
    public DataSource dataSource() {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/testdb");
        dataSource.setUsername("root");
        dataSource.setPassword("password");
        return dataSource;
    }
}

2.2.3 创建数据读取器类

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import java.util.List;
import java.util.Map;
@Component
public class DatabaseDataReader {
    private final JdbcTemplate jdbcTemplate;
    @Autowired
    public DatabaseDataReader(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }
    public List<Map<String, Object>> readDataFromDatabase() {
        String sql = "SELECT * FROM users";
        return jdbcTemplate.queryForList(sql);
    }
}

2.2.4 测试数据库读取

import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import java.util.List;
import java.util.Map;
public class DatabaseDataReaderTest {
    public static void main(String[] args) {
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(DataSourceConfig.class);
        DatabaseDataReader reader = context.getBean(DatabaseDataReader.class);
        List<Map<String, Object>> data = reader.readDataFromDatabase();
        for (Map<String, Object> row : data) {
            System.out.println(row);
        }
        context.close();
    }
}

2.3 代码解释

• DriverManagerDataSource 用于配置数据库连接信息。
• JdbcTemplate 是 Spring 提供的一个用于简化 JDBC 操作的工具类。
• queryForList 方法用于执行 SQL 查询并返回结果集。

3. 总结

通过以上介绍，我们可以看到 Spring 为我们提供了丰富的工具和方法，使得从文件和数据库中读取数据变得更加简单和高效。在实际开发中，我们可以根据具体需求选择合适的方式来读取数据。