a63a50a412
dbReturn special call test file, update main db test file Main class_test file with links update
414 lines
15 KiB
PHP
414 lines
15 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,
|
|
]);
|
|
// db connection and attach logger
|
|
$db = new CoreLibs\DB\IO(DB_CONFIG, $log);
|
|
$db->log->debug('START', '=============================>');
|
|
|
|
$PAGE_NAME = 'TEST CLASS: DB';
|
|
print "<!DOCTYPE html>";
|
|
print "<html><head><title>" . $PAGE_NAME . "</title><head>";
|
|
print "<body>";
|
|
print '<div><a href="class_test.php">Class Test Master</a></div>';
|
|
print '<div><a href="class_test.db.dbReturn.php">Class Test DB dbReturn</a></div>';
|
|
print '<div><h1>' . $PAGE_NAME . '</h1></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>";
|
|
print "DB search path: " . $db->dbGetSchema() . "<br>";
|
|
|
|
$to_db_version = '13.6';
|
|
print "VERSION DB: " . $db->dbVersion() . "<br>";
|
|
print "VERSION LONG DB: " . $db->dbVersionInfo('server', false) . "<br>";
|
|
print "VERSION NUMERIC DB: " . $db->dbVersionNumeric() . "<br>";
|
|
print "SERVER ENCODING: " . $db->dbVersionInfo('server_encoding') . "<br>";
|
|
print "ALL PG VERSION PARAMETERS: <pre>" . print_r($db->dbVersionInfoParameters(), true) . "</pre><br>";
|
|
print "ALL OUTPUT [TEST]: <pre>" . print_r(pg_version($db->dbGetDbh()), true) . "</pre><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>";
|
|
|
|
$db->dbSetEncoding('SJIS');
|
|
print "ENCODING TEST: " . $db->dbVersionInfo('client_encoding') . "/" . $db->dbGetEncoding() . "<br>";
|
|
$db->dbResetEncoding();
|
|
|
|
// TEST CACHE READS
|
|
|
|
$res = $db->dbReturn("SELECT * FROM max_test");
|
|
print "DB RETURN ROWS: " . $db->dbGetNumRows() . "<br>";
|
|
|
|
while (is_array($res = $db->dbReturn("SELECT * FROM max_test", DbIo::USE_CACHE, true))) {
|
|
print "UUD/TIME: " . $res['uid'] . "/" . $res['time'] . "<br>";
|
|
}
|
|
print "CACHED DATA: <pre>" . print_r($db->dbGetCursorExt(), true) . "</pre><br>";
|
|
while (is_array($res = $db->dbReturn("SELECT * FROM max_test", DbIo::USE_CACHE))) {
|
|
print "[CACHED] UID/TIME: " . $res['uid'] . "/" . $res['time'] . "<br>";
|
|
// print "****RES: <pre>" . print_r($res, true) . "</pre><br>";
|
|
}
|
|
// print "CACHED REREAD DATA: <pre>" . print_r($db->dbGetCursorExt(), true) . "</pre><br>";
|
|
while (is_array($res = $db->dbReturn("SELECT * FROM max_test", DbIo::NO_CACHE))) {
|
|
print "[NO CACHE] UID.TIME: " . $res['uid'] . "/" . $res['time'] . "<br>";
|
|
// print "****RES: <pre>" . print_r($res, true) . "</pre><br>";
|
|
}
|
|
print "NO CACHED DATA: <pre>" . print_r($db->dbGetCursorExt(), true) . "</pre><br>";
|
|
// alternate check for valid data
|
|
// while (($res = $db->dbReturn("SELECT * FROM max_test")) !== false) {
|
|
// print "[CACHED] TIME: " . $res['time'] . "<br>";
|
|
// }
|
|
// while (is_array($res = $db->dbReturn("SELECT * FROM max_test", DbIo::USE_CACHE))) {
|
|
// print "UUD/TIME: " . $res['uid'] . "/" . $res['time'] . "<br>";
|
|
// }
|
|
|
|
// dbReturn tests on separate page
|
|
print "<br>";
|
|
print "<b>dbReturn CACHE tests</b><br>";
|
|
print '<a href="class_test.db.dbReturn.php">Class Test DB dbReturn</a><br>';
|
|
print "<br>";
|
|
|
|
print "<pre>";
|
|
|
|
print "SOCKET: " . pg_socket($db->dbGetDbh()) . "<br>";
|
|
|
|
// 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) . " |<br>"
|
|
. "QUERY: " . $db->dbGetQuery() . " |<br>"
|
|
. "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) . " |<br>"
|
|
. "QUERY: " . $db->dbGetQuery() . " |<br>"
|
|
. "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) . " |<br>"
|
|
. "QUERY: " . $db->dbGetQuery() . " |<br>"
|
|
. "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) . " |<br>"
|
|
. "QUERY: " . $db->dbGetQuery() . " |<br>"
|
|
. "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) . " |<br>"
|
|
. "QUERY: " . $db->dbGetQuery() . " |<br>"
|
|
. "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 ('WITHOUT DATA', 456)");
|
|
print "INSERT WITH NO PRIMARY KEY NO RETURNING STATUS: " . Support::printToString($status) . " |<br>"
|
|
. "QUERY: " . $db->dbGetQuery() . " |<br>"
|
|
. "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) . " |<br>"
|
|
. "QUERY: " . $db->dbGetQuery() . " |<br>"
|
|
. "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 "Rows: " . $db->dbGetNumRows() . ", 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): "
|
|
. $db->dbGetLastError() . "/" . $db->dbGetLastWarning() . "/"
|
|
. "<pre>" . print_r($db->dbGetCombinedErrorHistory(), true) . "</pre><br>";
|
|
$query = "SELECT invalid FROM invalid";
|
|
$data = $db->dbReturnArray($query);
|
|
print "ERROR (HARD ERROR): "
|
|
. $db->dbGetLastError() . "/" . $db->dbGetLastWarning() . "/"
|
|
. "<pre>" . print_r($db->dbGetCombinedErrorHistory(), true) . "</pre><br>";
|
|
// Now a good query will fail
|
|
$query = "SELECT type, sdate, integer FROM foobar";
|
|
$data = $db->dbReturnRow($query, true);
|
|
print "GOOD SELECT AFTER ERROR: "
|
|
. $db->dbGetLastError() . "/" . $db->dbGetLastWarning() . "/"
|
|
. "<pre>" . print_r($db->dbGetCombinedErrorHistory(), true) . "</pre><br>";
|
|
print "GOOD SELECT AFTER ERROR: <br><pre>" . print_r($data, true) . "</pre><br>";
|
|
|
|
/*
|
|
set error id in
|
|
dbPrepare
|
|
dbExecute
|
|
dbExecAsync
|
|
dbWriteDataExt
|
|
dbReturnArray
|
|
dbReturnRow
|
|
dbFetchArray (?)
|
|
dbExec (if not set before)
|
|
dbReturn
|
|
dbShowTableMetaData
|
|
*/
|
|
|
|
// 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>";
|
|
*/
|
|
|
|
/*
|
|
$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__
|