Add UserRepositoryImpl saveAll 함수 추가

team-xquare · Jan 10, 2024 · 2387118 · 2387118
1 parent 180f5d7
commit 2387118
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/...astructure/src/main/kotlin/com/xquare/v1userservice/user/repository/UserRepositoryImpl.kt b/...astructure/src/main/kotlin/com/xquare/v1userservice/user/repository/UserRepositoryImpl.kt
@@ -26,6 +26,16 @@ class UserRepositoryImpl(
     private val reactiveQueryFactory: HibernateMutinyReactiveQueryFactory,
     private val userDomainMapper: UserDomainMapper
 ) : UserRepositorySpi {
+
+    override suspend fun saveAll(user: List<User>) {
+        val userAllSave = user.map { userDomainMapper.userDomainToEntity(it) }
+        reactiveQueryFactory.transactionWithFactory { session, _ ->
+            userAllSave.forEach { userEntity ->
+                session.persistUserEntityConcurrently(userEntity)
+            }
+        }
+    }
+
     override suspend fun saveUser(user: User): User {
         val userEntityToSave = userDomainMapper.userDomainToEntity(user)
         reactiveQueryFactory.transactionWithFactory { session, _ ->