51a0276268
Move autolaoder loading from config.master.php to config.php and before we read config.master.php The read env function has moved into a class and is launched after the auto loader has been loaded DB IO class update with better error reporting with last error set and error history of all errors in order. TODO: per query or per action error grouping
351 lines
12 KiB
PHP
351 lines
12 KiB
PHP
<?php // phpcs:ignore warning
|
|
|
|
/**
|
|
* @phan-file-suppress PhanTypeSuspiciousStringExpression
|
|
*/
|
|
|
|
declare(strict_types=1);
|
|
|
|
// turn on all error reporting
|
|
error_reporting(E_ALL | E_STRICT | E_ERROR | E_WARNING | E_PARSE | E_COMPILE_ERROR);
|
|
|
|
ob_start();
|
|
|
|
// basic class test file
|
|
define('USE_DATABASE', true);
|
|
// sample config
|
|
require 'config.php';
|
|
// override ECHO ALL FALSE
|
|
$ECHO_ALL = true;
|
|
// define log file id
|
|
$LOG_FILE_ID = 'classTest-db';
|
|
ob_end_flush();
|
|
|
|
use CoreLibs\Debug\Support as DgS;
|
|
use CoreLibs\DB\IO as DbIo;
|
|
use CoreLibs\Debug\Support;
|
|
|
|
$log = new CoreLibs\Debug\Logging([
|
|
'log_folder' => BASE . LOG,
|
|
'file_id' => $LOG_FILE_ID,
|
|
// add file date
|
|
'print_file_date' => true,
|
|
// set debug and print flags
|
|
'debug_all' => $DEBUG_ALL ?? false,
|
|
'echo_all' => $ECHO_ALL ?? false,
|
|
'print_all' => $PRINT_ALL ?? false,
|
|
]);
|
|
// $basic = new CoreLibs\Basic($log, EDIT_SESSION_NAME);
|
|
//start session
|
|
\CoreLibs\Create\Session::startSession(EDIT_SESSION_NAME);
|
|
// db connection and attach logger
|
|
$db = new CoreLibs\Admin\Backend(DB_CONFIG, $log);
|
|
$db->log->debug('START', '=============================>');
|
|
|
|
print "<html><head><title>TEST CLASS: DB</title><head>";
|
|
print "<body>";
|
|
print '<div><a href="class_test.php">Class Test Master</a></div>';
|
|
|
|
print "LOGFILE NAME: " . $db->log->getSetting('log_file_name') . "<br>";
|
|
print "LOGFILE ID: " . $db->log->getSetting('log_file_id') . "<br>";
|
|
print "DBINFO: " . $db->dbInfo() . "<br>";
|
|
echo "DB_CONFIG_SET constant: <pre>" . print_r(DB_CONFIG, true) . "</pre><br>";
|
|
|
|
// DB client encoding
|
|
print "DB Client encoding: " . $db->dbGetEncoding() . "<br>";
|
|
|
|
while (is_array($res = $db->dbReturn("SELECT * FROM max_test", DbIo::USE_CACHE, true))) {
|
|
print "TIME: " . $res['time'] . "<br>";
|
|
}
|
|
print "CACHED DATA: <pre>" . print_r($db->cursor_ext, true) . "</pre><br>";
|
|
while (is_array($res = $db->dbReturn("SELECT * FROM max_test"))) {
|
|
print "[CACHED] TIME: " . $res['time'] . "<br>";
|
|
}
|
|
// alternate check for valid data
|
|
// while (($res = $db->dbReturn("SELECT * FROM max_test")) !== false) {
|
|
// print "[CACHED] TIME: " . $res['time'] . "<br>";
|
|
// }
|
|
|
|
print "<pre>";
|
|
|
|
// truncate test_foo table before testing
|
|
print "<b>TRUNCATE test_foo</b><br>";
|
|
$query = "TRUNCATE test_foo";
|
|
$db->dbExec($query);
|
|
print "<b>TRUNCATE test_foobar</b><br>";
|
|
$query = "TRUNCATE test_foobar";
|
|
$db->dbExec($query);
|
|
|
|
$status = $db->dbExec("INSERT INTO test_foo (test) VALUES ('FOO TEST " . time() . "') RETURNING test");
|
|
print "DIRECT INSERT STATUS: " . Support::printToString($status) . "| "
|
|
. "DB OBJECT: <pre>" . print_r($status, true) . "</pre>| "
|
|
. "PRIMARY KEY: " . $db->dbGetInsertPK() . " | "
|
|
. "RETURNING EXT: " . print_r($db->dbGetReturningExt(), true) . " | "
|
|
. "RETURNING EXT[test]: " . print_r($db->dbGetReturningExt('test'), true) . " | "
|
|
. "RETURNING ARRAY: " . print_r($db->dbGetReturningArray(), true) . "<br>";
|
|
|
|
// should throw deprecated error
|
|
// $db->getReturningExt();
|
|
print "DIRECT INSERT PREVIOUS INSERTED: "
|
|
. print_r($db->dbReturnRow("SELECT test_foo_id, test FROM test_foo "
|
|
. "WHERE test_foo_id = " . $db->dbGetInsertPK()), true) . "<br>";
|
|
|
|
// PREPARED INSERT
|
|
$db->dbPrepare("ins_test_foo", "INSERT INTO test_foo (test) VALUES ($1) RETURNING test");
|
|
$status = $db->dbExecute("ins_test_foo", ['BAR TEST ' . time()]);
|
|
print "PREPARE INSERT[ins_test_foo] STATUS: " . Support::printToString($status) . " | "
|
|
. "PRIMARY KEY: " . $db->dbGetInsertPK() . " | "
|
|
. "RETURNING EXT: " . print_r($db->dbGetReturningExt(), true) . " | "
|
|
. "RETURNING RETURN: " . print_r($db->dbGetReturningArray(), true) . "<br>";
|
|
|
|
print "PREPARE INSERT PREVIOUS INSERTED: "
|
|
. print_r($db->dbReturnRow("SELECT test_foo_id, test FROM test_foo "
|
|
. "WHERE test_foo_id = " . $db->dbGetInsertPK()), true) . "<br>";
|
|
// returning test with multiple entries
|
|
// $status = $db->db_exec(
|
|
// "INSERT INTO test_foo (test) VALUES "
|
|
// . "('BAR 1 " . time() . "'), "
|
|
// . "('BAR 2 " . time() . "'), "
|
|
// . "('BAR 3 " . time() . "') "
|
|
// . "RETURNING test_foo_id"
|
|
// );
|
|
$status = $db->dbExec(
|
|
"INSERT INTO test_foo (test) VALUES "
|
|
. "('BAR 1 " . time() . "'), "
|
|
. "('BAR 2 " . time() . "'), "
|
|
. "('BAR 3 " . time() . "') "
|
|
. "RETURNING test_foo_id, test"
|
|
);
|
|
print "DIRECT MULTIPLE INSERT WITH RETURN STATUS: " . Support::printToString($status) . " | "
|
|
. "PRIMARY KEYS: " . print_r($db->dbGetInsertPK(), true) . " | "
|
|
. "RETURNING EXT: " . print_r($db->dbGetReturningExt(), true) . " | "
|
|
. "RETURNING EXT[test]: " . print_r($db->dbGetReturningExt('test'), true) . " | "
|
|
. "RETURNING ARRAY: " . print_r($db->dbGetReturningArray(), true) . "<br>";
|
|
|
|
// no returning, but not needed ;
|
|
$status = $db->dbExec("INSERT INTO test_foo (test) VALUES ('FOO; TEST " . time() . "');");
|
|
print "DIRECT INSERT NO RETURN STATUS: " . Support::printToString($status) . " | "
|
|
. "PRIMARY KEY: " . $db->dbGetInsertPK() . " | "
|
|
. "RETURNING EXT: " . print_r($db->dbGetReturningExt(), true) . " | "
|
|
. "RETURNING ARRAY: " . print_r($db->dbGetReturningArray(), true) . "<br>";
|
|
$last_insert_pk = $db->dbGetInsertPK();
|
|
|
|
// is_array read test
|
|
$q = "SELECT test_foo_id, test FROM test_foo WHERE test_foo_id = " . $last_insert_pk;
|
|
if (is_array($s_res = $db->dbReturnRow($q)) && !empty($s_res['test'])) {
|
|
print "WE HAVE DATA FOR: " . $last_insert_pk . " WITH: " . $s_res['test'] . "<br>";
|
|
}
|
|
|
|
// UPDATE WITH RETURNING
|
|
$status = $db->dbExec("UPDATE test_foo SET test = 'SOMETHING DIFFERENT' "
|
|
. "WHERE test_foo_id = " . $last_insert_pk . " RETURNING test");
|
|
print "UPDATE WITH PK " . $last_insert_pk
|
|
. " RETURN STATUS: " . Support::printToString($status) . " | "
|
|
. "RETURNING EXT: " . print_r($db->dbGetReturningExt(), true) . " | "
|
|
. "RETURNING ARRAY: " . print_r($db->dbGetReturningArray(), true) . "<br>";
|
|
|
|
|
|
// INSERT WITH NO RETURNING
|
|
$status = $db->dbExec("INSERT INTO test_foobar (type, integer) VALUES ('WITH DATA', 123)");
|
|
print "INSERT WITH NO PRIMARY KEY NO RETURNING STATUS: " . Support::printToString($status) . " | "
|
|
. "PRIMARY KEY: " . $db->dbGetInsertPK() . " | "
|
|
. "RETURNING EXT: " . print_r($db->dbGetReturningExt(), true) . " | "
|
|
. "RETURNING ARRAY: " . print_r($db->dbGetReturningArray(), true) . "<br>";
|
|
|
|
$status = $db->dbExec("INSERT INTO test_foobar (type, integer) VALUES ('WITH DATA', 123) RETURNING type, integer");
|
|
print "INSERT WITH NO PRIMARY KEY WITH RETURNING STATUS: " . Support::printToString($status) . " | "
|
|
. "PRIMARY KEY: " . $db->dbGetInsertPK() . " | "
|
|
. "RETURNING EXT: " . print_r($db->dbGetReturningExt(), true) . " | "
|
|
. "RETURNING ARRAY: " . print_r($db->dbGetReturningArray(), true) . "<br>";
|
|
|
|
print "</pre>";
|
|
|
|
// READ PREPARE
|
|
if (
|
|
$db->dbPrepare(
|
|
'sel_test_foo',
|
|
"SELECT test_foo_id, test, some_bool, string_a, number_a, number_a_numeric, some_time "
|
|
. "FROM test_foo ORDER BY test_foo_id DESC LIMIT 5"
|
|
) === false
|
|
) {
|
|
print "Error in sel_test_foo prepare<br>";
|
|
} else {
|
|
$max_rows = 6;
|
|
// do not run this in dbFetchArray directly as
|
|
// dbFetchArray(dbExecute(...))
|
|
// this will end in an endless loop
|
|
$cursor = $db->dbExecute('sel_test_foo', []);
|
|
$i = 1;
|
|
while (($res = $db->dbFetchArray($cursor, true)) !== false) {
|
|
print "DB PREP EXEC FETCH ARR: " . $i . ": <pre>" . print_r($res, true) . "</pre><br>";
|
|
$i++;
|
|
}
|
|
}
|
|
|
|
|
|
# db write class test
|
|
$table = 'test_foo';
|
|
print "TABLE META DATA: " . DgS::printAr($db->dbShowTableMetaData($table)) . "<br>";
|
|
// insert first, then use primary key to update
|
|
$primary_key = ''; # unset
|
|
$db_write_table = ['test', 'string_a', 'number_a', 'some_bool'];
|
|
$object_fields_not_touch = [];
|
|
$object_fields_not_update = [];
|
|
$data = [
|
|
'test' => 'dbWriteDataExt: BOOL TEST SOMETHING ' . time(), 'string_a' => 'SOME TEXT', 'number_a' => 5
|
|
];
|
|
$primary_key = $db->dbWriteDataExt(
|
|
$db_write_table,
|
|
$primary_key,
|
|
$table,
|
|
$object_fields_not_touch,
|
|
$object_fields_not_update,
|
|
$data
|
|
);
|
|
print "Wrote to DB tabel $table with data " . print_r($data, true) . " and got primary key $primary_key<br>";
|
|
$data = [
|
|
'test' => 'dbWriteDataExt: BOOL TEST ON ' . time(), 'string_a' => '', 'number_a' => 0, 'some_bool' => 1
|
|
];
|
|
$primary_key = $db->dbWriteDataExt(
|
|
$db_write_table,
|
|
$primary_key,
|
|
$table,
|
|
$object_fields_not_touch,
|
|
$object_fields_not_update,
|
|
$data
|
|
);
|
|
print "Wrote to DB tabel $table with data " . print_r($data, true) . " and got primary key $primary_key<br>";
|
|
$data = [
|
|
'test' => 'dbWriteDataExt: BOOL TEST OFF ' . time(), 'string_a' => null, 'number_a' => null, 'some_bool' => 0
|
|
];
|
|
$primary_key = $db->dbWriteDataExt(
|
|
$db_write_table,
|
|
$primary_key,
|
|
$table,
|
|
$object_fields_not_touch,
|
|
$object_fields_not_update,
|
|
$data
|
|
);
|
|
print "Wrote to DB tabel $table with data " . print_r($data, true) . " and got primary key $primary_key<br>";
|
|
$data = [
|
|
'test' => 'dbWriteDataExt: BOOL TEST UNSET ' . time()
|
|
];
|
|
$primary_key = $db->dbWriteDataExt(
|
|
$db_write_table,
|
|
$primary_key,
|
|
$table,
|
|
$object_fields_not_touch,
|
|
$object_fields_not_update,
|
|
$data
|
|
);
|
|
print "Wrote to DB tabel $table with data " . print_r($data, true) . " and got primary key $primary_key<br>";
|
|
|
|
// return Array Test
|
|
$query = "SELECT type, sdate, integer FROM foobar";
|
|
$data = $db->dbReturnArray($query, true);
|
|
print "Full foobar list: <br><pre>" . print_r($data, true) . "</pre><br>";
|
|
|
|
// trigger a warning
|
|
print "<b>WARNING NEXT</b><br>";
|
|
// trigger an error
|
|
print "<b>ERROR NEXT</b><br>";
|
|
$query = "INSERT invalid FROM invalid";
|
|
$data = $db->dbReturnArray($query);
|
|
print "ERROR (INS ON dbExec): <pre>" . print_r($db->dbGetErrorHistory(true), true) . "</pre><br>";
|
|
$query = "SELECT invalid FROM invalid";
|
|
$data = $db->dbReturnArray($query);
|
|
print "ERROR (HARD ERROR): <pre>" . print_r($db->dbGetErrorHistory(true), true) . "</pre><br>";
|
|
|
|
// how to handle HARD errors
|
|
|
|
# async test queries
|
|
/*
|
|
$db->dbExecAsync("SELECT test FROM test_foo, (SELECT pg_sleep(10)) as sub WHERE test_foo_id IN (27, 50, 67, 44, 10)");
|
|
echo "WAITING FOR ASYNC: ";
|
|
$chars = ['|', '/', '-', '\\'];
|
|
while (($ret = $db->dbCheckAsync()) === true)
|
|
{
|
|
if ((list($_, $char) = each($chars)) === FALSE)
|
|
{
|
|
reset($chars);
|
|
list($_, $char) = each($chars);
|
|
}
|
|
print $char;
|
|
sleep(1);
|
|
flush();
|
|
}
|
|
print "<br>END STATUS: " . $ret . "<br>";
|
|
// while ($res = $db->dbFetchArray($ret))
|
|
while ($res = $db->dbFetchArray())
|
|
{
|
|
echo "RES: " . $res['test'] . "<br>";
|
|
}
|
|
# test async insert
|
|
$db->dbExecAsync("INSERT INTO test_foo (Test) VALUES ('ASYNC TEST " . time() . "')");
|
|
echo "WAITING FOR ASYNC INSERT: ";
|
|
while (($ret = $db->dbCheckAsync()) === true)
|
|
{
|
|
print " . ";
|
|
sleep(1);
|
|
flush();
|
|
}
|
|
print "<br>END STATUS: " . $ret . " | PK: " . $db->insert_id . "<br>";
|
|
print "ASYNC PREVIOUS INSERTED: "
|
|
. print_r(
|
|
$db->dbReturnRow("SELECT test_foo_id, test FROM test_foo WHERE test_foo_id = "
|
|
. $db->insert_id),
|
|
true
|
|
) . "<br>";
|
|
*/
|
|
|
|
$to_db_version = '9.1.9';
|
|
print "VERSION DB: " . $db->dbVersion() . "<br>";
|
|
print "DB Version smaller $to_db_version: " . $db->dbCompareVersion('<' . $to_db_version) . "<br>";
|
|
print "DB Version smaller than $to_db_version: " . $db->dbCompareVersion('<=' . $to_db_version) . "<br>";
|
|
print "DB Version equal $to_db_version: " . $db->dbCompareVersion('=' . $to_db_version) . "<br>";
|
|
print "DB Version bigger than $to_db_version: " . $db->dbCompareVersion('>=' . $to_db_version) . "<br>";
|
|
print "DB Version bigger $to_db_version: " . $db->dbCompareVersion('>' . $to_db_version) . "<br>";
|
|
|
|
/*
|
|
$q = "Select * from test_foo";
|
|
$test_foo = $db->dbExecAsync($q);
|
|
print "[ERR] Query: " . $q . "<br>";
|
|
print "[ERR] RESOURCE: $test_foo<br>";
|
|
while (($ret = $db->dbCheckAsync()) === true)
|
|
{
|
|
print "[ERR]: $ret<br>";
|
|
sleep(5);
|
|
}
|
|
*/
|
|
|
|
// search path check
|
|
$q = "SHOW search_path";
|
|
$cursor = $db->dbExec($q);
|
|
$data = $db->dbFetchArray($cursor)['search_path'];
|
|
print "RETURN DATA FOR search_path: " . $data . "<br>";
|
|
// print "RETURN DATA FOR search_path: " . DgS::printAr($data) . "<br>";
|
|
// insert something into test.schema_test and see if we get the PK back
|
|
$status = $db->dbExec(
|
|
"INSERT INTO test.schema_test (contents, id) VALUES "
|
|
. "('TIME: " . time() . "', " . rand(1, 10) . ")"
|
|
);
|
|
print "OTHER SCHEMA INSERT STATUS: "
|
|
. Support::printToString($status)
|
|
. " | PK NAME: " . $db->dbGetInsertPKName()
|
|
. ", PRIMARY KEY: " . $db->dbGetInsertPK() . "<br>";
|
|
|
|
print "<b>NULL TEST DB READ</b><br>";
|
|
$q = "SELECT uid, null_varchar, null_int FROM test_null_data WHERE uid = 'A'";
|
|
$res = $db->dbReturnRow($q);
|
|
var_dump($res);
|
|
print "RES: " . DgS::printAr($res) . "<br>";
|
|
print "ISSET: " . isset($res['null_varchar']) . "<br>";
|
|
print "EMPTY: " . empty($res['null_varchar']) . "<br>";
|
|
|
|
// error message
|
|
print $log->printErrorMsg();
|
|
|
|
print "</body></html>";
|
|
|
|
// __END__
|