Spring Boot, JPAを使用したリレーション関係にあるテーブルへの一括INSERT

Question

1. 質問概要

Spring Boot を使用して、リレーション関係にあるテーブルに対して、親子同時にInsert処理を実施したいのですができません。
1テーブルずつINSERTして最後にCommitするしかないのでしょうか？

PostgreSQLのテーブルにマッピングしたPOJOクラスをRepositoryを使用してコミットしたいのですが、
その方法をご教示ください。

1. 該当のソースコード

・リレーションの親に相当するPOJOクラス

package ***;

import java.util.List;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.JoinColumn;
import javax.persistence.OneToMany;
import javax.persistence.Table;

@Entity
@Table(name = "users")
public class User {

	@Id
	@Column(name = "uid")
	private String uId;

	@Column(name = "photo_url")
	private String photoUrl;

	@OneToMany
	@JoinColumn(name = "uid", nullable = true)
	private List<UserLicense> licenses;

       // Getter / Setter は記載を省略

・リレーションの子に相当するPOJOクラス

package ***;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;

@Entity
@Table(name = "user_licenses")
public class UserLicnse {

	@Id
	@Column(name = "license_id")
	private int licenseId;

	@Column(name = "uid")
	private String uId;

	@Column(name = "authenticated")
	private boolean authenticated;

       // Getter / Setter は記載を省略

・Repositoryクラス

package ***;

import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;

import ***;

@Repository
public interface UserRepository extends JpaRepository<User, Long>{
}

・Repository呼出クラス

package ***;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import ***.bean.User;
import ***.repository.UserRepository;

@RestController
public class UsersControl {

	@Autowired
	UserRepository userRepository;

	@RequestMapping(value="/v1/user", method=RequestMethod.POST, consumes=MediaType.APPLICATION_JSON_VALUE)
	public void postUserInfo(@RequestBody User user) {

                // ここでエラーが発生する
		userRepository.save(user);

	}
}

・発生しているエラー

org.postgresql.util.PSQLException: ERROR: 列licenses0_.user_uidは存在しません
  ポジション: 324
	at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2433) ~[postgresql-42.2.2.jar:42.2.2]
	at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2178) ~[postgresql-42.2.2.jar:42.2.2]
	at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:306) ~[postgresql-42.2.2.jar:42.2.2]
	at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:441) ~[postgresql-42.2.2.jar:42.2.2]
	at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:365) ~[postgresql-42.2.2.jar:42.2.2]
	at org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:155) ~[postgresql-42.2.2.jar:42.2.2]

・テーブル構造

/* ユーザーテーブル */
CREATE TABLE users (
    uid VARCHAR NOT NULL -- ユーザーID
  , photo_url VARCHAR -- 写真URL
  , PRIMARY KEY (uid)
);
/* ユーザーテーブル */
CREATE TABLE user_licenses (
    license_id SERIAL NOT NULL -- ライセンスID
  , uid VARCHAR NOT NULL -- ユーザーID
  , authenticated BOOLEAN -- 認証済み
  , PRIMARY KEY (license_id)
  , FOREIGN KEY (uid) REFERENCES users(uid)
);

大変基礎的なことで申し訳ございませんが、
ご教示よろしくお願いいたします。

Comments

[退会済みユーザー]

OneToMany/ManyToOne が対になってないからとかじゃないの?

[baseballyama]

添付するエラーメッセージが誤っていたので修正したのですが、出てきているメッセージは、子テーブル(user_licenses)に、指定された情報がありません、といったものだと考えています。ついては、まず子テーブルをINSERTし、そのあと親テーブルをINSETする処理を自動で実施することはできないかと考えています。

[退会済みユーザー]

テーブル構成見直してください。なエラーになったな

[baseballyama]

右記はテーブル構造です。/* ユーザーテーブル */ CREATE TABLE users ( uid VARCHAR NOT NULL -- ユーザーID , photo_url VARCHAR -- 写真URL , PRIMARY KEY (uid) ); /* ユーザーテーブル */ CREATE TABLE user_licenses ( license_id SERIAL NOT NULL -- ライセンスID , uid VARCHAR NOT NULL -- ユーザーID , authenticated BOOLEAN -- 認証済み , PRIMARY KEY (license_id) , FOREIGN KEY (uid) REFERENCES users(uid) );

[baseballyama]

上記読みづらいので、質問本文に記載させて頂きました。

Answer 1

気になっていたので参考リンクを見ながらsave 1回でinsertできるよう検証してみました。

参考リンク曰く、UserからUserLicenseが参照でき、UserLicenseからUserが参照できる双方向リンクはあまり良いとはいえないそうですが、問題準拠で双方向リンクにしています。

環境

• Java 1.8
• Spring Boot 1.5.14
• H2DB(mode=PostgreSQL)
• Spring Data JPA

試験コード

@RunWith(SpringRunner.class)
@SpringBootTest
public class DemoApplicationTests {

  @Autowired
  private UserRepository userRepository;

  @Test
  public void insertUser() {
    User user = new User();
    user.setUId("user01");
    user.setPhotoUrl("/sample");

    userRepository.save(user);

    User selectUser = userRepository.findOne("user01");
    assertEquals("/sample", selectUser.getPhotoUrl());
    assertEquals(0, selectUser.getLicenses().size());
  }

  @Test
  public void insertUserWithLicense() {
    User user = new User();
    user.setUId("user02");
    user.setPhotoUrl("/sample");

    UserLicense ul = new UserLicense();
    ul.setUser(user);
    ul.setAuthenticated(true);
    user.getLicenses().add(ul);

    userRepository.save(user);

    User selectUser = userRepository.findOne("user02");
    assertEquals("/sample", selectUser.getPhotoUrl());
    assertEquals(1, selectUser.getLicenses().size());
    assertTrue(selectUser.getLicenses().get(0).isAuthenticated());
  }

}

UserRepository の変更点

// PK の型修正
public interface UserRepository extends JpaRepository<User, String>{
}

User の変更点

  // OneToMany アノテーションにパラメータを追加
  @OneToMany(cascade = CascadeType.ALL, fetch = FetchType.EAGER, mappedBy = "user")
  private List<UserLicense> licenses = new ArrayList<>();
  
  // get/set uId を get/set UId に変更(自動生成すると引っかかる)
  // 省略

UserLicense の変更点

  // String uid の代わりに User を持つ
  @ManyToOne(fetch = FetchType.EAGER)
  @JoinColumn(name = "uid", nullable = false)
  private User user;

---

参考リンク
OneToManyの参考リンク

Comments

[baseballyama]

レスホンスが大変遅くなり申し訳ございません。
上記プログラムで再度試してみました。
結果としてうまくいきました。ありがとうございます。

ただ、ページネーションの問題は大きいと感じました。
ページネーションのことも考えて（その他性能のことも考えて）
設計しないとデータが増えた場合に性能劣化の懸念があると感じました。
大変勉強になりました。ありがとうございます。

Answer 2

1テーブルずつINSERTして最後にCommitするしかないのでしょうか？

何行INSERTしても構いませんが、親テーブルが先にINSERTされている必要があります。

org.postgresql.util.PSQLException: ERROR: 列licenses0_.user_uidは存在しません

外部キーが設定してありますから、親テーブル users の id が先に insert されていないと、子テーブル user_licenses の id は insert できません。
親テーブルを先にinsertしてから子テーブルをinsertすればcommitは後でも大丈夫です。

Comments

[baseballyama]

質問が伝わりづらかったと思いますが、トランザクションを張って、テーブルごとにINSERTを実施し、コミットすればできることは理解しています。しかし折角アノテーションでリレーション関係を表現しているので、1行でコミットできるとプログラムが簡潔になって良いと思っています。この方法を知りたいのです。