From 27a28b5613a96de563e23baacb038f82588c5fbb Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期一, 08 九月 2025 21:35:12 +0800
Subject: [PATCH] 删除中间表
---
/dev/null | 38 --------------------------------------
1 files changed, 0 insertions(+), 38 deletions(-)
diff --git a/src/main/java/com/zy/common/config/ds/AbstractRoutingDataSource.java b/src/main/java/com/zy/common/config/ds/AbstractRoutingDataSource.java
deleted file mode 100644
index d8b8519..0000000
--- a/src/main/java/com/zy/common/config/ds/AbstractRoutingDataSource.java
+++ /dev/null
@@ -1,38 +0,0 @@
-package com.zy.common.config.ds;
-
-import org.springframework.beans.factory.InitializingBean;
-import org.springframework.jdbc.datasource.AbstractDataSource;
-import org.springframework.util.Assert;
-
-import javax.sql.DataSource;
-import java.util.Map;
-
-public abstract class AbstractRoutingDataSource extends AbstractDataSource implements InitializingBean {
- //澶氭暟鎹簮map闆嗗悎
- private Map<Object, Object> targetDataSources;
- //榛樿鏁版嵁婧�
- private Object defaultTargetDataSource;
- //鍏跺疄灏辨槸targetDataSources锛屽悗闈㈢殑afterPropertiesSet锛堬級鏂规硶浼氬皢targetDataSources璧嬪�肩粰resolvedDataSources
- private Map<Object, DataSource> resolvedDataSources;
- private DataSource resolvedDefaultDataSource;
-
- public void setTargetDataSources(Map<Object, Object> targetDataSources) {
- this.targetDataSources = targetDataSources;
- }
-
- protected DataSource determineTargetDataSource() {
- Assert.notNull(this.resolvedDataSources, "DataSource router not initialized");
- Object lookupKey = this.determineCurrentLookupKey();
- DataSource dataSource = (DataSource) this.resolvedDataSources.get(lookupKey);
- if (dataSource == null && ( lookupKey == null)) {
- dataSource = this.resolvedDefaultDataSource;
- }
- if (dataSource == null) {
- throw new IllegalStateException("Cannot determine target DataSource for lookup key [" + lookupKey + "]");
- } else {
- return dataSource;
- }
- }
-
- protected abstract Object determineCurrentLookupKey();
-}
\ No newline at end of file
diff --git a/src/main/java/com/zy/common/config/ds/DataSourceAop.java b/src/main/java/com/zy/common/config/ds/DataSourceAop.java
deleted file mode 100644
index 4de4666..0000000
--- a/src/main/java/com/zy/common/config/ds/DataSourceAop.java
+++ /dev/null
@@ -1,27 +0,0 @@
-package com.zy.common.config.ds;
-
-import org.aspectj.lang.annotation.Aspect;
-import org.aspectj.lang.annotation.Before;
-import org.springframework.stereotype.Component;
-
-@Aspect
-@Component
-public class DataSourceAop {
- @Before("execution(* com.zy.asrs..*(..))")
- public void setDataSource2test01() {
- //System.err.println("test01涓氬姟");
- DataSourceType.setDataBaseType(DataSourceType.DataBaseType.TEST01);
- }
-
- @Before("execution(* com.zy.system..*(..))")
- public void setDataSource2test012() {
- //System.err.println("test01涓氬姟");
- DataSourceType.setDataBaseType(DataSourceType.DataBaseType.TEST01);
- }
-
- @Before("execution(* com.zy.nc..*(..))")
- public void setDataSource2test02() {
- //System.err.println("test02涓氬姟");
- DataSourceType.setDataBaseType(DataSourceType.DataBaseType.TEST02);
- }
-}
diff --git a/src/main/java/com/zy/common/config/ds/DataSourceConfig.java b/src/main/java/com/zy/common/config/ds/DataSourceConfig.java
deleted file mode 100644
index 755f6d3..0000000
--- a/src/main/java/com/zy/common/config/ds/DataSourceConfig.java
+++ /dev/null
@@ -1,44 +0,0 @@
-package com.zy.common.config.ds;
-
-import org.springframework.beans.factory.annotation.Value;
-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 javax.sql.DataSource;
-
-@Configuration
-public class DataSourceConfig {
-
- @Value("${other.datasource.jdbc-url}")
- private String url;
- @Value("${other.datasource.username}")
- private String username;
- @Value("${other.datasource.password}")
- private String password;
- @Value("${other.datasource.driver-class-name}")
- private String driverClassName;
-
- // 涓绘暟鎹簮
- @Bean(name = "dataSource")
- @Primary
- @ConfigurationProperties(prefix = "spring.datasource")
- public DataSource primaryDataSource() {
- return DataSourceBuilder.create().build();
- }
-
- // 娆℃暟鎹簮
- @Bean(name = "slaveDataSource")
- public DataSource secondaryDataSource() {
- return DataSourceBuilder.create()
- .driverClassName(driverClassName)
- .url(url)
- .username(username)
- .password(password)
- .build();
-
- }
-
-}
diff --git a/src/main/java/com/zy/common/config/ds/DataSourceType.java b/src/main/java/com/zy/common/config/ds/DataSourceType.java
deleted file mode 100644
index 57ce62b..0000000
--- a/src/main/java/com/zy/common/config/ds/DataSourceType.java
+++ /dev/null
@@ -1,32 +0,0 @@
-package com.zy.common.config.ds;
-
-public class DataSourceType {
-
- public enum DataBaseType {
- TEST01, TEST02
- }
-
- // 浣跨敤ThreadLocal淇濊瘉绾跨▼瀹夊叏
- private static final ThreadLocal<DataBaseType> TYPE = new ThreadLocal<DataBaseType>();
-
- // 寰�褰撳墠绾跨▼閲岃缃暟鎹簮绫诲瀷
- public static void setDataBaseType(DataBaseType dataBaseType) {
- if (dataBaseType == null) {
- throw new NullPointerException();
- }
- //System.err.println("[灏嗗綋鍓嶆暟鎹簮鏀逛负]锛�" + dataBaseType);
- TYPE.set(dataBaseType);
- }
-
- // 鑾峰彇鏁版嵁婧愮被鍨�
- public static DataBaseType getDataBaseType() {
- DataBaseType dataBaseType = TYPE.get() == null ? DataBaseType.TEST01 : TYPE.get();
- //System.err.println("[鑾峰彇褰撳墠鏁版嵁婧愮殑绫诲瀷涓篯锛�" + dataBaseType);
- return dataBaseType;
- }
-
- // 娓呯┖鏁版嵁绫诲瀷
- public static void clearDataBaseType() {
- TYPE.remove();
- }
-}
diff --git a/src/main/java/com/zy/common/config/ds/DynamicDataSource.java b/src/main/java/com/zy/common/config/ds/DynamicDataSource.java
deleted file mode 100644
index a0e228c..0000000
--- a/src/main/java/com/zy/common/config/ds/DynamicDataSource.java
+++ /dev/null
@@ -1,11 +0,0 @@
-package com.zy.common.config.ds;
-
-import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
-
-public class DynamicDataSource extends AbstractRoutingDataSource {
- @Override
- protected Object determineCurrentLookupKey() {
- DataSourceType.DataBaseType dataBaseType = DataSourceType.getDataBaseType();
- return dataBaseType;
- }
-}
diff --git a/src/main/java/com/zy/common/config/ds/PrimaryDataSourceConfig.java b/src/main/java/com/zy/common/config/ds/PrimaryDataSourceConfig.java
deleted file mode 100644
index 16b482c..0000000
--- a/src/main/java/com/zy/common/config/ds/PrimaryDataSourceConfig.java
+++ /dev/null
@@ -1,40 +0,0 @@
-package com.zy.common.config.ds;
-
-import com.baomidou.mybatisplus.plugins.PaginationInterceptor;
-import com.baomidou.mybatisplus.spring.MybatisSqlSessionFactoryBean;
-import org.apache.ibatis.plugin.Interceptor;
-import org.mybatis.spring.annotation.MapperScan;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.context.annotation.Primary;
-import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
-import org.springframework.jdbc.datasource.DataSourceTransactionManager;
-
-import javax.sql.DataSource;
-
-@Configuration
-@MapperScan(basePackages = {"com.zy.asrs.mapper", "com.zy.system.mapper"}, sqlSessionFactoryRef = "primarySqlSessionFactory")
-public class PrimaryDataSourceConfig {
-
- @Bean(name = "primarySqlSessionFactory")
- @Primary
- public MybatisSqlSessionFactoryBean primarySqlSessionFactory(@Qualifier("dataSource") DataSource dataSource, PaginationInterceptor paginationInterceptor) throws Exception {
- MybatisSqlSessionFactoryBean sessionFactory = new MybatisSqlSessionFactoryBean();
- sessionFactory.setDataSource(dataSource);
- // 璁剧疆MyBatis鐨凪apper XML鏂囦欢璺緞
- sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
- .getResources("classpath:mapper/asrs/*.xml"));
- Interceptor[] interceptors = new Interceptor[]{paginationInterceptor};
- sessionFactory.setPlugins(interceptors);
- return sessionFactory;
- }
-
- @Bean(name = "transactionManager")
- @Primary
- public DataSourceTransactionManager primaryTransactionManager(@Qualifier("dataSource") DataSource dataSource) {
- return new DataSourceTransactionManager(dataSource);
- }
-
-
-}
diff --git a/src/main/java/com/zy/common/config/ds/SecondaryDataSourceConfig.java b/src/main/java/com/zy/common/config/ds/SecondaryDataSourceConfig.java
deleted file mode 100644
index 48652f8..0000000
--- a/src/main/java/com/zy/common/config/ds/SecondaryDataSourceConfig.java
+++ /dev/null
@@ -1,38 +0,0 @@
-package com.zy.common.config.ds;
-
-import com.baomidou.mybatisplus.plugins.PaginationInterceptor;
-import com.baomidou.mybatisplus.spring.MybatisSqlSessionFactoryBean;
-import org.apache.ibatis.plugin.Interceptor;
-import org.mybatis.spring.annotation.MapperScan;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
-import org.springframework.jdbc.datasource.DataSourceTransactionManager;
-
-import javax.sql.DataSource;
-
-@Configuration
-@MapperScan(basePackages = "com.zy.nc.mapper", sqlSessionFactoryRef = "secondarySqlSessionFactory")
-public class SecondaryDataSourceConfig {
-
- @Bean(name = "secondarySqlSessionFactory")
- public MybatisSqlSessionFactoryBean secondarySqlSessionFactory(@Qualifier("slaveDataSource") DataSource dataSource, PaginationInterceptor paginationInterceptor) throws Exception {
- MybatisSqlSessionFactoryBean sessionFactory = new MybatisSqlSessionFactoryBean();
- sessionFactory.setDataSource(dataSource);
- // 璁剧疆MyBatis鐨凪apper XML鏂囦欢璺緞
- sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
- .getResources("classpath:mapper/nc/*.xml"));
- Interceptor[] interceptors = new Interceptor[] { paginationInterceptor };
- sessionFactory.setPlugins(interceptors);
-
- return sessionFactory;
- }
-
- @Bean(name = "secondaryTransactionManager")
- public DataSourceTransactionManager secondaryTransactionManager(@Qualifier("slaveDataSource") DataSource dataSource) {
- return new DataSourceTransactionManager(dataSource);
- }
-
-
-}
--
Gitblit v1.9.1