Examples of com.sleepycat.je.Transaction.commit()

com.sleepycat.je.Transaction.commit()
End the transaction. If the environment is configured for synchronous commit, the transaction will be committed synchronously to stable storage before the call returns. This means the transaction will exhibit all of the ACID (atomicity, consistency, isolation, and durability) properties.
If the environment is not configured for synchronous commit, the commit will not necessarily have been committed to stable storage before the call returns. This means the transaction will exhibit the ACI (atomicity, consistency, and isolation) properties, but not D (durability); that is, database integrity will be maintained, but it is possible this transaction may be undone during recovery.

All cursors opened within the transaction must be closed before the transaction is committed.

If the method encounters an error, the transaction will have been aborted when the call returns.

After this method has been called, regardless of its return, the {@link Transaction} handle may not be accessed again, with oneexception: the {@code abort} method may be called any number of timesto simplify error handling.
@throws com.sleepycat.je.rep.InsufficientReplicasException if the masterin a replicated environment could not contact a quorum of replicas as determined by the {@link ReplicaAckPolicy}. @throws com.sleepycat.je.rep.InsufficientAcksException if the master ina replicated environment did not receive enough replica acknowledgments, although the commit succeeded locally. @throws com.sleepycat.je.rep.ReplicaWriteException if a write operationwas performed with this transaction, but this node is now a Replica. @throws OperationFailureException if this exception occurred earlier andcaused the transaction to be invalidated. @throws EnvironmentFailureException if an unexpected, internal orenvironment-wide failure occurs. @throws IllegalStateException if the transaction or environment has beenclosed, or cursors associated with the transaction are still open.

            Transaction transaction = entityStore.getEnvironment().beginTransaction(null, null);
            try {
                copyTileSets(transaction);
                DeleteLayer deleteCommand = new DeleteLayer(oldLayerName);
                deleteCommand.call(transaction);
                transaction.commit();
            } catch (RuntimeException e) {
                transaction.abort();
                throw e;
            }
            return null;

View Full Code Here


                        pageStats.addTiles(tilesAdded, tilesPerPage);
                        pageStatsById.putNoReturn(tx, pageStats);
                    }
                }
                tx.commit();
                return null;
            } catch (RuntimeException e) {
                e.printStackTrace();
                tx.abort();
                throw e;

View Full Code Here

                    pageStats.addHitsAndAccessTime(addedHits, lastAccessTimeMinutes,
                            creationTimeMinutes);
                    pageStatsById.putNoReturn(tx, pageStats);
                    allStats.add(pageStats);
                }
                tx.commit();
                return allStats;
            } catch (RuntimeException e) {
                tx.abort();
                throw e;
            }

View Full Code Here

                PageStats pageStats = pageStatsByPageId.get(tx, tilePage.getId(), null);
                if (pageStats != null) {
                    pageStats.setFillFactor(0f);
                    pageStatsById.putNoReturn(tx, pageStats);
                }
                tx.commit();
                return pageStats;
            } catch (Exception e) {
                tx.abort();
                throw e;
            }

View Full Code Here

    
    Transaction txn = null;
    try {
      txn = env.beginTransaction(null, null);
      if (haveUser(txn, publicHash)) {
        txn.commit();
        return false;// User already exists
      }


      DatabaseEntry ph = new DatabaseEntry(publicHash);
      OperationStatus res = db.put(txn, USERS, ph);

View Full Code Here

      if (res != OperationStatus.SUCCESS) {
        log.severe("Could not add publicKey: " + res.toString());
        txn.abort();
        return false;
      }
      txn.commit();
      return true;
    } catch (DatabaseException e) {
      severe("Exception while adding user", e);
      try {
        if (txn != null) {

View Full Code Here

        } else {
          return false;
        }
      } finally {
        cursor.close();
        txn.commit();
      }
    } catch (DatabaseException e) {
      severe("Exception while deleting user", e);
      return false;
    }

View Full Code Here

      txn = env.beginTransaction(null, null);
      DatabaseEntry noncesKey = makeNoncesKey(publicKey);
      DatabaseEntry nonceValue = new DatabaseEntry(nonce.toToken());
      OperationStatus status = db.getSearchBoth(txn, noncesKey, nonceValue, null);
      if (status == OperationStatus.SUCCESS) {
        txn.commit();
        return false;// Nonce already used
      }
      status = db.put(txn, noncesKey, nonceValue);
      if (status == OperationStatus.SUCCESS) {
        txn.commit();

View Full Code Here

        txn.commit();
        return false;// Nonce already used
      }
      status = db.put(txn, noncesKey, nonceValue);
      if (status == OperationStatus.SUCCESS) {
        txn.commit();
        return true;
      } else {
        txn.abort();
        return false;
      }

View Full Code Here

    Transaction txn = null;
    try {
      txn = env.beginTransaction(null, null);
      OperationStatus lookupExists = db.getSearchBoth(txn, makeStoresKey(user), new DatabaseEntry(key), null);
      if (OperationStatus.SUCCESS != lookupExists){
        txn.commit();
        return null;
      }
      Collection<RevValue> collection = new ArrayList<RevValue>();
      Cursor cursor = db.openCursor(txn, null);
      try {

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.