zentao/module/bi/tao.php

<?php
class biTao extends biModel
{
    /**
     * Fetch tables.
     *
     * @access protected
     * @return array
     */
    protected function fetchAllTables()
    {
        $prefix   = $this->config->db->prefix;
        $excludes = $this->config->bi->duckdbExcludeTables;
        foreach($excludes as $index => $table) $excludes[$index] = $prefix . $table;

        return $this->dao->select("table_name as 'table'")
            ->from('information_schema.tables')
            ->where('table_type')->eq('BASE TABLE')
            ->andWhere('table_schema')->eq($this->config->db->name)
            ->andWhere('table_name')->notin($excludes)
            ->fetchPairs();
    }

    /**
     * Fetch table queue.
     *
     * @access protected
     * @return array
     */
    protected function fetchTableQueue()
    {
        $prefix   = $this->config->db->prefix;
        $excludes = $this->config->bi->duckdbExcludeTables;
        foreach($excludes as $index => $table) $excludes[$index] = $prefix . $table;

        return $this->dao->select('object')->from(TABLE_DUCKDBQUEUE)
            ->where('object')->notin($excludes)
            ->andWhere('updatedTime >= syncTime', true)
            ->orWhere('syncTime IS NULL')
            ->markRight(1)
            ->fetchPairs();
    }

    /**
     * Update sync time.
     *
     * @param  array    $tables
     * @access protected
     * @return void
     */
    protected function updateSyncTime($tables)
    {
        $this->dao->update(TABLE_DUCKDBQUEUE)
            ->set('syncTime')->eq(helper::now())
            ->where('object')->in($tables)
            ->exec();
    }

    /**
     * Fetch action date.
     *
     * @access protected
     * @return object
     */
    protected function fetchActionDate()
    {
        return $this->dao->select('min(date) as minDate, max(date) as maxDate')
            ->from(TABLE_ACTION)
            ->where('date')->ge('2009-01-01')
            ->fetch();
    }

}