当前位置：首页>编程语言>正文

Java 流式读取csv文件 jpa 流式读取数据

编程语言2024-06-04 20:49:47

开篇词

该指南将引导构建你使用 Spring Data JPA 来在关系型数据库中存储和检索数据的应用。

你将创建的应用

我们将构建一个在基于内存的数据库中存储客户 POJO（普通 Java 对象）的应用。

你将需要的工具

大概 15 分钟左右；
你最喜欢的文本编辑器或集成开发环境（IDE）
JDK 1.8 或更高版本；
Gradle 4+ 或 Maven 3.2+
你还可以将代码直接导入到 IDE 中：

Spring Too Suite (STS)
IntelliJ IDEA

如何完成这个指南

像大多数的 Spring 入门指南一样，你可以从头开始并完成每个步骤，也可以绕过你已经熟悉的基本设置步骤。如论哪种方式，你最终都有可以工作的代码。

要从头开始，移步至从 Spring Initializr 开始；
要跳过基础，执行以下操作：

下载并解压缩该指南将用到的源代码，或借助 Git 来对其进行克隆操作：git clone https://github.com/spring-guides/gs-accessing-data-jpa.git
切换至 gs-accessing-data-jpa/initial 目录；
跳转至该指南的定义简单实体。

待一切就绪后，可以检查一下 gs-accessing-data-jpa/complete 目录中的代码。

从 Spring Initializr 开始

对于所有的 Spring 应用来说，你应该从 Spring Initializr 开始。Initializr 提供了一种快速的方法来提取应用程序所需的依赖，并为你完成许多设置。该示例需要 JPA 和 H2 依赖。下图显示了此示例项目的 Initializr 设置：

Java 流式读取csv文件 jpa 流式读取数据,Java 流式读取csv文件 jpa 流式读取数据_Java 流式读取csv文件,第1张

上图显示了选择 Maven 作为构建工具的 Initializr。你也可以使用 Gradle。它还将 com.example 和 accessing-data-jpa 的值分别显示为 Group 和 Artifact。在本示例的其余部分，将用到这些值。

以下清单显示了选择 Maven 时创建的 pom.xml 文件：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.2.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.example</groupId>
    <artifactId>accessing-data-jpa</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>accessing-data-jpa</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>

        <dependency>
            <groupId>com.h2database</groupId>
            <artifactId>h2</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

以下清单显示了在选择 Gradle 时创建的 build.gradle 文件：

plugins {
    id 'org.springframework.boot' version '2.2.2.RELEASE'
    id 'io.spring.dependency-management' version '1.0.8.RELEASE'
    id 'java'
}

group = 'com.example'
version = '0.0.1-SNAPSHOT'
sourceCompatibility = '1.8'

repositories {
    mavenCentral()
}

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
    runtimeOnly 'com.h2database:h2'
    testImplementation('org.springframework.boot:spring-boot-starter-test') {
        exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'
    }
}

test {
    useJUnitPlatform()
}

定义简单实体

在该示例中，我们存储了 Customer 对象，没个对象都被标注为 JPA 实体。以下清单显示了 Customer 类（在 src/main/java/com/example/accessingdatajpa/Customer.java）：

package com.example.accessingdatajpa;

import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;

@Entity
public class Customer {

  @Id
  @GeneratedValue(strategy=GenerationType.AUTO)
  private Long id;
  private String firstName;
  private String lastName;

  protected Customer() {}

  public Customer(String firstName, String lastName) {
    this.firstName = firstName;
    this.lastName = lastName;
  }

  @Override
  public String toString() {
    return String.format(
        "Customer[id=%d, firstName='%s', lastName='%s']",
        id, firstName, lastName);
  }

  public Long getId() {
    return id;
  }

  public String getFirstName() {
    return firstName;
  }

  public String getLastName() {
    return lastName;
  }
}

这里，我们有一个 Customer 类，其三个属性分别为：id、firstName 和 lastName。我们也有两个构造函数。仅为了 JPA 而存在的默认构造函数。我们不直接使用它，因此将其指定为 protected。另一个构造函数是为要保存到数据库的 Customer 实例所创建的。

用 @Entity 标注 Customer 类，表明它是一个 JPA 实体。（由于没有用到 @Table 注解，因此假定该实体已映射到名为 Customer 的表。）

Customer 对象的 id 属性用 @Id 来标注，以便 JPA 将其识别为对象的 ID。id 属性也用 @GeneratedValue 来标注，以指示应该自动生成 ID。

其他两个属性，firstName 和 lastName，未被标注。假定它们映射到与属性名称相同的列。

方便的 toString() 方法可以打印出客户的属性。

创建简单查询

Spring Data JPA 专注于使用 JPA 将数据存储在关系型数据库中。它最引人注目的功能是能够在运行时从存储库接口自动创建存储库实现。

要查看其工作方式，请创建一个与 Customer 实体配合使用的存储库接口，如下清单（在 src/main/java/com/example/accessingdatajpa/CustomerRepository.java）所示：

package com.example.accessingdatajpa;

import java.util.List;

import org.springframework.data.repository.CrudRepository;

public interface CustomerRepository extends CrudRepository<Customer, Long> {

  List<Customer> findByLastName(String lastName);

  Customer findById(long id);
}

CustomerRepository 扩展了 CrudRepository 接口。在 CrudRepository 的通用参数中指定了与之配合使用的实体类型和 ID（Customer 和 Long）。通过扩展 CrudRepository，CustomerRepository 继承了几种用于处理 Customer 持久性的方法，包括保存、删除和查找 Customer 实体的方法。

Spring Data JPA 还允许我们通过声明其他方法的方法签名来定义它们。例如，CustomerRepository 包括 findByLastName() 方法。

在典型的 Java 应用中，我们可能希望写一个实现 CustomerRepository 的类。但是，这就是使 Spring Data JPA 如此强大的原因：我们无需编写存储库接口实现。当我们运行应用时，Spring Data JPA 将创建一个实现。

现在，我们可以连接该示例并查看其运行结果！

创建应用类

Spring Initializr 为应用创建了一个简单的类。以下清单显示了 Initializr 为该示例创建的类（在 src/main/java/com/example/accessingdatajpa/AccessingDataJpaApplication.java 中）：

package com.example.accessingdatajpa;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class AccessingDataJpaApplication {

  public static void main(String[] args) {
    SpringApplication.run(AccessingDataJpaApplication.class, args);
  }

}

@SpringBootApplication 是一个便利的注解，它添加了以下所有内容：

@Configuration：将类标记为应用上下文 Bean 定义的源；
@EnableAutoConfiguration：告诉 Spring Boot 根据类路径配置、其他 bean 以及各种属性的配置来添加 bean。
@ComponentScan：告知 Spring 在 com/example 包中寻找他组件、配置以及服务。

main() 方法使用 Spring Boot 的 SpringApplication.run() 方法启动应用。

现在，我们需要修改 Initializr 为我们创建的简单类。要获得输出（在该示例中为控制台），我们需要设置一个记录器。然后，我们需要设置一些数据并将其用于生成输出。以下清单显示了完成的 AccessingDataJpaApplication 类（在 src/main/java/com/example/accessingdatajpa/AccessingDataJpaApplication.java 中）：

package com.example.accessingdatajpa;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class AccessingDataJpaApplication {

  private static final Logger log = LoggerFactory.getLogger(AccessingDataJpaApplication.class);

  public static void main(String[] args) {
    SpringApplication.run(AccessingDataJpaApplication.class);
  }

  @Bean
  public CommandLineRunner demo(CustomerRepository repository) {
    return (args) -> {
      // save a few customers
      repository.save(new Customer("Jack", "Bauer"));
      repository.save(new Customer("Chloe", "O'Brian"));
      repository.save(new Customer("Kim", "Bauer"));
      repository.save(new Customer("David", "Palmer"));
      repository.save(new Customer("Michelle", "Dessler"));

      // fetch all customers
      log.info("Customers found with findAll():");
      log.info("-------------------------------");
      for (Customer customer : repository.findAll()) {
        log.info(customer.toString());
      }
      log.info("");

      // fetch an individual customer by ID
      Customer customer = repository.findById(1L);
      log.info("Customer found with findById(1L):");
      log.info("--------------------------------");
      log.info(customer.toString());
      log.info("");

      // fetch customers by last name
      log.info("Customer found with findByLastName('Bauer'):");
      log.info("--------------------------------------------");
      repository.findByLastName("Bauer").forEach(bauer -> {
        log.info(bauer.toString());
      });
      // for (Customer bauer : repository.findByLastName("Bauer")) {
      //  log.info(bauer.toString());
      // }
      log.info("");
    };
  }

}

Application 包含一个 demo() 方法，该方法将对 CustomerRepository 进行一些测试。首先，它从 Spring 应用上下文中获取 CustomerRepository。然后，它保存了一些 Customer 对象，演示了 save() 方法并设置了一些可使用的数据。接下来，它调用 findAll() 从数据库中获取所有 Customer 对象。然后，它调用 findOne() 以通过其 ID 获取单个 Customer。最后，它调用 findByLastName() 来查找姓氏为 “Bauer” 的所有客户。demo() 方法返回一个 CommandLineRunner bean，该 bean 在应用启动时自动运行代码。

AccessingDataJpaApplication 类包含 main() 方法，该方法使 CustomerRepository 经过一些测试。首先，它从 Spring 应用上下文中获取 CustomerRepository。然后，它保存了少量 Customer 对象，演示了 save() 方法并设置了一些要使用的数据。接下来，它调用 findAll() 从数据库中获取所有 Customer 对象。然后，它调用 findOne() 以通过其 ID 提取单个 Customer。最后，它调用 findByLastName() 来查找姓氏为 “Bauer” 的所有客户。

默认情况下，Spring Boot 启用 JPA 存储库支持，并在 @SpringBootApplication 所在的包（及其子包）中查找。如果我们将 JPA 存储库接口定义配置在不可见的包中，则可以使用 @EnableJpaRepositories 及其类型安全的 basePackageClasses=MyRepository.class 参数指出用来代替的包。

构建可执行 JAR

我们可以结合 Gradle 或 Maven 来从命令行运行该应用。我们还可以构建一个包含所有必须依赖项、类以及资源的可执行 JAR 文件，然后运行该文件。在整个开发生命周期中，跨环境等等情况下，构建可执行 JAR 可以轻松地将服务作为应用进行发布、版本化以及部署。

如果使用 Gradle，则可以借助 ./gradlew bootRun 来运行应用。或通过借助 ./gradlew build 来构建 JAR 文件，然后运行 JAR 文件，如下所示：

java -jar build/libs/gs-accessing-data-jpa-0.1.0.jar

由官网提供的以上这条命令的执行结果与我本地的不一样，我需要这样才能运行：java -jar build/libs/accessing-data-jpa-0.0.1-SNAPSHOT.jar。

如果使用 Maven，则可以借助 ./mvnw spring-boot:run 来运行该用。或可以借助 ./mvnw clean package 来构建 JAR 文件，然后运行 JAR 文件，如下所示：

java -jar target/gs-accessing-data-jpa-0.1.0.jar

由官网提供的以上这条命令的执行结果与我本地的不一样，我需要这样才能运行：java -jar target/accessing-data-jpa-0.0.1-SNAPSHOT.jar。
我们还可以构建一个经典的 WAR 文件。

运行应用后，我们应该看到以下输出：

== Customers found with findAll():
Customer[id=1, firstName='Jack', lastName='Bauer']
Customer[id=2, firstName='Chloe', lastName='O'Brian']
Customer[id=3, firstName='Kim', lastName='Bauer']
Customer[id=4, firstName='David', lastName='Palmer']
Customer[id=5, firstName='Michelle', lastName='Dessler']

== Customer found with findById(1L):
Customer[id=1, firstName='Jack', lastName='Bauer']

== Customer found with findByLastName('Bauer'):
Customer[id=1, firstName='Jack', lastName='Bauer']
Customer[id=3, firstName='Kim', lastName='Bauer']

概述

恭喜你！我们已经编写了一个简单的应用，该应用使用 Spring Data JPA 将对象保存到数据库中并从数据库中获取它们，而所有这些都无需编写具体的存储库实现。

如果你想轻松地使用基于超媒体的 RESTful 前段暴露 JPA 存储库，则可能需要阅读使用 REST 访问 JPA 数据库（尽请期待～）。

查看全文

https://www.xamrdz.com/lan/5mn1963275.html

开篇词