[Resolves #6] redis config 설정 및 테스트 코드

build.gradle

@@ -22,6 +22,7 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
     implementation 'org.springframework.boot:spring-boot-starter-validation'
     implementation 'org.springframework.boot:spring-boot-starter-web'
+    implementation 'org.springframework.boot:spring-boot-starter-data-redis'
     compileOnly 'org.projectlombok:lombok'
     runtimeOnly 'com.h2database:h2'
     runtimeOnly 'mysql:mysql-connector-java'

src/main/java/oncoding/concoder/ConcoderApplication.java

@@ -2,7 +2,9 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
 
+@EnableJpaAuditing
 @SpringBootApplication
 public class ConcoderApplication {
 

src/main/java/oncoding/concoder/config/RedisConfig.java

@@ -0,0 +1,62 @@
+package oncoding.concoder.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.lettuce.LettuceConnection;
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+@Configuration
+public class RedisConfig {
+
+    @Value("${spring.redis.host}")
+    private String host;
+
+    @Value("${spring.redis.port}")
+    private int port;
+
+    /*
+    Spring Data Redis는 Redis에 두 가지 접근 방식을 제공합니다.
+    하나는 RedisTemplate을 이용한 방식이며, 다른 하나는 RedisRepository를 이용한 방식
+
+    두 방식 모두 Redis에 접근하기 위해서는 Redis 저장소와 연결하는 과정이 필요
+    이 과정을 위해 RedisConnectionFactory 인터페이스(LettuceConnectionFactory )를 사용
+    * */
+    @Bean //redisConnectionFactory 이름의 빈(역할)은 LettuceConnectionFactory(host, port)를 구현체로 선택한 것
+    public LettuceConnectionFactory redisConnectionFactory() {
+        return new LettuceConnectionFactory(host, port);
+    }
+
+    /*
+    redisTemplate을 사용하여 Redis 저장소에 접근하기로 한다
+    RedisTemplate은 Redis 저장소에 오브젝트를 저장할 때 기본값으로 정의된 JdkSerializationRedisSerializer을 이용
+     */
+    @Bean
+    public RedisTemplate<String,Object> redisTemplate(){
+        RedisTemplate<String,Object> redisTemplate = new RedisTemplate<>();
+        redisTemplate.setKeySerializer(new StringRedisSerializer());
+        redisTemplate.setValueSerializer(new StringRedisSerializer());
+        redisTemplate.setConnectionFactory(redisConnectionFactory());
+        return redisTemplate;
+    }
+
+    /*
+    대부분 레디스 key-value 는 문자열 위주이기 때문에 문자열에 특화된 템플릿을 제공
+    RedisTemplate 을 상속받은 클래스임.
+    StringRedisSerializer로 직렬화함
+     */
+    @Bean
+    public StringRedisTemplate stringRedisTemplate(){
+        final StringRedisTemplate stringRedisTemplate = new StringRedisTemplate();
+        stringRedisTemplate.setKeySerializer(new StringRedisSerializer());
+        stringRedisTemplate.setValueSerializer(new StringRedisSerializer());
+        stringRedisTemplate.setConnectionFactory(redisConnectionFactory());
+        return stringRedisTemplate;
+    }
+
+
+
+}

src/main/java/oncoding/concoder/model/Category.java

@@ -0,0 +1,17 @@
+package oncoding.concoder.model;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.validation.constraints.NotNull;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class Category extends JpaBaseEntity {
+    @Column
+    @NotNull
+    private String name;
+}

src/main/java/oncoding/concoder/model/JpaBaseEntity.java

@@ -0,0 +1,15 @@
+package oncoding.concoder.model;
+
+import java.util.UUID;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import javax.persistence.MappedSuperclass;
+import lombok.Getter;
+
+@Getter
+@MappedSuperclass
+public class JpaBaseEntity {
+    @Id
+    @GeneratedValue
+    private UUID id;
+}

src/main/java/oncoding/concoder/model/Level.java

@@ -0,0 +1,17 @@
+package oncoding.concoder.model;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.validation.constraints.NotNull;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class Level extends JpaBaseEntity {
+    @Column
+    @NotNull
+    private String name;
+}

src/main/java/oncoding/concoder/model/Problem.java

@@ -0,0 +1,41 @@
+package oncoding.concoder.model;
+
+import java.util.ArrayList;
+import java.util.List;
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.FetchType;
+import javax.persistence.ManyToOne;
+import javax.persistence.OneToMany;
+import javax.validation.constraints.NotNull;
+
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class Problem extends JpaBaseEntity {
+    @Column(unique = true)
+    @NotNull
+    private Integer number;
+
+    @Column
+    @NotNull
+    private String title;
+
+    @Column
+    private Float rate;
+
+    @Column
+    @NotNull
+    private String content;
+
+    @ManyToOne(fetch = FetchType.EAGER)
+    private Level level;
+
+    @OneToMany(fetch = FetchType.EAGER, mappedBy = "problem")
+    private List<ProblemCategory> categories = new ArrayList<>();
+
+}

src/main/java/oncoding/concoder/model/ProblemCategory.java

@@ -0,0 +1,18 @@
+package oncoding.concoder.model;
+
+import javax.persistence.Entity;
+import javax.persistence.ManyToOne;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class ProblemCategory extends JpaBaseEntity {
+    @ManyToOne
+    private Problem problem;
+
+    @ManyToOne
+    private Category category;
+}

src/main/java/oncoding/concoder/model/Snapshot.java

@@ -0,0 +1,35 @@
+package oncoding.concoder.model;
+
+import java.time.LocalDateTime;
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.EntityListeners;
+import javax.validation.constraints.NotNull;
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.springframework.data.annotation.CreatedDate;
+import org.springframework.data.jpa.domain.support.AuditingEntityListener;
+
+@Entity
+@Getter
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@EntityListeners(AuditingEntityListener.class)
+public class Snapshot extends JpaBaseEntity {
+
+    @CreatedDate
+    @Column(updatable=false, nullable = false)
+    private LocalDateTime createdDate;
+
+    @Column
+    @NotNull
+    private String memo;
+
+    @Column
+    @NotNull
+    private String content;
+}

src/main/java/oncoding/concoder/repository/CategoryRepository.java

@@ -0,0 +1,9 @@
+package oncoding.concoder.repository;
+
+import java.util.UUID;
+import oncoding.concoder.model.Category;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface CategoryRepository extends JpaRepository<Category, UUID> {
+
+}

src/main/java/oncoding/concoder/repository/LevelRepository.java

@@ -0,0 +1,9 @@
+package oncoding.concoder.repository;
+
+import java.util.UUID;
+import oncoding.concoder.model.Level;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface LevelRepository extends JpaRepository<Level, UUID> {
+
+}

src/main/java/oncoding/concoder/repository/ProblemCategoryRepository.java

@@ -0,0 +1,9 @@
+package oncoding.concoder.repository;
+
+import java.util.UUID;
+import oncoding.concoder.model.ProblemCategory;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface ProblemCategoryRepository extends JpaRepository<ProblemCategory, UUID> {
+
+}

src/main/java/oncoding/concoder/repository/ProblemRepository.java

@@ -0,0 +1,9 @@
+package oncoding.concoder.repository;
+
+import java.util.UUID;
+import oncoding.concoder.model.Problem;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface ProblemRepository extends JpaRepository<Problem, UUID> {
+
+}

src/main/resources/application.yml

@@ -1 +1,4 @@
-
+spring:
+  redis:
+    host: localhost
+    port: 6379

src/test/java/oncoding/concoder/config/RedisBasicTest.java

@@ -0,0 +1,88 @@
+package oncoding.concoder.config;
+
+
+import java.util.concurrent.TimeUnit;
+import org.assertj.core.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.jdbc.AutoConfigureTestDatabase;
+import org.springframework.boot.test.autoconfigure.jdbc.AutoConfigureTestDatabase.Replace;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.ValueOperations;
+
+@SpringBootTest
+@AutoConfigureTestDatabase(replace = Replace.NONE)
+public class RedisBasicTest {
+
+    @Autowired
+    RedisTemplate<String, String> redisTemplate;
+
+
+    public static class RedisUserDto{
+        private String name;
+        private String password;
+
+        public RedisUserDto(String name, String password){
+            this.name = name;
+            this.password = password;
+        }
+
+        public RedisUserDto() {
+
+        }
+
+        public String getName(){
+            return this.name;
+        }
+
+        public String getPassword(){
+            return this.password;
+        }
+
+    }
+
+    /**
+     * 단순 연결 테스트 -  key와 value 삽입
+     */
+    @Test
+    void redisConnectionTest() {
+        final String key = "a";
+        final String data = "1";
+
+        final ValueOperations<String, String> valueOperations = redisTemplate.opsForValue();
+        valueOperations.set(key, data);
+
+        final String s = valueOperations.get(key);
+        Assertions.assertThat(s).isEqualTo(data);
+    }
+
+    @Test
+    void redisInsertObject(){
+        RedisUserDto redisUserDto = new RedisUserDto("kenux", "password");
+
+        final ValueOperations<String, String> valueOperations = redisTemplate.opsForValue();
+        valueOperations.set(redisUserDto.getName(), String.valueOf(redisUserDto));
+
+        final String result = valueOperations.get(redisUserDto.getName());
+
+    }
+
+    /**
+     * 위 코드 redis에 삽입한 아이템에 대해서 5초의 expire time을 설정하고, 5초가 지난 후에 redis에서 해당 키가 조회되는지 테스트하는 코드
+     * @throws InterruptedException
+     */
+    @Test
+    void redisExpireTest() throws InterruptedException {
+        final String key = "a";
+        final String data = "1";
+
+        final ValueOperations<String, String> valueOperations = redisTemplate.opsForValue();
+        valueOperations.set(key, data);
+        final Boolean expire = redisTemplate.expire(key, 5, TimeUnit.SECONDS);
+        Thread.sleep(6000);
+        final String s = valueOperations.get(key);
+
+    }
+
+}