Inheritance diagram for org.turro.log.SystemLogAccumulator:

Collaboration diagram for org.turro.log.SystemLogAccumulator:

Public Member Functions
	SystemLogAccumulator (Dao dao)

void	run ()

Static Public Member Functions
static void	accumulate ()

Detailed Description

Author: Lluis Turró Cutiller lluis.nosp@m.@tur.nosp@m.ro.or.nosp@m.g

Definition at line 33 of file SystemLogAccumulator.java.

Constructor & Destructor Documentation

◆ SystemLogAccumulator()

org.turro.log.SystemLogAccumulator.SystemLogAccumulator ( Dao dao )

Definition at line 43 of file SystemLogAccumulator.java.

                                        {
     this.dao = dao;
   }

Here is the caller graph for this function:

Member Function Documentation

◆ accumulate()

static void org.turro.log.SystemLogAccumulator.accumulate ( )

static

Definition at line 38 of file SystemLogAccumulator.java.

                                   {
     SystemLogAccumulator accumulator = new SystemLogAccumulator(new ElephantPU());
     new Thread(accumulator, "ElephantLog accumulator").start();
   }

Here is the call graph for this function:

Here is the caller graph for this function:

◆ run()

void org.turro.log.SystemLogAccumulator.run ( )

Definition at line 60 of file SystemLogAccumulator.java.

                     {
     Date until = new CheckDate().addYears(-MAX_YEARS).getDate();
     ensureCounts();
     SqlClause.select(Words.csv("l.logType").add("l.generatorPath").add("l.entityPath")
                           .add("l.generatorName").add("l.entityName").add("l.comment")
                           .add("sum(l.counts)").add("max(l.dateLog)").toString())
             .from("SystemLog l")
             .where().smallerOrEqual("l.dateLog", until)
             .groupBy(Words.csv("l.logType").add("l.generatorPath").add("l.entityPath")
                           .add("l.generatorName").add("l.entityName").add("l.comment").toString())
             .dao(dao)
             .resultList(Object[].class).forEach(c -> {
               SystemLog sl = new SystemLog();
               sl.setLogType((SystemLogType) c[0]);
               sl.setGeneratorPath((String) c[1]);
               sl.setEntityPath((String) c[2]);
               sl.setGeneratorName((String) c[3]);
               sl.setEntityName((String) c[4]);
               sl.setComment((String) c[5]);
               sl.setCounts((int)(long) c[6]);
               sl.setDateLog(until);
               sl.setData(getDataFrom(sl, (Date) c[7]));
               dao.saveObject(sl);
             });
     SqlClause.delete("SystemLog").where().smaller("logDate", until);
   }