本文整理了Java中org.springframework.transaction.annotation.Transactional类的一些代码示例，展示了Transactional类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Transactional类的具体详情如下：
包路径：org.springframework.transaction.annotation.Transactional
类名称：Transactional

Transactional介绍

暂无

代码示例

代码示例来源：origin: shuzheng/zheng

/**
* PayMchService实现
* Created by shuzheng on 2017/3/29.
*/
@Service
@Transactional
@BaseService
public class PayMchServiceImpl extends BaseServiceImpl<PayMchMapper, PayMch, PayMchExample> implements PayMchService {

  private static final Logger log = LoggerFactory.getLogger(PayMchServiceImpl.class);

  @Autowired
  PayMchMapper payMchMapper;

}

代码示例来源：origin: kaaproject/kaa

@Repository("propertiesFacade")
@Transactional("admin")
public class PropertiesFacade {
 @Autowired
 private SessionFactory adminSessionFactory;

代码示例来源：origin: AxonFramework/AxonFramework

@ContextConfiguration(classes = GenericJpaRepositoryIntegrationTest.TestContext.class)
@TestPropertySource("classpath:hsqldb.database.properties")
@Transactional
public class GenericJpaRepositoryIntegrationTest implements EventMessageHandler {
  @Autowired
  @Qualifier("simpleRepository")
  private GenericJpaRepository<JpaAggregate> repository;
  @Autowired
  private EventBus eventBus;
  @PersistenceContext
  private EntityManager entityManager;
  private SubscribingEventProcessor eventProcessor;

代码示例来源：origin: mitreid-connect/OpenID-Connect-Java-Spring-Server

@Override
@Transactional(value="defaultTransactionManager")
public Collection<ApprovedSite> getByUserId(String userId) {
  TypedQuery<ApprovedSite> query = manager.createNamedQuery(ApprovedSite.QUERY_BY_USER_ID, ApprovedSite.class);
  query.setParameter(ApprovedSite.PARAM_USER_ID, userId);
  return query.getResultList();
}

代码示例来源：origin: zstackio/zstack

@Transactional
private void deleteConsoleProxyByManagementNode(final String managementHostName) {
  String sql = "delete from ConsoleProxyVO q where q.proxyHostname = :managementHostName";
  Query q = dbf.getEntityManager().createQuery(sql);
  q.setParameter("managementHostName", managementHostName);
  q.executeUpdate();
}

代码示例来源：origin: spring-projects/spring-framework

@Transactional
interface ITestBean3 {
  int getAge();
  void setAge(int age);
  String getName();
  void setName(String name);
}

代码示例来源：origin: spring-projects/spring-data-examples

@Override
@Transactional
public Customer save(Customer customer) {
  // Is new?
  if (customer.getId() == null) {
    em.persist(customer);
    return customer;
  } else {
    return em.merge(customer);
  }
}

代码示例来源：origin: mitreid-connect/OpenID-Connect-Java-Spring-Server

@Override
@Transactional(value="defaultTransactionManager")
public void clearDuplicateAccessTokens() {
  Query query = manager.createQuery("select a.jwt, count(1) as c from OAuth2AccessTokenEntity a GROUP BY a.jwt HAVING count(1) > 1");
  @SuppressWarnings("unchecked")
  List<Object[]> resultList = query.getResultList();
  List<JWT> values = new ArrayList<>();
  for (Object[] r : resultList) {
    logger.warn("Found duplicate access tokens: {}, {}", ((JWT)r[0]).serialize(), r[1]);
    values.add((JWT) r[0]);
  }
  if (values.size() > 0) {
    CriteriaBuilder cb = manager.getCriteriaBuilder();
    CriteriaDelete<OAuth2AccessTokenEntity> criteriaDelete = cb.createCriteriaDelete(OAuth2AccessTokenEntity.class);
    Root<OAuth2AccessTokenEntity> root = criteriaDelete.from(OAuth2AccessTokenEntity.class);
    criteriaDelete.where(root.get("jwt").in(values));
    int result = manager.createQuery(criteriaDelete).executeUpdate();
    logger.warn("Deleted {} duplicate access tokens", result);
  }
}

代码示例来源：origin: zstackio/zstack

@Transactional(readOnly = true)
private Timestamp getCurrentSqlDate() {
  Query query = dbf.getEntityManager().createNativeQuery("select current_timestamp()");
  return (Timestamp) query.getSingleResult();
}

代码示例来源：origin: mitreid-connect/OpenID-Connect-Java-Spring-Server

@Override
@Transactional(value="defaultTransactionManager")
public Collection<BlacklistedSite> getAll() {
  TypedQuery<BlacklistedSite> query = manager.createNamedQuery(BlacklistedSite.QUERY_ALL, BlacklistedSite.class);
  return query.getResultList();
}

代码示例来源：origin: BroadleafCommerce/BroadleafCommerce

@Override
@Transactional(value = "blTransactionManager", propagation = Propagation.REQUIRES_NEW)
public IdGeneration findNextId(String idType, Long batchSize) throws OptimisticLockException, Exception {
  IdGeneration response;
  Query query = em.createNamedQuery("BC_FIND_NEXT_ID");
  query.setParameter("idType", idType);
  try {
    IdGeneration idGeneration =  (IdGeneration) query.getSingleResult();
    response =  (IdGeneration) entityConfiguration.createEntityInstance("org.broadleafcommerce.profile.core.domain.IdGeneration");
    response.setBatchSize(idGeneration.getBatchSize());
    em.merge(idGeneration);
    em.flush();
  } catch (NoResultException nre) {

代码示例来源：origin: spring-projects/spring-data-jpa

@Transactional
@Override
public void flush() {
  em.flush();
}

代码示例来源：origin: spring-projects/spring-data-jpa

@Transactional
@Override
public void delete(T entity) {
  Assert.notNull(entity, "The entity must not be null!");
  em.remove(em.contains(entity) ? entity : em.merge(entity));
}

代码示例来源：origin: spring-projects/spring-integration-samples

@Transactional
public void remove() {
  if (this.entityManager == null) {
    this.entityManager = entityManager();
  }
  if (this.entityManager.contains(this)) {
    this.entityManager.remove(this);
  } else {
    LoanShark attached = this.entityManager.find(this.getClass(), this.id);
    this.entityManager.remove(attached);
  }
}

代码示例来源：origin: spring-projects/spring-data-jpa

@Transactional
@Override
public void deleteAllInBatch() {
  em.createQuery(getDeleteAllQueryString()).executeUpdate();
}

代码示例来源：origin: zstackio/zstack

@Override
  @Transactional
  public List<EipVO> call() {
    String sql = "select eip from EipVO eip, VmNicVO nic, UsedIpVO ip where nic.uuid = ip.vmNicUuid and ip.l3NetworkUuid = :l3uuid and nic.uuid = eip.vmNicUuid and nic.uuid = :nicUuid";
    Query q = dbf.getEntityManager().createQuery(sql);
    q.setParameter("l3uuid", l3.getUuid());
    q.setParameter("nicUuid", nic.getUuid());
    return q.getResultList();
  }
}.call();

代码示例来源：origin: spring-projects/spring-integration-samples

@Transactional
public LoanShark merge() {
  if (this.entityManager == null) {
    this.entityManager = entityManager();
  }
  LoanShark merged = this.entityManager.merge(this);
  this.entityManager.flush();
  return merged;
}

代码示例来源：origin: spring-projects/spring-integration-samples

@Transactional
public void persist() {
  if (this.entityManager == null) {
    this.entityManager = entityManager();
  }
  this.entityManager.persist(this);
}

代码示例来源：origin: BroadleafCommerce/BroadleafCommerce

@Override
@Transactional("blTransactionManager")
public OrderItem save(final OrderItem orderItem) {
  return em.merge(orderItem);
}

代码示例来源：origin: spring-projects/spring-batch

@Test
  @Transactional
  public void shouldExecuteParameterizedQuery() throws Exception {

    String sqlQuery = "select * from T_FOOS where value >= :limit";

    jpaQueryProvider.setSqlQuery(sqlQuery);
    jpaQueryProvider.afterPropertiesSet();
    jpaQueryProvider.setEntityManager(entityManagerFactory.createEntityManager());

    Query query = jpaQueryProvider.createQuery();
    query.setParameter("limit", 3);

    List<Foo> expectedFoos = new ArrayList<>();

    expectedFoos.add(new Foo(3, "bar3", 3));
    expectedFoos.add(new Foo(4, "bar4", 4));
    expectedFoos.add(new Foo(5, "bar5", 5));

    @SuppressWarnings("unchecked")
    List<Foo> actualFoos = query.getResultList();

    assertEquals(actualFoos, expectedFoos);
  }
}