Apache是否支持分布式事务

Question

           IgniteTransactions transactions = ignite.transactions();
           p1.setSalary(500);
           p2_1.setSalary(1500);
           Transaction tx = transactions.txStart(TransactionConcurrency.PESSIMISTIC,TransactionIsolation.SERIALIZABLE);
        
         try {
           cache.put(1L, p1);
           
           cache2.put(1L,p2_1);
           
           tx.commit();
         }catch(Exception e) {
             tx.rollback();
         }

    public void write(Entry<? extends Long, ? extends Person> entry) throws CacheWriterException {
      System.out.println(" +++++++++++  single wirte");
       Long key = entry.getKey();
        Person val = entry.getValue();

        System.out.println(">>> Store write [key=" + key + ", val=" + val + ']');

        try {
            Connection conn = dataSource.getConnection();

            int updated;

            // Try update first. If it does not work, then try insert.
            // Some databases would allow these to be done in one 'upsert' operation.
            try (PreparedStatement st = conn.prepareStatement(
                "update PERSON set orgId = ?, name = ?, salary=?  where id = ?")) {
                st.setLong(1, val.getOrgId());
                st.setString(2, val.getName());
                st.setLong(3, val.getSalary());
                st.setLong(4, val.getId());

                updated = st.executeUpdate();
            }

            // If update failed, try to insert.
            if (updated == 0) {
                try (PreparedStatement st = conn.prepareStatement(
                    "insert into PERSON (id, orgId,name, salary) values (?, ?, ?,?)")) {
                    st.setLong(1, val.getId());
                    st.setLong(2, val.getOrgId());
                    st.setString(3, val.getName());
                    st.setLong(4, val.getSalary());
                    st.executeUpdate();
                }
            }
        }
        catch (SQLException e) {
            throw new CacheWriterException("Failed to write object [key=" + key + ", val=" + val + ']', e);
        }
    
    
}

Answer 1

Ignite确实支持事务处理。但有两件事需要考虑：

1. 您需要将缓存定义为事务性的。默认值为原子，不支持事务
2. 它当前不支持使用SQL的事务。您需要使用键值API

我不确定您在哪里看到过关于Ignite对事务更快的说法，但一般的原则是，通过将所有内容都保存在内存中，Ignite可以比遗留数据库快得多。