sda-php
/
nur-sery
11
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

modifs.mineures sans commentaires

This commit is contained in:
Jephté Clain 2024-06-06 12:19:06 +04:00
parent eb710b3c2b
commit d223446e3c
9 changed files with 131 additions and 91 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
nur_bin/mysql-storage.php
View File

@ -21,16 +21,21 @@ Application::run(new class extends Application {
["-d", "--dbconn", "args" => 1, ["-d", "--dbconn", "args" => 1,
"help" => "nom de la connexion à la base de données", "help" => "nom de la connexion à la base de données",
], ],
["-c", "--channel", "args" => 1, ["-t", "--table-name", "args" => 1,
"help" => "nom de la table porteuse du canal de données", "help" => "nom de la table porteuse du canal de données",
], ],
["-c", "--channel-class", "args" => 1,
"help" => "nom de la classe dérivée de CapacitorChannel",
],
]; ];
protected $dbconn; protected ?string $dbconn = null;
protected $channel; protected ?string $tableName = null;
protected $args; protected ?string $channelClass = null;
protected ?array $args = null;
protected static function isa_cond(string $arg, ?array &$ms=null): bool { protected static function isa_cond(string $arg, ?array &$ms=null): bool {
return preg_match('/^(.+?)\s*(=|<>|<|>|<=|>=|(?:is\s+)?null|(?:is\s+)?not\s+null)\s*(.*)$/', $arg, $ms); return preg_match('/^(.+?)\s*(=|<>|<|>|<=|>=|(?:is\s+)?null|(?:is\s+)?not\s+null)\s*(.*)$/', $arg, $ms);
@ -43,15 +48,21 @@ Application::run(new class extends Application {
if ($tmp === null) self::die("$dbconn: base de données invalide"); if ($tmp === null) self::die("$dbconn: base de données invalide");
$dbconn = $tmp; $dbconn = $tmp;
if ($this->channel === null) self::die("Vous devez spécifier le canal de données"); if ($this->channelClass !== null) {
$channelClass = str_replace("/", "\\", $this->channelClass);
$channel = new $channelClass;
} elseif ($this->tableName !== null) {
$channel = new class($this->tableName) extends CapacitorChannel {
public function __construct(?string $name=null) {
parent::__construct($name);
$this->tableName = $name;
}
};
} else {
self::die("Vous devez spécifier le canal de données");
}
$storage = new MysqlStorage($dbconn); $storage = new MysqlStorage($dbconn);
$channel = new class($this->channel) extends CapacitorChannel {
public function __construct(?string $name=null) {
parent::__construct($name);
$this->tableName = $name;
}
};
$capacitor = new Capacitor($storage, $channel); $capacitor = new Capacitor($storage, $channel);
$args = $this->args; $args = $this->args;

33
nur_bin/sqlite-storage.php
View File

@ -19,16 +19,21 @@ Application::run(new class extends Application {
["-f", "--dbfile", "args" => 1, ["-f", "--dbfile", "args" => 1,
"help" => "chemin vers la base de données", "help" => "chemin vers la base de données",
], ],
["-c", "--channel", "args" => 1, ["-t", "--table-name", "args" => 1,
"help" => "nom de la table porteuse du canal de données", "help" => "nom de la table porteuse du canal de données",
], ],
["-c", "--channel-class", "args" => 1,
"help" => "nom de la classe dérivée de CapacitorChannel",
],
]; ];
protected $dbfile; protected ?string $dbfile = null;
protected $channel; protected ?string $tableName = null;
protected $args; protected ?string $channelClass = null;
protected ?array $args = null;
protected static function isa_cond(string $arg, ?array &$ms=null): bool { protected static function isa_cond(string $arg, ?array &$ms=null): bool {
return preg_match('/^(.+?)\s*(=|<>|<|>|<=|>=|(?:is\s+)?null|(?:is\s+)?not\s+null)\s*(.*)$/', $arg, $ms); return preg_match('/^(.+?)\s*(=|<>|<|>|<=|>=|(?:is\s+)?null|(?:is\s+)?not\s+null)\s*(.*)$/', $arg, $ms);
@ -39,15 +44,21 @@ Application::run(new class extends Application {
if ($dbfile === null) self::die("Vous devez spécifier la base de données"); if ($dbfile === null) self::die("Vous devez spécifier la base de données");
if (!file_exists($dbfile)) self::die("$dbfile: fichier introuvable"); if (!file_exists($dbfile)) self::die("$dbfile: fichier introuvable");
if ($this->channel === null) self::die("Vous devez spécifier le canal de données"); if ($this->channelClass !== null) {
$channelClass = str_replace("/", "\\", $this->channelClass);
$channel = new $channelClass;
} elseif ($this->tableName !== null) {
$channel = new class($this->tableName) extends CapacitorChannel {
public function __construct(?string $name=null) {
parent::__construct($name);
$this->tableName = $name;
}
};
} else {
self::die("Vous devez spécifier le canal de données");
}
$storage = new SqliteStorage($dbfile); $storage = new SqliteStorage($dbfile);
$channel = new class($this->channel) extends CapacitorChannel {
public function __construct(?string $name=null) {
parent::__construct($name);
$this->tableName = $name;
}
};
$capacitor = new Capacitor($storage, $channel); $capacitor = new Capacitor($storage, $channel);
$args = $this->args; $args = $this->args;

16
src/db/Capacitor.php
View File

@ -2,7 +2,7 @@
namespace nur\sery\db; namespace nur\sery\db;
/** /**
* Class Capacitor: un objet permettant d'attaquer un canal spécique d'une * Class Capacitor: un objet permettant d'attaquer un canal spécifique d'une
* instance de {@link CapacitorStorage} * instance de {@link CapacitorStorage}
*/ */
class Capacitor { class Capacitor {
@ -15,9 +15,17 @@ class Capacitor {
/** @var CapacitorStorage */ /** @var CapacitorStorage */
protected $storage; protected $storage;
function getStorage(): CapacitorStorage {
return $this->storage;
}
/** @var CapacitorChannel */ /** @var CapacitorChannel */
protected $channel; protected $channel;
function getChannel(): CapacitorChannel {
return $this->channel;
}
function exists(): bool { function exists(): bool {
return $this->storage->_exists($this->channel); return $this->storage->_exists($this->channel);
} }
@ -30,11 +38,11 @@ class Capacitor {
$this->storage->_reset($this->channel); $this->storage->_reset($this->channel);
} }
function charge($item, ?callable $func=null, ?array $args=null): int { function charge($item, $func=null, ?array $args=null): int {
return $this->storage->_charge($this->channel, $item, $func, $args); return $this->storage->_charge($this->channel, $item, $func, $args);
} }
function discharge($filter=null, ?bool $reset=null): iterable { function discharge(bool $reset=true): iterable {
return $this->storage->_discharge($this->channel, $reset); return $this->storage->_discharge($this->channel, $reset);
} }
@ -50,7 +58,7 @@ class Capacitor {
return $this->storage->_all($this->channel, $filter); return $this->storage->_all($this->channel, $filter);
} }
function each($filter, ?callable $func=null, ?array $args=null): int { function each($filter, $func=null, ?array $args=null): int {
return $this->storage->_each($this->channel, $filter, $func, $args); return $this->storage->_each($this->channel, $filter, $func, $args);
} }

51
src/db/CapacitorChannel.php
View File

@ -115,7 +115,7 @@ class CapacitorChannel {
* chargement de $item * chargement de $item
* *
* Cette méthode est utilisée par {@link Capacitor::charge()}. Si la clé * Cette méthode est utilisée par {@link Capacitor::charge()}. Si la clé
* primaire est retournée (il s'agit généralement de "id_"), la ligne * primaire est incluse (il s'agit généralement de "id_"), la ligne
* correspondate est mise à jour si elle existe. * correspondate est mise à jour si elle existe.
*/ */
function getItemValues($item): ?array { function getItemValues($item): ?array {
@ -137,36 +137,46 @@ class CapacitorChannel {
* créer un nouvel élément * créer un nouvel élément
* *
* @param mixed $item l'élément à charger * @param mixed $item l'élément à charger
* @param array $updates les valeurs calculées par {@link getItemValues()} * @param array $rowValues la ligne à créer, calculée à partir de $item et des
* @return ?array le cas échéant, un tableau non null à merger dans $updates * valeurs retournées par {@link getItemValues()}
* @return ?array le cas échéant, un tableau non null à merger dans $rowValues
* et utilisé pour provisionner la ligne nouvellement créée * et utilisé pour provisionner la ligne nouvellement créée
* *
* Si $item est modifié dans cette méthode, il est possible de le retourner * Si $item est modifié dans cette méthode, il est possible de le retourner
* avec la clé "item" pour mettre à jour la ligne correspondante. * avec la clé "item" pour mettre à jour la ligne correspondante.
*/ */
function onCreate($item, array $updates): ?array { function onCreate($item, array $rowValues): ?array {
return null; return null;
} }
/**
* retourne true si un nouvel élément ou un élément mis à jour a été chargé.
* false si l'élément chargé est identique au précédent.
*
* cette méthode doit être utilisée dans {@link self::onUpdate()}
*/
function wasModified(array $rowValues): bool {
return array_key_exists("modified_", $rowValues);
}
/** /**
* méthode appelée lors du chargement avec {@link Capacitor::charge()} pour * méthode appelée lors du chargement avec {@link Capacitor::charge()} pour
* mettre à jour un élément existant * mettre à jour un élément existant
* *
* @param mixed $item l'élément à charger * @param mixed $item l'élément à charger
* @param array $updates les valeurs calculées par {@link getItemValues()} * @param array $rowValues la nouvelle ligne, calculée à partir de $item et
* Si l'élément a été modifié par rapport au dernier chargement, ce tableau * des valeurs retournées par {@link getItemValues()}
* contient une clé "modified_" avec la date de modification. * @param array $prowValues la précédente ligne, chargée depuis la base de
* @param array $row la ligne à mettre à jour. * données
* @return ?array le cas échéant, un tableau non null à merger dans $updates * @return ?array null s'il ne faut pas mettre à jour la ligne. sinon, ce
* et utilisé pour mettre à jour la ligne existante * tableau est mergé dans $values puis utilisé pour mettre à jour la ligne
* existante
* *
* Si $item est modifié dans cette méthode, il est possible de le retourner * - Il est possible de mettre à jour $item en le retourant avec la clé "item"
* avec la clé "item" pour mettre à jour la ligne correspondante. * - La clé primaire (il s'agit généralement de "id_") ne peut pas être
*
* La clé primaire (il s'agit généralement de "id_") ne peut pas être
* modifiée. si elle est retournée, elle est ignorée * modifiée. si elle est retournée, elle est ignorée
*/ */
function onUpdate($item, array $updates, array $row): ?array { function onUpdate($item, array $rowValues, array $prowValues): ?array {
return null; return null;
} }
@ -175,16 +185,15 @@ class CapacitorChannel {
* {@link Capacitor::each()} * {@link Capacitor::each()}
* *
* @param mixed $item l'élément courant * @param mixed $item l'élément courant
* @param ?array $row la ligne à mettre à jour. * @param ?array $rowValues la ligne courante
* @return ?array le cas échéant, un tableau non null utilisé pour mettre à * @return ?array le cas échéant, un tableau non null utilisé pour mettre à
* jour la ligne courante * jour la ligne courante
* *
* Si $item est modifié dans cette méthode, il est possible de le retourner * - Il est possible de mettre à jour $item en le retourant avec la clé "item"
* avec la clé "item" pour mettre à jour la ligne correspondante * - La clé primaire (il s'agit généralement de "id_") ne peut pas être
* La colonne "id_" ne peut pas être modifiée: si "id_" est retourné, il est * modifiée. si elle est retournée, elle est ignorée
* ignoré
*/ */
function onEach($item, array $row): ?array { function onEach($item, array $rowValues): ?array {
return null; return null;
} }
} }

17
src/db/CapacitorStorage.php
View File

@ -27,9 +27,8 @@ abstract class CapacitorStorage {
return $channel; return $channel;
} }
const PRIMARY_KEY_DEFINITION = [ /** DOIT être défini dans les classes dérivées */
"id_" => "integer primary key autoincrement", const PRIMARY_KEY_DEFINITION = null;
];
const COLUMN_DEFINITIONS = [ const COLUMN_DEFINITIONS = [
"item__" => "text", "item__" => "text",
@ -41,9 +40,9 @@ abstract class CapacitorStorage {
protected function ColumnDefinitions(CapacitorChannel $channel): array { protected function ColumnDefinitions(CapacitorChannel $channel): array {
$definitions = []; $definitions = [];
if ($channel->getPrimaryKeys() === null) { if ($channel->getPrimaryKeys() === null) {
$definitions[] = self::PRIMARY_KEY_DEFINITION; $definitions[] = static::PRIMARY_KEY_DEFINITION;
} }
$definitions[] = self::COLUMN_DEFINITIONS; $definitions[] = static::COLUMN_DEFINITIONS;
$definitions[] = $channel->getColumnDefinitions(); $definitions[] = $channel->getColumnDefinitions();
return cl::merge(...$definitions); return cl::merge(...$definitions);
} }
@ -130,7 +129,7 @@ abstract class CapacitorStorage {
$this->_reset($this->getChannel($channel)); $this->_reset($this->getChannel($channel));
} }
abstract function _charge(CapacitorChannel $channel, $item, ?callable $func, ?array $args): int; abstract function _charge(CapacitorChannel $channel, $item, $func, ?array $args): int;
/** /**
* charger une valeur dans le canal * charger une valeur dans le canal
@ -144,7 +143,7 @@ abstract class CapacitorStorage {
* @return int 1 si l'objet a été chargé ou mis à jour, 0 s'il existait * @return int 1 si l'objet a été chargé ou mis à jour, 0 s'il existait
* déjà à l'identique dans le canal * déjà à l'identique dans le canal
*/ */
function charge(?string $channel, $item, ?callable $func=null, ?array $args=null): int { function charge(?string $channel, $item, $func=null, ?array $args=null): int {
return $this->_charge($this->getChannel($channel), $item, $func, $args); return $this->_charge($this->getChannel($channel), $item, $func, $args);
} }
@ -184,7 +183,7 @@ abstract class CapacitorStorage {
return $this->_all($this->getChannel($channel), $filter); return $this->_all($this->getChannel($channel), $filter);
} }
abstract function _each(CapacitorChannel $channel, $filter, ?callable $func, ?array $args): int; abstract function _each(CapacitorChannel $channel, $filter, $func, ?array $args): int;
/** /**
* appeler une fonction pour chaque élément du canal spécifié. * appeler une fonction pour chaque élément du canal spécifié.
@ -196,7 +195,7 @@ abstract class CapacitorStorage {
* *
* @return int le nombre de lignes parcourues * @return int le nombre de lignes parcourues
*/ */
function each(?string $channel, $filter, ?callable $func=null, ?array $args=null): int { function each(?string $channel, $filter, $func=null, ?array $args=null): int {
return $this->_each($this->getChannel($channel), $filter, $func, $args); return $this->_each($this->getChannel($channel), $filter, $func, $args);
} }

34
src/db/mysql/MysqlStorage.php
View File

@ -22,6 +22,10 @@ class MysqlStorage extends CapacitorStorage {
return $this->mysql; return $this->mysql;
} }
const PRIMARY_KEY_DEFINITION = [
"id_" => "integer primary key auto_increment",
];
protected function _create(CapacitorChannel $channel): void { protected function _create(CapacitorChannel $channel): void {
if (!$channel->isCreated()) { if (!$channel->isCreated()) {
$cols = $this->ColumnDefinitions($channel); $cols = $this->ColumnDefinitions($channel);
@ -58,8 +62,9 @@ class MysqlStorage extends CapacitorStorage {
$channel->setCreated(false); $channel->setCreated(false);
} }
function _charge(CapacitorChannel $channel, $item, ?callable $func, ?array $args): int { function _charge(CapacitorChannel $channel, $item, $func, ?array $args): int {
$this->_create($channel); $this->_create($channel);
$tableName = $channel->getTableName();
$now = date("Y-m-d H:i:s"); $now = date("Y-m-d H:i:s");
$item__ = serialize($item); $item__ = serialize($item);
$sum_ = sha1($item__); $sum_ = sha1($item__);
@ -73,13 +78,7 @@ class MysqlStorage extends CapacitorStorage {
# modification # modification
$prow = $this->mysql->one([ $prow = $this->mysql->one([
"select", "select",
"cols" => array_merge($primaryKeys, [ "from" => $tableName,
"item__",
"sum_",
"created_",
"modified_",
]),
"from" => $channel->getTableName(),
"where" => $rowIds, "where" => $rowIds,
]); ]);
} }
@ -98,10 +97,12 @@ class MysqlStorage extends CapacitorStorage {
$args = [$item, $values, ...$args]; $args = [$item, $values, ...$args];
} else { } else {
# modification # modification
$row = cl::merge($row, [ if ($sum_ !== $prow["sum_"]) {
"modified_" => $now, $insert = false;
]); $row = cl::merge($row, [
if ($sum_ !== $prow["sum_"]) $insert = false; "modified_" => $now,
]);
}
if ($func === null) $func = "->onUpdate"; if ($func === null) $func = "->onUpdate";
func::ensure_func($func, $channel, $args); func::ensure_func($func, $channel, $args);
$values = $this->unserialize($channel, $row); $values = $this->unserialize($channel, $row);
@ -129,13 +130,13 @@ class MysqlStorage extends CapacitorStorage {
} elseif ($insert) { } elseif ($insert) {
$this->mysql->exec([ $this->mysql->exec([
"insert", "insert",
"into" => $channel->getTableName(), "into" => $tableName,
"values" => $row, "values" => $row,
]); ]);
} else { } else {
$this->mysql->exec([ $this->mysql->exec([
"update", "update",
"table" => $channel->getTableName(), "table" => $tableName,
"values" => $row, "values" => $row,
"where" => $rowIds, "where" => $rowIds,
]); ]);
@ -195,8 +196,9 @@ class MysqlStorage extends CapacitorStorage {
} }
} }
function _each(CapacitorChannel $channel, $filter, ?callable $func, ?array $args): int { function _each(CapacitorChannel $channel, $filter, $func, ?array $args): int {
if ($func === null) $func = [$channel, "onEach"]; if ($func === null) $func = "->onEach";
func::ensure_func($func, $channel, $args);
$onEach = func::_prepare($func); $onEach = func::_prepare($func);
$mysql = $this->mysql; $mysql = $this->mysql;
$tableName = $channel->getTableName(); $tableName = $channel->getTableName();

2
src/db/pdo/Pdo.php
View File

@ -19,8 +19,6 @@ class Pdo {
"config" => $pdo->config, "config" => $pdo->config,
"migrate" => $pdo->migration, "migrate" => $pdo->migration,
], $params)); ], $params));
} elseif (is_array($pdo)) {
return new static(null, cl::merge($pdo, $params));
} else { } else {
return new static($pdo, $params); return new static($pdo, $params);
} }

34
src/db/sqlite/SqliteStorage.php
View File

@ -22,6 +22,10 @@ class SqliteStorage extends CapacitorStorage {
return $this->sqlite; return $this->sqlite;
} }
const PRIMARY_KEY_DEFINITION = [
"id_" => "integer primary key autoincrement",
];
protected function _create(CapacitorChannel $channel): void { protected function _create(CapacitorChannel $channel): void {
if (!$channel->isCreated()) { if (!$channel->isCreated()) {
$cols = $this->ColumnDefinitions($channel); $cols = $this->ColumnDefinitions($channel);
@ -56,8 +60,9 @@ class SqliteStorage extends CapacitorStorage {
$channel->setCreated(false); $channel->setCreated(false);
} }
function _charge(CapacitorChannel $channel, $item, ?callable $func, ?array $args): int { function _charge(CapacitorChannel $channel, $item, $func, ?array $args): int {
$this->_create($channel); $this->_create($channel);
$tableName = $channel->getTableName();
$now = date("Y-m-d H:i:s"); $now = date("Y-m-d H:i:s");
$item__ = serialize($item); $item__ = serialize($item);
$sum_ = sha1($item__); $sum_ = sha1($item__);
@ -71,13 +76,7 @@ class SqliteStorage extends CapacitorStorage {
# modification # modification
$prow = $this->sqlite->one([ $prow = $this->sqlite->one([
"select", "select",
"cols" => array_merge($primaryKeys, [ "from" => $tableName,
"item__",
"sum_",
"created_",
"modified_",
]),
"from" => $channel->getTableName(),
"where" => $rowIds, "where" => $rowIds,
]); ]);
} }
@ -96,10 +95,12 @@ class SqliteStorage extends CapacitorStorage {
$args = [$item, $values, ...$args]; $args = [$item, $values, ...$args];
} else { } else {
# modification # modification
$row = cl::merge($row, [ if ($sum_ !== $prow["sum_"]) {
"modified_" => $now, $insert = false;
]); $row = cl::merge($row, [
if ($sum_ !== $prow["sum_"]) $insert = false; "modified_" => $now,
]);
}
if ($func === null) $func = "->onUpdate"; if ($func === null) $func = "->onUpdate";
func::ensure_func($func, $channel, $args); func::ensure_func($func, $channel, $args);
$values = $this->unserialize($channel, $row); $values = $this->unserialize($channel, $row);
@ -127,13 +128,13 @@ class SqliteStorage extends CapacitorStorage {
} elseif ($insert) { } elseif ($insert) {
$this->sqlite->exec([ $this->sqlite->exec([
"insert", "insert",
"into" => $channel->getTableName(), "into" => $tableName,
"values" => $row, "values" => $row,
]); ]);
} else { } else {
$this->sqlite->exec([ $this->sqlite->exec([
"update", "update",
"table" => $channel->getTableName(), "table" => $tableName,
"values" => $row, "values" => $row,
"where" => $rowIds, "where" => $rowIds,
]); ]);
@ -193,8 +194,9 @@ class SqliteStorage extends CapacitorStorage {
} }
} }
function _each(CapacitorChannel $channel, $filter, ?callable $func, ?array $args): int { function _each(CapacitorChannel $channel, $filter, $func, ?array $args): int {
if ($func === null) $func = [$channel, "onEach"]; if ($func === null) $func = "->onEach";
func::ensure_func($func, $channel, $args);
$onEach = func::_prepare($func); $onEach = func::_prepare($func);
$sqlite = $this->sqlite; $sqlite = $this->sqlite;
$tableName = $channel->getTableName(); $tableName = $channel->getTableName();

2
tests/db/sqlite/SqliteStorageTest.php
View File

@ -77,7 +77,7 @@ class SqliteStorageTest extends TestCase {
}; };
$capacitor->each(["age" => [">", 10]], $setDone, ["++"]); $capacitor->each(["age" => [">", 10]], $setDone, ["++"]);
$capacitor->each(["done" => 0], $setDone, null); $capacitor->each(["done" => 0], $setDone, null);
Txx(cl::all($capacitor->discharge(null, false))); Txx(cl::all($capacitor->discharge(false)));
$capacitor->close(); $capacitor->close();
self::assertTrue(true); self::assertTrue(true);