Package javax.transaction

Examples of javax.transaction.TransactionManager.commit()

33
34
35
36
37
38
39
40
41
42
43
         assert cache.get(fqn, "k").equals("v");
         assert cache.getRoot().getChildren().size() == 1;
         tm.setRollbackOnly();
         try
         {
            tm.commit();
            assert false : "Should have rolled back";
         }
         catch (RollbackException expected)
         {
         }
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
         {
           assert expected.getCause() instanceof RollbackException : "exception wrapped and thrown should be RollbackException. Exception class "+expected.getCause().getClass();
         }
         try
         {
            tm.commit();
            assert false : "Should have rolled back";
         }
         catch (RollbackException expected)
         {
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
         public void run()
         {
            try
            {
               tm.resume(tx);
               tm.commit();
            }
            catch (Exception e)
            {
            }
         }
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
               // notify the reading thread
               readerCanRead.countDown();

               readerDone.await();

               tx.commit();
            }
            catch (AssertionError e)
            {
               writerError = e;
            }
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
               // notify the reading thread
               readerCanRead.countDown();

               readerDone.await();

               tm.commit();
            }
            catch (AssertionError e)
            {
               writerError = e;
            }
View Full Code Here
20
21
22
23
24
25
26
27
28
29
30
      TransactionManager tm = getTransactionManager(cache);
      tm.begin();
      cache.put("/a/b/c", "k", "v");
      cache.startBatch();
      cache.put("/a/b/c", "k2", "v2");
      tm.commit();

      assert "v".equals(cache.get("/a/b/c", "k"));
      assert "v2".equals(cache.get("/a/b/c", "k2"));

      cache.endBatch(false); // should be a no op
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
      assert getOnDifferentThread(cache, "/a/b/c", "k") == null;
      assert getOnDifferentThread(cache, "/a/b/c", "k2") == null;

      try
      {
         tm.commit(); // should have no effect
      }
      catch (Exception e)
      {
         // the TM may barf here ... this is OK.
      }
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
      // basic node manipulation events
      if (tx)
         tm.begin();
      cache1.put(fqn, "k", "v");
      if (tx)
         tm.commit();
      if (tx)
         tm.begin();
      cache1.get(fqn, "k");
      if (tx)
         tm.commit();
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
         tm.commit();
      if (tx)
         tm.begin();
      cache1.get(fqn, "k");
      if (tx)
         tm.commit();
      if (tx)
         tm.begin();
      cache1.put(fqn, "k", "v2");
      if (tx)
         tm.commit();
View Full Code Here
147
148
149
150
151
152
153
154
155
156
157
         tm.commit();
      if (tx)
         tm.begin();
      cache1.put(fqn, "k", "v2");
      if (tx)
         tm.commit();
      if (tx)
         tm.begin();
      cache1.removeNode(fqn);
      if (tx)
         tm.commit();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.