FEATURE : modify entity model for composite primary key #4

src/main/kotlin/eom/improve/kafkaboot/model/FilmActor.kt

@@ -0,0 +1,10 @@
+package eom.improve.kafkaboot.model
+
+import java.io.Serializable
+import java.time.LocalDateTime
+
+data class FilmActor(
+    val actorId: Int,
+    val filmId: Int,
+    val lastUpdate: LocalDateTime
+) : Serializable

src/main/kotlin/eom/improve/kafkaboot/model/FilmCategory.kt

@@ -0,0 +1,10 @@
+package eom.improve.kafkaboot.model
+
+import java.io.Serializable
+import java.time.LocalDateTime
+
+data class FilmCategory(
+    val filmId: Int,
+    val categoryId: Int,
+    val lastUpdate: LocalDateTime
+) : Serializable

src/main/kotlin/eom/improve/kafkaboot/repository/FilmActorRepository.kt

@@ -1,4 +1,11 @@
 package eom.improve.kafkaboot.repository
 
-interface FilmActorRepository {
+import eom.improve.kafkaboot.model.FilmActor
+import org.springframework.data.r2dbc.repository.R2dbcRepository
+import reactor.core.publisher.Flux
+import reactor.core.publisher.Mono
+
+interface FilmActorRepository : R2dbcRepository<FilmActor, Int> {
+    fun findAllByFilmId(filmId: Int) : Flux<FilmActor>
+    fun deleteByFilmId(filmId: Int) : Mono<Void>
 }

src/main/kotlin/eom/improve/kafkaboot/repository/FilmCategoryRepository.kt

@@ -1,4 +1,11 @@
 package eom.improve.kafkaboot.repository
 
-interface FilmCategoryRepository {
+import eom.improve.kafkaboot.model.FilmCategory
+import org.springframework.data.r2dbc.repository.R2dbcRepository
+import reactor.core.publisher.Flux
+import reactor.core.publisher.Mono
+
+interface FilmCategoryRepository : R2dbcRepository<FilmCategory, Int> {
+    fun findAllByFilmId(filmId: Int) : Flux<FilmCategory>
+    fun deleteByFilmId(filmId: Int) : Mono<Void>
 }