MyBatisPlus又在搞事了！发布神器，一个依赖轻松搞定权限问题( 三 ) _MyBatisPlus

}

可以开启主从策略，当然也是可以开启健康检查！具体配置：

mybatis-mate:
sharding:
health: true # 健康检测
primary: mysql # 默认选择数据源
datasource:
mysql: # 数据库组
- key: node1
...
- key: node2
cluster: slave # 从库读写分离时候负责 sql 查询操作，主库 master 默认可以不写
...
postgres:
- key: node1 # 数据节点
...

2.7 分布式事务日志打印

部分配置如下：

/**
* <p>
* 性能分析拦截器，用于输出每条 SQL 语句及其执行时间
* </p>
*/
@Slf4j
@Component
@Intercepts({@Signature(type = StatementHandler.class, method = "query", args = {Statement.class, ResultHandler.class}),
@Signature(type = StatementHandler.class, method = "update", args = {Statement.class}),
@Signature(type = StatementHandler.class, method = "batch", args = {Statement.class})})
public class PerformanceInterceptor implements Interceptor {
/**
* SQL 执行最大时长，超过自动停止运行，有助于发现问题。
*/
private long maxTime = 0;
/**
* SQL 是否格式化
*/
private boolean format = false;
/**
* 是否写入日志文件<br>
* true 写入日志文件，不阻断程序执行！<br>
* 超过设定的最大执行时长异常提示！
*/
private boolean writeInLog = false;
@Override
public Object intercept(Invocation invocation) throws Throwable {
Statement statement;
Object firstArg = invocation.getArgs()[0];
if (Proxy.isProxyClass(firstArg.getClass())) {
statement = (Statement) SystemMetaObject.forObject(firstArg).getValue("h.statement");
} else {
statement = (Statement) firstArg;
}
MetaObject stmtMetaObj = SystemMetaObject.forObject(statement);
try {
statement = (Statement) stmtMetaObj.getValue("stmt.statement");
} catch (Exception e) {
// do nothing
}
if (stmtMetaObj.hasGetter("delegate")) {//Hikari
try {
statement = (Statement) stmtMetaObj.getValue("delegate");
} catch (Exception e) {
}
}
String originalSql = null;
if (originalSql == null) {
originalSql = statement.toString();
}
originalSql = originalSql.replaceAll("[\s]+", " ");
int index = indexOfSqlStart(originalSql);
if (index > 0) {
originalSql = originalSql.substring(index);
}
// 计算执行 SQL 耗时
long start = SystemClock.now();
Object result = invocation.proceed();
long timing = SystemClock.now() - start;
// 格式化 SQL 打印执行结果
Object target = PluginUtils.realTarget(invocation.getTarget());
MetaObject metaObject = SystemMetaObject.forObject(target);
MappedStatement ms = (MappedStatement) metaObject.getValue("delegate.mappedStatement");
StringBuilder formatSql = new StringBuilder();
formatSql.append(" Time：").append(timing);
formatSql.append(" ms - ID：").append(ms.getId());
formatSql.append("n Execute SQL：").append(sqlFormat(originalSql, format)).append("n");
if (this.isWriteInLog()) {
if (this.getMaxTime() >= 1 && timing > this.getMaxTime()) {
log.error(formatSql.toString());
} else {
log.debug(formatSql.toString());
}
} else {
System.err.println(formatSql);
if (this.getMaxTime() >= 1 && timing > this.getMaxTime()) {
throw new RuntimeException(" The SQL execution time is too large, please optimize ! ");
}
}
return result;
}
@Override
public Object plugin(Object target) {
if (target instanceof StatementHandler) {
return Plugin.wrap(target, this);
}
return target;
}
@Override
public void setProperties(Properties prop) {
String maxTime = prop.getProperty("maxTime");
String format = prop.getProperty("format");
if (StringUtils.isNotEmpty(maxTime)) {
this.maxTime = Long.parseLong(maxTime);
}
if (StringUtils.isNotEmpty(format)) {
this.format = Boolean.valueOf(format);

MyBatisPlus又在搞事了！发布神器，一个依赖轻松搞定权限问题( 三 )

推荐阅读

烤冷面烤冷面怎么保存？

买卖怎么区分？

普洱茶功效降血脂,普洱茶为什么有减肥降脂功效

央视新闻客户端|特朗普签署延长薪酬保障计划法律

|万和证券、新时代证券、民生证券因违规荐股等遭罚

「三叉戟」目前热播的五部悬疑剧：《三叉戟》挤进前三，第一值得熬夜追剧

小玲星座|桃花运旺，月老亲自送姻缘，前任主动邂逅的4大星座，下个月起

迪利普·高希|印度疫情结束了？

滇红茶陈年,醉金枝大叶滇红茶

华为手机如何设置闹钟？

黄瓜跟牛奶能一起吃吗

与非网|加码国内硬件企业助力中国突破国产瓶颈，深圳灵矽微获数千万元Pre-A轮融资

支架|蓝帆医疗：Biofreedom Ultra钴铬合金支架获得CE证书

爱奇艺爱奇艺《我是唱作人2》成为平台首个内容热度值破7000的会员抢先看自制综艺

如果你爱的人得了不治之症，整天忍受病痛折磨，你也要承担巨额药费，她提出要放弃治疗，你会同意么

「降准」年内第二次全面降准16日落地：谁将受益？

青眼|赵圆圆“消失”了？，直播带货首秀放鸽子

烹饪|分享一款粽叶花生糯米饼，清香软糯，营养好吃，老少皆宜的美食

何超莲|不装了！何超欣避不恭喜何超莲，何猷君内涵何猷启被何超莲取关

玛卡长期服用会有害吗