DbPrintExceptByMessage.java

package com.yanzuoguang.mq.dao.impl;

import com.yanzuoguang.db.DbPrintSqlExcept;
import com.yanzuoguang.db.impl.SqlInfo;
import org.springframework.stereotype.Component;

/**
 * 过滤Sql语句打印消息
 *
 * @author 颜佐光
 */
@Component
public class DbPrintExceptByMessage implements DbPrintSqlExcept {
    /**
     * 当前包的Sql语句不打印
     */
    private final Package aPackage = DbPrintExceptByMessage.class.getPackage();

    @Override
    public boolean isPrintExcept(SqlInfo sqlInfo, long time, int row) {
        if (sqlInfo == null || sqlInfo.getTargetClass() == null) {
            return false;
        }
        return sqlInfo.getTargetClass().getPackage() == aPackage;
    }
}