spring boot 에서 다중 db연결...

Question

살려주세여../com/login 가 로그인 페이지 인데 /com/login 에 진입해서 세션값에 따라 디비를 선택해서 재연결을 하려고하는데 determineCurrentLookupKey 값이 너무 불안정하고 datasource1 로 하면 잘되는데datasource2 로 바꿔서 돌리면 키값이 datasource2로 갔다가 1로 돌아옵니다..determineCurrentLookupKey 메서드가 계속 호줄되서 그런것같은데..어떻게 해결방법없을까요 ㅜㅜㅜ@RequestMapping(value = "/com/login") public String getCommon(HttpServletRequest request, Model model, HttpSession session) { if (session.getAttribute("db_key") == null) { session.setAttribute("db_key","datasource1"); session.setMaxInactiveInterval(-1); DBConfiguration dbConf = new DBConfiguration(); dbConf.createRouterDatasource(); } String path = request.getServletPath(); Map param = new HashMap(); param.put("path", path); path = path.substring(1); System.out.println(" PATH :: " + path); return path; }@Bean public DataSource createRouterDatasource() { AbstractRoutingDataSource routingDataSource = new MyRoutingDataSource(); Map targetDataSources = new HashMap<>(); Object currentLookupKey = ((MyRoutingDataSource) routingDataSource).determineCurrentLookupKey(); System.out.println("Current database key: " + currentLookupKey); if(currentLookupKey.equals("datasource1")){ targetDataSources.put("datasource1", createDataSource("jdbc:log4jdbc:mariadb://localhost:3306","root","0314")); System.out.println("Current== database1"); }else if(currentLookupKey.equals("datasource2")){ targetDataSources.put("datasource2", createDataSource("jdbc:log4jdbc:mariadb://132.188.147.236:3307/test?allowMultiQueries=true","test","test1")); System.out.println("Current== database2"); } routingDataSource.setTargetDataSources(targetDataSources); routingDataSource.afterPropertiesSet(); return routingDataSource; } private DataSource createDataSource(String url,String user, String password) { com.zaxxer.hikari.HikariDataSource dataSource = new com.zaxxer.hikari.HikariDataSource(); dataSource.setDriverClassName("net.sf.log4jdbc.sql.jdbcapi.DriverSpy"); dataSource.setUsername(user); dataSource.setPassword(password); dataSource.setJdbcUrl(url); System.out.println("test="+url); return dataSource; } @Override public Object determineCurrentLookupKey() { RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes(); Object dbKey; if (requestAttributes != null) { dbKey = requestAttributes.getAttribute("db_key", RequestAttributes.SCOPE_SESSION); if (dbKey != null) { logger.info("Current DB Key: {}", dbKey); } else { dbKey = "datasource1"; // 기본 데이터 소스 키 설정 logger.info("DB Key not found in session. Using default: {}", dbKey); } } else { dbKey = "datasource1"; // 기본 데이터 소스 키 설정 logger.warn("RequestAttributes not found. Using default DB Key: {}", dbKey); } return dbKey; }}

kenu,전독시 · Answer

Spring Boot에서 다중 DB 연결을 구현하려면, 여러 데이터 소스를 설정하고, 각각의 데이터 소스에 대한 빈을 생성해야 합니다. 이를 위해 @Configuration 클래스를 사용하여 각 데이터 소스에 대한 DataSource 빈을 정의하고, 각각의 EntityManager와 TransactionManager를 설정합니다. 아래는 이를 구현하는 방법에 대한 단계별 가이드입니다.1. *의존성 추가*: 먼저, pom.xml 파일에 필요한 의존성을 추가합니다. Spring Boot에서는 기본적으로 H2 데이터베이스를 사용하므로, 다른 데이터베이스를 사용하려면 해당 데이터베이스의 의존성을 추가해야 합니다.2. *데이터 소스 설정*: application.properties 또는 application.yml 파일에 각 데이터 소스에 대한 설정을 추가합니다. 예를 들어, 두 개의 MySQL 데이터베이스에 연결하려면 다음과 같이 설정할 수 있습니다.```properties# 첫 번째 데이터 소스spring.datasource.db1.url=jdbc:mysql://localhost:3306/db1spring.datasource.db1.username=user1spring.datasource.db1.password=pass1# 두 번째 데이터 소스spring.datasource.db2.url=jdbc:mysql://localhost:3306/db2spring.datasource.db2.username=user2spring.datasource.db2.password=pass2```3. *데이터 소스 빈 생성*: @Configuration 클래스를 생성하여 각 데이터 소스에 대한 DataSource 빈을 정의합니다.```java@Configurationpublic class DataSourceConfig { @Bean @ConfigurationProperties("spring.datasource.db1") public DataSource db1DataSource() { return DataSourceBuilder.create().build(); } @Bean @ConfigurationProperties("spring.datasource.db2") public DataSource db2DataSource() { return DataSourceBuilder.create().build(); }}```4. *EntityManager 및 TransactionManager 설정*: 각 데이터 소스에 대한 EntityManager와 TransactionManager를 설정합니다. 이를 위해 @Primary 어노테이션을 사용하여 기본 EntityManager와 TransactionManager를 지정할 수 있습니다.```java@Configuration@EnableTransactionManagementpublic class JpaConfig { @Primary @Bean(name = "db1EntityManager") public LocalContainerEntityManagerFactoryBean db1EntityManagerFactory(EntityManagerFactoryBuilder builder, @Qualifier("db1DataSource") DataSource dataSource) { return builder .dataSource(dataSource) .packages("com.example.model.db1") .persistenceUnit("db1") .build(); } @Primary @Bean(name = "db1TransactionManager") public PlatformTransactionManager db1TransactionManager(@Qualifier("db1EntityManager") EntityManagerFactory entityManagerFactory) { return new JpaTransactionManager(entityManagerFactory); } @Bean(name = "db2EntityManager") public LocalContainerEntityManagerFactoryBean db2EntityManagerFactory(EntityManagerFactoryBuilder builder, @Qualifier("db2DataSource") DataSource dataSource) { return builder .dataSource(dataSource) .packages("com.example.model.db2") .persistenceUnit("db2") .build(); } @Bean(name = "db2TransactionManager") public PlatformTransactionManager db2TransactionManager(@Qualifier("db2EntityManager") EntityManagerFactory entityManagerFactory) { return new JpaTransactionManager(entityManagerFactory); }}```5. *서비스 레이어에서 사용*: 이제 각 데이터 소스에 대한 EntityManager와 TransactionManager를 사용하여 데이터베이스 연산을 수행할 수 있습니다. @Transactional 어노테이션을 사용하여 트랜잭션 관리를 적용할 수 있습니다.```java@Servicepublic class MyService { @Autowired @Qualifier("db1EntityManager") private EntityManager db1EntityManager; @Autowired @Qualifier("db2EntityManager") private EntityManager db2EntityManager; @Transactional("db1TransactionManager") public void someDb1Operation() { // db1에 대한 연산 } @Transactional("db2TransactionManager") public void someDb2Operation() { // db2에 대한 연산 }}```이 방법을 사용하면 Spring Boot에서 다중 데이터베이스 연결을 구현할 수 있습니다. 각 데이터 소스에 대한 설정을 별도로 관리하고, 필요에 따라 다른 데이터 소스를 사용하여 데이터베이스 연산을 수행할 수 있습니다.Citations:[1] https://jangjjolkit.tistory.com/55[2] https://jong-bae.tistory.com/58[3] https://velog.io/@jonghne/Spring-Boot-%EB%8B%A4%EC%A4%91-%EB%8D%B0%EC%9D%B4%ED%84%B0%EB%B2%A0%EC%9D%B4%EC%8A%A4-%EC%82%AC%EC%9A%A9%ED%95%98%EA%B8%B0[4] https://jiurinie.tistory.com/136[5] https://www.dotnetnote.com/docs/spring-boot/spring-boot-multiple-database-connection/[6] https://www.youtube.com/watch?v=kr1qSddBygk[7] https://nizimo.tistory.com/286[8] https://dev-yujji.tistory.com/21[9] https://ospace.tistory.com/890[10] https://velog.io/@dhkim1522/Spring-%EB%8B%A4%EC%A4%91-DB-%EC%97%B0%EA%B2%B0-%EA%B5%AC%ED%98%84from: https://www.phind.com/search?cache=cej45ee95r8mzmb93jz2nqdo

spring boot 에서 다중 db연결...

1개의 답변

Q&A 목록