发帖网站有哪些iis创建网站

当前位置： 首页 > news >正文

发帖网站有哪些,iis创建网站,浅谈中兴电子商务网站建设,附近广告公司联系电话如何搭建多数据源项目只要以下简单几步; 一. 创建核心在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