🔖 Releasing / Version tags. 3.1.0

🔖 Releasing / Version tags. 3.1.0

🔖 Releasing / Version tags. 3.1.0

🔖 Releasing / Version tags. 3.1.0
This commit is contained in:
pigxcloud committed 2019-06-06 22:03:21 +08:00
1 parent 94043766fe
commit 6da4461a29
67 files changed
+151 -4976

No files matched your search

@@ -1,17 +1,15 @@
package com.pig4cloud.pigx.common.datasource.config;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.pig4cloud.pigx.common.datasource.support.DynamicDataSourceContextHolder;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.lang.Nullable;
import org.springframework.stereotype.Component;
import org.springframework.web.servlet.HandlerInterceptor;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
* @author lengleng
* @date 2019-05-18
@@ -22,15 +20,18 @@ import org.springframework.web.servlet.HandlerInterceptor;
@Component
@AllArgsConstructor
public class DynamicDatasourceInterceptor implements HandlerInterceptor {
private final RedisTemplate redisTemplate;
/**
* TODO 根据上线文判断路由哪个数据库
*
* @param request
* @param response
* @param handler
* @return
*/
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
redisTemplate.setHashValueSerializer(new Jackson2JsonRedisSerializer<>(String.class));
HashOperations<String, String, String> vo = redisTemplate.opsForHash();
// String dbName = vo.get("db_route_key", 1);
DynamicDataSourceContextHolder.setDataSourceType(1);
log.info("数据源切换:{}", 1);
return true;
}