nsmcp::AccessRecordStoreSQLite method rollupSource (protected)

 <instance of nsmcp::AccessRecordStoreSQLite> rollupSource \
    options

Defined in /usr/local/ns/tcl/nsmcp/log-traffic-record-store.tcl

Parameters:

options (required)

Testcases:

No testcase defined.

Source code:

if {
    !${:fullScope} || ![:dict getdef ${:settings} unified false] ||
    ![:stateGet rollupsReady 0] || [dict get $options pathLiteral] ne {}
} {
    return {}
}
set from [dict get $options from]
set to [dict get $options to]
# Full minutes use the ingestion rollup. Only the disjoint partial
# minutes use the time index; never round the requested window.
set from [expr {max($from,[:retentionFloor])}]
if {$from<0} {
    return {}
}
set lo [expr {wide(ceil($from/60.0))*60}]
set hi [expr {wide(floor($to/60.0))*60}]
set parts {}
set timeIndex [expr {${:partitionInterval}>0 ? {} : {INDEXED BY by_time_status}}]
if {$lo<$hi} {
    lappend parts "
        SELECT 0 AS kind, slot AS t, status, pool, method, source, n FROM main.minutes m JOIN
        temp.nsmcp_record_scope s ON m.fid=s.fid WHERE slot>=$lo AND slot<$hi
    "
    set edges [list [list $from $lo] [list $hi $to]]
} else {
    set edges [list [list $from $to]]
}
foreach edge $edges {
    lassign $edge start end
    if {$start>=$end} {
        continue
    }
    lappend parts "
        SELECT kind, t, status, pool, method, source, 1 AS n FROM main.rows r $timeIndex
        JOIN temp.nsmcp_record_scope s ON r.fid=s.fid AND r.off>=s.lo AND r.stop<=s.hi WHERE kind=0 AND
        t>=[ns_dbquotevalue $start] AND t<[ns_dbquotevalue $end]
    "
}
if {![llength $parts]} {
    return  {SELECT 0 AS kind,0 AS t,0 AS status,'' AS pool,'' AS method,'' AS source,0 AS n WHERE 0}
}
return [join $parts { UNION ALL }]

XQL Not present:

Generic, PostgreSQL, Oracle