本文整理了Java中com.google.inject.persist.Transactional
类的一些代码示例,展示了Transactional
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Transactional
类的具体详情如下:
包路径:com.google.inject.persist.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;
}
内容来源于网络,如有侵权,请联系作者删除!