viscous/espocrm
1
0
Fork 0
mirror of https://github.com/espocrm/espocrm.git synced 2026-06-28 15:06:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

find by query sth

Browse Source
This commit is contained in:
yuri
2019-02-21 16:20:23 +02:00
parent 0721bd5c27
commit d3b0e9ed5d
3 changed files with 21 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
application/Espo/ORM/EntityManager.php
View File

@@ -33,6 +33,7 @@ use \Espo\Core\Exceptions\Error;
class EntityManager
{
const STH_COLLECTION = 'sthCollection';
protected $pdo;

10
application/Espo/ORM/Repositories/RDB.php
View File

@@ -227,11 +227,17 @@ class RDB extends \Espo\ORM\Repository
return null;
}
public function findByQuery($sql)
public function findByQuery(string $sql, ?string $collectionType = null)
{
$dataArr = $this->getMapper()->selectByQuery($this->seed, $sql);
$collection = new EntityCollection($dataArr, $this->entityType, $this->entityFactory);
if (!$collectionType) {
$collection = new EntityCollection($dataArr, $this->entityType, $this->entityFactory);
} else if ($collectionType === \Espo\ORM\EntityManager::STH_COLLECTION) {
$collection = $this->getEntityManager()->createSthCollection($this->entityType);
$collection->setQuery($sql);
}
$this->reset();
return $collection;

13
application/Espo/ORM/SthCollection.php
View File

@@ -39,6 +39,8 @@ class SthCollection implements \IteratorAggregate
private $sth = null;
private $sql = null;
public function __construct(string $entityType, EntityManager $entityManager = null, array $selectParams = [])
{
$this->selectParams = $selectParams;
@@ -51,9 +53,18 @@ class SthCollection implements \IteratorAggregate
$this->selectParams = $selectParams;
}
public function setQuery(?string $sql)
{
$this->sql = $sql;
}
public function executeQuery()
{
$sql = $this->entityManager->getQuery()->createSelectQuery($this->entityType, $this->selectParams);
if ($this->sql) {
$sql = $this->sql;
} else {
$sql = $this->entityManager->getQuery()->createSelectQuery($this->entityType, $this->selectParams);
}
$sth = $this->entityManager->getPdo()->prepare($sql);
$sth->execute();