com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.<init>()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(8.6k)|赞(0)|评价(0)|浏览(124)

本文整理了Java中com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.<init>()方法的一些代码示例，展示了XAResourceRecord.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。XAResourceRecord.<init>()方法的具体详情如下：
包路径：com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord
类名称：XAResourceRecord
方法名：<init>

XAResourceRecord.<init>介绍

[英]The params represent specific parameters we need to recreate the connection to the database in the event of a failure. If they're not set then recovery is out of our control. Could also use it to pass other information, such as the readonly flag.
[中]参数表示在发生故障时重新创建与数据库的连接所需的特定参数。如果它们没有被设定，那么复苏就失去了我们的控制。还可以使用它传递其他信息，例如只读标志。

代码示例

代码示例来源：origin: jboss.jbossts/jbossjts

  1. public static AbstractRecord create()
  2. {
  3.   return new XAResourceRecord();
  4. }

代码示例来源：origin: org.jboss.jbossts/jbossjta

  1. /**
  2.  * Attempt to create an AbstractRecord wrapping the given XAResource. Return null if this fails, or
  3.  * is diallowed by the current configuration of multiple last resource behaviour.
  4.  *
  5.  * @param xaRes
  6.  * @param params
  7.  * @param xid
  8.  * @return
  9.  */
  10. private AbstractRecord createRecord(XAResource xaRes, Object[] params, Xid xid)
  11. {
  12.   final AbstractRecord record;
  13.   if ((xaRes instanceof LastResourceCommitOptimisation)
  14.       || ((LAST_RESOURCE_OPTIMISATION_INTERFACE != null) && LAST_RESOURCE_OPTIMISATION_INTERFACE
  15.       .isInstance(xaRes)))
  16.   {
  17.     record = new LastResourceRecord(new XAOnePhaseResource(xaRes, xid, params));
  18.   }
  19.   else
  20.   {
  21.     record = new XAResourceRecord(this, xaRes, xid, params);
  22.   }
  23.   return record;
  24. }

代码示例来源：origin: jboss.jbossts/jbossjts

  1. /**
  2.  * Attempt to create an AbstractRecord wrapping the given XAResource. Return null if this fails, or
  3.  * is diallowed by the current configuration of multiple last resource behaviour.
  4.  *
  5.  * @param xaRes
  6.  * @param params
  7.  * @param xid
  8.  * @return
  9.  */
  10. private AbstractRecord createRecord(XAResource xaRes, Object[] params, Xid xid)
  11. {
  12.   final AbstractRecord record;
  13.   if ((xaRes instanceof LastResourceCommitOptimisation)
  14.       || ((LAST_RESOURCE_OPTIMISATION_INTERFACE != null) && LAST_RESOURCE_OPTIMISATION_INTERFACE
  15.       .isInstance(xaRes)))
  16.   {
  17.     record = new LastResourceRecord(new XAOnePhaseResource(xaRes, xid, params));
  18.   }
  19.   else
  20.   {
  21.     record = new XAResourceRecord(this, xaRes, xid, params);
  22.   }
  23.   return record;
  24. }

代码示例来源：origin: org.jboss.jbossts.jta/narayana-jta

  1. return new XAResourceRecord(this, xaRes, xid, params);

代码示例来源：origin: org.jboss.narayana.jta/jta

  1. return new XAResourceRecord(this, xaRes, xid, params);

代码示例来源：origin: jbosstm/narayana

  1. return new XAResourceRecord(this, xaRes, xid, params);

代码示例来源：origin: jbosstm/narayana

  1. return new XAResourceRecord(this, xaRes, xid, params);

代码示例来源：origin: org.jboss.narayana.jts/narayana-jts-idlj

  1. return new XAResourceRecord(this, xaRes, xid, params);

代码示例来源：origin: jbosstm/narayana

  1. SubordinateAtomicAction saa = new SubordinateAtomicAction();
  2. saa.add(new XAResourceRecord(null, new XAResource() {
  3.   @Override
  4.   public void commit(Xid xid, boolean b) throws XAException {

代码示例来源：origin: jbosstm/narayana

  1. XAResourceRecord xares = new XAResourceRecord(tx, res, tx.getTxId(), null);
  2. xares = new XAResourceRecord(tx, new FailureXAResource(FailLocation.end, FailType.normal), tx.getTxId(), null);
  3. xares = new XAResourceRecord(tx, new FailureXAResource(FailLocation.end, FailType.timeout), tx.getTxId(), null);
  4. xares = new XAResourceRecord(tx, new FailureXAResource(FailLocation.end, FailType.XA_RBCOMMFAIL), tx.getTxId(), null);
  5. xares = new XAResourceRecord(tx, new FailureXAResource(FailLocation.commit, FailType.heurcom), tx.getTxId(), null);
  6. xares = new XAResourceRecord(tx, new FailureXAResource(FailLocation.commit, FailType.timeout), tx.getTxId(), null);
  7. xares = new XAResourceRecord(tx, new FailureXAResource(FailLocation.commit, FailType.nota), tx.getTxId(), null);
  8. xares = new XAResourceRecord(tx, new FailureXAResource(FailLocation.commit, FailType.inval), tx.getTxId(), null);
  9. xares = new XAResourceRecord(tx, new FailureXAResource(FailLocation.commit, FailType.proto), tx.getTxId(), null);
  10. xares = new XAResourceRecord(tx, new FailureXAResource(FailLocation.commit, FailType.rmfail), tx.getTxId(), null);

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2. public void testValid2PC () throws Exception
  3. {
  4.   TransactionImple tx = new TransactionImple(0);
  5.   DummyXA res = new DummyXA(false);
  6.   XAResourceRecord xares = new XAResourceRecord(tx, res, tx.getTxId(), null);
  7.   
  8.   assertEquals(xares.topLevelPrepare(), TwoPhaseOutcome.PREPARE_OK);
  9.   assertEquals(xares.topLevelCommit(), TwoPhaseOutcome.FINISH_OK);
  10. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2. public void testRecover () throws Exception
  3. {
  4.   ArrayList<String> r = new ArrayList<String>();
  5.   TransactionImple tx = new TransactionImple(0);
  6.   
  7.   assertTrue(tx.enlistResource(new RecoveryXAResource()));
  8.   
  9.   assertEquals(tx.doPrepare(), TwoPhaseOutcome.PREPARE_OK);
  10.   
  11.   r.add("com.hp.mwtests.ts.jta.recovery.DummyXARecoveryResource");
  12.   jtaPropertyManager.getJTAEnvironmentBean().setXaResourceRecoveryClassNames(r);
  13.   
  14.   XARecoveryModule xarm = new XARecoveryModule();
  15.   assertNull(xarm.getNewXAResource( new XAResourceRecord(null, null, new XidImple(), null) ));
  16.   
  17.   for (int i = 0; i < 11; i++)
  18.   {
  19.     xarm.periodicWorkFirstPass();
  20.     xarm.periodicWorkSecondPass();
  21.   }
  22.   
  23.   assertTrue(xarm.getNewXAResource(  new XAResourceRecord(null, null, new XidImple(new Uid()), null) ) == null);
  24.   
  25.   assertNull(xarm.getNewXAResource( new XAResourceRecord(null, null, new XidImple(), null) ));
  26. }

代码示例来源：origin: jbosstm/narayana

  1. assertEquals(AddOutcome.AR_ADDED, aa.add(new XAResourceRecord(null, new XARRTestResource(), new XidImple(aa), null)));

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2.   public void testNested () throws Exception
  3.   {
  4.     XAResourceRecord xares = new XAResourceRecord();
  5.     
  6.     assertEquals(xares.nestedOnePhaseCommit(), TwoPhaseOutcome.FINISH_ERROR);
  7.     assertEquals(xares.nestedPrepare(), TwoPhaseOutcome.PREPARE_OK);
  8.     assertEquals(xares.nestedCommit(), TwoPhaseOutcome.FINISH_OK);
  9.     assertEquals(xares.nestedAbort(), TwoPhaseOutcome.FINISH_OK);
  10.   }
  11. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2. public void testCommitFailure () throws Exception
  3. {
  4.   FailureXAResource fxa = new FailureXAResource(FailureXAResource.FailLocation.commit);
  5.   TransactionImple tx = new TransactionImple(0);
  6.   XAResourceRecord xares = new XAResourceRecord(tx, fxa, tx.getTxId(), null);
  7.   
  8.   assertEquals(xares.topLevelPrepare(), TwoPhaseOutcome.PREPARE_OK);
  9.   assertEquals(xares.topLevelCommit(), TwoPhaseOutcome.HEURISTIC_MIXED);
  10.   assertTrue(xares.forgetHeuristic());
  11. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2. public void test () throws Exception
  3. {
  4.   XAResourceRecord xares = new XAResourceRecord();
  5.   Object obj = new Object();
  6.   
  7.   xares.setValue(obj);
  8.   
  9.   assertTrue(xares.value() != obj);
  10.   
  11.   DummyRecoverableXAConnection rc = new DummyRecoverableXAConnection();
  12.   Object[] params = new Object[1];
  13.   
  14.   params[XAResourceRecord.XACONNECTION] = rc;
  15.   
  16.   xares = new XAResourceRecord(new TransactionImple(0), new DummyXA(false), new XidImple(new Uid()), params);
  17.   
  18.   assertTrue(xares.type() != null);
  19.   
  20.   xares.merge(xares);
  21.   xares.replace(xares);
  22.   
  23.   assertTrue(xares.toString() != null);
  24. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2. public void testRollbackFailure () throws Exception
  3. {
  4.   FailureXAResource fxa = new FailureXAResource(FailureXAResource.FailLocation.rollback);
  5.   TransactionImple tx = new TransactionImple(0);
  6.   XAResourceRecord xares = new XAResourceRecord(tx, fxa, tx.getTxId(), null);
  7.   
  8.   assertEquals(xares.topLevelPrepare(), TwoPhaseOutcome.PREPARE_OK);
  9.   assertEquals(xares.topLevelAbort(), TwoPhaseOutcome.HEURISTIC_MIXED);
  10.   assertTrue(xares.forgetHeuristic());
  11. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2. public void testInvalid () throws Exception
  3. {
  4.   XAResourceRecord xares = new XAResourceRecord();
  5.   
  6.   assertEquals(xares.getXid(), null);
  7.   assertEquals(xares.value(), null);
  8.   assertEquals(xares.topLevelOnePhaseCommit(), TwoPhaseOutcome.ONE_PHASE_ERROR);
  9.   assertEquals(xares.topLevelPrepare(), TwoPhaseOutcome.PREPARE_NOTOK);
  10.   assertEquals(xares.topLevelAbort(), TwoPhaseOutcome.FINISH_ERROR);
  11.   assertEquals(xares.topLevelCommit(), TwoPhaseOutcome.FINISH_ERROR);
  12. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2. public void testReadonly () throws Exception
  3. {
  4.   XAResourceRecord xares;
  5.   
  6.   DummyRecoverableXAConnection rc = new DummyRecoverableXAConnection();
  7.   Object[] params = new Object[1];
  8.   
  9.   params[XAResourceRecord.XACONNECTION] = rc;
  10.   
  11.   xares = new XAResourceRecord(new TransactionImple(0), new TestResource(true), new XidImple(new Uid()), params);
  12.   
  13.   assertEquals(xares.topLevelCommit(), TwoPhaseOutcome.NOT_PREPARED);
  14.   assertEquals(xares.topLevelPrepare(), TwoPhaseOutcome.PREPARE_READONLY);
  15. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2. public void testPackUnpack () throws Exception
  3. {
  4.   XAResourceRecord xares;      
  5.   DummyRecoverableXAConnection rc = new DummyRecoverableXAConnection();
  6.   Object[] params = new Object[1];
  7.   
  8.   params[XAResourceRecord.XACONNECTION] = rc;
  9.   
  10.   xares = new XAResourceRecord(new TransactionImple(0), new DummyXA(false), new XidImple(new Uid()), params);
  11.   
  12.   OutputObjectState os = new OutputObjectState();
  13.   
  14.   assertTrue(xares.save_state(os, ObjectType.ANDPERSISTENT));
  15.   
  16.   InputObjectState is = new InputObjectState(os);
  17.   
  18.   assertTrue(xares.restore_state(is, ObjectType.ANDPERSISTENT));
  19.   
  20.   xares = new XAResourceRecord(new TransactionImple(0), new DummyXA(false), new XidImple(new Uid()), null);
  21.   
  22.   os = new OutputObjectState();
  23.   
  24.   assertTrue(xares.save_state(os, ObjectType.ANDPERSISTENT));
  25.   
  26.   is = new InputObjectState(os);
  27.   
  28.   assertTrue(xares.restore_state(is, ObjectType.ANDPERSISTENT));
  29. }

内容来源于网络，如有侵权，请联系作者删除！

XAResourceRecord

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    XAResourceRecord类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com