1 files changed, 134 insertions, 0 deletions
diff --git a/modules/monitoring/library/Monitoring/Backend/Ido/Query/EventhistoryQuery.php b/modules/monitoring/library/Monitoring/Backend/Ido/Query/EventhistoryQuery.php
new file mode 100644
index 0000000..680e2ca
--- /dev/null
+++ b/modules/monitoring/library/Monitoring/Backend/Ido/Query/EventhistoryQuery.php
@@ -0,0 +1,134 @@
+<?php
+/* Icinga Web 2 | (c) 2013 Icinga Development Team | GPLv2+ */
+
+namespace Icinga\Module\Monitoring\Backend\Ido\Query;
+
+use Icinga\Data\Filter\FilterExpression;
+use Zend_Db_Select;
+use Icinga\Data\Filter\Filter;
+
+/**
+ * Query for event history records
+ */
+class EventhistoryQuery extends IdoQuery
+{
+    /**
+     * {@inheritdoc}
+     */
+    protected $useSubqueryCount = true;
+
+    /**
+     * Subqueries used for the event history query
+     *
+     * @type    IdoQuery[]
+     */
+    protected $subQueries = array();
+
+    /**
+     * {@inheritdoc}
+     */
+    protected $columnMap = array(
+        'eventhistory' => array(
+            'id'                    => 'eh.id',
+            'host_name'             => 'eh.host_name',
+            'service_description'   => 'eh.service_description',
+            'object_type'           => 'eh.object_type',
+            'timestamp'             => 'eh.timestamp',
+            'state'                 => 'eh.state',
+            'output'                => 'eh.output',
+            'type'                  => 'eh.type',
+            'host_display_name'     => 'eh.host_display_name',
+            'service_display_name'  => 'eh.service_display_name'
+        )
+    );
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function joinBaseTables()
+    {
+        $columns = array(
+            'id',
+            'timestamp',
+            'output',
+            'type',
+            'state',
+            'object_type',
+            'host_name',
+            'service_description',
+            'host_display_name',
+            'service_display_name'
+        );
+        $this->subQueries = array(
+            $this->createSubQuery('Notificationhistory', $columns),
+            $this->createSubQuery('Statehistory', $columns),
+            $this->createSubQuery('Downtimestarthistory', $columns),
+            $this->createSubQuery('Downtimeendhistory', $columns),
+            $this->createSubQuery('Commenthistory', $columns),
+            $this->createSubQuery('Commentdeletionhistory', $columns),
+            $this->createSubQuery('Flappingstarthistory', $columns),
+            $this->createSubQuery('Flappingendhistory', $columns)
+        );
+        $sub = $this->db->select()->union($this->subQueries, Zend_Db_Select::SQL_UNION_ALL);
+        $this->select->from(array('eh' => $sub), array());
+        $this->joinedVirtualTables['eventhistory'] = true;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function allowsCustomVars()
+    {
+        foreach ($this->subQueries as $query) {
+            if (! $query->allowsCustomVars()) {
+                return false;
+            }
+        }
+
+        return true;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function order($columnOrAlias, $dir = null)
+    {
+        foreach ($this->subQueries as $sub) {
+            $sub->requireColumn($columnOrAlias);
+        }
+        return parent::order($columnOrAlias, $dir);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function where($condition, $value = null)
+    {
+        $this->requireColumn($condition);
+        foreach ($this->subQueries as $sub) {
+            $sub->where($condition, $value);
+        }
+        return $this;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function addFilter(Filter $filter)
+    {
+        foreach ($this->subQueries as $sub) {
+            $sub->applyFilter(clone $filter);
+        }
+        return $this;
+    }
+
+    public function whereEx(FilterExpression $ex)
+    {
+        $this->requireColumn($ex->getColumn());
+        foreach ($this->subQueries as $sub) {
+            $sub->whereEx($ex);
+        }
+
+        return $this;
+    }
+}