2 Commits

Author SHA1 Message Date
Gregory Letellier
293eb9e555 cast extended models when loading from database 2025-01-09 12:00:25 +01:00
Gregory Letellier
d961d2a80f ajout model de type readonly pour une requête de select uniquement 2024-06-18 13:02:18 +02:00
3 changed files with 58 additions and 35 deletions

View File

@@ -12,21 +12,28 @@ class Model implements JsonSerializable
protected string $connection = ""; protected string $connection = "";
protected string $pk; protected string $pk;
private bool $new; private bool $new;
private bool $ro;
public function __construct() public function __construct($ro = false)
{ {
$this->new = true; $this->new = true;
$this->values = array(); $this->values = array();
$this->updated = array(); $this->updated = array();
$this->pk = "id"; $this->pk = "id";
$this->ro = $ro;
$this->initTable(); $this->initTable();
} }
private function initTable(): void private function initTable(): void
{ {
if (!$this->ro) {
if ($this->table == "") { if ($this->table == "") {
$this->table = $this->getDefaultTableName(); $this->table = $this->getDefaultTableName();
} }
} else {
$this->table = "ReadOnlyModel";
$this->pk = "__idpk";
}
} }
public function getTable(): string public function getTable(): string
@@ -77,7 +84,7 @@ class Model implements JsonSerializable
public function find(mixed $key): mixed public function find(mixed $key): mixed
{ {
$qb = $this->newQueryBuilder(); $qb = $this->newQueryBuilder(get_class($this));
$find = $qb->find($key); $find = $qb->find($key);
if ($find !== null) { if ($find !== null) {
$this->fillData($find->getValues()); $this->fillData($find->getValues());
@@ -89,7 +96,8 @@ class Model implements JsonSerializable
public function save(): bool public function save(): bool
{ {
$ret = false; $ret = false;
$qb = $this->newQueryBuilder(); if (!$this->ro) {
$qb = $this->newQueryBuilder("");
if ($this->new) { if ($this->new) {
$query = $qb->getPreparedQuery($this->values); $query = $qb->getPreparedQuery($this->values);
$id = Connection::getInstance($this->connection)->insertQuery($query); $id = Connection::getInstance($this->connection)->insertQuery($query);
@@ -114,12 +122,13 @@ class Model implements JsonSerializable
} }
} }
} }
}
return $ret; return $ret;
} }
public function newQueryBuilder(): QueryBuilder public function newQueryBuilder($className): QueryBuilder
{ {
return new QueryBuilder($this->table, $this->pk, $this->connection); return new QueryBuilder($this->table, $this->pk, $this->connection, $className);
} }
public function __set($name, $value): void public function __set($name, $value): void
@@ -139,10 +148,16 @@ class Model implements JsonSerializable
} }
} }
public static function getClassName()
{
return static::class;
}
public static function q(): QueryBuilder public static function q(): QueryBuilder
{ {
$cls = self::getClassName();
$ist = new static(); $ist = new static();
return $ist->newQueryBuilder(); return $ist->newQueryBuilder($cls);
} }
public function __get($name): mixed public function __get($name): mixed

View File

@@ -10,6 +10,7 @@ class QueryBuilder
protected array $orders; protected array $orders;
protected array $groupby; protected array $groupby;
protected string $table; protected string $table;
protected string $classname;
protected string $connection; protected string $connection;
protected string $pk; protected string $pk;
protected ?int $take; protected ?int $take;
@@ -20,8 +21,9 @@ class QueryBuilder
public const MODE_AND = 0; public const MODE_AND = 0;
public const MODE_OR = 1; public const MODE_OR = 1;
public function __construct($table, $pk = "id", $connection = "") public function __construct($table, $pk = "id", $connection = "", $classname = "")
{ {
$this->classname = $classname;
$this->table = $table; $this->table = $table;
$this->pk = $pk; $this->pk = $pk;
$this->connection = $connection; $this->connection = $connection;
@@ -208,7 +210,12 @@ class QueryBuilder
{ {
$ret = array(); $ret = array();
foreach ($data as $row) { foreach ($data as $row) {
if ($this->classname != "") {
$model = new $this->classname();
} else {
$model = new Model(); $model = new Model();
}
$ret[] = $model->setPk($this->pk)->setTable($this->table)->fillData($row); $ret[] = $model->setPk($this->pk)->setTable($this->table)->fillData($row);
} }
return new Collection($ret); return new Collection($ret);
@@ -238,8 +245,7 @@ class QueryBuilder
$this->fillData($ret); $this->fillData($ret);
if($where!="" && $Orwhere!="") if ($where != "" && $Orwhere != "") {
{
$Orwhere = " OR " . $Orwhere; $Orwhere = " OR " . $Orwhere;
} }
@@ -257,7 +263,7 @@ class QueryBuilder
private function fillData(Query &$query): void private function fillData(Query &$query): void
{ {
foreach (array_merge($this->wheres,$this->orwheres) as $expression) { foreach (array_merge($this->wheres, $this->orwheres) as $expression) {
if ($expression instanceof Expression) { if ($expression instanceof Expression) {
if ($expression->hasData()) { if ($expression->hasData()) {
$query->addData($expression->getValue()); $query->addData($expression->getValue());

View File

@@ -116,6 +116,8 @@ test("extending model",function()
$row = $qbs->find(1); $row = $qbs->find(1);
expect($row->id)->toBe(1); expect($row->id)->toBe(1);
expect($row->col1)->toBe("test"); expect($row->col1)->toBe("test");
expect($row)->toBeInstanceOf(Test::class);
}); });
test("order by", function(){ test("order by", function(){