list = delete.getTables();
for (Table t : list) {
parserTable(t, true);
}
} else if (statement instanceof Insert) {
Insert insert = (Insert) statement;
parserTable(insert.getTable(), false);
}
StatementDeParser deParser = new StatementDeParser(new StringBuilder());
statement.accept(deParser);
sql = deParser.getBuffer().toString();
ReflectionUtils.setFieldValue(statementHandler.getBoundSql(), "sql", sql);
}
}
return invocation.proceed();
}
private Object realTarget(Object target) {
if (Proxy.isProxyClass(target.getClass())) {
MetaObject metaObject = SystemMetaObject.forObject(target);
return realTarget(metaObject.getValue("h.target"));
} else {
return target;
}
}
/**
* 覆蓋表名設置別名
*
* @param table
* @return
*/
private Table parserTable(Table table, boolean alias) {
if (null != table) {
if (alias) {
table.setAlias(new Alias(table.getName()));
}
table.setName(getTargetTableName(table.getName()));
}
return table;
}
@Override
public Object plugin(Object target) {
if (target instanceof StatementHandler) {
return Plugin.wrap(target, this);
}
return target;
}
@Override
public void setProperties(Properties properties) {
}
@Override
public String getTargetTableName(String tableName) {
if (shardProperties.isAgentTable(tableName)) {
return ShardUtil.getTargetTableName(tableName);
}
return tableName;
}
}
/**
@author chonglou
@date 2019/2/2218:24
*/
public interface ShardAgent {
String getTargetTableName(String name);
}
/**
*工具
@author chonglou
@date 2019/2/2514:11
*/
public class ShardUtil {
private final static String KEY_GENERATOR = "keyGenerator";
public static void setKeyGenerator(Object keyGenerator) {
HttpServletRequest request = SpringContextHolder.getRequest();
request.setAttribute(KEY_GENERATOR, keyGenerator);
}
public static String getTargetTableName(String tableName) {
HttpServletRequest request = SpringContextHolder.getRequest();
Object productId = request.getAttribute(KEY_GENERATOR);
if (null == productId) {
throw new RuntimeException("keyGenerator is null.");
}
return tableName.concat("_").concat(productId.toString());
}
}
/**
Spring的ApplicationContext的持有者,可以用靜態方法的方式獲取spring容器中的bean,
Request 以及 Session
*
@author chonglou
*/
@Component
public class SpringContextHolder implements ApplicationContextAware {
private static ApplicationContext applicationContext;
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
SpringContextHolder.applicationContext = applicationContext;
}
public static ApplicationContext getApplicationContext() {
assertApplicationContext();
return applicationContext;
}
public static T getBean(String beanName) {
assertApplicationContext();
return (T) applicationContext.getBean(beanName);
}
public static T getBean(Class requiredType) {
assertApplicationContext();
return applicationContext.getBean(requiredType);
}
private static void assertApplicationContext() {
if (null == SpringContextHolder.applicationContext) {
throw new RuntimeException("applicationContext屬性為null,請檢查是否注入了SpringContextHolder!");
}
}
/**
* 獲取當前請求的Request對象
*
* @return HttpServletRequest
*/
public static HttpServletRequest getRequest() {
ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
return requestAttributes.getRequest();
}
/**
* 獲取當前請求的session對象
*
* @return HttpSession
*/
public static HttpSession getSession() {
return getRequest().getSession();
}
}
/**
查詢語句修改
@author chonglou
@date 2019/2/2211:31
*/
public class TableNameModifier extends SelectDeParser {
private ShardAgent shardAgent;
TableNameModifier(ShardAgent shardAgent) {
super();
this.shardAgent = shardAgent;
}
@Override
public void visit(Table tableName) {
StringBuilder buffer = new StringBuilder();
tableName.setName(shardAgent.getTargetTableName(tableName.getName()));
buffer.append(tableName.getFullyQualifiedName());
Alias alias = tableName.getAlias();
if (alias == null) {
alias = new Alias(tableName.getName());
}
buffer.append(alias);
Pivot pivot = tableName.getPivot();
if (pivot != null) {
pivot.accept(this);
}
MySQLIndexHint indexHint = tableName.getIndexHint();
if (indexHint != null) {
buffer.append(indexHint);
}
}
}
/**
@author chonglou
@date 2019/2/2215:34
*/
@ConfigurationProperties(prefix = "shard.config")
public class ShardProperties {
private List exceptionMapperId;
private List agentTables;
public boolean isException(String mapperId) {
return null != exceptionMapperId && exceptionMapperId.contains(mapperId);
}
public boolean isAgentTable(String tableName) {
return null != agentTables && agentTables.contains(tableName);
}
public List getExceptionMapperId() {
return exceptionMapperId;
}
public void setExceptionMapperId(List exceptionMapperId) {
this.exceptionMapperId = exceptionMapperId;
}
public List getAgentTables() {
return agentTables;
}
public void setAgentTables(List agentTables) {
this.agentTables = agentTables;
}
}
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。
轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/77460.html
-
摘要：目錄其中每個章節知識點都是相關連由淺入深的一步步全面分析了技術原理以及實戰由于文案較長想深入學習以及對于該文檔感興趣的朋友們可以加群免費獲取。這些場景在大量的編碼中使用，具備較強的實用價值，這些內容都是通過實戰得來的，供讀者們參考。
前言系統掌握MyBatis編程技巧已經成了用Java構建移動互聯網網站的必要條件
本文主要講解了Mybatis的應用，解析了其原理，從而形成一個完整的知識...
MoAir
評論0
收藏0
-
摘要：實現數據庫分庫分表可以自己實現，也可以使用和實現。分布式數據庫的自增不是自增的。分布式數據庫分頁查詢需要使用插入時間實現。包含分庫分片和讀寫分離功能。
Sharding-Jdbc實現mysql分庫分表
簡單介紹
數據庫分庫分表和讀寫分離區別，分庫分表是在多個庫建相同的表和同一個庫建不同的表，根據隨機或者哈希等方式查找實現。讀寫分離是為了解決數據庫的讀寫性能不足，使用主庫master進行...
go4it
評論0
收藏0
-
摘要：攔截器的使用場景主要是更新數據庫的通用字段，分庫分表，加解密等的處理。攔截器均需要實現該接口。攔截器攔截器的使用需要查看每一個所提供的方法參數。對應構造器，為，為，為。可參考攔截器原理探究。
攔截器（Interceptor）在 Mybatis 中被當做插件（plugin）對待，官方文檔提供了 Executor（攔截執行器的方法），ParameterHandler（攔截參數的處理），Re...
nemo
評論0
收藏0
-
摘要：現在的分片策略是上海深圳分別建庫，每個庫都存各自交易所的兩支股票的，且按照月分表。五配置分片策略數據庫分片策略在這個實例中，數據庫的分庫就是根據上海和深圳來分的，在中是單鍵分片。
由于當當發布了最新的Sharding-Sphere，所以本文已經過時，不日將推出新的版本
項目中遇到了分庫分表的問題，找到了shrding-jdbc，于是就搞了一個springboot+sharding-jd...
-
摘要：今天就給大家介紹下方式的使用，主要講解讀寫分離的配置，其余的后面再介紹。主要還是用提供的，配置如下配置內容如下主數據源從數據源讀寫分離配置查詢時的負載均衡算法，目前有種算法，輪詢和隨機，算法接口是。
在我《Spring Cloud微服務-全棧技術與案例解析》書中，第18章節分庫分表解決方案里有對Sharding-JDBC的使用進行詳細的講解。
之前是通過XML方式來配置數據源，讀寫分離...
男|高級講師
-
閱讀 1357·2021-11-24 09:39
-
閱讀 1346·2021-11-04 16:12
-
閱讀 2686·2021-09-24 09:47
-
閱讀 3337·2021-09-01 10:50
-
閱讀 1477·2019-08-30 15:55
-
閱讀 1423·2019-08-30 15:43
-
閱讀 642·2019-08-30 11:08
-
閱讀 3578·2019-08-23 18:33
