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

배경

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

public 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)
);

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

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

지속성 작업이 실패하는 경우(예: 외래 키가 고유성 제약 조건을 위반하는 경우) A가 발생합니다. 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에서 생성한 on 빌더를 사용하여 필터를 정의합니다. 이를 통해 스트림을 프로그래밍 방식으로 분석하고 다음과 같은 SQL 문으로 줄일 수 있습니다.

SELECT COUNT(id) FROM hares.hareWHERE 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 上找到。

更多Java 8 Streams 中的数据库 CRUD 操作相关文章请关注PHP中文网！