iis创建网站,wordpress autopost,规划设计公司年终总结,营销型网站特点如何搭建多数据源项目只要以下简单几步;
一. 创建核心在config.datasource文件夹里
二. 引入相对应的jar包
三. 创建数据库连接配置
四. 写逻辑代码进行验证 1.DataSource
package com.irootech.config.datasource;import java.lang.annotation.*;Target({ElementType.MET…如何搭建多数据源项目只要以下简单几步;
一. 创建核心在config.datasource文件夹里
二. 引入相对应的jar包
三. 创建数据库连接配置
四. 写逻辑代码进行验证 1.DataSource
package com.irootech.config.datasource;import java.lang.annotation.*;Target({ElementType.METHOD, ElementType.TYPE})
Retention(RetentionPolicy.RUNTIME)
Documented
public interface DataSource {DataSourceType value() default DataSourceType.MYSQL;
}
2.DataSourceAspect
package com.irootech.config.datasource;import org.aspectj.lang.annotation.After;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.springframework.stereotype.Component;Aspect
Component
public class DataSourceAspect {Before(annotation(dataSource))public void changeDataSource(DataSource dataSource) {DataSourceType dataSourceType dataSource.value();DynamicDataSource.setDataSourceType(dataSourceType);}After(annotation(dataSource))public void restoreDataSource(DataSource dataSource) {DynamicDataSource.clearDataSourceType();}
}
3.DataSourceConfig
package com.irootech.config.datasource;import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;import javax.sql.DataSource;
import java.util.HashMap;
import java.util.Map;Configuration
MapperScan(basePackages com.irootech.mapper, sqlSessionFactoryRef sqlSessionFactory)
public class DataSourceConfig {Bean(name mysqlDataSource)ConfigurationProperties(prefix spring.datasource.mysql)public DataSource mysqlDataSource() {return DataSourceBuilder.create().build();}Bean(name postgresDataSource)ConfigurationProperties(prefix spring.datasource.postgres)public DataSource postgresDataSource() {return DataSourceBuilder.create().build();}Bean(name phoenixDataSource)ConfigurationProperties(prefix spring.datasource.phoenix)public DataSource phoenixDataSource() {return DataSourceBuilder.create().build();}Bean(name dorisDataSource)ConfigurationProperties(prefix spring.datasource.doris)public DataSource dorisDataSource() {return DataSourceBuilder.create().build();}BeanPrimarypublic DynamicDataSource dataSource(Qualifier(mysqlDataSource) DataSource mysqlDataSource,Qualifier(postgresDataSource) DataSource postgresDataSource,Qualifier(phoenixDataSource) DataSource phoenixDataSource,Qualifier(dorisDataSource) DataSource dorisDataSource) {MapObject, Object targetDataSources new HashMap();targetDataSources.put(DataSourceType.MYSQL, mysqlDataSource);targetDataSources.put(DataSourceType.POSTGRES, postgresDataSource);targetDataSources.put(DataSourceType.PHOENIX, phoenixDataSource);targetDataSources.put(DataSourceType.DORIS, dorisDataSource);return new DynamicDataSource(mysqlDataSource,targetDataSources);}Beanpublic SqlSessionFactory sqlSessionFactory(Qualifier(dataSource) DataSource dataSource) throws Exception {MybatisSqlSessionFactoryBean bean new MybatisSqlSessionFactoryBean();bean.setDataSource(dataSource);return bean.getObject();}Beanpublic DataSourceTransactionManager transactionManager(Qualifier(dataSource) DataSource dataSource) {return new DataSourceTransactionManager(dataSource);}
}4.DataSourceType
package com.irootech.config.datasource;public enum DataSourceType {MYSQL,POSTGRES,PHOENIX,DORIS
}5.DynamicDataSource
package com.irootech.config.datasource;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;import javax.sql.DataSource;
import java.util.Map;public class DynamicDataSource extends AbstractRoutingDataSource {private static final ThreadLocalDataSourceType contextHolder new ThreadLocal();public DynamicDataSource(DataSource defaultTargetDataSource, MapObject, Object targetDataSources) {super.setDefaultTargetDataSource(defaultTargetDataSource);super.setTargetDataSources(targetDataSources);super.afterPropertiesSet();}Overrideprotected Object determineCurrentLookupKey() {return contextHolder.get();}public static void setDataSourceType(DataSourceType dataSourceType) {contextHolder.set(dataSourceType);}public static DataSourceType getDataSourceType() {return contextHolder.get();}public static void clearDataSourceType() {contextHolder.remove();}
}
6. DataSourceMapper
package com.irootech.mapper;import com.irootech.config.datasource.DataSource;
import com.irootech.config.datasource.DataSourceType;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;import java.util.List;Mapper
public interface DataSourceMapper {DataSource(DataSourceType.MYSQL)Select(select * from data_source)ListObject getDataSourceMysql();DataSource(DataSourceType.PHOENIX)Select(select * from data_source)ListObject getDataSourcePhoenix();
}7. DataSourceServiceImpl
package com.irootech.service.impl;import com.irootech.mapper.DataSourceMapper;
import com.irootech.service.DataSourceService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.List;Service
public class DataSourceServiceImpl implements DataSourceService {Autowiredprivate DataSourceMapper dataSourceMapper;Overridepublic ListObject getDataSourceMysql() {return dataSourceMapper.getDataSourceMysql();}Overridepublic ListObject getDataSourcePhoenix() {return dataSourceMapper.getDataSourcePhoenix();}
}8. WebController
package com.irootech.web;import com.irootech.service.DataSourceService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;RestController
RequestMapping(/web_controller)
public class WebController {Autowiredprivate DataSourceService dataSourceService;GetMapping(value /message)public String message() {ListObject dataSourceMysqlList dataSourceService.getDataSourceMysql();System.out.println(dataSourceMysqlList);ListObject dataSourcePhoenixList dataSourceService.getDataSourcePhoenix();System.out.println(dataSourcePhoenixList);return WebController created;}
}下载demo地址https://download.csdn.net/download/u013772876/90233957
