package com.jkurrent.framework.mybatis;
import com.jkurrent.framework.service.sqlmap.impl.SqlMapFactoryBean;
import org.apache.ibatis.builder.xml.XMLMapperBuilder;
import org.apache.ibatis.executor.ErrorContext;
import org.apache.ibatis.session.Configuration;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.core.NestedIOException;
import org.springframework.core.io.Resource;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.core.io.support.ResourcePatternResolver;
import org.springframework.util.ClassUtils;
import org.springframework.util.StringUtils;
import java.io.IOException;
import java.lang.reflect.Field;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
/**
* 监听MyBatis的Mapper.xml的修改，自动刷新配置
*
* @author wuzhilang
* @version V1.00
*/
public class XMLMapperLoader implements DisposableBean, InitializingBean, ApplicationContextAware {
private ConfigurableApplicationContext context = null;
private transient String basePackage = null;
private HashMap<String, String> fileMapping = new HashMap<String, String>();
private Scanner scanner = null;
private ScheduledExecutorService service = null;
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.context = (ConfigurableApplicationContext) applicationContext;
}
@Override
public void afterPropertiesSet() throws Exception {
try {
service = Executors.newScheduledThreadPool(1);
// 获取xml所在包
basePackage = "sqlmap";
// 触发文件监听事件
scanner = new Scanner();
scanner.scan();
service.scheduleAtFixedRate(new Task(), 5, 5, TimeUnit.SECONDS);
} catch (Exception e1) {
e1.printStackTrace();
}
}
class Task implements Runnable {
@Override
public void run() {
try {
if (scanner.isChanged()) {
// System.out.println("*_SqlMap.xml文件改变,重新加载.");
scanner.reloadXML();
System.out.println("加载完毕.");
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
@SuppressWarnings({"rawtypes"})
class Scanner {
private String[] basePackages;
private static final String XML_RESOURCE_PATTERN = "**\\*_SqlMap.xml";
private ResourcePatternResolver resourcePatternResolver = new PathMatchingResourcePatternResolver();
public Scanner() {
basePackages = StringUtils.tokenizeToStringArray(XMLMapperLoader.this.basePackage,
ConfigurableApplicationContext.CONFIG_LOCATION_DELIMITERS);
}
public Resource[] getResource(String basePackage, String pattern) throws IOException {
String packageSearchPath = ResourcePatternResolver.CLASSPATH_ALL_URL_PREFIX
+ ClassUtils.convertClassNameToResourcePath(context.getEnvironment().resolveRequiredPlaceholders(
basePackage)) + "/" + pattern;
Resource[] resources = resourcePatternResolver.getResources(packageSearchPath);
return resources;
}
public void reloadXML() throws Exception {
Set<Map.Entry<String, SqlMapFactoryBean>> set = context.getBeansOfType(SqlMapFactoryBean.class).entrySet();
for(Map.Entry<String, SqlMapFactoryBean> entry : set) {
System.out.println("更新数据源：" + entry);
SqlMapFactoryBean factory = entry.getValue();
Configuration configuration = factory.getSqlSessionFactory().getConfiguration();
// 移除加载项
removeConfig(configuration);
// 重新扫描加载
for (String basePackage : basePackages) {
Resource[] resources = getResource(basePackage, XML_RESOURCE_PATTERN);
if (resources != null) {
for (int i = 0; i < resources.length; i++) {
if (resources[i] == null) {
continue;
}
try {
XMLMapperBuilder xmlMapperBuilder = new XMLMapperBuilder(resources[i].getInputStream(),
configuration, resources[i].toString(), configuration.getSqlFragments());
xmlMapperBuilder.parse();
} catch (Exception e) {
throw new NestedIOException("Failed to parse mapping resource: '" + resources[i] + "'", e);
} finally {
ErrorContext.instance().reset();
}
}
}
}
}
}
private void removeConfig(Configuration configuration) throws Exception {
Class<?> classConfig = configuration.getClass();
clearMap(classConfig, configuration, "mappedStatements");
clearMap(classConfig, configuration, "caches");
clearMap(classConfig, configuration, "resultMaps");
clearMap(classConfig, configuration, "parameterMaps");
clearMap(classConfig, configuration, "keyGenerators");
clearMap(classConfig, configuration, "sqlFragments");
clearSet(classConfig, configuration, "loadedResources");
}
private void clearMap(Class<?> classConfig, Configuration configuration, String fieldName) throws Exception {
Field field = classConfig.getDeclaredField(fieldName);
field.setAccessible(true);
Map mapConfig = (Map) field.get(configuration);
mapConfig.clear();
}
private void clearSet(Class<?> classConfig, Configuration configuration, String fieldName) throws Exception {
Field field = classConfig.getDeclaredField(fieldName);
field.setAccessible(true);
Set setConfig = (Set) field.get(configuration);
setConfig.clear();
}
public void scan() throws IOException {
if (!fileMapping.isEmpty()) {
return;
}
for (String basePackage : basePackages) {
Resource[] resources = getResource(basePackage, XML_RESOURCE_PATTERN);
if (resources != null) {
for (int i = 0; i < resources.length; i++) {
String multi_key = getValue(resources[i]);
fileMapping.put(resources[i].getFile().getPath(), multi_key);
}
}
}
}
private String getValue(Resource resource) throws IOException {
String contentLength = String.valueOf((resource.contentLength()));
String lastModified = String.valueOf((resource.lastModified()));
return new StringBuilder(contentLength).append(lastModified).toString();
}
public boolean isChanged() throws IOException {
boolean isChanged = false;
for (String basePackage : basePackages) {
Resource[] resources = getResource(basePackage, XML_RESOURCE_PATTERN);
if (resources != null) {
for (int i = 0; i < resources.length; i++) {
String name = resources[i].getFile().getPath();
String value = fileMapping.get(name);
String multi_key = getValue(resources[i]);
if (!multi_key.equals(value)) {
System.out.println(name + "文件改变, 准备重新加载");
isChanged = true;
fileMapping.put(name, multi_key);
}
}
}
}
return isChanged;
}
}
@Override
public void destroy() throws Exception {
if (service != null) {
service.shutdownNow();
}
}
public String getBasePackage() {
return basePackage;
}
public void setBasePackage(String basePackage) {
this.basePackage = basePackage;
}
}
© 著作权归作者所有
举报
加载中
其他人还在看
热门评论
悲哀
《计算机信息网络国际联网管理暂行规定实施办法》中就说了，“信道”是物理信道。文中情节明显不存在使用非法信道联网的问题。太儿戏了
罚款200能理解，补税也能理解。没收全部收入无法理解，明明可以直接强的，还要专门牵强个条文，太感动了。小燕子罚款都没这么多。
还有韭菜
libreoffice一直都都想让openoffice.org直接跳转到libreoffice.org
不会吧
这不就是前端届的李佳琦吗 哈哈哈
谢谢!😊
个人认为不涉及国家安全，不是什么违法收入（例如诈骗），就别这么搞。都是打工人，这年头赚点儿钱不容易，更何况赚外国人的钱。如果漏税，就按收入补税，适当罚款就行了。全部没收，真是无语。以后如果真这么搞，润出去的人更多。以后也别说什么为什么人才外流，留在国内掏大粪？
Wordpress我一直在使用，配合woocommerce，比国内的很多伪开源好用！！！
不要加班996了，因为996是违法的，所以你在996期间的收入都是违法收入。
你说反了
688好像不够
java 这个虚拟线程特性，再加上GraalVM 的原生编译，感觉go的优势越来越小。
<dependency> <groupId>org.teasoft</groupId> <artifactId>bee-spring-boot</artifactId> <version>2.1.8</version> </dependency> <version>2.1.8</version>默认使用spring boot 2.7.12
竟然不把虚拟线程战绩写出来
呵呵，之前知乎上网友说vue的中文文档跟不上，他鼻孔朝天的怼网友让网友学英语，吃完饭骂厨子:-1:
扯TM蛋，中文文档几乎是最后上的，而且之前还说啥凭啥要花时间照顾不学英语的人！这会儿都忘了？？？
访问github算违法，那么中国科技不得倒退20年? "自主创新"怎么办?
https://www.oschina.net/news/259948/bee-2-1-8-updated
ubuntu 下登陆失败 [call 2] LoginManager.checkLoginQrCodeStateAsync time:125 params:[8] [call 1] LoginManager.loginByLoginQrCodeAsync [call 2] LoginManager.loginByLoginQrCodeAsync time:6772 params:[9]
想多了吧，看多了其实也就那样，一堆反智言论
正常的工作都处罚，有没有危害，为啥这样搞？以后还怎么发展科技
防民之口甚于防川，怕你们看到外面精彩的世界，这叫杀鸡儆猴
我现在的中国的软件随用随删，我以后买pixel刷GrapheneOS，斯诺登推荐的操作系统。
没感觉好用
别老是拿美元区的价格说事
真棒
应该学鲶鱼，润就完事了。
意大利电商不行啊
《中华人民共和国计算机信息网络国际联网管理暂行规定》，非法浏览境外网站的，处15000元以下的罚款，请各位程序员，大家自觉去自首..
我还是喜欢迷你主机
我甚至有点怀疑这个病是早期电子设备有害物质超标导致的
现在的macOS上的docker运行的是linux容器啊，这个可以运行macOS容器了
套了赶紧跑路去新的创业
持续关注
给IT界一点小小的中国震撼
shiro好久不见
“中文文档哪里重要了，不要乱说，vue一直都是先出英文文档，开源框架很难的，有时候找找自己原因，这么多年了技术涨没涨，有没有认真学英语？”🤪
闲鱼上有个847 plus控制板，才几十块包邮，性能比这个好还是差
Bee2.1.8支持Spring Boot 3.0.11,active命令行选择多环境,多表查改增删
已更新，从这一版本开始，gu已经删除，native-image已经内置了，see https://github.com/oracle/graal/issues/6855
看rmb的价格，太贵的还是算了。毕竟700-800已经买4核3.4Ghz的n100.
还算有点意思，静态编译的Python
大概率事件，每个windos和苹果系统都有底层后门，移动端也是一样。 安卓和linux 稍微好点不排除
已从.net 转java了。 .net 全是维护祖传代码的项目。 工资给的低的离谱
这样就对了，重点推广项目优势、解决的痛点，而不是将“国产”作为卖点，java都不是国产，还在乎java之上的一个框架是不是国产吗
就这？还想弯道超车
这个版本必将成为又一个里程碑
有可能是:blush:
PHP总体算一门很灵活的语言，不同于Java的呆板，对于灵活的语言，越是高手代码越精炼，越是菜鸟代码越杂乱，因为给了你足够多的灵活性，你可以胡来， 灵活性排序，Java <<<< Python < PHP ~= Js < Perl < Ruby <<<< Haskell，Java这种呆板语言，很适合一个大规模团队整体协作，比如阿里这种团队，里面菜鸟高手混杂，最终高手被拉到和菜鸟一个水平， 因为没有灵活性，没有发货的余地，到处都是类套类，一层层套下去，无限冗余的来完成一个PHP只需要一两个人就可以完成的项目，极大的提升了就业率，所以越庞大的团队越喜欢Java，混在里面，写一辈子，也没人看得出水平高低， PHP就不同了，一个菜鸟的PHP代码，立刻会被老鸟看出来，被踢出去，到Java里安静的混日子，动弹还在的时候，有人发了过一个java代码，涉及到两次排序，竟然是先用Java的Sort排完，然后循环来一个冒泡排序，但凡写过PHP和JS都知道，usort、sort回调函数可以一次完成多重排序，Java的呆板禁锢了思维
支持下
打劫，此路是我开，此树是我栽，要想过此路，留下买路财
我记得有个go语言写的在慢慢崛起
恶龙了
windows的webp扩展应该修复了吧，这漏洞影响范围很大啊
在太监面前，站着撒尿就是大罪
看评论区的评论，就像逍遥游里的麻雀议论大鹏一样。
Go 1.20.7
我昨晚连夜下载Java21测试虚拟线程，java其它11版本，17版本我都跳过更新了，直接从java1.8更新到21版本
选择专区和圈子：{{title}}
{{o.name}}
{{m.name}}
公众号
视频号
深圳市奥思网络科技有限公司版权所有
粤ICP备12009483号
