本次更新如下：
1. 添加了对PosrgreSQL的分页支持。
2. 在使用ConditionBuilder时可以只查一条数据。
3. 对查询入参的处理方式换成了反射处理，这样可以保持原类型。
4. 去除了ConcurrentTaskSync的回调，因为意义不大，不如在runner里直接try catch。
Magic是Magician旗下的一个工具包，支持并发处理、生产者与消费者模型、数据库操作等.
01 数据库操作
首先需要创建一个Spring的JdbcTemplate对象
@Resource
private JdbcTemplate jdbcTemplate;
单表查询
// 创建查询条件
ConditionBuilder conditionBuilder = ConditionBuilder.createCondition()
.add("age = ?", "300")
.add(" order by age desc", Condition.NOT_WHERE);
// 执行查询操作
List<DemoPO> demoPOS = MagicDBUtils.get(jdbcTemplate)
.select("m_user_info", conditionBuilder, DemoPO.class);
单表插入
// 创建要插入的对象和值
DemoPO demoPO = DemoPO.builder()
.id(UUID.randomUUID().toString())
.age(18)
.content("哈哈哈")
.amount(new BigDecimal("10000"))
.length(new BigInteger("10000000000"))
.createTime(new Date())
.updateTime(new Date())
.build();
// 执行插入操作
MagicDBUtils.get(jdbcTemplate).insert("m_user_info", demoPO);
单表更新
// 创建修改条件
ConditionBuilder = conditionBuilder = ConditionBuilder.createCondition()
.add("id = ? and age = ?", "00df4362-d7ad-48d2-8bcb-05cf859b7e64", 500);
// 需要修改的字段和对应的值
DemoPO demoPO = DemoPO.builder()
.age(122)
.content("嘿嘿嘿")
.amount(new BigDecimal("100002.33"))
.length(new BigInteger("100000000002"))
.createTime(new Date())
.updateTime(new Date())
.build();
// 执行修改操作
MagicDBUtils.get(jdbcTemplate).update("m_user_info", demoPO, conditionBuilder);
单表删除
// 创建删除条件
ConditionBuilder = conditionBuilder = ConditionBuilder.createCondition()
.add("id = ?", "00df4362-d7ad-48d2-8bcb-05cf859b7e64");
// 执行删除操作
MagicDBUtils.get(jdbcTemplate).delete("m_user_info", conditionBuilder);
自定义SQL查询
DemoPO demoPO = DemoPO.builder()
.age(122)
.build();
MagicDBUtils.get(jdbcTemplate).selectList("select * from m_user_info where age > {age}", demoPO, DemoPO.class);
自定义SQL分页
// 查询参数
PageParamModel pageParamModel = PageParamModel
.getPageParamModel(1, 10)
.setParam(
DemoPO.builder()
.age(10)
.build()
);
// 执行查询操作
PageModel<DemoPO> pageModel = MagicDBUtils.get(jdbcTemplate).selectPage("select * from m_user_info where age > {age}", pageParamModel, DemoPO.class);
02 并发处理任务
MagicDataProcessing.getConcurrentTaskSync()
.setTimeout(1000) // 超时时间
.setTimeUnit(TimeUnit.MILLISECONDS) // 超时时间的单位
.add(() -> { // 添加一个任务
// 在这里可以写上任务的业务逻辑
})
.add(() -> { // 添加一个任务
// 在这里可以写上任务的业务逻辑
})
.start();
03 并发处理List，Set等所有Collection类集合里的元素
// 假如有一个List需要并发处理里面的元素
List<String> dataList = new ArrayList<>();
// 只需要将他传入syncRunner方法即可，每个参数的具体含义可以参考文档
MagicDataProcessing.getConcurrentCollectionSync()
.syncRunner(dataList, data -> {
// 这里可以拿到List里的元素，进行处理
System.out.println(data);
}, 10, 1, TimeUnit.MINUTES);
// 也可以用syncGroupRunner方法，每个参数的具体含义可以参考文档
MagicDataProcessing.getConcurrentCollectionSync()
.syncGroupRunner(dataList, data -> {
// 这里是每一组List
for(String item : data){
// 这里可以拿到List里的元素，进行处理
System.out.println(data);
}
}, 10, 1, TimeUnit.MINUTES);
04 生产者与消费者
// 创建一组生产者与消费者，支持多对多
MagicDataProcessing.getProducerAndConsumerManager()
.addProducer(new MagicianProducer() { // 添加一个生产者（可以添加多个）
@Override
public void producer() {
// 查询这张表里符合条件的数据
List<Object> dataList = selectList();
// 然后将他推送给消费者
this.publish(dataList);
}
}).addConsumer(new MagicianConsumer() { // 添加一个消费者（可以添加多个）
@Override
public void doRunner(Object data) {
// 处理生产者发来的数据
System.out.println(data);
}
}).start();
因同名软件太多，选择关联软件时无法分辨，所以选了自己的另一个项目。
本项目的链接如下：
github: https://github.com/JMagician/Magic
gitee: https://gitee.com/jmagician/Magic
