Examples of org.springframework.transaction.support.TransactionOperations.execute()

org.springframework.transaction.support.TransactionOperations.execute()
Execute the action specified by the given callback object within a transaction.
Allows for returning a result object created within the transaction, that is, a domain object or a collection of domain objects. A RuntimeException thrown by the callback is treated as a fatal exception that enforces a rollback. Such an exception gets propagated to the caller of the template. @param action the callback object that specifies the transactional action @return a result object returned by the callback, or null if none @throws TransactionException in case of initialization, rollback, or system errors @throws RuntimeException if thrown by the TransactionCallback

    //and
    final TransactionOperations tx = new TransactionTemplate(
        new DataSourceTransactionManager(dataSource));


    //when
    final List<User> users = tx.execute(new TransactionCallback<List<User>>() {
      @Override
      public List<User> doInTransaction(TransactionStatus status) {
        final User user = new User("john", new Date(), 0, false);
        userRepository.save(user);
        return userRepository.findAll();

View Full Code Here

    /**
     * Retrieves a ClusterMutex in a new TX
     */
    protected ClusterMutex getClusterMutexInternal(final String mutexName) {
        final TransactionOperations transactionOperations = this.getTransactionOperations();
        return transactionOperations.execute(new TransactionCallback<ClusterMutex>() {
            @Override
            public ClusterMutex doInTransaction(TransactionStatus status) {
                final CacheKey key = CacheKey.build(CLUSTER_MUTEX_SOURCE, mutexName);
                ClusterMutex clusterMutex = entityManagerCache.get(PERSISTENCE_UNIT_NAME, key);
                if (clusterMutex != null) {

View Full Code Here

                    //into a circular dependency loop from JPA to Ehcache to jGroups and back to JPA
                    final DataSource ds = new SingleConnectionDataSource(con, true);
                    final PlatformTransactionManager ptm = new DataSourceTransactionManager(ds);
                    final TransactionOperations to = new TransactionTemplate(ptm);
                    
                    to.execute(new TransactionCallbackWithoutResult() {
                        @Override
                        protected void doInTransactionWithoutResult(TransactionStatus status) {
                            logger.info("Creating jGroups auth token");
                            final String authToken = RandomTokenGenerator.INSTANCE.generateRandomToken(authTokenLength);

View Full Code Here

        
        final CriteriaQuery<T> criteriaQuery = builder.apply(criteriaBuilder);
        
        //Do in TX so the EM gets closed correctly
        final TransactionOperations transactionOperations = this.getTransactionOperations();
        transactionOperations.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus status) {
                entityManager.createQuery(criteriaQuery); //pre-compile critera query to avoid race conditions when setting aliases
            }
        });

View Full Code Here

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.