Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 40 for selectCursor (0.05 sec)

  1. src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java

            final long timeout = fessConfig.getIndexBackupLogLoadTimeoutAsInteger().longValue();
            return writer -> {
                final SearchLogBhv bhv = ComponentUtil.getComponent(SearchLogBhv.class);
                bhv.selectCursor(cb -> {
                    cb.query().matchAll();
                    cb.query().addOrderBy_RequestedAt_Asc();
                }, new LogEntityRowHandler<SearchLog>() {
                    @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 29.8K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/job/CrawlJobTest.java

            scheduledJobs.add(job1);
            scheduledJobs.add(job2);
            scheduledJobs.add(job3);
    
            ComponentUtil.register(new ScheduledJobBhv() {
                @Override
                public void selectCursor(CBCall<ScheduledJobCB> cbLambda, EntityRowHandler<ScheduledJob> entityLambda) {
                    for (ScheduledJob job : scheduledJobs) {
                        entityLambda.handle(job);
                    }
                }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 25K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/app/service/RoleService.java

            ComponentUtil.getLdapManager().delete(role);
    
            roleBhv.delete(role, op -> {
                op.setRefreshPolicy(Constants.TRUE);
            });
    
            userBhv.selectCursor(cb -> cb.query().setRoles_Equal(role.getId()), entity -> {
                entity.setRoles(
                        stream(entity.getRoles()).get(stream -> stream.filter(s -> !s.equals(role.getId())).toArray(n -> new String[n])));
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/service/GroupService.java

            ComponentUtil.getLdapManager().delete(group);
    
            groupBhv.delete(group, op -> {
                op.setRefreshPolicy(Constants.TRUE);
            });
    
            userBhv.selectCursor(cb -> cb.query().setGroups_Equal(group.getId()), entity -> {
                entity.setGroups(
                        stream(entity.getGroups()).get(stream -> stream.filter(s -> !s.equals(group.getId())).toArray(n -> new String[n])));
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/service/ScheduledJobService.java

            });
        }
    
        /**
         * Starts all available scheduled jobs.
         * @param cron The cron scheduler.
         */
        public void start(final LaCron cron) {
            scheduledJobBhv.selectCursor(cb -> {
                cb.query().setAvailable_Equal(Constants.T);
                cb.query().addOrderBy_SortOrder_Asc();
                cb.query().addOrderBy_Name_Asc();
            }, scheduledJob -> {
                try {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/opensearch/log/bsbhv/BsClickLogBhv.java

        public PagingResultBean<ClickLog> selectPage(CBCall<ClickLogCB> cbLambda) {
            // #pending same?
            return (PagingResultBean<ClickLog>) facadeSelectList(createCB(cbLambda));
        }
    
        public void selectCursor(CBCall<ClickLogCB> cbLambda, EntityRowHandler<ClickLog> entityLambda) {
            facadeSelectCursor(createCB(cbLambda), entityLambda);
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/opensearch/user/bsbhv/BsRoleBhv.java

        }
    
        public PagingResultBean<Role> selectPage(CBCall<RoleCB> cbLambda) {
            // #pending same?
            return (PagingResultBean<Role>) facadeSelectList(createCB(cbLambda));
        }
    
        public void selectCursor(CBCall<RoleCB> cbLambda, EntityRowHandler<Role> entityLambda) {
            facadeSelectCursor(createCB(cbLambda), entityLambda);
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsFailureUrlBhv.java

        public PagingResultBean<FailureUrl> selectPage(CBCall<FailureUrlCB> cbLambda) {
            // #pending same?
            return (PagingResultBean<FailureUrl>) facadeSelectList(createCB(cbLambda));
        }
    
        public void selectCursor(CBCall<FailureUrlCB> cbLambda, EntityRowHandler<FailureUrl> entityLambda) {
            facadeSelectCursor(createCB(cbLambda), entityLambda);
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsRequestHeaderBhv.java

            // #pending same?
            return (PagingResultBean<RequestHeader>) facadeSelectList(createCB(cbLambda));
        }
    
        public void selectCursor(CBCall<RequestHeaderCB> cbLambda, EntityRowHandler<RequestHeader> entityLambda) {
            facadeSelectCursor(createCB(cbLambda), entityLambda);
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsThumbnailQueueBhv.java

            // #pending same?
            return (PagingResultBean<ThumbnailQueue>) facadeSelectList(createCB(cbLambda));
        }
    
        public void selectCursor(CBCall<ThumbnailQueueCB> cbLambda, EntityRowHandler<ThumbnailQueue> entityLambda) {
            facadeSelectCursor(createCB(cbLambda), entityLambda);
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 9.8K bytes
    - Viewed (0)
Back to top