com.google.inject.persist.Transactional类的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(6.7k)|赞(0)|评价(0)|浏览(154)

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

Transactional介绍

暂无

代码示例

代码示例来源:origin: org.eclipse.che.core/che-core-api-ssh

@Transactional
protected void doCreate(SshPairImpl entity) {
 EntityManager manager = managerProvider.get();
 manager.persist(entity);
 manager.flush();
}

代码示例来源:origin: org.eclipse.che.multiuser/che-multiuser-api-resource

@Transactional
protected void doRemove(String id) {
 final EntityManager manager = managerProvider.get();
 final FreeResourcesLimitImpl resourcesLimit = manager.find(FreeResourcesLimitImpl.class, id);
 if (resourcesLimit != null) {
  manager.remove(resourcesLimit);
  manager.flush();
 }
}

代码示例来源:origin: org.eclipse.che.multiuser/che-multiuser-permission-workspace

@Transactional
protected WorkerImpl doGet(String userId, String instanceId) {
 return managerProvider
   .get()
   .createNamedQuery("Worker.getByUserAndWorkspaceId", WorkerImpl.class)
   .setParameter("workspaceId", instanceId)
   .setParameter("userId", userId)
   .getSingleResult();
}

代码示例来源:origin: salesforce/Argus

@Transactional
private boolean _isSchedulingServiceEnabled() {
  synchronized (_serviceManagementRecordService) {
    return _serviceManagementRecordService.isServiceEnabled(Service.SCHEDULING);
  }
}

代码示例来源:origin: timolson/cointrader

@Transactional
public void evict(EntityBase entity) {
  try {
    // entityManager.get().(entity);
    synchronized (entity) {
      entityManager.get().detach(entity);
    }
  } catch (Error | Exception ex) {
    throw ex;
  }
  // TODO Auto-generated method stub
}

代码示例来源:origin: salesforce/Argus

@Transactional
private boolean _isSchedulingServiceEnabled() {
  synchronized (_serviceManagementRecordService) {
    return _serviceManagementRecordService.isServiceEnabled(Service.SCHEDULING);
  }
}

代码示例来源:origin: salesforce/Argus

@Transactional
private boolean _isSchedulingServiceEnabled() {
  synchronized (_serviceManagementRecordService) {
    return _serviceManagementRecordService.isServiceEnabled(Service.SCHEDULING);
  }
}

代码示例来源:origin: com.salesforce.argus/argus-core

@Transactional
private boolean _isSchedulingServiceEnabled() {
  synchronized (_serviceManagementRecordService) {
    return _serviceManagementRecordService.isServiceEnabled(Service.SCHEDULING);
  }
}

代码示例来源:origin: com.salesforce.argus/argus-core

@Transactional
private boolean _isSchedulingServiceEnabled() {
  synchronized (_serviceManagementRecordService) {
    return _serviceManagementRecordService.isServiceEnabled(Service.SCHEDULING);
  }
}

代码示例来源:origin: com.salesforce.argus/argus-core

@Transactional
private boolean _isSchedulingServiceEnabled() {
  synchronized (_serviceManagementRecordService) {
    return _serviceManagementRecordService.isServiceEnabled(Service.SCHEDULING);
  }
}

代码示例来源:origin: com.salesforce.argus/argus-core

@Transactional
private boolean _isSchedulingServiceEnabled() {
  synchronized (_serviceManagementRecordService) {
    return _serviceManagementRecordService.isServiceEnabled(Service.SCHEDULING);
  }
}

代码示例来源:origin: timolson/cointrader

@Override
@Transactional
public boolean contains(EntityBase entity) {
  try {
    return entityManager.get().contains(entity);
  } catch (Error | Exception ex) {
    log.error("Unable to perform request in " + this.getClass().getSimpleName() + ":contains, full stack trace follows:", ex);
    throw ex;
  }
}

代码示例来源:origin: timolson/cointrader

@Transactional
public <T> T getReference(Class<T> resultType, UUID id) {
  try {
    return entityManager.get().getReference(resultType, id);
  } catch (Error | Exception ex) {
    log.error("Unable to perform request in " + this.getClass().getSimpleName() + ":getReference, full stack trace follows:", ex);
    throw ex;
  }
}

代码示例来源:origin: salesforce/Argus

@Override
@Transactional
public void deleteExpiredHistory() {
  requireNotDisposed();
  try {
    int deletedCount = History.deleteExpiredHistory(emf.get());
    _logger.info("Deleted {} expired job history records.", deletedCount);
  } catch (Exception ex) {
    _logger.warn("Couldn't delete expired job history : {}", ex.getMessage());
  }
}

代码示例来源:origin: salesforce/Argus

@Override
@Transactional
public synchronized void startAlertScheduling() {
  requireNotDisposed();
  if (_alertSchedulingThread != null && _alertSchedulingThread.isAlive()) {
    _logger.info("Request to start alert scheduler aborted as it is already running.");
  } else {
    _logger.info("Starting alert scheduling thread.");
    _alertSchedulingThread = new SchedulingThread("schedule-alerts", LockType.ALERT_SCHEDULING);
    _alertSchedulingThread.start();
    _logger.info("Alert scheduling thread started.");
  }
}

代码示例来源:origin: salesforce/Argus

@Override
@Transactional
public synchronized void startAlertScheduling() {
  requireNotDisposed();
  if (_alertSchedulingThread != null && _alertSchedulingThread.isAlive()) {
    _logger.info("Request to start alert scheduling aborted as it is already running.");
  } else {
    _logger.info("Starting alert scheduling thread.");
    _alertSchedulingThread = new SchedulingThread("schedule-alerts", LockType.ALERT_SCHEDULING);
    _alertSchedulingThread.start();
    _logger.info("Alert scheduling thread started.");
  }
}

代码示例来源:origin: salesforce/Argus

@Override
@Transactional
public void deleteExpiredAudits() {
  requireNotDisposed();
  try {
    int deletedCount = Audit.deleteExpired(emf.get());
    _logger.info("Deleted {} expired audit entries.", deletedCount);
  } catch (Exception ex) {
    _logger.warn("Couldn't delete expired audits : {}", ex.getMessage());
  }
}

代码示例来源:origin: salesforce/Argus

@Override
@Transactional
public int deleteExpiredAuthCodesByUserName(Timestamp currentTime,String userName) {
  requireNotDisposed();
  _logger.debug("Deleting expired records by currentTime: {} and userName: {}", currentTime,userName);
  int result = OAuthAuthorizationCode.deleteByTimeStamp(emf.get(), currentTime,userName);
  _logger.debug("Query for deleting records by currentTime:{} and userName: {} resulted in : {} rows deleted",currentTime, userName,result);
  return result;
}

代码示例来源:origin: com.walterjwhite.infrastructure.datastore.modules/google-guice-persist-criteria-builder

@Transactional(ignore = {NoResultException.class})
public EntityReference findOrCreate(AbstractEntity entity) {
 try {
  return (findOrCreateByEntityTypeAndId(entity.getClass().getName(), entity.getId()));
 } catch (ClassNotFoundException e) {
  throw (new IllegalStateException("Application is mis-configured", e));
 }
}

代码示例来源:origin: com.salesforce.argus/argus-core

@Override
@Transactional
public int deleteExpiredAuthCodesByUserName(Timestamp currentTime,String userName) {
  requireNotDisposed();
  _logger.debug("Deleting expired records by currentTime: {} and userName: {}", currentTime,userName);
  int result = OAuthAuthorizationCode.deleteByTimeStamp(emf.get(), currentTime,userName);
  _logger.debug("Query for deleting records by currentTime:{} and userName: {} resulted in : {} rows deleted",currentTime, userName,result);
  return result;
}

相关文章