From 1ff5c35de5dbd70a782875a91dd2232fd01b002b Mon Sep 17 00:00:00 2001
From: Daniel Baumann <daniel.baumann@progress-linux.org>
Date: Sun, 28 Apr 2024 14:38:04 +0200
Subject: Adding upstream version 0.10.1.

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
---
 vendor/ipl/orm/src/UnionQuery.php | 59 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 59 insertions(+)
 create mode 100644 vendor/ipl/orm/src/UnionQuery.php

(limited to 'vendor/ipl/orm/src/UnionQuery.php')

diff --git a/vendor/ipl/orm/src/UnionQuery.php b/vendor/ipl/orm/src/UnionQuery.php
new file mode 100644
index 0000000..1229ff2
--- /dev/null
+++ b/vendor/ipl/orm/src/UnionQuery.php
@@ -0,0 +1,59 @@
+<?php
+
+namespace ipl\Orm;
+
+use ipl\Sql\Select;
+
+class UnionQuery extends Query
+{
+    /** @var Query[] Underlying queries */
+    private $unions;
+
+    /**
+     * Get the underlying queries
+     *
+     * @return Query[]
+     */
+    public function getUnions()
+    {
+        if ($this->unions === null) {
+            $this->unions = [];
+
+            foreach ($this->getModel()->getUnions() as list($target, $relations, $columns)) {
+                $query = (new Query())
+                    ->setDb($this->getDb())
+                    ->setModel(new $target())
+                    ->columns($columns)
+                    ->disableDefaultSort()
+                    ->with($relations);
+
+                $this->unions[] = $query;
+            }
+        }
+
+        return $this->unions;
+    }
+
+    public function getSelectBase()
+    {
+        if ($this->selectBase === null) {
+            $this->selectBase = new Select();
+        }
+
+        $union = new Select();
+
+        foreach ($this->getUnions() as $query) {
+            $select = $query->assembleSelect();
+            $columns = $select->getColumns();
+            $select->resetColumns();
+            ksort($columns);
+            $select->columns($columns);
+
+            $union->unionAll($select);
+        }
+
+        $this->selectBase->from([$this->getModel()->getTableName() => $union]);
+
+        return $this->selectBase;
+    }
+}
-- 
cgit v1.2.3