[JAVA] Ich möchte eine Verbindung herstellen, wenn eine Datenbank mit Spring und MyBatis erstellt wird

Was willst du tun

• Jeder Server verfügt über MySQL und Sie können über die App auf jeden zugreifen
• static_db（10.0.0.101:3306） --Pool-Verbindungen beim Starten der App
• dynamic_db（10.0.0.111:3306 ～ 10.0.0.115:3306） --dynamic_db wurde beim Start der App noch nicht erstellt
• ** Entscheiden Sie, zu welcher Datenbank beim Erstellen eine Verbindung hergestellt werden soll **, und stellen Sie eine Verbindung her

Realisierungsmethode

--static_db verwendet normalerweise die XML-Konfigurationsdatei (spring-servlet.xml) --dynamic_db generiert dynamisch SqlSessionFactory ohne ** Verwendung der XML-Konfigurationsdatei **

• How do I build SqlSessionFactory without XML?

Implementierung

Verschiedene Versionen

• Java 1.8
• Spring 4.2.4.RELEASE
• MyBatis 3.2.2
• MyBatis-Spring 1.2.1
• MySQL 5.6.39

Festlegen der Verbindungsinformationen für static_db

spring-servlet.xml

  <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    <property name="url" value="jdbc:mysql://10.0.0.101:3306/static_db" />
    <property name="username" value="root" />
    <property name="password" value="password" />
  </bean>

  <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    <property name="basePackage" value="sample.da.mapper" />
    <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>
  </bean>

  <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean" name="sqlSessionFactory">
    <property name="dataSource" ref="dataSource"></property>
    <property name="mapperLocations" value="classpath*:sample/da/mapper/*.xml"/>
  </bean>

  <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource"/>
  </bean>
  <tx:annotation-driven transaction-manager="transactionManager"/>

Zugriff auf static_db

Verwenden Sie eine DI Mapper-Instanz

@Service
public class StaticDb01AccessService {

	@Autowired
	private UsersMapper usersMapper;
	
	public void insert() {
		Users record = new Users();
		record.setNum("001");
		record.setName("Ichiro Tanaka");
		record.setCreated(new Date());
		record.setUpdated(new Date());
		usersMapper.insert(record);
	}
}

Zugriff auf dynamic_db

Generieren Sie manuell SqlSessionFactory und Mapper

@Service
public class DynamicDbAccessService {

	//Zum Beispiel 10.0.0.115 dynamisch_Wird aufgerufen, als db erstellt wurde
	public void insert(String endpoint) throws Exception {
		DataSource dataSource = getDataSource(endpoint); // endpoint「10.0.0.115」
		
		TransactionFactory trxFactory = new JdbcTransactionFactory();
		
		Environment env = new Environment("dynamic_db", trxFactory, dataSource);
		
		Configuration config = new Configuration(env);
		TypeAliasRegistry aliases = config.getTypeAliasRegistry();
		aliases.registerAlias("user", Users.class);
		
		config.addMapper(UsersMapper.class);
		
		SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(config);
		SqlSession session = factory.openSession();
		
		try {
			UsersMapper usersMapper = session.getMapper(UsersMapper.class);
			
			Users record = new Users();
			record.setNum("001");
			record.setName("Ichiro Tanaka");
			record.setCreated(new Date());
			record.setUpdated(new Date());
			
			usersMapper.insert(record);
			
			session.commit();
		} catch (Exception e) {
			session.rollback();
		} finally {
			session.close();
		}
	}

	private DataSource getDataSource(String endpoint) {
		BasicDataSource dataSource = new BasicDataSource();
		dataSource.setDriverClassName("com.mysql.jdbc.Driver");
		dataSource.setUrl(String.format("jdbc:mysql://%s/dynamic_db", endpoint));
		dataSource.setUsername("root");
		dataSource.setPassword("password");
		return dataSource;
	}
}