Java 8 스트림의 데이터베이스 CRUD 작업

새로운 도구를 접할 때 처음에 극복해야 할 가장 큰 장애물은 먼저 작은 것을 만들어 보는 방법입니다. 이제 새로운 Stream API가 Java 8에서 작동하는 방식을 더 확신할 수 있지만 데이터베이스 쿼리를 수행하는 데 이를 사용하지 않았을 수도 있습니다. Stream API를 사용하여 SQL 데이터베이스를 생성, 수정 및 읽기를 시작하는 데 도움이 되도록 이 빠른 시작 자습서에 모든 내용을 정리했습니다. 스트리밍 API 사용을 개선하는 데 도움이 되기를 바랍니다!

백그라운드

Speedment는 Java 엔터티를 생성하고 우리를 하나로 모으는 데 사용할 수 있는 오픈 소스 도구 세트입니다. 데이터베이스의 통신 프로세스가 관리됩니다. . 그래픽 도구를 사용하여 데이터베이스에 연결하고 도메인 모델을 나타내는 전체 ORM 프레임워크 코드 세트를 생성할 수 있습니다. 그러나 Speedment는 단순한 코드 생성기 그 이상입니다. 이는 애플리케이션에 연결하여 Java 8 스트리밍 코드를 최적화된 SQL 쿼리로 변환할 수 있는 런타임 프로그램입니다. 이 부분도 이번 글에서 구체적으로 다루려고 하는 부분이다.

코드 생성

Maven 프로젝트에서 Speedment 사용을 시작하려면 pom.xml 파일에 다음 코드 줄을 추가해야 합니다. 이 예에서는 MySQL을 사용하고 있지만 PostgreSQL 또는 MariaDB를 사용하도록 선택할 수도 있습니다. Oracle과 같은 독점 데이터베이스는 기업 고객에게 제공됩니다.

Pom.xml

<properties> 
  <speedment.version>3.0.1</speedment.version> 
  <db.groupId>mysql</db.groupId> 
  <db.artifactId>mysql-connector-java</db.artifactId> 
  <db.version>5.1.39</db.version> 
</properties>  
<dependencies> 
  <dependency> 
    <groupId>com.speedment</groupId> 
    <artifactId>runtime</artifactId> 
    <version>${speedment.version}</version> 
    <type>pom</type> 
  </dependency>  
  <dependency> 
    <groupId>${db.groupId}</groupId> 
    <artifactId>${db.artifactId}</artifactId> 
    <version>${db.version}</version> 
  </dependency> 
</dependencies>  
<build> 
  <plugins> 
    <plugin> 
      <groupId>com.speedment</groupId> 
      <artifactId>speedment-maven-plugin</artifactId> 
      <version>${speedment.version}</version>  
      <dependencies> 
        <dependency> 
          <groupId>${db.groupId}</groupId> 
          <artifactId>${db.artifactId}</artifactId> 
          <version>${db.version}</version> 
        </dependency> 
      </dependencies> 
    </plugin> 
  </plugins> 
</build>

이제 이 툴킷을 더 쉽게 사용할 수 있는 다양한 새로운 Maven 저장소에 액세스할 수 있습니다. Speedment UI를 시작하려면 다음 명령을 실행하십시오.

mvn speedment:tool

그러면 데이터베이스에 연결하고 코드 생성을 구성하는 프로세스가 진행됩니다. 가장 쉬운 시작 방법은 먼저 기본 설정으로 실행하는 것입니다. 생성 버튼을 누르면 Speedment가 데이터베이스 메타데이터를 분석하고 엔터티 및 엔터티 관리자와 같은 클래스를 프로젝트에 추가합니다.

Speedment 초기화

도메인 모델이 생성되면 Speedment 설정이 쉽습니다. 새 Main.java 파일을 만들고 다음 코드 줄을 추가합니다. 표시되는 클래스는 생성되므로 데이터베이스 스키마, 테이블 및 열 이름을 기반으로 이름이 지정됩니다.

Main.java

ublic class Main {  
public static void main(String... param) {  
final HaresApplication app = new HaresApplicationBuilder()  
.withPassword("password")  
.build();  
}  
}

위 코드는 생성된 생성자 패턴을 사용하는 새 애플리케이션 엔터티를 생성합니다. 생성자를 사용하면 데이터베이스 비밀번호와 같은 런타임 구성 세부 정보를 설정할 수 있습니다.

애플리케이션 엔터티가 있으면 이를 사용하여 생성된 엔터티 관리자에 액세스할 수 있습니다. 여기 내 데이터베이스에는 "hare", "carrot", "human" 및 "friend"라는 4개의 테이블이 있습니다(여기에서 전체 데이터베이스 정의를 찾을 수 있습니다).

final CarrotManager carrots = app.getOrThrow(CarrotManager.class);  
final HareManager hares = app.getOrThrow(HareManager.class);  
final HumanManager humans = app.getOrThrow(HumanManager.class);  
final FriendManager hares = app.getOrThrow(FriendManager.class);

이제 이러한 엔터티 관리자를 사용하여 모든 CRUD 작업을 수행할 수 있습니다.

엔티티 생성

엔티티 생성은 매우 간단합니다. 우리는 엔터티 생성 구현을 사용하고 열 값을 설정한 후 이를 데이터 소스에 유지합니다.

hares.persist(  
new HareImpl()  
.setName("Harry")  
.setColor("Gray")  
.setAge(8) 
 );

지속 메소드는 "id"와 같은 자동 생성 키가 이미 설정된 Hare의 (잠재적인) 새 인스턴스를 반환합니다. 지속성 이후 Harry를 계속 사용하려면 지속 메소드에서 반환된 이를 사용할 수 있습니다.

final Hare harry = hares.persist(  
new HareImpl()  
.setName("Harry")  
.setColor("Gray")  
.setAge(8)  
);

지속성 작업이 실패하는 경우(예: 외래 키가 고유 제약 조건을 위반하는 경우) SpeedmentException이 발생합니다. 우리는 이것을 확인해야 하며, 이 토끼 레코드를 유지하는 것을 방해하는 암시적인 무언가가 있는 경우 오류 메시지를 표시해야 합니다.

try {  
final Hare harry = hares.persist(  
new HareImpl()  
.setName("Harry")  
.setColor("Gray")  
.setAge(8)  
);  
} catch (final SpeedmentException ex) {  
System.err.println(ex.getMessage());  
return;  
}

엔티티 읽기

Speedment 런타임의 가장 멋진 기능은 Java 8의 Stream API를 사용하여 데이터베이스의 데이터를 스트리밍하는 기능입니다. "이게 왜 멋지지?"라고 스스로에게 물어볼 수도 있습니다. "요즘은 Hibernate도 스트리밍 작업을 지원합니다!"가 답이었습니다.

Speedment 스트리밍 작업을 사용할 때 가장 좋은 점은 스트림을 구축하는 중간 작업과 종료 작업을 모두 고려한다는 것입니다. 즉, 스트림이 생성된 후 스트림에 필터를 추가하면 SQL 문을 구성할 때 필터도 고려됩니다.

다음은 데이터베이스의 총 토끼 레코드 수를 계산하려는 예입니다.

final long haresTotal = hares.stream().count(); 
System.out.format("There are %d hares in total.%n", haresTotal);

이 코드로 생성된 SQL 쿼리는 다음과 같습니다.

SELECT COUNT(id) FROM hares.hare;

여기서 종료 작업은 .count()이므로 Speedment는 SELECT COUNT( …)를 생성하는 것을 알고 있습니다. 성명. 또한 "hare" 테이블의 기본 키가 "id" 열이라는 것을 알고 있으므로 데이터베이스로 전송되는 전체 명령문을 이것으로 줄일 수 있습니다.

더 복잡한 예는 이름이 "rry"로 시작하고 나이가 5세 이상인 토끼의 수를 찾는 것입니다. 이는 다음과 같이 작성할 수 있습니다.

final long complexTotal = hares.stream()  .
filter(Hare.NAME.endsWith("rry"))  .
filter(Hare.AGE.greaterOrEqual(5))  .
count();

Speedment에서 생성한 현장 빌더를 사용하여 필터를 정의합니다. 이를 통해 스트림을 프로그래밍 방식으로 분석하고 이를 다음과 같은 SQL 문으로 줄일 수 있습니다.

SELECT COUNT(id) FROM hares.hare  
WHERE hare.name LIKE CONCAT("%", ?)  
AND hare.age >= 5;

如果我们添加了一个 Speedment 不可以对流进行优化的操作, 它就会像一般的 Java 8 流那被处理。我们永远都不会限制生成的位于构建器的使用，它能是流式操作更加的高效。

final long inefficientTotal = hares.stream()  .
filter(h -> h.getName().hashCode() == 52)  .
count();

上述代码会产生一条如下极其低效的语句，但是它仍然可以跑起来。

SELECT id,name,color,age FROM hares.hare;

更新实体

更新存在的实体和读取以及持久化实体非常相似。在我们调用update()方法之前，对实体本地拷贝的改变，不会影响数据库内容。

下面，我们拿到之前使用Hare创建的Harry，并将他的颜色变为棕色：

harry.setColor("brown");  
final Hare updatedHarry = hares.update(harry);

如果更新被接受了，那么管理器会返回hare的一个新的拷贝，因为我们在后面会继续使用这个实例。就想做“创建”的例子中，更新可能会失败。也许颜色被定义为“值唯一”，棕色已经存在于hare中。那样的话，会抛出一个SpeedmentException异常.

我们也可以通过合并多个实体到一个流中来同时更新他们。加入我们想将所有名字为Harry的hare变为棕色，我们可以这样做：

hares.stream()  .
filter(Hare.NAME.equal("Harry")) .
map(Hare.COLOR.setTo("Brown"))  .
forEach(hares.updater()); 
// 更新流中存在的元素

我们还应该使用try-catch语句来确保在运行过程中有失败发生时警告用户。

try {  hares.stream()  .
filter(Hare.NAME.equal("Harry"))  .
map(Hare.COLOR.setTo("Brown"))  .
forEach(hares.updater());  } 
catch (final SpeedmentException ex) {
  System.err.println(ex.getMessage());
    return; 
     }

实体删除

我们需要知道的最后一个 CRUD 操作就是从数据库中删除实体。这个操作几乎和“更新”操作时等同的。假如说我们要把年龄超过10岁的兔子的记录都删除，就要这样做:

try {  hares.stream()  .
filter(Hare.AGE.greaterThan(10))  .
forEach(hares.remover()); 
// Removes remaining hares  } 
catch (final SpeedmentException ex)
 {  
 System.err.println(ex.getMessage());
   return;
    }

  总结

通过阅读本文你已经了解了如何在一个 Maven 工程中对 Speedment 进行设置，还有如何使用 Java 8 的 Stream API 来从数据库中创建、更新、读取以及删除实体。这是你可以利用 Speedment 所能进行的操作的一个小的子集, 但已经是一个能让你上手的好的开始了。更多的示例以及更加高级的使用场景可以在GitHub-page上找到。