Compare commits
No commits in common. "c2773db2dd6d92ffb98d8347c5c6c3b0a5848971" and "55e67bd8c2e875b608819b785ab4b43ffa7c5ca3" have entirely different histories.
c2773db2dd
...
55e67bd8c2
@ -1,65 +0,0 @@
|
|||||||
<?php
|
|
||||||
/*
|
|
||||||
TPsoft.org 2000-2025
|
|
||||||
file for controlers/*.php
|
|
||||||
|
|
||||||
Molestones:
|
|
||||||
2025-05-27 21:36 Created
|
|
||||||
*/
|
|
||||||
|
|
||||||
class Test extends \TPsoft\DBmodel\DBmodel {
|
|
||||||
|
|
||||||
public $tables = array(
|
|
||||||
'test' => array(
|
|
||||||
'name' => 'test',
|
|
||||||
'primary_key_name' => 'id',
|
|
||||||
'allow_attributes' => array(
|
|
||||||
'name' => 'varchar(255)',
|
|
||||||
'created' => 'datetime'
|
|
||||||
)
|
|
||||||
),
|
|
||||||
);
|
|
||||||
|
|
||||||
public function exist($primary_key = null) {
|
|
||||||
return $this->existRecord('test', $primary_key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public function test($primary_key = null, $data = array()) {
|
|
||||||
return $this->record('test', $primary_key, $data);
|
|
||||||
}
|
|
||||||
|
|
||||||
public function testBy($colname, $colvalue) {
|
|
||||||
return $this->recordBy('test', $colname, $colvalue);
|
|
||||||
}
|
|
||||||
|
|
||||||
public function testSave($data = array()) {
|
|
||||||
return $this->test($this->exist($data) ? $data : null, $data);
|
|
||||||
}
|
|
||||||
|
|
||||||
public function testEmpty() {
|
|
||||||
return $this->recordEmpty('test');
|
|
||||||
}
|
|
||||||
|
|
||||||
public function testAttributes() {
|
|
||||||
return $this->typesAttributes('test');
|
|
||||||
}
|
|
||||||
|
|
||||||
public function testCount() {
|
|
||||||
return $this->count('test');
|
|
||||||
}
|
|
||||||
|
|
||||||
public function getList($search = array(), $reverse = false, $concat_or = false) {
|
|
||||||
return $this->search('test')
|
|
||||||
->where($search, $concat_or)
|
|
||||||
->order(array('id' => $reverse ? 'DESC' : 'ASC'))
|
|
||||||
->toArray();
|
|
||||||
}
|
|
||||||
|
|
||||||
public function testCombo($col_key, $col_value, $add_empty = false) {
|
|
||||||
return $this->search('test')
|
|
||||||
->toCombo($col_key, $col_value, $add_empty);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
?>
|
|
||||||
@ -27,7 +27,7 @@ class DBmodel
|
|||||||
public $log = null;
|
public $log = null;
|
||||||
public $tables = array();
|
public $tables = array();
|
||||||
|
|
||||||
public function __construct(?string $dsn = null, ?string $username = null, #[\SensitiveParameter] ?string $password = null, ?array $options = null)
|
public function __construct(string $dsn = null, ?string $username = null, #[\SensitiveParameter] ?string $password = null, ?array $options = null)
|
||||||
{
|
{
|
||||||
if (is_null($dsn)) {
|
if (is_null($dsn)) {
|
||||||
if (DBmodel::$instance) {
|
if (DBmodel::$instance) {
|
||||||
|
|||||||
@ -1,225 +0,0 @@
|
|||||||
<?php
|
|
||||||
/*
|
|
||||||
Copyright (c) TPsoft.org 2000-2025
|
|
||||||
Author: Ing. Igor Mino <mino@tpsoft.org>
|
|
||||||
License: GNU GPL-3.0 or later
|
|
||||||
|
|
||||||
Description: Tool for automatic maintenance of database in your project.
|
|
||||||
Version: 1.0.0
|
|
||||||
|
|
||||||
Milestones:
|
|
||||||
2025-05-29 07:59 Igor - Forked from Beteha to standalone public library
|
|
||||||
*/
|
|
||||||
|
|
||||||
namespace TPsoft\DBmodel;
|
|
||||||
|
|
||||||
class Maintenance
|
|
||||||
{
|
|
||||||
public const ABNORMAL = 0;
|
|
||||||
public const OK = 1;
|
|
||||||
public const FIXED = 2;
|
|
||||||
public const FIX_FAILED = 3;
|
|
||||||
public const UPDATED = 4;
|
|
||||||
public const UPDATE_FAIL = 5;
|
|
||||||
|
|
||||||
public string $lastMessage = '';
|
|
||||||
|
|
||||||
private DBmodel $dbh;
|
|
||||||
|
|
||||||
public function __construct(?DBmodel $dbh)
|
|
||||||
{
|
|
||||||
if (is_null($dbh)) {
|
|
||||||
if (!is_null(DBmodel::$instance)) {
|
|
||||||
$this->dbh = DBmodel::$instance;
|
|
||||||
} else {
|
|
||||||
throw new \Exception('DB handler is null');
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
$this->dbh = $dbh;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public function testDB($test, $test_out)
|
|
||||||
{
|
|
||||||
if (is_array($test_out)) {
|
|
||||||
$test_out = array_change_key_case($test_out, CASE_LOWER);
|
|
||||||
$row = $this->dbh->getRow($test);
|
|
||||||
if (!is_array($row)) return false;
|
|
||||||
$row = array_change_key_case($row, CASE_LOWER);
|
|
||||||
foreach ($test_out as $col => $val) {
|
|
||||||
if (strlen($row[$col]) != strlen($val)) {
|
|
||||||
$max_len = min(strlen($row[$col]), strlen($val));
|
|
||||||
if (substr(strtolower($row[$col]), 0, $max_len) != substr(strtolower($val), 0, $max_len)) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
if (strtolower($row[$col]) != strtolower($val)) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return true;
|
|
||||||
} else {
|
|
||||||
return $this->dbh->getOne($test) == $test_out;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public function checkDB($test, $test_out, $fix)
|
|
||||||
{
|
|
||||||
if ($this->testDB($test, $test_out)) {
|
|
||||||
return Maintenance::OK;
|
|
||||||
} else {
|
|
||||||
$this->dbh->query($fix);
|
|
||||||
if ($this->testDB($test, $test_out)) {
|
|
||||||
return Maintenance::FIXED;
|
|
||||||
} else {
|
|
||||||
return Maintenance::FIX_FAILED;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
public function checkDBTable($table_name, $definition)
|
|
||||||
{
|
|
||||||
if (strlen($table_name) <= 0) {
|
|
||||||
$this->lastMessage = 'Table ' . strtoupper($table_name) . ' - invalid index';
|
|
||||||
return Maintenance::ABNORMAL;
|
|
||||||
}
|
|
||||||
$status = $this->checkDB(
|
|
||||||
// TEST query
|
|
||||||
'SHOW TABLES LIKE "' . $table_name . '"',
|
|
||||||
// TEST output
|
|
||||||
$table_name,
|
|
||||||
// FIX query
|
|
||||||
'CREATE TABLE `' . $table_name . '` (' . $definition . ')'
|
|
||||||
);
|
|
||||||
$this->lastMessage = 'Table ' . strtoupper($table_name) . ' (' . $table_name . ')';
|
|
||||||
return $status;
|
|
||||||
}
|
|
||||||
|
|
||||||
public function existsColumn($table_name, $column)
|
|
||||||
{
|
|
||||||
return $this->testDB(
|
|
||||||
'DESCRIBE `' . $table_name . '` `' . $column . '`',
|
|
||||||
$column
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
public function checkDBAdd($table_name, $column, $definition)
|
|
||||||
{
|
|
||||||
$status = $this->checkDB(
|
|
||||||
// TEST query
|
|
||||||
'DESCRIBE `' . $table_name . '` `' . $column . '`',
|
|
||||||
// TEST output
|
|
||||||
$column,
|
|
||||||
// FIX query
|
|
||||||
'ALTER TABLE `' . $table_name . '` ADD `' . $column . '` ' . $definition
|
|
||||||
);
|
|
||||||
$this->lastMessage = "Added column $column to table $table_name";
|
|
||||||
return $status;
|
|
||||||
}
|
|
||||||
|
|
||||||
public function checkDBRename($table_name, $column_old, $column_new, $definition, $test = null)
|
|
||||||
{
|
|
||||||
if (!$this->existsColumn($table_name, $column_old)) {
|
|
||||||
return Maintenance::ABNORMAL;
|
|
||||||
}
|
|
||||||
$status = $this->checkDB(
|
|
||||||
// TEST query
|
|
||||||
'DESCRIBE `' . $table_name . '` `' . $column_old . '`',
|
|
||||||
// TEST output
|
|
||||||
$test,
|
|
||||||
// FIX query
|
|
||||||
'ALTER TABLE `' . $table_name . '` CHANGE `' . $column_old . '` `' . $column_new . '` ' . $definition
|
|
||||||
);
|
|
||||||
$this->lastMessage = "Renamed column $column_old to $column_new for $table_name";
|
|
||||||
return $status;
|
|
||||||
}
|
|
||||||
|
|
||||||
public function checkDBRetype($table_name, $column, $new_type, $definition)
|
|
||||||
{
|
|
||||||
if (!$this->existsColumn($table_name, $column_old)) {
|
|
||||||
return Maintenance::ABNORMAL;
|
|
||||||
}
|
|
||||||
$status = $this->checkDB(
|
|
||||||
// TEST query
|
|
||||||
'DESCRIBE `' . $table_name . '` `' . $column . '`',
|
|
||||||
// TEST output
|
|
||||||
array('type' => strtolower($new_type)),
|
|
||||||
// FIX query
|
|
||||||
'ALTER TABLE `' . $table_name . '` CHANGE `' . $column . '` `' . $column . '` ' . $definition
|
|
||||||
);
|
|
||||||
$this->lastMessage = "Changed type of column $column for table " . strtoupper($table_name) . " to tyoe " . strtoupper($new_type);
|
|
||||||
return $status;
|
|
||||||
}
|
|
||||||
|
|
||||||
public function checkDBRemove($table_name, $column)
|
|
||||||
{
|
|
||||||
$status = $this->checkDB(
|
|
||||||
// TEST query
|
|
||||||
'DESCRIBE `' . $table_name . '` `' . $column . '`',
|
|
||||||
// TEST output
|
|
||||||
NULL,
|
|
||||||
// FIX query
|
|
||||||
'ALTER TABLE `' . $table_name . '` DROP COLUMN `' . $column . '`'
|
|
||||||
);
|
|
||||||
$this->lastMessage = "Removed column $column for " . strtoupper($table_name);
|
|
||||||
return $status;
|
|
||||||
}
|
|
||||||
|
|
||||||
public function addKey($table_name, $key)
|
|
||||||
{
|
|
||||||
$test = 'SHOW INDEX FROM `' . $table_name . '` WHERE column_name = "' . $key . '"';
|
|
||||||
$test_out = array('table' => $table_name);
|
|
||||||
if ($this->testDB($test, $test_out)) {
|
|
||||||
$status = Maintenance::OK;
|
|
||||||
} else {
|
|
||||||
$fix = 'CREATE INDEX `' . $key . '` ON `' . $table_name . '` (`' . $key . '`)';
|
|
||||||
$this->dbh->query($fix);
|
|
||||||
if ($this->testDB($test, $test_out)) {
|
|
||||||
$status = Maintenance::FIXED;
|
|
||||||
} else {
|
|
||||||
$status = Maintenance::FIX_FAILED;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
$this->lastMessage = 'Added KEY ' . $key . ' for ' . strtoupper($table_name);
|
|
||||||
return $status;
|
|
||||||
}
|
|
||||||
|
|
||||||
public function dropKey($table_name, $key)
|
|
||||||
{
|
|
||||||
$test = 'SHOW INDEX FROM `' . $table_name . '` WHERE column_name = "' . $key . '"';
|
|
||||||
$test_out = null;
|
|
||||||
if ($this->testDB($test, $test_out)) {
|
|
||||||
$status = Maintenance::OK;
|
|
||||||
} else {
|
|
||||||
$index_info = $this->dbh->getRow('SHOW INDEX FROM `' . $table_name . '` WHERE column_name = "' . $key . '"');
|
|
||||||
$index_info = array_change_key_case($index_info, CASE_LOWER);
|
|
||||||
$index_name = $index_info['key_name'];
|
|
||||||
$fix = 'ALTER TABLE `' . $table_name . '` DROP INDEX `' . $index_name . '`';
|
|
||||||
$this->dbh->query($fix);
|
|
||||||
if ($this->testDB($test, $test_out)) {
|
|
||||||
$status = Maintenance::FIXED;
|
|
||||||
} else {
|
|
||||||
$status = Maintenance::FIX_FAILED;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
$this->lastMessage = 'Deleted KEY ' . $key . ' for ' . strtoupper($table_name);
|
|
||||||
return $status;
|
|
||||||
}
|
|
||||||
|
|
||||||
public function updateDB($test, $test_out, $update)
|
|
||||||
{
|
|
||||||
if (!$this->testDB($test, $test_out)) {
|
|
||||||
return Maintenance::OK;
|
|
||||||
} else {
|
|
||||||
$suc = $this->dbh->query($update);
|
|
||||||
if ($suc !== false) {
|
|
||||||
return Maintenance::UPDATED;
|
|
||||||
} else {
|
|
||||||
return Maintenance::UPDATE_FAIL;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,41 +0,0 @@
|
|||||||
<?php
|
|
||||||
|
|
||||||
require_once __DIR__.'/../src/DBmodel.php';
|
|
||||||
require_once __DIR__.'/../src/Maintenance.php';
|
|
||||||
|
|
||||||
$db = new \TPsoft\DBmodel\DBmodel('mysql:host=127.0.0.1;dbname=test;charset=utf8mb4', 'test', 'test');
|
|
||||||
|
|
||||||
$maintenance = new \TPsoft\DBmodel\Maintenance($db);
|
|
||||||
|
|
||||||
$suc = $maintenance->checkDBTable('users', '
|
|
||||||
`id` int(11) NOT NULL AUTO_INCREMENT,
|
|
||||||
`name` varchar(255) DEFAULT NULL,
|
|
||||||
`email` varchar(255) DEFAULT NULL,
|
|
||||||
PRIMARY KEY (`id`)
|
|
||||||
');
|
|
||||||
echo "\nCheckDBTable: "; var_dump($suc);
|
|
||||||
|
|
||||||
$suc = $maintenance->checkDBAdd('users', 'password', 'varchar(255) DEFAULT NULL');
|
|
||||||
echo "\nCheckDBAdd: "; var_dump($suc);
|
|
||||||
|
|
||||||
$suc = $maintenance->existsColumn('users', 'email');
|
|
||||||
echo "\nExistsColumn: "; var_dump($suc);
|
|
||||||
|
|
||||||
$suc = $maintenance->checkDBRename('users', 'email', 'email_new', 'varchar(255) DEFAULT NULL');
|
|
||||||
echo "\nCheckDBRename: "; var_dump($suc);
|
|
||||||
|
|
||||||
$suc = $maintenance->checkDBRetype('users', 'email_new', 'varchar(128)', 'varchar(128) DEFAULT NULL AFTER `password`');
|
|
||||||
echo "\nCheckDBRetype: "; var_dump($suc);
|
|
||||||
|
|
||||||
$suc = $maintenance->checkDBRemove('users', 'email_new');
|
|
||||||
echo "\nCheckDBRemove: "; var_dump($suc);
|
|
||||||
|
|
||||||
$suc = $maintenance->addKey('users', 'name');
|
|
||||||
echo "\nAddKey: "; var_dump($suc);
|
|
||||||
|
|
||||||
$suc = $maintenance->dropKey('users', 'name');
|
|
||||||
echo "\nDropKey: "; var_dump($suc);
|
|
||||||
|
|
||||||
echo "\nDone\n\n";
|
|
||||||
|
|
||||||
?>
|
|
||||||
Loading…
x
Reference in New Issue
Block a user