com.haulmont.cuba.core.Query.executeUpdate()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(9.1k)|赞(0)|评价(0)|浏览(296)

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

Query.executeUpdate介绍

[英]Execute an update or delete statement.
[中]执行update或delete语句。

代码示例

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. @Override
  2. @Transactional(timeout = 2)
  3. public String executeUpdateSql(String sql) {
  4.   checkTestMode();
  5.   log.info("started: " + sql);
  6.   EntityManager em = persistence.getEntityManager();
  7.   Query query = em.createNativeQuery(sql);
  8.   query.executeUpdate();
  9.   log.info("finished: " + sql);
  10.   return "Done";
  11. }

代码示例来源：origin: com.haulmont.fts/fts-core

  1. @Override
  2. public void emptyQueue() {
  3.   EntityManager em = persistence.getEntityManager();
  4.   Query q = em.createQuery("delete from sys$FtsQueue q");
  5.   q.executeUpdate();
  6. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. @Override
  2.   public void run(EntityManager em) {
  3.     Query query = em.createQuery("delete from sys$ScheduledExecution e where e.id in ?1");
  4.     query.setParameter(1, subList);
  5.     query.executeUpdate();
  6.   }
  7. });

代码示例来源：origin: com.haulmont.fts/fts-core

  1. protected void removeQueuedItems(List<FtsQueue> list) {
  2.   try (Transaction tx = persistence.createTransaction()) {
  3.     EntityManager em = persistence.getEntityManager();
  4.     for (int i = 0; i < list.size(); i += DEL_CHUNK) {
  5.       StringBuilder sb = new StringBuilder("delete from SYS_FTS_QUEUE where ID in (");
  6.       List<FtsQueue> sublist = list.subList(i, Math.min(i + DEL_CHUNK, list.size()));
  7.       for (int idx = 0; idx < sublist.size(); idx++) {
  8.         sb.append("?");
  9.         if (idx < sublist.size() - 1)
  10.           sb.append(", ");
  11.       }
  12.       sb.append(")");
  13.       DbTypeConverter converter = persistence.getDbTypeConverter();
  14.       Query query = em.createNativeQuery(sb.toString());
  15.       for (int idx = 0; idx < sublist.size(); idx++) {
  16.         query.setParameter(idx + 1, converter.getSqlObject(sublist.get(idx).getId()));
  17.       }
  18.       query.executeUpdate();
  19.     }
  20.     tx.commit();
  21.   }
  22. }

代码示例来源：origin: com.haulmont.fts/fts-core

  1. @Override
  2. public void emptyFakeQueue(String entityName) {
  3.   EntityManager em = persistence.getEntityManager();
  4.   Query q = em.createQuery("delete from sys$FtsQueue q where q.entityName = ?1 and q.fake = true");
  5.   q.setParameter(1, entityName);
  6.   q.executeUpdate();
  7. }

代码示例来源：origin: com.haulmont.fts/fts-core

  1. @Override
  2. public void emptyQueue(String entityName) {
  3.   EntityManager em = persistence.getEntityManager();
  4.   Query q = em.createQuery("delete from sys$FtsQueue q where q.entityName = ?1");
  5.   q.setParameter(1, entityName);
  6.   q.executeUpdate();
  7. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. @Override
  2. public void clearScheduledTasks() {
  3.   Transaction tx = persistence.createTransaction();
  4.   try {
  5.     EntityManager em = persistence.getEntityManager();
  6.     Query query = em.createNativeQuery("delete from SYS_SCHEDULED_EXECUTION");
  7.     query.executeUpdate();
  8.     query = em.createNativeQuery("delete from SYS_SCHEDULED_TASK");
  9.     query.executeUpdate();
  10.     tx.commit();
  11.   } finally {
  12.     tx.end();
  13.   }
  14. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. protected void deleteExpiredAccessTokensInDatabase() {
  2.   try (Transaction tx = persistence.createTransaction()) {
  3.     EntityManager em = persistence.getEntityManager();
  4.     em.createQuery("delete from sys$AccessToken t where t.expiry < CURRENT_TIMESTAMP")
  5.         .executeUpdate();
  6.     tx.commit();
  7.   }
  8. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. protected void deleteExpiredRefreshTokensInDatabase() {
  2.   try (Transaction tx = persistence.createTransaction()) {
  3.     EntityManager em = persistence.getEntityManager();
  4.     em.createQuery("delete from sys$RefreshToken t where t.expiry < CURRENT_TIMESTAMP")
  5.         .executeUpdate();
  6.     tx.commit();
  7.   }
  8. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. if (list.isEmpty()) {
  2.   query = em.createNativeQuery(sequenceSupport.createSequenceSql(sequenceName, sequence.getStartValue(), sequence.getIncrement()));
  3.   query.executeUpdate();

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. @Override
  2. public void resetRememberMeTokens() {
  3.   Transaction tx = persistence.createTransaction();
  4.   try {
  5.     EntityManager em = persistence.getEntityManager();
  6.     Query query = em.createQuery("delete from sec$RememberMeToken rt");
  7.     query.executeUpdate();
  8.     tx.commit();
  9.   } finally {
  10.     tx.end();
  11.   }
  12. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. protected void removeAccessTokenFromDatabase(String accessTokenValue) {
  2.   try (Transaction tx = persistence.getTransaction()) {
  3.     EntityManager em = persistence.getEntityManager();
  4.     em.createQuery("delete from sys$AccessToken t where t.tokenValue = :tokenValue")
  5.         .setParameter("tokenValue", accessTokenValue)
  6.         .executeUpdate();
  7.     tx.commit();
  8.   }
  9. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. protected void removeRefreshTokenFromDatabase(String refreshTokenValue) {
  2.   try (Transaction tx = persistence.getTransaction()) {
  3.     EntityManager em = persistence.getEntityManager();
  4.     em.createQuery("delete from sys$RefreshToken t where t.tokenValue = :tokenValue")
  5.         .setParameter("tokenValue", refreshTokenValue)
  6.         .executeUpdate();
  7.     tx.commit();
  8.   }
  9. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. @Authenticated
  2. @Override
  3. public String jpqlExecuteUpdate(String queryString, boolean softDeletion) {
  4.   try {
  5.     Transaction tx = persistence.createTransaction();
  6.     try {
  7.       EntityManager em = persistence.getEntityManager();
  8.       em.setSoftDeletion(softDeletion);
  9.       Query query = em.createQuery(queryString);
  10.       int count = query.executeUpdate();
  11.       tx.commit();
  12.       return "Done: " + count + " entities affected, softDeletion=" + softDeletion;
  13.     } finally {
  14.       tx.end();
  15.     }
  16.   } catch (Throwable e) {
  17.     log.error("jpqlExecuteUpdate error", e);
  18.     return ExceptionUtils.getStackTrace(e);
  19.   }
  20. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. @Override
  2. public void resetRememberMeTokens(List<UUID> userIds) {
  3.   Transaction tx = persistence.getTransaction();
  4.   try {
  5.     EntityManager em = persistence.getEntityManager();
  6.     Query query = em.createQuery("delete from sec$RememberMeToken rt where rt.user.id in :userIds");
  7.     query.setParameter("userIds", userIds);
  8.     query.executeUpdate();
  9.     tx.commit();
  10.   } finally {
  11.     tx.end();
  12.   }
  13. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. "delete from sec$ScreenHistory h where h.id in ?1");
  2. deleteQuery.setParameter(1, toDelete);
  3. deleteQuery.executeUpdate();
  4. tx.commitRetaining();

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. @Override
  2. public void deleteStatistics(String name) {
  3.   Transaction tx = persistence.createTransaction();
  4.   try {
  5.     EntityManager em = persistence.getEntityManager();
  6.     Query q = em.createQuery("delete from sys$EntityStatistics s where s.name = ?1");
  7.     q.setParameter(1, getOriginalOrThisEntityName(name));
  8.     q.executeUpdate();
  9.     tx.commit();
  10.   } finally {
  11.     tx.end();
  12.   }
  13.   flushStatisticsCache();
  14. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. protected void copyUserFolders(User fromUser, User toUser, Map<UUID, Presentation> presentationsMap) {
  2.   try (Transaction tx = persistence.createTransaction()) {
  3.     MetaClass effectiveMetaClass = metadata.getExtendedEntities().getEffectiveMetaClass(SearchFolder.class);
  4.     EntityManager em = persistence.getEntityManager();
  5.     try {
  6.       em.setSoftDeletion(false);
  7.       Query deleteSettingsQuery = em.createQuery(
  8.           String.format("delete from %s s where s.user.id = ?1", effectiveMetaClass.getName())
  9.       );
  10.       deleteSettingsQuery.setParameter(1, toUser.getId());
  11.       deleteSettingsQuery.executeUpdate();
  12.     } finally {
  13.       em.setSoftDeletion(true);
  14.     }
  15.     TypedQuery<SearchFolder> q = em.createQuery(
  16.         String.format("select s from %s s where s.user.id = ?1", effectiveMetaClass.getName()),
  17.         SearchFolder.class);
  18.     q.setParameter(1, fromUser.getId());
  19.     List<SearchFolder> fromUserFolders = q.getResultList();
  20.     Map<SearchFolder, SearchFolder> copiedFolders = new HashMap<>();
  21.     for (SearchFolder searchFolder : fromUserFolders) {
  22.       copyFolder(searchFolder, toUser, copiedFolders, presentationsMap);
  23.     }
  24.     tx.commit();
  25.   }
  26. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. @Override
  2. public void changeUserPassword(UUID userId, String newPasswordHash) {
  3.   Transaction tx = persistence.createTransaction();
  4.   try {
  5.     EntityManager em = persistence.getEntityManager();
  6.     User user = em.find(User.class, userId, CHANGE_PASSWORD_VIEW);
  7.     if (user == null) {
  8.       throw new EntityAccessException(User.class, userId);
  9.     }
  10.     user.setPassword(newPasswordHash);
  11.     user.setChangePasswordAtNextLogon(false);
  12.     // reset remember me for user
  13.     Query query = em.createQuery("delete from sec$RememberMeToken rt where rt.user.id=:userId");
  14.     query.setParameter("userId", userId);
  15.     query.executeUpdate();
  16.     tx.commit();
  17.   } finally {
  18.     tx.end();
  19.   }
  20. }

代码示例来源：origin: com.haulmont.cuba/cuba-core

  1. protected Map<UUID, Presentation> copyPresentations(User fromUser, User toUser) {
  2.   Map<UUID, Presentation> presentationMap = new HashMap<>();
  3.   try (Transaction tx = persistence.createTransaction()) {
  4.     EntityManager em = persistence.getEntityManager();
  5.     // delete existing
  6.     Query delete = em.createQuery("delete from sec$Presentation p where p.user.id = ?1");
  7.     delete.setParameter(1, toUser.getId());
  8.     delete.executeUpdate();
  9.     // copy settings
  10.     TypedQuery<Presentation> selectQuery = em.createQuery(
  11.         "select p from sec$Presentation p where p.user.id = ?1", Presentation.class);
  12.     selectQuery.setParameter(1, fromUser.getId());
  13.     List<Presentation> presentations = selectQuery.getResultList();
  14.     for (Presentation presentation : presentations) {
  15.       Presentation newPresentation = metadata.create(Presentation.class);
  16.       newPresentation.setUser(toUser);
  17.       newPresentation.setComponentId(presentation.getComponentId());
  18.       newPresentation.setAutoSave(presentation.getAutoSave());
  19.       newPresentation.setName(presentation.getName());
  20.       newPresentation.setXml(presentation.getXml());
  21.       presentationMap.put(presentation.getId(), newPresentation);
  22.       em.persist(newPresentation);
  23.     }
  24.     tx.commit();
  25.     return presentationMap;
  26.   }
  27. }

内容来源于网络，如有侵权，请联系作者删除！

query

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com