From b9e36dd343e9b582f109881ef5722c3cd0f08fce Mon Sep 17 00:00:00 2001 From: sinkyoungdeok Date: Sun, 5 Feb 2023 20:56:27 +0900 Subject: [PATCH] =?UTF-8?q?=ED=8A=B8=EB=9E=9C=EC=9E=AD=EC=85=98=20?= =?UTF-8?q?=EC=84=A4=EC=A0=95=20=EC=B6=94=EA=B0=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../common/config/MySQLConfiguration.kt | 32 +++++++++++++++++++ 1 file changed, 32 insertions(+) create mode 100644 server/src/main/kotlin/com/fone/filmone/common/config/MySQLConfiguration.kt diff --git a/server/src/main/kotlin/com/fone/filmone/common/config/MySQLConfiguration.kt b/server/src/main/kotlin/com/fone/filmone/common/config/MySQLConfiguration.kt new file mode 100644 index 0000000..1020f19 --- /dev/null +++ b/server/src/main/kotlin/com/fone/filmone/common/config/MySQLConfiguration.kt @@ -0,0 +1,32 @@ +package com.fone.filmone.common.config + +import io.r2dbc.spi.ConnectionFactories +import io.r2dbc.spi.ConnectionFactory +import org.springframework.beans.factory.annotation.Autowired +import org.springframework.beans.factory.annotation.Qualifier +import org.springframework.context.annotation.Bean +import org.springframework.context.annotation.Configuration +import org.springframework.core.env.Environment +import org.springframework.data.r2dbc.repository.config.EnableR2dbcRepositories +import org.springframework.r2dbc.connection.R2dbcTransactionManager +import org.springframework.transaction.ReactiveTransactionManager + +@Configuration +@EnableR2dbcRepositories(entityOperationsRef = "mySQLEntityTemplate") +class MySQLConfiguration { + + @Autowired + private lateinit var env: Environment + + @Bean + @Qualifier("mySQLConnectionFactory") + fun mySQLConnectionFactory(): ConnectionFactory { + val url = "r2dbcs:mysql://root:fone-flim-be@localhost:3306/fone" + return ConnectionFactories.get(url) + } + + @Bean + fun reactiveTransactionManager(@Qualifier("mySQLConnectionFactory") connectionFactory: ConnectionFactory): ReactiveTransactionManager { + return R2dbcTransactionManager(connectionFactory) + } +} \ No newline at end of file