小小的日常维护，Magic-1.0.5 发布
本次更新如下： 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
