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

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

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

Executor.getTransaction介绍

暂无

代码示例

代码示例来源:origin: abel533/Mapper

  1. Executor keyExecutor = configuration.newExecutor(executor.getTransaction(), ExecutorType.SIMPLE);
  2. List<Object> values = keyExecutor.query(keyStatement, parameter, RowBounds.DEFAULT, Executor.NO_RESULT_HANDLER);
  3. if (values.size() == 0) {

代码示例来源:origin: abel533/Mapper

  1. Executor keyExecutor = configuration.newExecutor(executor.getTransaction(), ExecutorType.SIMPLE);
  2. List<Object> values = keyExecutor.query(keyStatement, parameter, RowBounds.DEFAULT, Executor.NO_RESULT_HANDLER);
  3. if (values.size() == 0) {

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

  1. @Override
  2. public Transaction getTransaction() {
  3. return delegate.getTransaction();
  4. }

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

  1. @Override
  2. public Transaction getTransaction() {
  3. return delegate.getTransaction();
  4. }

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

  1. @Override
  2. public Connection getConnection() {
  3. try {
  4. return executor.getTransaction().getConnection();
  5. } catch (SQLException e) {
  6. throw ExceptionFactory.wrapException("Error getting a new connection. Cause: " + e, e);
  7. }
  8. }

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

  1. @Override
  2. public Connection getConnection() {
  3. try {
  4. return executor.getTransaction().getConnection();
  5. } catch (SQLException e) {
  6. throw ExceptionFactory.wrapException("Error getting a new connection. Cause: " + e, e);
  7. }
  8. }

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

  1. Executor keyExecutor = configuration.newExecutor(executor.getTransaction(), ExecutorType.SIMPLE);
  2. List<Object> values = keyExecutor.query(keyStatement, parameter, RowBounds.DEFAULT, Executor.NO_RESULT_HANDLER);
  3. if (values.size() == 0) {

代码示例来源:origin: ldlqdsdcn/eidea4

  1. @Override
  2. public Transaction getTransaction() {
  3. return executor.getTransaction();
  4. }

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

  1. Executor keyExecutor = configuration.newExecutor(executor.getTransaction(), ExecutorType.SIMPLE);
  2. List<Object> values = keyExecutor.query(keyStatement, parameter, RowBounds.DEFAULT, Executor.NO_RESULT_HANDLER);
  3. if (values.size() == 0) {

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

  1. public Transaction getTransaction() {
  2. return delegate.getTransaction();
  3. }

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

  1. public Connection getConnection() {
  2. return executor.getTransaction().getConnection();
  3. }

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

  1. private void processGeneratedKeys(Executor executor, MappedStatement ms, Statement stmt, Object parameter) {
  2. try {
  3. final Configuration configuration = ms.getConfiguration();
  4. if (parameter != null) {
  5. String keyStatementName = ms.getId() + SELECT_KEY_SUFFIX;
  6. if (configuration.hasStatement(keyStatementName)) {
  7. if (keyStatement != null) {
  8. String keyProperty = keyStatement.getKeyProperty();
  9. final MetaObject metaParam = configuration.newMetaObject(parameter);
  10. if (keyProperty != null && metaParam.hasSetter(keyProperty)) {
  11. // Do not close keyExecutor.
  12. // The transaction will be closed by parent executor.
  13. Executor keyExecutor = configuration.newExecutor(executor.getTransaction(), ExecutorType.SIMPLE);
  14. List values = keyExecutor.query(keyStatement, parameter, RowBounds.DEFAULT, Executor.NO_RESULT_HANDLER);
  15. if (values.size() > 1) {
  16. throw new ExecutorException("Select statement for SelectKeyGenerator returned more than one value.");
  17. }
  18. metaParam.setValue(keyProperty, values.get(0));
  19. }
  20. }
  21. }
  22. }
  23. } catch (Exception e) {
  24. throw new ExecutorException("Error selecting key or setting result to parameter object. Cause: " + e, e);
  25. }
  26. }

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

  1. public Object call() throws Exception {
  2. Integer count;
  3. Cache cache = ms.getCache();
  4. if(cache != null && ms.isUseCache() && ms.getConfiguration().isCacheEnabled()){
  5. CacheKey cacheKey = executor.createCacheKey(ms,parameter,new PageBounds(),copyFromBoundSql(ms,boundSql,dialect.getCountSQL(), boundSql.getParameterMappings(), boundSql.getParameterObject()));
  6. count = (Integer)cache.getObject(cacheKey);
  7. if(count == null){
  8. count = SQLHelp.getCount(ms,executor.getTransaction(),parameter,boundSql,dialect);
  9. cache.putObject(cacheKey, count);
  10. }
  11. }else{
  12. count = SQLHelp.getCount(ms,executor.getTransaction(),parameter,boundSql,dialect);
  13. }
  14. return new Paginator(pageBounds.getPage(), pageBounds.getLimit(), count);
  15. }
  16. };

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

  1. public Object call() throws Exception {
  2. Integer count;
  3. Cache cache = ms.getCache();
  4. if(cache != null && ms.isUseCache() && ms.getConfiguration().isCacheEnabled()){
  5. CacheKey cacheKey = executor.createCacheKey(ms,parameter,new PageBounds(),copyFromBoundSql(ms,boundSql,dialect.getCountSQL(), boundSql.getParameterMappings(), boundSql.getParameterObject()));
  6. count = (Integer)cache.getObject(cacheKey);
  7. if(count == null){
  8. count = SQLHelp.getCount(ms,executor.getTransaction(),parameter,boundSql,dialect);
  9. cache.putObject(cacheKey, count);
  10. }
  11. }else{
  12. count = SQLHelp.getCount(ms,executor.getTransaction(),parameter,boundSql,dialect);
  13. }
  14. return new Paginator(pageBounds.getPage(), pageBounds.getLimit(), count);
  15. }
  16. };

代码示例来源:origin: tk.mybatis/mapper-core

  1. Executor keyExecutor = configuration.newExecutor(executor.getTransaction(), ExecutorType.SIMPLE);
  2. List<Object> values = keyExecutor.query(keyStatement, parameter, RowBounds.DEFAULT, Executor.NO_RESULT_HANDLER);
  3. if (values.size() == 0) {

代码示例来源:origin: com.hand.hap.cloud/hap-mybatis-mapper-starter

  1. Executor keyExecutor = configuration.newExecutor(executor.getTransaction(), ExecutorType.SIMPLE);
  2. List<Object> values = keyExecutor.query(keyStatement, parameter, RowBounds.DEFAULT, Executor.NO_RESULT_HANDLER);
  3. if (values.size() == 0) {

代码示例来源:origin: com.hand.hap.cloud/hap-mybatis-mapper-starter

  1. @Override
  2. public Object intercept(Invocation invocation) throws Throwable {
  3. Object target = invocation.getTarget();
  4. if (target instanceof Executor) {
  5. Executor executor = (Executor) target;
  6. MappedStatement statement = (MappedStatement) invocation.getArgs()[0];
  7. Object parameter = invocation.getArgs()[1];
  8. EntityTable table = EntityHelper.getTableByMapper(MapperTemplate.getMapperClassName(statement.getId()));
  9. if(table != null && table.isMultiLanguage()){
  10. Object obj = invocation.proceed();
  11. Connection connection = executor.getTransaction().getConnection();
  12. switch (statement.getSqlCommandType()){
  13. case INSERT:
  14. insertMultiLanguage(table,parameter,connection);
  15. break;
  16. case UPDATE:
  17. updateMultiLanguage(table,parameter,connection);
  18. break;
  19. case DELETE:
  20. proceedDeleteMultiLanguage(table,parameter,connection);
  21. break;
  22. }
  23. return obj;
  24. }
  25. }
  26. return invocation.proceed();
  27. }

相关文章