org.hibernate.Query.setLockMode()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(4.9k)|赞(0)|评价(0)|浏览(325)

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

Query.setLockMode介绍

[英]Set the lockmode for the objects idententified by the given alias that appears in the FROM clause.
[中]

代码示例

代码示例来源:origin: hibernate/hibernate-orm

  1. Query q = s.createQuery("from Foo foo, Bar bar");
  2. if ( supportsLockingNullableSideOfJoin( getDialect() ) ) {
  3. q.setLockMode("bar", LockMode.UPGRADE);
  4. assertTrue( s.getCurrentLockMode(b)==LockMode.NONE );
  5. q = s.createQuery("from Foo foo");
  6. q.setLockMode( "foo", LockMode.READ );
  7. q.list();
  8. assertTrue( s.getCurrentLockMode( b ) == LockMode.READ );
  9. q = s.createQuery("from Foo foo, Bar bar, Bar bar2");
  10. if ( supportsLockingNullableSideOfJoin( getDialect() ) ) {
  11. q.setLockMode("bar", LockMode.UPGRADE);
  12. q.setLockMode("bar2", LockMode.READ);
  13. result = (Object[]) q.list().get(0);
  14. if ( supportsLockingNullableSideOfJoin( getDialect() ) ) {

代码示例来源:origin: ezbz/projectx

  1. @Override
  2. public Query setLockMode(final String alias, final LockMode lockMode) {
  3. return query.setLockMode(alias, lockMode);
  4. }

代码示例来源:origin: riotfamily/riot

  1. public TypedQuery<T> setLockMode(String alias, LockMode lockMode) {
  2. query.setLockMode(alias, lockMode);
  3. return this;
  4. }

代码示例来源:origin: com.github.cafdataprocessing/corepolicy-hibernate

  1. @Override
  2. public Query setLockMode(String s, LockMode lockMode) {
  3. return query.setLockMode(s, lockMode);
  4. }

代码示例来源:origin: org.wso2.bpel/ode-dao-hibernate

  1. public boolean lockPremieMessages() {
  2. try {
  3. return getSession().getNamedQuery(HCorrelatorMessage.SELECT_CORMESSAGE_BY_MEX).setLockMode("m", LockMode.UPGRADE).setParameter("mex", _hself).list().size() > 0;
  4. } catch (LockAcquisitionException e) {
  5. throw new Scheduler.JobProcessorException(e, true);
  6. }
  7. }

代码示例来源:origin: youseries/uflo

  1. @SuppressWarnings("unchecked")
  2. public Long execute(Context context) {
  3. long nextId=0;
  4. Session session=context.getSession();
  5. List<ContextProperty> list=session.createQuery("from "+ContextProperty.class.getName()+" as p where p.key=:key").setString("key", ID_KEY).setLockMode("p", LockMode.PESSIMISTIC_WRITE).list();
  6. if(list.size()>0){
  7. ContextProperty prop=list.get(0);
  8. nextId=Long.valueOf(prop.getValue());
  9. prop.setValue(String.valueOf(nextId+blockSize));
  10. session.update(prop);
  11. }else{
  12. ContextProperty prop=new ContextProperty();
  13. prop.setKey(ID_KEY);
  14. prop.setValue(String.valueOf(blockSize));
  15. session.save(prop);
  16. }
  17. return nextId+1;
  18. }
  19. }

代码示例来源:origin: com.bstek.uflo/uflo-core

  1. @SuppressWarnings("unchecked")
  2. public Long execute(Context context) {
  3. long nextId=0;
  4. Session session=context.getSession();
  5. List<ContextProperty> list=session.createQuery("from "+ContextProperty.class.getName()+" as p where p.key=:key").setString("key", ID_KEY).setLockMode("p", LockMode.PESSIMISTIC_WRITE).list();
  6. if(list.size()>0){
  7. ContextProperty prop=list.get(0);
  8. nextId=Long.valueOf(prop.getValue());
  9. prop.setValue(String.valueOf(nextId+blockSize));
  10. session.update(prop);
  11. }else{
  12. ContextProperty prop=new ContextProperty();
  13. prop.setKey(ID_KEY);
  14. prop.setValue(String.valueOf(blockSize));
  15. session.save(prop);
  16. }
  17. return nextId+1;
  18. }
  19. }

代码示例来源:origin: com.querydsl/querydsl-jpa

  1. @Override
  2. public long execute() {
  3. JPQLSerializer serializer = new JPQLSerializer(templates, null);
  4. serializer.serializeForUpdate(queryMixin.getMetadata(), updates);
  5. Map<Object, String> constants = serializer.getConstantToLabel();
  6. Query query = session.createQuery(serializer.toString());
  7. for (Map.Entry<Path<?>, LockMode> entry : lockModes.entrySet()) {
  8. query.setLockMode(entry.getKey().toString(), entry.getValue());
  9. }
  10. HibernateUtil.setConstants(query, constants, queryMixin.getMetadata().getParams());
  11. return query.executeUpdate();
  12. }

代码示例来源:origin: com.querydsl/querydsl-jpa

  1. @Override
  2. public long execute() {
  3. JPQLSerializer serializer = new JPQLSerializer(templates, null);
  4. serializer.serializeForDelete(queryMixin.getMetadata());
  5. Map<Object,String> constants = serializer.getConstantToLabel();
  6. Query query = session.createQuery(serializer.toString());
  7. for (Map.Entry<Path<?>, LockMode> entry : lockModes.entrySet()) {
  8. query.setLockMode(entry.getKey().toString(), entry.getValue());
  9. }
  10. HibernateUtil.setConstants(query, constants, queryMixin.getMetadata().getParams());
  11. return query.executeUpdate();
  12. }

代码示例来源:origin: org.nakedobjects/nos-objectstore-hibernate

  1. query.setLockMode(entry.getKey(), entry.getValue());

代码示例来源:origin: org.wso2.bpel/ode-dao-hibernate

  1. q.setLockMode("hs", LockMode.UPGRADE);

代码示例来源:origin: org.wso2.bpel/ode-dao-hibernate

  1. mcors = qry.setLockMode("this", LockMode.UPGRADE).iterate();
  2. } catch (LockAcquisitionException e) {
  3. throw new Scheduler.JobProcessorException(e, true);

代码示例来源:origin: com.mysema.querydsl/querydsl-hql

  1. query.setLockMode(entry.getKey().toString(), entry.getValue());

代码示例来源:origin: com.querydsl/querydsl-jpa

  1. query.setLockMode(entry.getKey().toString(), entry.getValue());

相关文章