91 lines
2.5 KiB
PHP
91 lines
2.5 KiB
PHP
|
#!/usr/bin/php
|
||
|
|
<?php
|
||
|
|
require $_composer_autoload_path?? __DIR__.'/../vendor/autoload.php';
|
||
|
|
|
||
|
|
use nur\b\io\CacheFile;
|
||
|
|
use nur\cli\Application;
|
||
|
|
use nur\config;
|
||
|
|
use nur\msg;
|
||
|
|
use nur\path;
|
||
|
|
use nur\sery\db\Capacitor;
|
||
|
|
use nur\sery\db\CapacitorChannel;
|
||
|
|
use nur\sery\db\mysql\MysqlStorage;
|
||
|
|
use nur\sery\db\sqlite\SqliteStorage;
|
||
|
|
use nur\yaml;
|
||
|
|
|
||
|
|
Application::run(new class extends Application {
|
||
|
|
const ARGS = [
|
||
|
|
"merge" => parent::ARGS,
|
||
|
|
"purpose" => "gestion d'un capacitor mysql",
|
||
|
|
"usage" => "-d DBCONN -c CHANNEL key=value...",
|
||
|
|
["-d", "--dbconn", "args" => 1,
|
||
|
|
"help" => "nom de la connexion à la base de données",
|
||
|
|
],
|
||
|
|
["-c", "--channel", "args" => 1,
|
||
|
|
"help" => "nom de la table porteuse du canal de données",
|
||
|
|
],
|
||
|
|
];
|
||
|
|
|
||
|
|
protected $dbconn;
|
||
|
|
|
||
|
|
protected $channel;
|
||
|
|
|
||
|
|
protected $args;
|
||
|
|
|
||
|
|
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);
|
||
|
|
}
|
||
|
|
|
||
|
|
function main() {
|
||
|
|
$dbconn = $this->dbconn;
|
||
|
|
if ($dbconn === null) self::die("Vous devez spécifier la base de données");
|
||
|
|
$tmp = config::db($dbconn);
|
||
|
|
if ($tmp === null) self::die("$dbconn: base de données invalide");
|
||
|
|
$dbconn = $tmp;
|
||
|
|
|
||
|
|
if ($this->channel === null) self::die("Vous devez spécifier le canal de données");
|
||
|
|
|
||
|
|
$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);
|
||
|
|
|
||
|
|
$args = $this->args;
|
||
|
|
if (!$args) {
|
||
|
|
# lister les id
|
||
|
|
$rows = $storage->mysql()->all([
|
||
|
|
"select id_",
|
||
|
|
"from" => $channel->getTableName(),
|
||
|
|
]);
|
||
|
|
foreach ($rows as $row) {
|
||
|
|
echo "$row[id_]\n";
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
# afficher les lignes correspondantes
|
||
|
|
if (count($args) == 1 && !self::isa_cond($args[0])) {
|
||
|
|
$filter = $args[0];
|
||
|
|
} else {
|
||
|
|
$filter = [];
|
||
|
|
$ms = null;
|
||
|
|
foreach ($args as $arg) {
|
||
|
|
if (self::isa_cond($arg, $ms)) {
|
||
|
|
$filter[$ms[1]] = [$ms[2], $ms[3]];
|
||
|
|
} else {
|
||
|
|
$filter[$arg] = ["not null"];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
$first = true;
|
||
|
|
$capacitor->each($filter, function ($item, $row) use (&$first) {
|
||
|
|
if ($first) $first = false;
|
||
|
|
else echo "---\n";
|
||
|
|
yaml::dump($row);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
}
|
||
|
|
});
|