如何才能将执行的SQL语句记录下来？

[deli-chen]

[Aresxue]

原有的MybatisPlugin是不支持的，建议

EnhanceModel query = EnhanceModel.builder()
        .classPattern("org.apache.ibatis.executor.BaseExecutor")
        .methodPatterns(new MethodPattern[]{
            MethodPattern.builder()
                .methodName("query")
                .parameterType(new String[]{"org.apache.ibatis.mapping.MappedStatement",
                    Object.class.getCanonicalName(), "org.apache.ibatis.session.RowBounds",
                    "org.apache.ibatis.session.ResultHandler", "org.apache.ibatis.cache.CacheKey",
                    "org.apache.ibatis.mapping.BoundSql"})
                .build()
        })
        .watchTypes(BEFORE, RETURN, THROWS)
        .build();
    // 更新操作
    EnhanceModel update = EnhanceModel.builder()
        .classPattern("org.apache.ibatis.executor.BaseExecutor")
        .methodPatterns(MethodPattern.transform("doUpdate"))
        .includeSubClasses(true)
        .watchTypes(BEFORE, RETURN, THROWS)
        .build();
    EnhanceModel doFlushStatements = EnhanceModel.builder()
        .classPattern("org.apache.ibatis.executor.BatchExecutor")
        .methodPatterns(MethodPattern.transform("doFlushStatements"))
        .watchTypes(BEFORE, RETURN, THROWS)
        .build();

用几个切面重写插件

[deli-chen]

多谢大佬回复，增加这几个切面后，在哪可以提取拦截的SQL呢

[Aresxue]

多谢大佬回复，增加这几个切面后，在哪可以提取拦截的SQL呢

query和doUpdate的第一个入参是org.apache.ibatis.mapping.MappedStatement，从这个里面getBoundSql就可以取到了
doFlushStatements从org.apache.ibatis.executor.BatchExecutor中提取batchResultList，batchResultList中有sql

[deli-chen]

我在 MybatisProcessor 增加了 printSql(BeforeEvent event)，但 if (event.target instanceof StatementHandler) 这里没有进来，还需要对 BeforeEvent 做改造？
class MybatisProcessor extends DefaultInvocationProcessor {
private final static Logger log = LoggerFactory.getLogger(MybatisProcessor.class);
MybatisProcessor(InvokeType type) {
super(type);
}

@Override
public Identity assembleIdentity(BeforeEvent event) {
    printSql(event);
    Object mapperMethod = event.target;
    // SqlCommand = MapperMethod.command
    Field field = FieldUtils.getDeclaredField(mapperMethod.getClass(), "command", true);
    if (field == null) {
        return new Identity(InvokeType.MYBATIS.name(), "Unknown", "Unknown", new HashMap<String, String>(1));
    }
    try {
        Object command = field.get(mapperMethod);
        Object name = MethodUtils.invokeMethod(command, "getName");
        Object type = MethodUtils.invokeMethod(command, "getType");
        return new Identity(InvokeType.MYBATIS.name(), type.toString(), name.toString(), new HashMap<String, String>(1));
    } catch (Exception e) {
        return new Identity(InvokeType.MYBATIS.name(), "Unknown", "Unknown", new HashMap<String, String>(1));
    }
}

public void printSql(BeforeEvent event){
    log.info("打印SQL：{}",JSON.toJSONString(event));
    Object statement = event.target;

    if (statement instanceof HikariProxyPreparedStatement) {
        HikariProxyPreparedStatement proxyStatement = (HikariProxyPreparedStatement) statement;
        // 处理 HikariProxyPreparedStatement 的逻辑
        // 可以通过 proxyStatement 获取底层的 PreparedStatement 进行操作
        log.info("拦截 StatementHandler SQL.....");
    } else if (statement instanceof StatementHandler) {
        StatementHandler statementHandler = (StatementHandler) statement;
        // 原有的处理 StatementHandler
        BoundSql boundSql = statementHandler.getBoundSql();
        String sql = boundSql.getSql();

        // 打印或处理 SQL 语句
        log.info("拦截 StatementHandler SQL:{} ", sql);
    } else {
        // 处理其他类型的逻辑
        log.info("拦截 其它 SQL.....");
    }
}

@Override
public Object[] assembleRequest(BeforeEvent event) {
    // MapperMethod#execute(SqlSession sqlSession, Object[] args)
    // args可能存在不可序序列化异常（例如使用tk.mybatis)
    return new Object[]{event.argumentArray[1]};
}

@Override
public boolean inTimeSerializeRequest(Invocation invocation, BeforeEvent event) {
    return false;
}

}

[Aresxue]

sandbox是完全类加载器隔离的，建议不要直接使用业务的类（还会存在版本不兼容的问题），1.4.0版本中这个代码肯定跑不起来的，你可以看下statement实例的类是哪个，StatementHandler可能是当前ModuleJarClassLoader的类自然和业务的statement匹配不上

[deli-chen]

我尝试将sql提取出来了，不过第一次提取没问题，第二次之后就报hessian序列化异常，stack 溢出，貌似是序列化时出现循环引用了

…

---- 回复的原邮件 ---- | 发件人 | ***@***.***> | | 发送日期 | 2025年05月26日 11:14 | | 收件人 | alibaba/jvm-sandbox-repeater ***@***.***> | | 抄送人 | deli-chen ***@***.***>, Author ***@***.***> | | 主题 | Re: [alibaba/jvm-sandbox-repeater] 如何才能将执行的SQL语句记录下来？ (Issue #234) | Aresxue left a comment (alibaba/jvm-sandbox-repeater#234) sandbox是完全类加载器隔离的，建议不要直接使用业务的类（还会存在版本不兼容的问题），1.4.0版本中这个代码肯定跑不起来的，你可以看下statement实例的类是哪个，StatementHandler可能是当前ModuleJarClassLoader的类自然和业务的statement匹配不上 — Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: ***@***.***>

[Aresxue]

我尝试将sql提取出来了，不过第一次提取没问题，第二次之后就报hessian序列化异常，stack 溢出，貌似是序列化时出现循环引用了
…

public class MybatisProcessor extends DefaultInvocationProcessor {

  private static final Logger LOGGER = LoggerFactory.getLogger(MybatisProcessor.class.getName());

  private static final String TYPE = "type";
  private static final Class<?> BATCH_RESULT_CLAZZ;

  static {
    try {
      BATCH_RESULT_CLAZZ = loadBusinessClass("org.apache.ibatis.executor.BatchResult");
    } catch (ClassNotFoundException classNotFoundException) {
      // 找不到类说明业务没有使用当前框架
      throw new PluginInitTerminateException();
    }
  }

  protected MybatisProcessor(InvokeType type) {
    super(type);
  }

  @Override
  public Identity buildIdentity(BeforeEvent beforeEvent) {
    try {
      String methodName = beforeEvent.javaMethodName;
      // doFlushStatements使用原始类名和方法名
      if (DO_FLUSH_STATEMENTS_METHOD_NAME.equals(methodName)) {
        // 获取实例对象的类名(*Mapper/Dao等)，对于单表写（新增/删除/更改）和单表读（查询）实例对象的类名和表名都是等价的
        // 一般来说写基本上都是单表，但读就不一定了，多表读的情况下实例对象的类名也是个不错的选择，暂时没想到更好的方案
        String className = extraClassName(beforeEvent);
        return new Identity(getType().getName(), className, methodName, null);
      }

      // org.apache.ibatis.mapping.MappedStatement
      Object mappedStatement = beforeEvent.argumentArray[0];
      // org.apache.ibatis.mapping.MappedStatement#id
      String id = ReflectionUtil.getFieldValue(mappedStatement, "id");
      int index = id.lastIndexOf(".");
      String location;
      String endpoint;
      if (INDEX_NOT_FOUND == index) {
        location = id;
        endpoint = "";
      } else {
        location = id.substring(0, index);
        endpoint = id.substring(index + 1);
      }
      // org.apache.ibatis.mapping.MappedStatement#sqlCommandType
      Object type = ReflectionUtil.getFieldValue(mappedStatement, "sqlCommandType");
      Map<String, String> extra = null;
      if (null != type) {
        extra = MapUtil.newMap(TYPE, type.toString());
      }
      return new Identity(getType().getName(), location, endpoint, extra);
    } catch (Exception exception) {
      throw new TerminateException(getType().getName() + " assemble identity fail", exception);
    }
  }

  protected String extraClassName(BeforeEvent beforeEvent) {
    String className = beforeEvent.javaClassName;
    try {
      // 可能是代理对象此方法不是代理对象的话也会返回本身
      Object target = ObjectUtil.getProxyTargetRecursively(beforeEvent.target);
      // 获取实例对象的类名
      return TypeUtil.getOriginClassName(target.getClass().getName());
    } catch (Exception e) {
      LOGGER.warn("extra mybatis class name fail, default name: {}, exception:", className, e);
    }
    return className;
  }

  @Override
  public Object[] buildRequest(BeforeEvent beforeEvent) {
    Object[] argumentArray = beforeEvent.argumentArray;
    String methodName = beforeEvent.javaMethodName;
    if (DO_FLUSH_STATEMENTS_METHOD_NAME.equals(methodName)) {
      // doFlushStatements单独处理
      return assembleDoFlushStatementsRequest(beforeEvent);
    } else {
      Object boundSql;
      if (QUERY_METHOD_NAME.equals(methodName)) {
        // org.apache.ibatis.executor.BaseExecutor.query(org.apache.ibatis.mapping.MappedStatement, java.lang.Object, org.apache.ibatis.session.RowBounds, org.apache.ibatis.session.ResultHandler, org.apache.ibatis.cache.CacheKey, org.apache.ibatis.mapping.BoundSql)
        boundSql = argumentArray[5];
      } else {
        // org.apache.ibatis.executor.BaseExecutor.doUpdate(org.apache.ibatis.mapping.MappedStatement, java.lang.Object)
        // org.apache.ibatis.mapping.MappedStatement#getBoundSql()
        boundSql = ReflectionUtil.invokeMethod(argumentArray[0], "getBoundSql", argumentArray[1]);
      }
      DatabaseRequest databaseRequest = new DatabaseRequest();
      // org.apache.ibatis.mapping.BoundSql#sql
      String sql = ReflectionUtil.getFieldValue(boundSql, "sql");
      List<String> commentList = new ArrayList<>();
      String simpleSql = SqlUtil.simpleSql(commentList, sql);
      databaseRequest.setSql(simpleSql);
      databaseRequest.setComments(commentList);
      Object parameterObject = buildParameter(boundSql);
      databaseRequest.setParameter(parameterObject);
      return new Object[]{databaseRequest};
    }
  }

  // 返回DatabaseRequest[]
  private Object[] assembleDoFlushStatementsRequest(BeforeEvent beforeEvent) {
    // org.apache.ibatis.executor.BatchExecutor#batchResultList
    List<Object> batchResultList = ReflectionUtil.getFieldValue(beforeEvent.target,
        "batchResultList");
    if (CollectionUtil.isEmpty(batchResultList)) {
      return new Object[0];
    }
    // 将List<BatchResult>转为DatabaseRequest[]
    Object[] requestArr = new Object[batchResultList.size()];
    for (int i = 0; i < batchResultList.size(); i++) {
      Object batchResult = batchResultList.get(i);
      if (null != batchResult) {
        DatabaseRequest databaseRequest = new DatabaseRequest();
        // org.apache.ibatis.executor.BatchResult#sql
        String sql = ReflectionUtil.getFieldValue(batchResult, "sql");
        List<String> commentList = new ArrayList<>();
        databaseRequest.setSql(SqlUtil.simpleSql(commentList, sql));
        databaseRequest.setComments(commentList);
        List<Object> parameterList = buildParameterList(batchResult);
        databaseRequest.setParameter(parameterList);
        requestArr[i] = databaseRequest;
      }
    }
    return requestArr;
  }

  protected List<Object> buildParameterList(Object batchResult) {
    // org.apache.ibatis.executor.BatchResult#parameterObjects
    return ReflectionUtil.getFieldValue(batchResult, "parameterObjects");
  }

  private Object buildParameter(Object boundSql) {
    // org.apache.ibatis.mapping.BoundSql#parameterObject
    Object parameterObject = ReflectionUtil.getFieldValue(boundSql, "parameterObject");
    if (parameterObject instanceof Map) {
      Map<?, ?> parameterObjectMap = (Map<?, ?>) parameterObject;
      if (MapUtil.isNotEmpty(parameterObjectMap)) {
        Map<Object, Object> paramMap = MapUtil.newMap(
            parameterObjectMap.size() / 2 + parameterObjectMap.size() % 2);
        parameterObjectMap.forEach((key, value) -> handleParamMap(paramMap, key, value));
        parameterObject = paramMap;
      }
    }
    return parameterObject;
  }

  protected void handleParamMap(Map<Object, Object> paramMap, Object key, Object value) {
    // 根据value去重
    if (!paramMap.containsValue(value)) {
      paramMap.put(key, value);
    }
  }


  @Override
  public Object buildResponse(Event event) {
    if (RETURN == event.type) {
      ReturnEvent returnEvent = (ReturnEvent) event;
      Object response = returnEvent.object;
      // doFlushStatements的响应不可序列化做适配
      if (response instanceof List) {
        List<?> list = (List<?>) response;
        if (CollectionUtil.isNotEmpty(list)) {
          if (BATCH_RESULT_CLAZZ.isInstance(list.get(0))) {
            return buildBatchResultAdapterList(list);
          }
        }
      }
      return response;
    }
    return null;
  }

  private List<Object> buildBatchResultAdapterList(List<?> list) {
    return list.stream().map((Function<Object, Object>) batchResult -> {
      BatchResultAdapter batchResultAdapter = new BatchResultAdapter();
      // org.apache.ibatis.executor.BatchResult#updateCounts
      int[] updateCounts = ReflectionUtil.getFieldValue(batchResult, "updateCounts");
      batchResultAdapter.setUpdateCounts(updateCounts);
      // org.apache.ibatis.executor.BatchResult#mappedStatement
      Object statement = ReflectionUtil.getFieldValue(batchResult, "mappedStatement");
      // org.apache.ibatis.mapping.MappedStatement#id
      String mappedStatementId = ReflectionUtil.getFieldValue(statement, "id");
      batchResultAdapter.setMappedStatementId(mappedStatementId);
      return batchResultAdapter;
    }).collect(Collectors.toList());
  }

  @Override
  public Object buildMockResponse(BeforeEvent beforeEvent, Invocation invocation) {
    String methodName = beforeEvent.javaMethodName;
    if (DO_FLUSH_STATEMENTS_METHOD_NAME.equals(methodName)) {
      return buildBatchResultList(beforeEvent, invocation);
    }
    return super.buildMockResponse(beforeEvent, invocation);
  }

  private List<Object> buildBatchResultList(BeforeEvent beforeEvent, Invocation invocation) {
    List<BatchResultAdapter> batchResultAdapterList = (List) invocation.getResponse();
    Map<String, int[]> updateCountsMap = batchResultAdapterList.stream().collect(
        Collectors.toMap(BatchResultAdapter::getMappedStatementId,
            BatchResultAdapter::getUpdateCounts));
    // org.apache.ibatis.executor.BatchExecutor#batchResultList
    List<Object> batchResultList = ReflectionUtil.getFieldValue(beforeEvent.target,
        "batchResultList");
    batchResultList.forEach(batchResult -> {
      // org.apache.ibatis.executor.BatchResult#mappedStatement
      Object statement = ReflectionUtil.getFieldValue(batchResult, "mappedStatement");
      // org.apache.ibatis.mapping.MappedStatement#id
      String mappedStatementId = ReflectionUtil.getFieldValue(statement, "id");
      int[] updateCounts = updateCountsMap.get(mappedStatementId);
      // org.apache.ibatis.executor.BatchResult#updateCounts
      ReflectionUtil.setFieldValue(batchResult, "updateCounts", updateCounts);
    });
    return batchResultList;
  }

  @Override
  public boolean requestMayBeChangeInMethod(Invocation invocation) {
    Identity identity = invocation.getIdentity();
    Map<String, String> extra = identity.getExtra();
    // 读不会修改入参
    if (MapUtil.isNotEmpty(extra) && DatabaseOperationType.isRead(extra.get(TYPE))) {
      return false;
    }
    return super.requestMayBeChangeInMethod(invocation);
  }

}

可以参考上述代码做处理，序列化异常说明序列化了不该序列化的对象

[deli-chen]

stack溢出问题解决，不过想请教一下：怎么在本地的idea调试mybatis插件？

…

---- 回复的原邮件 ---- | 发件人 | ***@***.***> | | 发送日期 | 2025年06月03日 19:20 | | 收件人 | alibaba/jvm-sandbox-repeater ***@***.***> | | 抄送人 | deli-chen ***@***.***>, Author ***@***.***> | | 主题 | Re: [alibaba/jvm-sandbox-repeater] 如何才能将执行的SQL语句记录下来？ (Issue #234) | Aresxue left a comment (alibaba/jvm-sandbox-repeater#234) 我尝试将sql提取出来了，不过第一次提取没问题，第二次之后就报hessian序列化异常，stack 溢出，貌似是序列化时出现循环引用了 … public class MybatisProcessor extends DefaultInvocationProcessor { private static final Logger LOGGER = LoggerFactory.getLogger(MybatisProcessor.class.getName()); private static final String TYPE = "type"; private static final Class<?> BATCH_RESULT_CLAZZ; static { try { BATCH_RESULT_CLAZZ = loadBusinessClass("org.apache.ibatis.executor.BatchResult"); } catch (ClassNotFoundException classNotFoundException) { // 找不到类说明业务没有使用当前框架 throw new PluginInitTerminateException(); } } protected MybatisProcessor(InvokeType type) { super(type); } @OverRide public Identity buildIdentity(BeforeEvent beforeEvent) { try { String methodName = beforeEvent.javaMethodName; // doFlushStatements使用原始类名和方法名 if (DO_FLUSH_STATEMENTS_METHOD_NAME.equals(methodName)) { // 获取实例对象的类名(*Mapper/Dao等)，对于单表写（新增/删除/更改）和单表读（查询）实例对象的类名和表名都是等价的 // 一般来说写基本上都是单表，但读就不一定了，多表读的情况下实例对象的类名也是个不错的选择，暂时没想到更好的方案 String className = extraClassName(beforeEvent); return new Identity(getType().getName(), className, methodName, null); } // org.apache.ibatis.mapping.MappedStatement Object mappedStatement = beforeEvent.argumentArray[0]; // org.apache.ibatis.mapping.MappedStatement#id String id = ReflectionUtil.getFieldValue(mappedStatement, "id"); int index = id.lastIndexOf("."); String location; String endpoint; if (INDEX_NOT_FOUND == index) { location = id; endpoint = ""; } else { location = id.substring(0, index); endpoint = id.substring(index + 1); } // org.apache.ibatis.mapping.MappedStatement#sqlCommandType Object type = ReflectionUtil.getFieldValue(mappedStatement, "sqlCommandType"); Map<String, String> extra = null; if (null != type) { extra = MapUtil.newMap(TYPE, type.toString()); } return new Identity(getType().getName(), location, endpoint, extra); } catch (Exception exception) { throw new TerminateException(getType().getName() + " assemble identity fail", exception); } } protected String extraClassName(BeforeEvent beforeEvent) { String className = beforeEvent.javaClassName; try { // 可能是代理对象此方法不是代理对象的话也会返回本身 Object target = ObjectUtil.getProxyTargetRecursively(beforeEvent.target); // 获取实例对象的类名 return TypeUtil.getOriginClassName(target.getClass().getName()); } catch (Exception e) { LOGGER.warn("extra mybatis class name fail, default name: {}, exception:", className, e); } return className; } @OverRide public Object[] buildRequest(BeforeEvent beforeEvent) { Object[] argumentArray = beforeEvent.argumentArray; String methodName = beforeEvent.javaMethodName; if (DO_FLUSH_STATEMENTS_METHOD_NAME.equals(methodName)) { // doFlushStatements单独处理 return assembleDoFlushStatementsRequest(beforeEvent); } else { Object boundSql; if (QUERY_METHOD_NAME.equals(methodName)) { // org.apache.ibatis.executor.BaseExecutor.query(org.apache.ibatis.mapping.MappedStatement, java.lang.Object, org.apache.ibatis.session.RowBounds, org.apache.ibatis.session.ResultHandler, org.apache.ibatis.cache.CacheKey, org.apache.ibatis.mapping.BoundSql) boundSql = argumentArray[5]; } else { // org.apache.ibatis.executor.BaseExecutor.doUpdate(org.apache.ibatis.mapping.MappedStatement, java.lang.Object) // org.apache.ibatis.mapping.MappedStatement#getBoundSql() boundSql = ReflectionUtil.invokeMethod(argumentArray[0], "getBoundSql", argumentArray[1]); } DatabaseRequest databaseRequest = new DatabaseRequest(); // org.apache.ibatis.mapping.BoundSql#sql String sql = ReflectionUtil.getFieldValue(boundSql, "sql"); List commentList = new ArrayList<>(); String simpleSql = SqlUtil.simpleSql(commentList, sql); databaseRequest.setSql(simpleSql); databaseRequest.setComments(commentList); Object parameterObject = buildParameter(boundSql); databaseRequest.setParameter(parameterObject); return new Object[]{databaseRequest}; } } // 返回DatabaseRequest[] private Object[] assembleDoFlushStatementsRequest(BeforeEvent beforeEvent) { // org.apache.ibatis.executor.BatchExecutor#batchResultList List batchResultList = ReflectionUtil.getFieldValue(beforeEvent.target, "batchResultList"); if (CollectionUtil.isEmpty(batchResultList)) { return new Object[0]; } // 将List转为DatabaseRequest[] Object[] requestArr = new Object[batchResultList.size()]; for (int i = 0; i < batchResultList.size(); i++) { Object batchResult = batchResultList.get(i); if (null != batchResult) { DatabaseRequest databaseRequest = new DatabaseRequest(); // org.apache.ibatis.executor.BatchResult#sql String sql = ReflectionUtil.getFieldValue(batchResult, "sql"); List commentList = new ArrayList<>(); databaseRequest.setSql(SqlUtil.simpleSql(commentList, sql)); databaseRequest.setComments(commentList); List parameterList = buildParameterList(batchResult); databaseRequest.setParameter(parameterList); requestArr[i] = databaseRequest; } } return requestArr; } protected List buildParameterList(Object batchResult) { // org.apache.ibatis.executor.BatchResult#parameterObjects return ReflectionUtil.getFieldValue(batchResult, "parameterObjects"); } private Object buildParameter(Object boundSql) { // org.apache.ibatis.mapping.BoundSql#parameterObject Object parameterObject = ReflectionUtil.getFieldValue(boundSql, "parameterObject"); if (parameterObject instanceof Map) { Map parameterObjectMap = (Map) parameterObject; if (MapUtil.isNotEmpty(parameterObjectMap)) { Map<Object, Object> paramMap = MapUtil.newMap( parameterObjectMap.size() / 2 + parameterObjectMap.size() % 2); parameterObjectMap.forEach((key, value) -> handleParamMap(paramMap, key, value)); parameterObject = paramMap; } } return parameterObject; } protected void handleParamMap(Map<Object, Object> paramMap, Object key, Object value) { // 根据value去重 if (!paramMap.containsValue(value)) { paramMap.put(key, value); } } @OverRide public Object buildResponse(Event event) { if (RETURN == event.type) { ReturnEvent returnEvent = (ReturnEvent) event; Object response = returnEvent.object; // doFlushStatements的响应不可序列化做适配 if (response instanceof List) { List list = (List) response; if (CollectionUtil.isNotEmpty(list)) { if (BATCH_RESULT_CLAZZ.isInstance(list.get(0))) { return buildBatchResultAdapterList(list); } } } return response; } return null; } private List buildBatchResultAdapterList(List<?> list) { return list.stream().map((Function<Object, Object>) batchResult -> { BatchResultAdapter batchResultAdapter = new BatchResultAdapter(); // org.apache.ibatis.executor.BatchResult#updateCounts int[] updateCounts = ReflectionUtil.getFieldValue(batchResult, "updateCounts"); batchResultAdapter.setUpdateCounts(updateCounts); // org.apache.ibatis.executor.BatchResult#mappedStatement Object statement = ReflectionUtil.getFieldValue(batchResult, "mappedStatement"); // org.apache.ibatis.mapping.MappedStatement#id String mappedStatementId = ReflectionUtil.getFieldValue(statement, "id"); batchResultAdapter.setMappedStatementId(mappedStatementId); return batchResultAdapter; }).collect(Collectors.toList()); } @OverRide public Object buildMockResponse(BeforeEvent beforeEvent, Invocation invocation) { String methodName = beforeEvent.javaMethodName; if (DO_FLUSH_STATEMENTS_METHOD_NAME.equals(methodName)) { return buildBatchResultList(beforeEvent, invocation); } return super.buildMockResponse(beforeEvent, invocation); } private List buildBatchResultList(BeforeEvent beforeEvent, Invocation invocation) { List batchResultAdapterList = (List) invocation.getResponse(); Map<String, int[]> updateCountsMap = batchResultAdapterList.stream().collect( Collectors.toMap(BatchResultAdapter::getMappedStatementId, BatchResultAdapter::getUpdateCounts)); // org.apache.ibatis.executor.BatchExecutor#batchResultList List batchResultList = ReflectionUtil.getFieldValue(beforeEvent.target, "batchResultList"); batchResultList.forEach(batchResult -> { // org.apache.ibatis.executor.BatchResult#mappedStatement Object statement = ReflectionUtil.getFieldValue(batchResult, "mappedStatement"); // org.apache.ibatis.mapping.MappedStatement#id String mappedStatementId = ReflectionUtil.getFieldValue(statement, "id"); int[] updateCounts = updateCountsMap.get(mappedStatementId); // org.apache.ibatis.executor.BatchResult#updateCounts ReflectionUtil.setFieldValue(batchResult, "updateCounts", updateCounts); }); return batchResultList; } @OverRide public boolean requestMayBeChangeInMethod(Invocation invocation) { Identity identity = invocation.getIdentity(); Map<String, String> extra = identity.getExtra(); // 读不会修改入参 if (MapUtil.isNotEmpty(extra) && DatabaseOperationType.isRead(extra.get(TYPE))) { return false; } return super.requestMayBeChangeInMethod(invocation); } } 可以参考上述代码做处理，序列化异常说明序列化了不该序列化的对象 — Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: ***@***.***>

[Aresxue]

stack溢出问题解决，不过想请教一下：怎么在本地的idea调试mybatis插件？
…

agent的调试和普通代码是一样的，用debug模式断点就可以了，字节码改写后桥接方法会把调用转接到插件中的

[deli-chen]

拦截sql的问题解决了，再请教个问题：有办法将jvm-sandbox- repeater做成一个javaagent吗？在java -jar启动命令加上这个agent，即不用命令单独启动工具

…

---- 回复的原邮件 ---- | 发件人 | ***@***.***> | | 发送日期 | 2025年06月04日 11:12 | | 收件人 | alibaba/jvm-sandbox-repeater ***@***.***> | | 抄送人 | deli-chen ***@***.***>, Author ***@***.***> | | 主题 | Re: [alibaba/jvm-sandbox-repeater] 如何才能将执行的SQL语句记录下来？ (Issue #234) | Aresxue left a comment (alibaba/jvm-sandbox-repeater#234) stack溢出问题解决，不过想请教一下：怎么在本地的idea调试mybatis插件？ … agent的调试和普通代码是一样的，用debug模式断点就可以了，字节码改写后桥接方法会把调用转接到插件中的 — Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: ***@***.***>