MyBatisPlusの效率与提升

pom.xml
 

1. <?xml version="1.0" encoding="UTF-8"?>
2. <project xmlns="http://maven.apache.org/POM/4.0.0"
3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5.     <parent>
6.     </parent>
7.     <modelVersion>4.0.0</modelVersion>
8.     <dependencies>
9.         <dependency>
10.             <groupId>com.baomidou</groupId>
11.             <artifactId>mybatis-plus-boot-starter</artifactId>
12.             <version>3.4.3.4</version>
13.             <optional>true</optional>
14.         </dependency>
16.     </dependencies>
18. </project>

复制代码

1. application.yml

复制代码

1. # MyBatis配置
2. mybatis:
3.   # 搜索指定包别名
4.   typeAliasesPackage: com.XX.**.domain.**
5.   # 配置mapper的扫描，找到所有的mapper.xml映射文件
6.   mapperLocations: classpath*:mapper/**/*Mapper.xml
7.   # 加载全局的配置文件
8.   configLocation: classpath:mybatis/mybatis-config.xml

复制代码

mybatisplus设置类

1. package com.example.config;
3. import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
4. import com.baomidou.mybatisplus.extension.plugins.PerformanceInterceptor;
5. import org.springframework.context.annotation.Bean;
6. import org.springframework.context.annotation.Configuration;
8. /**
9. * User: Administrator
10. * Date: 2020/4/7
11. * Time: 16:00
12. * Desc:
13. */
14. @Configuration
15. public class MybatisPlusConfig {
17.     /**
18.      * mybatis-plus SQL执行效率插件【生产环境可以关闭】
19.      */
20.     @Bean
21.     public PerformanceInterceptor performanceInterceptor() {
22.         return new PerformanceInterceptor();
23.     }
25.     /**
26.      * 分页插件
27.      */
28.     @Bean
29.     public PaginationInterceptor paginationInterceptor() {
30.         return new PaginationInterceptor();
31.     }
33. }

复制代码

model

1. import com.baomidou.mybatisplus.annotation.TableName;
2. import com.wgh.common.core.domain.BaseEntity;
3. import lombok.Data;
4. import lombok.EqualsAndHashCode;
6. import java.util.Date;
8. @EqualsAndHashCode(callSuper = true)
9. @Data
10. @TableName("task_management")
11. public class TaskManagement extends BaseEntity {
13.     private Long id;
14.     private String taskName;
15.     private String taskGroupName = "default";
17.     /**
18.      * 执行周期 不为空则按照周期执行
19.      */
20.     private String cron;
21.     private Integer taskFlag = 0; // 启用 1 /停用 0
22.     private Integer taskStatus; // 成功 1 | 未执行 0 | 失败 2
23.     private String taskFlowJson;
25. }

复制代码

dao

1. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
2. import com.wgh.web.domain.taskManagement.TaskManagement;
4. public interface TaskManagementMapper extends BaseMapper<TaskManagement> {
5. }

复制代码

1. [/code]service
2. [code]import com.wgh.web.domain.taskManagement.TaskManagement;
3. import com.baomidou.mybatisplus.extension.service.IService;
5. import java.util.List;
7. public interface ITaskManagementService extends IService<TaskManagement> {
8.     /**
9.      * 列表查找
10.      *
11.      * @param object 查询参数
12.      * @return 返回列表
13.      */
14.     List<TaskManagement> getList(TaskManagement object);
16.     /**
17.      * 修改停用启用状态
18.      *
19.      * @param id 任务ID
20.      * @return 0|修改失败 1|修改成功
21.      */
22.     int modifyTaskFlag(Long id);
23. }

复制代码

1. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
2. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
3. import com.wgh.common.utils.SecurityUtils;
4. import com.wgh.web.domain.taskManagement.TaskManagement;
5. import com.wgh.web.mapper.taskManagement.TaskManagementMapper;
6. import com.wgh.web.service.taskManagement.ITaskManagementService;
7. import org.slf4j.Logger;
8. import org.slf4j.LoggerFactory;
9. import org.springframework.stereotype.Service;
10. import org.springframework.transaction.annotation.Transactional;
12. import javax.annotation.Resource;
13. import java.util.ArrayList;
14. import java.util.Date;
15. import java.util.List;
17. @Service
18. public class TaskManagementServiceImpl extends ServiceImpl<TaskManagementMapper, TaskManagement> implements ITaskManagementService {
20.     private static final Logger log = LoggerFactory.getLogger(TaskManagementServiceImpl.class);
22.     @Resource
23.     private TaskManagementMapper taskManagementMapper;
25.     /**
26.      * 列表查找
27.      *
28.      * @param object 查询参数
29.      * @return 返回列表
30.      */
31.     @Override
32.     public List<TaskManagement> getList(TaskManagement object) {
33.         QueryWrapper<TaskManagement> queryWrapper = new QueryWrapper<>();
34.         return taskManagementMapper.selectList(queryWrapper);
35.     }
37.     /**
38.      * 修改停用启用状态
39.      *
40.      * @param id 任务ID
41.      * @return 0|修改失败 1|修改成功
42.      */
43.     @Override
44.     @Transactional
45.     public int modifyTaskFlag(Long id) {
46.         TaskManagement tmp = this.baseMapper.selectById(id);
47.         return this.baseMapper.updateById(tmp);
48.     }
49. }

复制代码

1. MyBatisConfig

复制代码

1. package com.wgh.framework.config;
3. import java.io.IOException;
4. import java.util.ArrayList;
5. import java.util.Arrays;
6. import java.util.HashSet;
7. import java.util.List;
8. import javax.sql.DataSource;
9. import org.apache.ibatis.io.VFS;
10. import org.apache.ibatis.session.SqlSessionFactory;
11. import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
12. import org.mybatis.spring.SqlSessionFactoryBean;
13. import org.mybatis.spring.boot.autoconfigure.SpringBootVFS;
14. import org.springframework.beans.factory.annotation.Autowired;
15. import org.springframework.context.annotation.Bean;
16. import org.springframework.context.annotation.Configuration;
17. import org.springframework.core.env.Environment;
18. import org.springframework.core.io.DefaultResourceLoader;
19. import org.springframework.core.io.Resource;
20. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
21. import org.springframework.core.io.support.ResourcePatternResolver;
22. import org.springframework.core.type.classreading.CachingMetadataReaderFactory;
23. import org.springframework.core.type.classreading.MetadataReader;
24. import org.springframework.core.type.classreading.MetadataReaderFactory;
25. import org.springframework.util.ClassUtils;
26. import com.wgh.common.utils.StringUtils;
28. /**
29. * Mybatis支持*匹配扫描包
30. *
31. * @author maj
32. */
33. @Configuration
34. public class MyBatisConfig
35. {
36.     @Autowired
37.     private Environment env;
39.     static final String DEFAULT_RESOURCE_PATTERN = "**/*.class";
41.     public static String setTypeAliasesPackage(String typeAliasesPackage)
42.     {
43.         ResourcePatternResolver resolver = (ResourcePatternResolver) new PathMatchingResourcePatternResolver();
44.         MetadataReaderFactory metadataReaderFactory = new CachingMetadataReaderFactory(resolver);
45.         List<String> allResult = new ArrayList<String>();
46.         try
47.         {
48.             for (String aliasesPackage : typeAliasesPackage.split(","))
49.             {
50.                 List<String> result = new ArrayList<String>();
51.                 aliasesPackage = ResourcePatternResolver.CLASSPATH_ALL_URL_PREFIX
52.                         + ClassUtils.convertClassNameToResourcePath(aliasesPackage.trim()) + "/" + DEFAULT_RESOURCE_PATTERN;
53.                 Resource[] resources = resolver.getResources(aliasesPackage);
54.                 if (resources != null && resources.length > 0)
55.                 {
56.                     MetadataReader metadataReader = null;
57.                     for (Resource resource : resources)
58.                     {
59.                         if (resource.isReadable())
60.                         {
61.                             metadataReader = metadataReaderFactory.getMetadataReader(resource);
62.                             try
63.                             {
64.                                 result.add(Class.forName(metadataReader.getClassMetadata().getClassName()).getPackage().getName());
65.                             }
66.                             catch (ClassNotFoundException e)
67.                             {
68.                                 e.printStackTrace();
69.                             }
70.                         }
71.                     }
72.                 }
73.                 if (result.size() > 0)
74.                 {
75.                     HashSet<String> hashResult = new HashSet<String>(result);
76.                     allResult.addAll(hashResult);
77.                 }
78.             }
79.             if (allResult.size() > 0)
80.             {
81.                 typeAliasesPackage = String.join(",", (String[]) allResult.toArray(new String[0]));
82.             }
83.             else
84.             {
85.                 throw new RuntimeException("mybatis typeAliasesPackage 路径扫描错误,参数typeAliasesPackage:" + typeAliasesPackage + "未找到任何包");
86.             }
87.         }
88.         catch (IOException e)
89.         {
90.             e.printStackTrace();
91.         }
92.         return typeAliasesPackage;
93.     }
95.     public Resource[] resolveMapperLocations(String[] mapperLocations)
96.     {
97.         ResourcePatternResolver resourceResolver = new PathMatchingResourcePatternResolver();
98.         List<Resource> resources = new ArrayList<Resource>();
99.         if (mapperLocations != null)
100.         {
101.             for (String mapperLocation : mapperLocations)
102.             {
103.                 try
104.                 {
105.                     Resource[] mappers = resourceResolver.getResources(mapperLocation);
106.                     resources.addAll(Arrays.asList(mappers));
107.                 }
108.                 catch (IOException e)
109.                 {
110.                     // ignore
111.                 }
112.             }
113.         }
114.         return resources.toArray(new Resource[resources.size()]);
115.     }
117.     @Bean
118.     public SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception
119.     {
120.         String typeAliasesPackage = env.getProperty("mybatis.typeAliasesPackage");
121.         String mapperLocations = env.getProperty("mybatis.mapperLocations");
122.         String configLocation = env.getProperty("mybatis.configLocation");
123.         typeAliasesPackage = setTypeAliasesPackage(typeAliasesPackage);
124.         VFS.addImplClass(SpringBootVFS.class);
126.         final MybatisSqlSessionFactoryBean sessionFactory = new MybatisSqlSessionFactoryBean();
127.         sessionFactory.setDataSource(dataSource);
128.         sessionFactory.setTypeAliasesPackage(typeAliasesPackage);
129.         sessionFactory.setMapperLocations(resolveMapperLocations(StringUtils.split(mapperLocations, ",")));
130.         sessionFactory.setConfigLocation(new DefaultResourceLoader().getResource(configLocation));
131.         return sessionFactory.getObject();
132.     }
133. }

复制代码

 
注意事项：必须使用 com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean 去更换 mybatis 的 SqlSessionFactoryBean (org.mybatis.spring.SqlSessionFactoryBean) 方才能完成对XML等默认SQL的添加处理

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。