溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要講解了“mybatis輸出SQL格式化的方法是什么”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“mybatis輸出SQL格式化的方法是什么”吧！
通過第三方日志工具可以控制日志級別的輸出，但是我們發現mybatis輸出的SQL不是那么的完整，我們SQL里的參數值并沒有打印出來，下面我就來講講怎么樣對mybatis的輸出sql格式化。
首先我這個案例是基于Spring boot 來開發的，所以配置和傳統的xml配置有所區別，spring boot大大簡化了一些配置，它把配置放到java代碼，我們只需要使用注解就可替代一些以前xml的配置。
import java.io.PrintStream;
import java.text.DateFormat;
import java.util.Date;
import java.util.List;
import java.util.Locale;
import java.util.Properties;
import java.util.regex.Matcher;
import org.apache.commons.collections.CollectionUtils;
import org.apache.ibatis.mapping.BoundSql;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.mapping.ParameterMapping;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.plugin.Intercepts;
import org.apache.ibatis.plugin.Invocation;
import org.apache.ibatis.plugin.Plugin;
import org.apache.ibatis.reflection.MetaObject;
import org.apache.ibatis.session.Configuration;
import org.apache.ibatis.type.TypeHandlerRegistry;
import org.springframework.stereotype.Component;
/**
* 自定義mybatis攔截器,格式化SQL輸出,
*
* @author zengsong
* @version 1.0
* @description 只對查詢和更新語句做了格式化，其它語句需要手動添加
* @date 2019/5/30 10:17
**/
@Intercepts({@org.apache.ibatis.plugin.Signature(type=org.apache.ibatis.executor.Executor.class, method="update", args={MappedStatement.class, Object.class}), @org.apache.ibatis.plugin.Signature(type=org.apache.ibatis.executor.Executor.class, method="query", args={MappedStatement.class, Object.class, org.apache.ibatis.session.RowBounds.class, org.apache.ibatis.session.ResultHandler.class})})
@Component
public class MybatisResultInterceptor
implements Interceptor
{
public Object intercept(Invocation invocation)
throws Throwable
{
try
{
MappedStatement mappedStatement = (MappedStatement)invocation.getArgs()[0];
Object parameter = null;
if (invocation.getArgs().length > 1) {
parameter = invocation.getArgs()[1];
}
String sqlId = mappedStatement.getId();
BoundSql boundSql = mappedStatement.getBoundSql(parameter);
Configuration configuration = mappedStatement.getConfiguration();
String sql = getSql(configuration, boundSql, sqlId);
System.out.println(sql);
}
catch (Exception localException) {}
return invocation.proceed();
}
public static String getSql(Configuration configuration, BoundSql boundSql, String sqlId)
{
String sql = showSql(configuration, boundSql);
StringBuilder str = new StringBuilder(100);
str.append(sqlId);
str.append(":");
str.append(sql);
return str.toString();
}
private static String getParameterValue(Object obj)
{
String value = null;
if ((obj instanceof String))
{
value = "'" + obj.toString() + "'";
}
else if ((obj instanceof Date))
{
DateFormat formatter = DateFormat.getDateTimeInstance(2, 2, Locale.CHINA);
value = "'" + formatter.format(new Date()) + "'";
}
else if (obj != null)
{
value = obj.toString();
}
else
{
value = "";
}
return value;
}
public static String showSql(Configuration configuration, BoundSql boundSql)
{
Object parameterObject = boundSql.getParameterObject();
List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
String sql = boundSql.getSql().replaceAll("[\\s]+", " ");
MetaObject metaObject;
if ((CollectionUtils.isNotEmpty(parameterMappings)) && (parameterObject != null))
{
TypeHandlerRegistry typeHandlerRegistry = configuration.getTypeHandlerRegistry();
if (typeHandlerRegistry.hasTypeHandler(parameterObject.getClass()))
{
sql = sql.replaceFirst("\\?", Matcher.quoteReplacement(getParameterValue(parameterObject)));
}
else
{
metaObject = configuration.newMetaObject(parameterObject);
for (ParameterMapping parameterMapping : parameterMappings)
{
String propertyName = parameterMapping.getProperty();
if (metaObject.hasGetter(propertyName))
{
Object obj = metaObject.getValue(propertyName);
sql = sql.replaceFirst("\\?", Matcher.quoteReplacement(getParameterValue(obj)));
}
else if (boundSql.hasAdditionalParameter(propertyName))
{
Object obj = boundSql.getAdditionalParameter(propertyName);
sql = sql.replaceFirst("\\?", Matcher.quoteReplacement(getParameterValue(obj)));
}
else
{
sql = sql.replaceFirst("\\?", "缺失");
}
}
}
}
return sql;
}
public Object plugin(Object target)
{
return Plugin.wrap(target, this);
}
public void setProperties(Properties properties) {}
}import com.sengled.cloud.data.platform.dao.mybatis.MybatisResultInterceptor;
import java.util.Properties;
import javax.annotation.Resource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* 自定義mybatis攔截器
*
* @author zengsong
* @version 1.0
* @description
* @date 2019/5/30 10:17
**/
@Configuration
public class MybatisInterceptorConfig
{
@Resource
private MybatisResultInterceptor mybatisResultInterceptor;
@Bean
public String myInterceptor()
{
Properties properties = new Properties();
this.mybatisResultInterceptor.setProperties(properties);
return "interceptor";
}
}<logger name="com.apache.ibatis" level="TRACE"/> <logger name="java.sql.Connection" level="DEBUG"/> <logger name="java.sql.Statement" level="DEBUG"/> <logger name="java.sql.PreparedStatement" level="DEBUG"/> <root level="INFO"> <appender-ref ref="STDOUT" /> <appender-ref ref="FILE" /> </root>
標題SQL語句格式化
trim標記：是格式化sql的標記
prefix：前綴
suffix：后綴
prefixOverrides：指定去除多余的前綴內容
suffixOverrides：指定去除多余的后綴內容
<select id="" parameterType="" resultType="">
select * from tb_user
<trim perfis="WHERE" prefixOverrides = "AND | OR">
<if test="name != null"> AND name = #{name}</if>
<if test="gender != null"> AND gender= #{gender}</if>
</trim>
</select>執行結果為：
select * from tb_user where and name = #{name} andgender = #{gender}
<insert id="" parameterType="">
insert into tb_user
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
id,
</if>
<if test="name!= null">
name,
</if>
<if test="gender!= null">
gender,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="id != null">
#{id,jdbcType=BIGINT},
</if>
<if test="name!= null">
#{name,jdbcType=VARCHAR},
</if>
<if test="gender!= null">
#{gender,jdbcType=BIGINT},
</if>
</trim>
</insert>執行結果為：
insert into tb_user (id,name,gender) values(1,“張三”,20)
<update id="">
update tb_user
<trim prefix="set" suffix=" where id = #{id}" suffixOverrides="," >
<if test="name != null"> name = #{name} , </if>
<if test="gender != null"> gender = #{gender} ,</if>
</trim>
</update>執行結果為：
update tb_user set name = “張三”，gender = 30 where id = 1
感謝各位的閱讀，以上就是“mybatis輸出SQL格式化的方法是什么”的內容了，經過本文的學習后，相信大家對mybatis輸出SQL格式化的方法是什么這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
