SpringDataJPA-Tips

우선 Docker(CE)를 로컬에 인스톨한다.

Mac : https://store.docker.com/editions/community/docker-ce-desktop-mac https://hub.docker.com/r/mysql/mysql-server/

MYSQL_USER="githubstudy" \
MYSQL_DATABASE="jpa-study" \
MYSQL_CONTAINER_NAME="mysql" \
MYSQL_ROOT_PASSWORD="githubstudy" \
MYSQL_PASSWORD="githubstudy" 

$ echo $MYSQL_USER

docker \
  run \
  --detach \
  --env MYSQL_ROOT_PASSWORD=${MYSQL_ROOT_PASSWORD} \
  --env MYSQL_USER=${MYSQL_USER} \
  --env MYSQL_PASSWORD=${MYSQL_PASSWORD} \
  --env MYSQL_DATABASE=${MYSQL_DATABASE} \
  --name ${MYSQL_CONTAINER_NAME} \
  --publish 3306:3306 \
  mysql:5.7

JPA Query new XXXX(args..)를 사용하여 조회.

@Query Annotation 등으로 특정 컬럼만 호출하도록 한다. findById와 같이 일반적인 select에서는 해당 entity의 모든속성을 호출하게 되어있다. 이경우 불필요한 컬럼과 자식entity까지 가져오게 되므로 아래와 같이 처리하는게 좋을 수도 있다.

예) company table 에서 code 컬럼만 조회.

@Query("select new Company(o.code) from Company o where o.id = :id")
Company findColumnById(@Param("id")Long id);

JPA Lock - @Version 사용하기

기본적으로 @Version사용시 낙관적 락이 적용된다.(LockModeType.NONE)

A 사용자가 [OrderId 1번 조회후 ProductId를 10으로 변경] B 사용자가 [OrderId 1번 조회후 ProductId를 5으로 변경]

먼저 A사용자가 ProductId의 변경을 시동하지만 이런저런 이슈로 하나의 TX가 15초 걸린다고 가정하고, (http://localhost:8080/orders/1/products/10/update-tx-lock?ms=15000)

이후 B사용자는 걸림없이 ProductId를 5로 수정했다. (http://localhost:8080/orders/1/products/10/update-tx-lock?ms=0)

이경우 A사용자는 먼저 find가 실행되어 해당 Version을 가지게 되고, B사용자는 늦게 find가 실행되어 A사용자보다 높은 Version을 갖게된다.

A사용자의 경우 OptimisticLock과련 오류가 throw되게 되고, B사용자의 ProductId로 업데이트된다.

중간에 find만 할경우는 Update가 완료된 B사용자의 ProductId가 적용되어 보이게된다. (http://localhost:8080/orders/1?ms=0)

JPA Spring Data Redis와 같이 사용하기

https://redis.io/download -> Redis 설치

application.properties 에 redis정보를 추가한다.
spring.redis.host=127.0.0.1
spring.redis.port=6379

설정

@Configuration
@EnableCaching
public class RedisCacheConfiguration {

	@Autowired
	private JedisConnectionFactory jedisConnectionFactory;

	...
}

JPA Hibernate Second Level Cache / Query Cache 를 적용

• L2 캐시가 적용된 Company Entity 를 최초 조회시 select 구문 호출 확인.
• Company Update 이후 다시 select 구문이 실행 여부 확인.

@..
@Cacheable
@org.hibernate.annotations.Cache(usage = CacheConcurrencyStrategy.READ_WRITE)
public class Company extends AuditingEntity implements Serializable {

	public Company(String code) {
		this.code = code;
	}

	@Id
	@Column(name = "id")
	@GeneratedValue(strategy = GenerationType.AUTO)
	private Long id;

Spring Boot 1.5.8 Up!

Spring Boot 1.5.9 Up!

1.5.8에서 QueryDslRepositorySupport 관련 bug로 인해 1.5.9로 버전 올림

JPA QueryDSL와 같이 사용하기

public class CompanyRepositoryImpl extends QueryDslRepositorySupport implements CompanyRepositoryCustom {

    public CompanyRepositoryImpl() {
        super(Company.class);
    }

    @Override
    public Long findMaxId() {
        return from(QCompany.company).select(QCompany.company.id.max()).fetchOne();
    }

}

@SqlResultSetMapping 를 이용한 커스텀 엔티티 적용.

@SqlResultSetMappings({
        @SqlResultSetMapping(name = "SimpleCompany",
                classes = @ConstructorResult(targetClass = SimpleCompany.class,
                        columns = {
                                @ColumnResult(name = "code", type = String.class),
                                @ColumnResult(name = "name", type = String.class)
                        }))
})
...
public class Company extends AuditingEntity implements Serializable {
    ...
}

    @Override
    public List<SimpleCompany> findSimpleCompanies() {
        StringBuilder queryBuilder = new StringBuilder("SELECT");
        queryBuilder.append(" code,");
        queryBuilder.append(" name");
        queryBuilder.append(" FROM company ");
        queryBuilder.append(" LIMIT 10 ");
        Query query = getEntityManager().createNativeQuery(queryBuilder.toString(), "SimpleCompany");
        List<SimpleCompany> results = query.getResultList();
        return results;
    }