Files
smeti/bin/smeti_db.inc.php
2020-03-02 11:09:22 +00:00

111 lines
3.9 KiB
PHP

<?php
function clearLine()
{
echo "\033[2K\r";
}
function replaceOut($str)
{
$numNewLines = substr_count($str, "\n");
echo chr(27) . "[0G"; // Set cursor to first column
echo $str;
echo chr(27) . "[" . $numNewLines ."A"; // Set cursor up x lines
}
function progressBar($n, $m)
{
static $maxsize = 80;
static $linesize = 0;
static $even = 0;
if (0 == ($linesize % $maxsize))
{
$even = 1 - $even;
$linesize = 0;
echo chr(27) . "[0G";
printf('[ %010d / %010d ] ', $n, $m);
}
$linesize += 1;
if ($even == 1) echo '.';
else echo 'X';
}
class SMETI_db
{
static $plugin = 0;
static $libelle = '';
static $item = 0;
static $code = '';
static $link = 0;
static $child = 0;
static $parent = 0;
static $rank = 0;
static $pdo;
static $req0;
static $req1;
static $req2;
static $req3;
static function init($pdo_cn_string = 'sqlite:../data/base.sqlite')
{
try{
self::$pdo = new PDO($pdo_cn_string);
self::$pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
self::$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // ERRMODE_WARNING | ERRMODE_EXCEPTION | ERRMODE_SILENT
} catch(Exception $e) {
echo "Impossible d'accéder à la base de données SQLite : ".$e->getMessage();
die();
}
self::$req0 = self::$pdo->prepare('INSERT INTO plugins(libelle) VALUES(:libelle)');
self::$req0->bindParam('libelle', self::$libelle, PDO::PARAM_STR);
self::$req1 = self::$pdo->prepare('INSERT INTO items(plugin, code, libelle) VALUES(:plugin, :code, :libelle)');
self::$req1->bindParam('plugin', self::$plugin, PDO::PARAM_INT);
self::$req1->bindParam('code', self::$code, PDO::PARAM_STR);
self::$req1->bindParam('libelle', self::$libelle, PDO::PARAM_STR);
self::$req2 = self::$pdo->prepare('INSERT INTO links(link, item) VALUES(:link, :item)');
self::$req2->bindParam('link', self::$link, PDO::PARAM_INT);
self::$req2->bindParam('item', self::$item, PDO::PARAM_INT);
self::$req3 = self::$pdo->prepare('INSERT INTO nodes(child, parent, rank) VALUES(:child, :parent, :rank)');
self::$req3->bindParam('child', self::$child, PDO::PARAM_INT);
self::$req3->bindParam('parent', self::$parent, PDO::PARAM_INT);
self::$req3->bindParam('rank', self::$rank, PDO::PARAM_INT);
}
static function removePlugin($plugin_name)
{
$select_clause="SELECT id FROM plugins WHERE libelle = '$plugin_name'";
// Parce que je n'ai pas réussi à faire correctement marcher le DELETE CASCADE !
self::$pdo->exec("DELETE FROM nodes WHERE parent IN (SELECT DISTINCT id FROM v_items WHERE plugin IN ( $select_clause ))");
self::$pdo->exec("DELETE FROM nodes WHERE child IN (SELECT DISTINCT id FROM v_items WHERE plugin IN ( $select_clause ))");
self::$pdo->exec("DELETE FROM links WHERE item IN (SELECT DISTINCT id FROM items WHERE plugin IN ( $select_clause ))");
self::$pdo->exec("DELETE FROM links WHERE link = 1 AND id IN ( SELECT id FROM v_items_tree WHERE parent IS NULL)");
self::$pdo->exec("DELETE FROM items WHERE plugin IN ( $select_clause)");
self::$pdo->exec("DELETE FROM plugins WHERE libelle = '$plugin_name' ");
// Parce que je n'ai pas réussi à faire correctement marcher le DELETE CASCADE !
self::$pdo->exec('VACUUM');
}
static function addPlugin($plugin_name)
{
self::$libelle = $plugin_name;
self::$req0->execute();
self::$plugin = self::$pdo->lastInsertId();
}
static function setCurPlugin($plugin_name)
{
$sql = self::$pdo->prepare("SELECT id FROM plugins WHERE libelle = '$plugin_name'");
$sql->execute();
$row = $sql->fetch(PDO::FETCH_NUM);
self::$plugin = $row[0];
}
}
?>