Initial commit

Author: Daniel Stříbrný

.gitignore

@@ -0,0 +1,5 @@
+.idea/
+
+/vendor/
+
+composer.lock

README.md

@@ -0,0 +1,47 @@
+# Ublaboo Datagrid data source bindings for Kdyby Doctrine query objects
+
+## Installation
+
+via composer:
+
+```sh
+composer require adt/query-object-data-source
+```
+
+and in config.neon:
+
+```neon
+extensions:
+	- ADT\QueryObjectDataSource\DI\QueryObjectDataSourceExtension
+```
+
+## Usage
+
+Inject or autowire QueryObjectDataSourceFactory:
+```php
+/** @var \ADT\QueryObjectDataSource\IQueryObjectDataSourceFactory @autowire */
+protected $queryObjectDataSourceFactory;
+```
+
+Create query object and wrap it as data source:
+```php
+$qo = /* create query object */;
+
+$dataSource = $this->queryObjectDataSourceFactory->create($qo, "id")
+	->setSortCallback(function($queryObject, \Ublaboo\DataGrid\Utils\Sorting $sorting) {
+		$sort = $sorting->getSort();
+
+		if (!empty($sort)) {
+			foreach ($sort as $order => $by) {
+				$queryObject->order("e.$order", $by);
+			}
+		}
+	})
+	->setFilterCallback(function ($queryObject, array $filter) {
+		foreach ($filter as $field => $value) {
+			$queryObject->{'by' . $field}($value);
+		}
+	});
+
+$grid->setDataSource($queryObjectDataSource);
+```

composer.json

@@ -0,0 +1,22 @@
+{
+	"name": "adt/query-object-data-source",
+	"description": "Ublaboo Datagrid data source bindings for Kdyby Doctrine query objects.",
+	"type": "library",
+	"license": [
+		"MIT",
+		"BSD-3-Clause",
+		"GPL-2.0",
+		"GPL-3.0"
+	],
+	"require-dev": {
+		"kdyby/doctrine": "^3.1",
+		"ublaboo/datagrid": "^5.0",
+		"nette/utils": "^2.4",
+		"nette/di": "^2.4"
+	},
+	"autoload": {
+		"psr-4": {
+			"ADT\\QueryObjectDataSource\\": "src/"
+		}
+	}
+}

src/DI/QueryObjectDataSourceExtension.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace ADT\QueryObjectDataSource\DI;
+
+class QueryObjectDataSourceExtension extends \Nette\DI\CompilerExtension {
+
+	public function loadConfiguration() {
+
+		$this->getContainerBuilder()
+			->addDefinition($this->prefix('factory'))
+			->setImplement(\ADT\QueryObjectDataSource\IQueryObjectDataSourceFactory::class);
+	}
+
+}

src/QueryObjectDataSource.php

@@ -0,0 +1,164 @@
+<?php
+
+namespace ADT\QueryObjectDataSource;
+
+interface IQueryObjectDataSourceFactory {
+
+	/** @return QueryObjectDataSource */
+	function create(\Kdyby\Doctrine\QueryObject $queryObject, $primaryKey);
+
+}
+
+
+class QueryObjectDataSource extends \Nette\Object implements \Ublaboo\DataGrid\DataSource\IDataSource {
+
+	/** @var \Kdyby\Doctrine\EntityManager */
+	protected $em;
+
+	/** @var \Kdyby\Doctrine\ResultSet */
+	protected $resultSet;
+
+	/** @var \Kdyby\Doctrine\QueryObject */
+	protected $queryObject;
+
+	/** @var string */
+	protected $primaryKey;
+
+	/** @var callable */
+	public $filterCallback;
+
+	/** @var callable */
+	public $filterOneCallback;
+
+	/** @var callable */
+	public $sortCallback;
+
+	/**
+	 * @param \Kdyby\Doctrine\QueryObject $queryObject
+	 * @param string $primaryKey
+	 * @param \Kdyby\Doctrine\EntityManager $em
+	 */
+	public function __construct(\Kdyby\Doctrine\QueryObject $queryObject, $primaryKey, \Kdyby\Doctrine\EntityManager $em) {
+		$this->queryObject = $queryObject;
+		$this->primaryKey = $primaryKey;
+		$this->em = $em;
+	}
+
+	/**
+	 * @param callable $callback
+	 * @return self
+	 */
+	public function setFilterCallback($callback) {
+		$this->filterCallback = $callback;
+		return $this;
+	}
+
+	/**
+	 * @param callable $callback
+	 * @return self
+	 */
+	public function setFilterOneCallback($callback) {
+		$this->filterOneCallback = $callback;
+		return $this;
+	}
+
+	/**
+	 * @param callable $callback
+	 * @return self
+	 */
+	public function setSortCallback($callback) {
+		$this->sortCallback = $callback;
+		return $this;
+	}
+
+	protected function getResultSet() {
+		if (!$this->resultSet) {
+			$this->resultSet = $this->em->getRepository($this->queryObject->getEntity())
+				->fetch($this->queryObject);
+		}
+
+		return $this->resultSet;
+	}
+
+	/**
+	 * Get count of data
+	 * @return int
+	 */
+	public function getCount() {
+		return $this->em->getRepository($this->queryObject->getEntity())
+			->fetch($this->queryObject)
+			->getTotalCount();
+	}
+
+	/**
+	 * Get the data
+	 * @return array
+	 */
+	public function getData() {
+		return $this->getResultSet()->toArray();
+	}
+
+	/**
+	 * Filter data
+	 * @param array $filters
+	 * @return static
+	 */
+	public function filter(array $filters) {
+		foreach ($filters as $filter) {
+			if ($filter->isValueSet()) {
+				if ($filter->hasConditionCallback()) {
+					\Nette\Utils\Callback::invokeArgs(
+						$filter->getConditionCallback(), [ $this->queryObject, $filter->getValue() ]
+					);
+				}
+			}
+		}
+
+		if (is_callable($this->filterCallback)) {
+			$this->filterCallback($this->queryObject, $filters);
+		}
+
+		return $this;
+	}
+
+	/**
+	 * Filter data - get one row
+	 * @param array $filter
+	 * @return static
+	 */
+	public function filterOne(array $filter) {
+
+		if (is_callable($this->filterOneCallback)) {
+			$this->filterOneCallback($this->queryObject, $filter);
+		}
+
+		return $this;
+	}
+
+	/**
+	 * Apply limit and offset on data
+	 * @param int $offset
+	 * @param int $limit
+	 * @return static
+	 */
+	public function limit($offset, $limit) {
+		$this->getResultSet()->applyPaging($offset, $limit);
+
+		return $this;
+	}
+
+	/**
+	 * Sort data
+	 * @param \Ublaboo\DataGrid\Utils\Sorting $sorting
+	 * @return static
+	 */
+	public function sort(\Ublaboo\DataGrid\Utils\Sorting $sorting) {
+
+		if (is_callable($this->sortCallback)) {
+			$this->sortCallback($this->queryObject, $sorting);
+		}
+
+		return $this;
+	}
+
+}