【免费】mybatis执行自定义sql工具包_mybatis获取执行sql的工具类资源-CSDN文库

共3个文件

java：3个

需积分: 0 151 浏览量 2024-06-03 11:05:53 上传评论收藏 4KB ZIP 举报

MyBatis是一个优秀的Java持久层框架，它支持定制化SQL、存储过程以及高级映射。在实际开发中，为了提高代码的复用性和灵活性，我们经常需要创建自定义的SQL工具包。`mybatis-helper`这个工具包就是为了帮助开发者更方便地在MyBatis中执行自定义SQL而设计的。在MyBatis中，我们通常通过Mapper接口和XML配置文件来编写和执行SQL。然而，这种静态方式对于复杂的业务逻辑和多变的查询需求可能会显得不够灵活。`mybatis-helper`工具包提供了一种动态的方式来处理这些情况，它允许开发者动态读取SQL语句，并在运行时根据业务需求动态编译和传递参数。让我们了解一下如何在MyBatis中执行自定义SQL。在MyBatis中，可以通过`@Select`、`@Insert`、`@Update`和`@Delete`等注解在Mapper接口的方法上直接写SQL，或者将SQL写在对应的XML配置文件中。这样的方式虽然简单，但不便于管理和维护复杂的SQL。而`mybatis-helper`工具包引入了动态SQL的概念，你可以将SQL语句写在一个单独的资源文件（如.properties或.xml）中，然后在运行时根据需要加载和执行。使用`mybatis-helper`，你可以实现以下功能： 1. 动态SQL：通过读取配置文件中的SQL模板，根据业务参数动态拼接SQL，增加了SQL的灵活性。 2. 参数编译：工具包提供了方法来处理动态传入的参数，可以避免手动拼接字符串带来的风险，如SQL注入问题。 3. 批量操作：支持批量插入、更新等操作，通过一次调用处理多个数据。 4. 性能优化：通过缓存预编译的SQL和参数设置，可以提高执行效率，降低数据库压力。在实际应用中，`mybatis-helper`的使用流程大致如下： 1. 引入`mybatis-helper`依赖到项目中。 2. 创建SQL模板文件，如`sql.properties`或`sql.xml`，在其中定义动态SQL语句。 3. 在服务类或DAO中，使用`mybatis-helper`提供的API加载并执行SQL，如`SqlHelper.execute()`方法，该方法接受SQL模板ID和参数，返回结果集或影响行数。 4. 参数传递可以是Map对象，键值对应SQL语句中的占位符，也可以是JavaBean对象，通过反射匹配属性和SQL占位符。通过以上步骤，你可以实现更灵活的SQL操作，同时保持代码的整洁和可维护性。`mybatis-helper`工具包的使用，不仅简化了开发工作，也提高了项目在应对复杂查询和动态数据处理时的适应能力。总结来说，`mybatis-helper`是一个为MyBatis提供自定义SQL执行能力的工具包，它通过动态读取SQL和编译入参，解决了静态SQL配置在某些场景下的局限性，增强了MyBatis在处理复杂业务逻辑时的灵活性和可扩展性。通过合理使用`mybatis-helper`，开发者可以更高效地管理和执行SQL，提升项目的整体质量。

资源推荐

资源详情

资源评论

收起资源包目录

mybatis-helper.zip （3个子文件）

mybatis-helper

RowMapperStatementBuilder.java 7KB

RowSqlMapper.java 7KB

RowSqlMapperTest.java 1KB

package com.supervision.util.mybatis; import cn.hutool.crypto.digest.MD5; import org.apache.ibatis.builder.StaticSqlSource; import org.apache.ibatis.mapping.*; import org.apache.ibatis.scripting.LanguageDriver; import org.apache.ibatis.session.Configuration; import java.util.ArrayList; import java.util.Map; /** * 一个基于mybatis简单粗暴的构建MappedStatement的实现 */ public class RowMapperStatementBuilder { private final Configuration configuration; private final LanguageDriver languageDriver; public RowMapperStatementBuilder(Configuration configuration) { this.configuration = configuration; this.languageDriver = configuration.getDefaultScriptingLanguageInstance(); } /** * 创建MSID * * @param sql 执行的sql * @param sql 执行的sqlCommandType * @return */ private String generateMappedStatementId(String sql, SqlCommandType sqlCommandType) { return sqlCommandType.toString() + "." + MD5.create().digestHex(sql); } /** * 是否已经存在该ID * * @param msId * @return */ private boolean hasMappedStatement(String msId) { return configuration.hasStatement(msId, false); } /** * 创建一个查询的MS * * @param msId * @param sqlSource 执行的sqlSource * @param resultType 返回的结果类型 */ private void cacheSelectMappedStatement(String msId, SqlSource sqlSource, final Class<?> resultType) { if (configuration.hasStatement(msId,false)){ return; } MappedStatement ms = new MappedStatement.Builder(configuration, msId, sqlSource, SqlCommandType.SELECT) .resultMaps(new ArrayList<ResultMap>() { { add(new ResultMap.Builder(configuration, "defaultResultMap", resultType, new ArrayList<ResultMapping>(0)).build()); } }) .build(); //缓存MappedStatement configuration.addMappedStatement(ms); } /** * 创建一个简单的MS * * @param msId * @param sqlSource 执行的sqlSource * @param sqlCommandType 执行的sqlCommandType */ private void newUpdateMappedStatement(String msId, SqlSource sqlSource, SqlCommandType sqlCommandType) { MappedStatement ms = new MappedStatement.Builder(configuration, msId, sqlSource, sqlCommandType) .resultMaps(new ArrayList<ResultMap>() { { add(new ResultMap.Builder(configuration, "defaultResultMap", int.class, new ArrayList<ResultMapping>(0)).build()); } }) .build(); //缓存 configuration.addMappedStatement(ms); } public String select(String sql) { String msId = generateMappedStatementId(sql, SqlCommandType.SELECT); if (hasMappedStatement(msId)) { return msId; } StaticSqlSource sqlSource = new StaticSqlSource(configuration, sql); cacheSelectMappedStatement(msId, sqlSource, Map.class); return msId; } public String selectDynamic(String sql, Class<?> parameterType) { String msId = generateMappedStatementId(sql , SqlCommandType.SELECT); if (hasMappedStatement(msId)) { return msId; } SqlSource sqlSource = languageDriver.createSqlSource(configuration, sql, parameterType); cacheSelectMappedStatement(msId, sqlSource, Map.class); return msId; } public String select(String sql, Class<?> resultType) { String msId = generateMappedStatementId(resultType + sql, SqlCommandType.SELECT); if (hasMappedStatement(msId)) { return msId; } StaticSqlSource sqlSource = new StaticSqlSource(configuration, sql); cacheSelectMappedStatement(msId, sqlSource, resultType); return msId; } public String selectDynamic(String sql, Class<?> parameterType, Class<?> resultType) { String msId = generateMappedStatementId(resultType + sql + parameterType, SqlCommandType.SELECT); if (hasMappedStatement(msId)) { return msId; } SqlSource sqlSource = languageDriver.createSqlSource(configuration, sql, parameterType); cacheSelectMappedStatement(msId, sqlSource, resultType); return msId; } public String insert(String sql) { String msId = generateMappedStatementId(sql, SqlCommandType.INSERT); if (hasMappedStatement(msId)) { return msId; } StaticSqlSource sqlSource = new StaticSqlSource(configuration, sql); newUpdateMappedStatement(msId, sqlSource, SqlCommandType.INSERT); return msId; } public String insertDynamic(String sql, Class<?> parameterType) { String msId = generateMappedStatementId(sql + parameterType, SqlCommandType.INSERT); if (hasMappedStatement(msId)) { return msId; } SqlSource sqlSource = languageDriver.createSqlSource(configuration, sql, parameterType); newUpdateMappedStatement(msId, sqlSource, SqlCommandType.INSERT); return msId; } public String update(String sql) { String msId = generateMappedStatementId(sql, SqlCommandType.UPDATE); if (hasMappedStatement(msId)) { return msId; } StaticSqlSource sqlSource = new StaticSqlSource(configuration, sql); newUpdateMappedStatement(msId, sqlSource, SqlCommandType.UPDATE); return msId; } public String updateDynamic(String sql, Class<?> parameterType) { String msId = generateMappedStatementId(sql + parameterType, SqlCommandType.UPDATE); if (hasMappedStatement(msId)) { return msId; } SqlSource sqlSource = languageDriver.createSqlSource(configuration, sql, parameterType); newUpdateMappedStatement(msId, sqlSource, SqlCommandType.UPDATE); return msId; } public String delete(String sql) { String msId = generateMappedStatementId(sql, SqlCommandType.DELETE); if (hasMappedStatement(msId)) { return msId; } StaticSqlSource sqlSource = new StaticSqlSource(configuration, sql); newUpdateMappedStatement(msId, sqlSource, SqlCommandType.DELETE); return msId; } public String deleteDynamic(String sql, Class<?> parameterType) { String msId = generateMappedStatementId(sql + parameterType, SqlCommandType.DELETE); if (hasMappedStatement(msId)) { return msId; } SqlSource sqlSource = languageDriver.createSqlSource(configuration, sql, parameterType); newUpdateMappedStatement(msId, sqlSource, SqlCommandType.DELETE); return msId; } }

评论收藏

内容反馈