apache shardingsphere 事务的实现方法

这篇文章主要讲解了“apache shardingsphere 事务的实现方法”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“apache shardingsphere 事务的实现方法”吧！

• 本地事务

• TransactionTypeHolder.set(TransactionType.LOCAL)

• connection.setAutoCommit(true)

• statement.executeUpdate("update user set name='kk' where id = 1");

• connection.commit() or commit.rollback();

• 在Threadlocal 里放入事务类型,默认Local ，所以这句可以省略

• 在ShardingConnection 所有 缓存的真实Connection上执行setAutoCommit(true)

• 将这个操作 缓存在 ShardingConnection 的 jdbcMethodInvocations 中

• 在执行过程中，如果需要创建新的真实Connection,则同样会在新的Connection上执行 setAutoCommit(true)

• 在新连接中执行 setAutoCommit(true) 是通过 jdbcMethodInvocations 实现

• 新的连接同样会被缓存起来

• 提交或者回滚 也会在ShardingConnection 所有 缓存的真实Connection上执行

•         DataSource dataSource = ShardingDataSourceFactory.createDataSource(datasourceMap, shardingRuleConfig, pros);
          Connection connection = null;
          try {
              connection = dataSource.getConnection();
              connection.setAutoCommit(false);
              Statement statement = connection.createStatement();
              statement.executeUpdate("update user set name  = 'meichaofeng' where ex_id = 201");
              connection.commit();
              statement.close();
              connection.close();
          } catch (SQLException e) {
              try {
                  connection.rollback();
              } catch (SQLException e1) {
                  e1.printStackTrace();
              }
          }

感谢各位的阅读，以上就是“apache shardingsphere 事务的实现方法”的内容了，经过本文的学习后，相信大家对apache shardingsphere 事务的实现方法这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是亿速云，小编将为大家推送更多相关知识点的文章，欢迎关注！