org.apache.ibatis.executor.ErrorContext.activity()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(11.3k)|赞(0)|评价(0)|浏览(82)

本文整理了Java中org.apache.ibatis.executor.ErrorContext.activity()方法的一些代码示例,展示了ErrorContext.activity()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ErrorContext.activity()方法的具体详情如下:
包路径:org.apache.ibatis.executor.ErrorContext
类名称:ErrorContext
方法名:activity

ErrorContext.activity介绍

暂无

代码示例

代码示例来源:origin: baomidou/mybatis-plus

@Override
@SuppressWarnings("unchecked")
public void setParameters(PreparedStatement ps) {
  ErrorContext.instance().activity("setting parameters").object(mappedStatement.getParameterMap().getId());
  List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
  if (parameterMappings != null) {

代码示例来源:origin: camunda/camunda-bpm-platform

@Override
public <E> Cursor<E> handleCursorResultSets(Statement stmt) throws SQLException {
 ErrorContext.instance().activity("handling cursor results").object(mappedStatement.getId());
 ResultSetWrapper rsw = getFirstResultSet(stmt);
 List<ResultMap> resultMaps = mappedStatement.getResultMaps();
 int resultMapCount = resultMaps.size();
 validateResultMapsCount(rsw, resultMapCount);
 if (resultMapCount != 1) {
  throw new ExecutorException("Cursor results cannot be mapped to multiple resultMaps");
 }
 ResultMap resultMap = resultMaps.get(0);
 return new DefaultCursor<E>(this, resultMap, rsw, rowBounds);
}

代码示例来源:origin: org.mybatis/mybatis

@Override
public <E> Cursor<E> handleCursorResultSets(Statement stmt) throws SQLException {
 ErrorContext.instance().activity("handling cursor results").object(mappedStatement.getId());
 ResultSetWrapper rsw = getFirstResultSet(stmt);
 List<ResultMap> resultMaps = mappedStatement.getResultMaps();
 int resultMapCount = resultMaps.size();
 validateResultMapsCount(rsw, resultMapCount);
 if (resultMapCount != 1) {
  throw new ExecutorException("Cursor results cannot be mapped to multiple resultMaps");
 }
 ResultMap resultMap = resultMaps.get(0);
 return new DefaultCursor<>(this, resultMap, rsw, rowBounds);
}

代码示例来源:origin: camunda/camunda-bpm-platform

@Override
public int update(MappedStatement ms, Object parameter) throws SQLException {
 ErrorContext.instance().resource(ms.getResource()).activity("executing an update").object(ms.getId());
 if (closed) {
  throw new ExecutorException("Executor was closed.");
 }
 clearLocalCache();
 return doUpdate(ms, parameter);
}

代码示例来源:origin: camunda/camunda-bpm-platform

private ResultMap resultMapElement(XNode resultMapNode, List<ResultMapping> additionalResultMappings) throws Exception {
 ErrorContext.instance().activity("processing " + resultMapNode.getValueBasedIdentifier());
 String id = resultMapNode.getStringAttribute("id",
   resultMapNode.getValueBasedIdentifier());

代码示例来源:origin: org.mybatis/mybatis

@Override
public int update(MappedStatement ms, Object parameter) throws SQLException {
 ErrorContext.instance().resource(ms.getResource()).activity("executing an update").object(ms.getId());
 if (closed) {
  throw new ExecutorException("Executor was closed.");
 }
 clearLocalCache();
 return doUpdate(ms, parameter);
}

代码示例来源:origin: org.mybatis/mybatis

private ResultMap resultMapElement(XNode resultMapNode, List<ResultMapping> additionalResultMappings, Class<?> enclosingType) throws Exception {
 ErrorContext.instance().activity("processing " + resultMapNode.getValueBasedIdentifier());
 String id = resultMapNode.getStringAttribute("id",
   resultMapNode.getValueBasedIdentifier());

代码示例来源:origin: camunda/camunda-bpm-platform

@Override
public List<Object> handleResultSets(Statement stmt) throws SQLException {
 ErrorContext.instance().activity("handling results").object(mappedStatement.getId());

代码示例来源:origin: org.mybatis/mybatis

@Override
public List<Object> handleResultSets(Statement stmt) throws SQLException {
 ErrorContext.instance().activity("handling results").object(mappedStatement.getId());

代码示例来源:origin: camunda/camunda-bpm-platform

@Override
public void setParameters(PreparedStatement ps) {
 ErrorContext.instance().activity("setting parameters").object(mappedStatement.getParameterMap().getId());
 List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
 if (parameterMappings != null) {

代码示例来源:origin: org.mybatis/mybatis

@Override
public void setParameters(PreparedStatement ps) {
 ErrorContext.instance().activity("setting parameters").object(mappedStatement.getParameterMap().getId());
 List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
 if (parameterMappings != null) {

代码示例来源:origin: org.mybatis/mybatis

@SuppressWarnings("unchecked")
@Override
public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {
 ErrorContext.instance().resource(ms.getResource()).activity("executing a query").object(ms.getId());
 if (closed) {
  throw new ExecutorException("Executor was closed.");

代码示例来源:origin: camunda/camunda-bpm-platform

@SuppressWarnings("unchecked")
@Override
public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {
 ErrorContext.instance().resource(ms.getResource()).activity("executing a query").object(ms.getId());
 if (closed) {
  throw new ExecutorException("Executor was closed.");

代码示例来源:origin: org.apache.ibatis/ibatis-core

private ResultMap resultMapElement(XNode resultMapNode, List<ResultMapping> additionalResultMappings) throws Exception {
 ErrorContext.instance().activity("processing " + resultMapNode.getValueBasedIdentifier());
 String id = resultMapNode.getStringAttribute("id",
   resultMapNode.getValueBasedIdentifier());
 String type = resultMapNode.getStringAttribute("type",
   resultMapNode.getStringAttribute("ofType",
     resultMapNode.getStringAttribute("resultType",
       resultMapNode.getStringAttribute("javaType"))));
 String extend = resultMapNode.getStringAttribute("extends");
 Class typeClass = resolveClass(type);
 Discriminator discriminator = null;
 List<ResultMapping> resultMappings = new ArrayList<ResultMapping>();
 resultMappings.addAll(additionalResultMappings);
 List<XNode> resultChildren = resultMapNode.getChildren();
 for (XNode resultChild : resultChildren) {
  if ("constructor".equals(resultChild.getName())) {
   processConstructorElement(resultChild, typeClass, resultMappings);
  } else if ("discriminator".equals(resultChild.getName())) {
   discriminator = processDiscriminatorElement(resultChild, typeClass, resultMappings);
  } else {
   ArrayList<ResultFlag> flags = new ArrayList<ResultFlag>();
   if ("id".equals(resultChild.getName())) {
    flags.add(ResultFlag.ID);
   }
   resultMappings.add(buildResultMappingFromContext(resultChild, typeClass, flags));
  }
 }
 return builderAssistant.addResultMap(id, typeClass, extend, discriminator, resultMappings);
}

代码示例来源:origin: org.apache.ibatis/ibatis-core

public int update(MappedStatement ms, Object parameter) throws SQLException {
 ErrorContext.instance().resource(ms.getResource()).activity("executing an update").object(ms.getId());
 if (closed) throw new ExecutorException("Executor was closed.");
 clearLocalCache();
 return doUpdate(ms, parameter);
}

代码示例来源:origin: com.github.tianjing/tgtools.activiti.dm

private void changeSql()
  ErrorContext.instance().activity("setting parameters").object(mappedStatement.getParameterMap().getId());
  List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();

代码示例来源:origin: org.apache.ibatis/ibatis-core

public void setParameters(PreparedStatement ps)
  throws SQLException {
 ErrorContext.instance().activity("setting parameters").object(mappedStatement.getParameterMap().getId());
 List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
 if (parameterMappings != null) {

代码示例来源:origin: miemiedev/mybatis-paginator

public void setParameters(PreparedStatement ps) throws SQLException {
  ErrorContext.instance().activity("setting parameters").object(mappedStatement.getParameterMap().getId());
  List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
  if (parameterMappings != null) {
    MetaObject metaObject = parameterObject == null ? null : configuration.newMetaObject(parameterObject);
    for (int i = 0; i < parameterMappings.size(); i++) {
      ParameterMapping parameterMapping = parameterMappings.get(i);
      if (parameterMapping.getMode() != ParameterMode.OUT) {
        Object value;
        String propertyName = parameterMapping.getProperty();
        if (boundSql.hasAdditionalParameter(propertyName)) { // issue #448 ask first for additional params
          value = boundSql.getAdditionalParameter(propertyName);
        } else if (parameterObject == null) {
          value = null;
        } else if (typeHandlerRegistry.hasTypeHandler(parameterObject.getClass())) {
          value = parameterObject;
        } else {
          value = metaObject == null ? null : metaObject.getValue(propertyName);
        }
        TypeHandler typeHandler = parameterMapping.getTypeHandler();
        if (typeHandler == null) {
          throw new ExecutorException("There was no TypeHandler found for parameter " + propertyName + " of statement " + mappedStatement.getId());
        }
        JdbcType jdbcType = parameterMapping.getJdbcType();
        if (value == null && jdbcType == null) jdbcType = configuration.getJdbcTypeForNull();
        typeHandler.setParameter(ps, i + 1, value, jdbcType);
      }
    }
  }
}

代码示例来源:origin: com.github.miemiedev/mybatis-paginator

public void setParameters(PreparedStatement ps) throws SQLException {
  ErrorContext.instance().activity("setting parameters").object(mappedStatement.getParameterMap().getId());
  List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
  if (parameterMappings != null) {
    MetaObject metaObject = parameterObject == null ? null : configuration.newMetaObject(parameterObject);
    for (int i = 0; i < parameterMappings.size(); i++) {
      ParameterMapping parameterMapping = parameterMappings.get(i);
      if (parameterMapping.getMode() != ParameterMode.OUT) {
        Object value;
        String propertyName = parameterMapping.getProperty();
        if (boundSql.hasAdditionalParameter(propertyName)) { // issue #448 ask first for additional params
          value = boundSql.getAdditionalParameter(propertyName);
        } else if (parameterObject == null) {
          value = null;
        } else if (typeHandlerRegistry.hasTypeHandler(parameterObject.getClass())) {
          value = parameterObject;
        } else {
          value = metaObject == null ? null : metaObject.getValue(propertyName);
        }
        TypeHandler typeHandler = parameterMapping.getTypeHandler();
        if (typeHandler == null) {
          throw new ExecutorException("There was no TypeHandler found for parameter " + propertyName + " of statement " + mappedStatement.getId());
        }
        JdbcType jdbcType = parameterMapping.getJdbcType();
        if (value == null && jdbcType == null) jdbcType = configuration.getJdbcTypeForNull();
        typeHandler.setParameter(ps, i + 1, value, jdbcType);
      }
    }
  }
}

代码示例来源:origin: org.apache.ibatis/ibatis-core

public List query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler) throws SQLException {
 ErrorContext.instance().resource(ms.getResource()).activity("executing a query").object(ms.getId());
 if (closed) throw new ExecutorException("Executor was closed.");
 List list;
 try {
  queryStack++;
  CacheKey key = createCacheKey(ms, parameter, rowBounds);
  final List cachedList = (List) localCache.getObject(key);
  if (cachedList != null) {
   list = cachedList;
  } else {
   localCache.putObject(key, EXECUTION_PLACEHOLDER);
   try {
    list = doQuery(ms, parameter, rowBounds, resultHandler);
   } finally {
    localCache.removeObject(key);
   }
   localCache.putObject(key, list);
  }
 } finally {
  queryStack--;
 }
 if (queryStack == 0) {
  for (DeferredLoad deferredLoad : deferredLoads) {
   deferredLoad.load();
  }
 }
 return list;
}

相关文章