Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for selectCursor (0.07 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/app/service/BadWordService.java

            try {
                final List<String> list = new ArrayList<>();
                list.add("BadWord");
                csvWriter.writeValues(list);
    
                badWordBhv.selectCursor(cb -> cb.query().matchAll(), new EntityRowHandler<BadWord>() {
                    @Override
                    public void handle(final BadWord entity) {
                        final List<String> list = new ArrayList<>();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 8.6K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/service/ElevateWordService.java

                list.add("Reading");
                list.add("Permissions");
                list.add("Labels");
                list.add("Boost");
                csvWriter.writeValues(list);
    
                elevateWordBhv.selectCursor(cb -> cb.query().matchAll(), new EntityRowHandler<ElevateWord>() {
                    @Override
                    public void handle(final ElevateWord entity) {
                        final List<String> list = new ArrayList<>();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/job/CrawlJob.java

        protected int getRunningJobCount() {
            final AtomicInteger counter = new AtomicInteger(0);
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            ComponentUtil.getComponent(ScheduledJobBhv.class).selectCursor(cb -> {
                cb.query().setAvailable_Equal(Constants.T);
                cb.query().setCrawler_Equal(Constants.T);
            }, scheduledJob -> {
                if (fessConfig.isSchedulerTarget(scheduledJob.getTarget())) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.6K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java

                csvWriter.writeValues(list);
                final DateTimeFormatter formatter = DateTimeFormatter.ofPattern(CoreLibConstants.DATE_FORMAT_ISO_8601_EXTEND);
                crawlingInfoParamBhv.selectCursor(cb -> cb.query().matchAll(), new EntityRowHandler<CrawlingInfoParam>() {
                    @Override
                    public void handle(final CrawlingInfoParam entity) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.9K bytes
    - Viewed (0)
Back to top