aboutsummaryrefslogtreecommitdiffstats
path: root/mayor-orig/www/include/base/mysql.php
diff options
context:
space:
mode:
authorM.Gergo2019-03-08 21:20:34 +0100
committerM.Gergo2019-03-08 21:20:34 +0100
commitf51c9ed2abe5c68211bb3736be5f70b1fe2c9ec0 (patch)
treee13e60e4b94a3b58f1e2bfbe271102c8f04b67bd /mayor-orig/www/include/base/mysql.php
parentc76a004b0135786f2742283f8d5f917106f58bd8 (diff)
downloadmayor-f51c9ed2abe5c68211bb3736be5f70b1fe2c9ec0.tar.gz
mayor-f51c9ed2abe5c68211bb3736be5f70b1fe2c9ec0.zip
további rendrakás
Diffstat (limited to 'mayor-orig/www/include/base/mysql.php')
-rw-r--r--mayor-orig/www/include/base/mysql.php396
1 files changed, 0 insertions, 396 deletions
diff --git a/mayor-orig/www/include/base/mysql.php b/mayor-orig/www/include/base/mysql.php
deleted file mode 100644
index b2e22f82..00000000
--- a/mayor-orig/www/include/base/mysql.php
+++ /dev/null
@@ -1,396 +0,0 @@
-<?php
-
- error_reporting(E_ALL && ~E_NOTICE);
-// error_reporting(E_ALL);
-
- //if (!defined("MYSQLI_ENABLED")) define("MYSQLI_ENABLED",function_exists('mysqli_connect'));
- if (!defined("MYSQLI_ENABLED")) define("MYSQLI_ENABLED",false); // egyelőre kikapcsoljuk, mert az Illyés-ben pl egfeküdt a szerver ettől
- if (is_array($AUTH)) foreach ($AUTH as $_policy => $config) {
- if ($config['backend'] == 'mysql') {
- $MYSQL_DATA[$_policy . ' auth'] = array(
- 'user' => $config['mysql user'],
- 'host' => $config['mysql host'],
- 'pw' => $config['mysql pw'],
- 'db' => $config['mysql db'],
- );
- if ($MYSQL_DATA[$_policy . ' auth']['host']=='')
- if ($MYSQL_DATA['host']=='')
- $MYSQL_DATA[$_policy . ' auth']['host'] = 'localhost';
- else
- $MYSQL_DATA[$_policy . ' auth']['host'] = $MYSQL_DATA['host'];
- }
- }
-//-----------------------------------------------------------------------//
-
- function db_selectDb($db,$lr) {
- if (MYSQLI_ENABLED===true)
- return mysqli_select_db($lr,$db);
- else
- return mysql_select_db($db,$lr);
- }
-
- function db_connect($modul, $SET = array('priv' => null, 'force' => true, 'host'=> null, 'username' => null, 'password' => null, 'db' => null, 'fv' => null)) {
-
- global $MYSQL_DATA;
-
- $lr = false;
- extract($SET);
- if (!isset($force)) $force = true;
- if (!isset($priv)) $priv = '';
-
- //if ($MYSQL_DATA['persistent']===true) $mysql_connect = 'mysql_pconnect'; else $mysql_connect = 'mysql_connect';
- $mysql_connect = 'mysql_connect';
- /* setting host */
- if (!isset($host)) {
- if ($MYSQL_DATA[$modul]['host'.$priv]=='') {
- if ($MYSQL_DATA[$modul]['host']=='') {
- if ($MYSQL_DATA['host']=='') {
- $host = 'localhost';
- } else {
- $host = $MYSQL_DATA['host'];
- }
- } else {
- $host = $MYSQL_DATA[$modul]['host'];
- }
- } else {
- $host = $MYSQL_DATA[$modul]['host'.$priv];
- }
- }
- /* --- */
- if ($priv == 'root') {
- if (MYSQLI_ENABLED===true)
- $lr = @mysqli_connect($host, $username, $password); // force new ???
- else
- $lr = @$mysql_connect($host, $username, $password, $force);
- } else {
- /* --- */
- if (is_array($MYSQL_DATA[$modul])) {
- if (isset($priv) && $priv != '' && isset($MYSQL_DATA[$modul]['user'.$priv])) { // Először megpróbálunk $priv szerinti privilégiummal csatlakozni
- if (MYSQLI_ENABLED===true)
- $lr = @mysqli_connect($host, $MYSQL_DATA[$modul]['user'.$priv], $MYSQL_DATA[$modul]['pw'.$priv], $MYSQL_DATA[$modul]['db']);
- else
- $lr = @$mysql_connect($host, $MYSQL_DATA[$modul]['user'.$priv], $MYSQL_DATA[$modul]['pw'.$priv], $force);
- }
- if ($lr === false) {// Ha nem sikerült, vagy nem volt megadva privilégium, akkor próbáljunk anélkül csatlakozni
- if (MYSQLI_ENABLED===true)
- $lr = @mysqli_connect($host, $MYSQL_DATA[$modul]['user'], $MYSQL_DATA[$modul]['pw'], $MYSQL_DATA[$modul]['db']);
- else
- $lr = @$mysql_connect($host, $MYSQL_DATA[$modul]['user'], $MYSQL_DATA[$modul]['pw'], $force);
- }
- } else {
- $_SESSION['alert'][] = "message:sql_failure/${SET['fv']}:db_connect:modul $modul has no config";
- }
- }
- if ($lr) {
- // mysql_set_charset('utf8', $lr);
- if ($priv != 'root') $db = $MYSQL_DATA[$modul]['db'];
- if ($db != '') {
- $result = db_selectDb($db , $lr);
- if ($result === true) {
- if (MYSQLI_ENABLED===true) {
- mysqli_set_charset($lr, "utf8");
- mysqli_query($lr, "SET NAMES utf8");
- mysqli_query($lr, "SET collation_connection='utf8_hungarian_ci'");
- } else {
- mysql_query("SET NAMES utf8", $lr);
- mysql_query("SET collation_connection='utf8_hungarian_ci'", $lr);
- }
- } else {
- $_SESSION['alert'][] = "message:sql_select_db_failure:db_connect/${SET['fv']}:$modul:".$MYSQL_DATA[$modul]['db'];
- mysql_close($lr);
- return false;
- }
- } elseif (!isset($MYSQL_DATA[$modul]['db'])) {
- $_SESSION['alert'][] = "message:sql_warning:db_connect/${SET['fv']}:modul $modul has empty database config value";
- }
- } else {
- if (__DEBUG || (defined('__DETAILED') && __DETAILED)) $_SESSION['alert'][] = "message:sql_connect_failure:db_connect/${SET['fv']}:modul - $modul, priv - $priv, username - $username, db - $db";
- else $_SESSION['alert'][] = "message:sql_connect_failure:db_connect/${SET['fv']}:$modul modul";
- }
- return $lr;
-
- }
-
- function db_close($lr) {
- if ($MYSQL_DATA['persistent']!==true) {
- if (MYSQLI_ENABLED===true)
- return mysqli_close($lr);
- else
- return mysql_close($lr);
- } else
- return true; // not closing;
- }
-
-//-----------------------------------------------------------------------//
-
- function db_query($q, $SET, $olr = null) {
- /*
- $SET = array(
- 'modul' => '...'
- 'fv' => '...'
- 'result' => 'indexed'|'assoc'|'multiassoc'|'idonly'|'value'|'record'|'keyvaluepair'|'insert'|'affected rows'
- 'keyfield' => '...' (if result in (assoc,multiassoc))
- 'detailed' => true | false (default) (echo the query in error messages)
- 'debug' => true | false (default) (echo the query before quering it)
- 'rollback' => true | false (default)
- 'values' => array(...) (if $q is an sprintf format string)
- );
- */
- global $_JSON;
-
- if (!isset($q) || $q == '') {
- $_SESSION['alert'][] = 'message:sql_query_failure:db_query/'.$SET['fv'].':query is empty';
- return false;
- }
-
- if (!isset($SET['result'])) $SET['result'] = '';
-
- // Adatbázis csatlakozás (ha szükséges)
- if (isset($olr) && $olr != '') {
- if (MYSQLI_ENABLED===true)
- $mysql_get_server_info = mysqli_get_server_info($olr);
- else
- $mysql_get_server_info = @mysql_get_server_info($olr);
- }
- if (isset($olr) && $olr != '' && $mysql_get_server_info !== false) {
- $lr = $olr;
- } else {
- unset($olr);
- if (in_array(substr(strtolower($q),0,4), array('sele','show','expl','set ','use '))) $lr = @db_connect($SET['modul'], array('priv' => 'Read', 'fv' => $SET['fv']));
- else $lr = @db_connect($SET['modul'], array('priv' => 'Write', 'fv' => $SET['fv']));
- }
- if ($lr === false) {
- if ($SET['detailed'] === true || __DETAILED) $_SESSION['alert'][] = 'message:sql_connect_failure:db_query/'.$SET['fv'].':'.$SET['modul'].':'.$q;
- else $_SESSION['alert'][] = 'message:sql_connect_failure:db_query/'.$SET['fv'];
- return false;
- }
-
- // Ha behelyettesítendő paraméterek vannak
- if (isset($SET['values']) && is_array($SET['values']) && count($SET['values']) > 0) {
- $SET['values'] = array_map('db_escape_string', $SET['values'], array_fill(0 , count($SET['values']), $lr));
- array_unshift($SET['values'], $q);
- $q_pattern = $q;
- $q = @call_user_func_array('sprintf', $SET['values']);
- if ($q === false) {
- $_SESSION['alert'][] = 'message:wrong_data:db_query:behelyettesítés:'.$SET['fv'];
- return false;
- }
- }
- if ((isset($SET['debug']) && $SET['debug']===true) || (defined('__DEBUG') && __DEBUG === true)) {
- $_q = str_replace(" ",'',$q);
- echo '<pre>info:debug:'.htmlspecialchars($SET['modul'].':'.$SET['fv'].':'.date('Y-m-d H:i:s').': '." \n".$_q)."<hr /></pre>";
- if ($_GET['skin'] == 'ajax') $_JSON['sql log'][] = $SET['modul'].':'.$SET['fv'].':'.date('Y-m-d H:i:s').': '." \n".$_q;
- if ($_GET['skin'] == 'rpc') {
- openlog("MaYoR", LOG_PID | LOG_PERROR, LOG_LOCAL0);
- syslog(LOG_WARNING, '[RPC]MySQL: '.(json_encode($SET)).", query: $_q {$_SERVER['REMOTE_ADDR']} ({$_SERVER['HTTP_USER_AGENT']})");
- closelog();
- }
- }
- if (
- ($SET['detailed'] === true || __DETAILED)
- && strpos($q_pattern, '%s') !== false
- && (strpos($q_pattern, '`%s`') === false && strpos($q_pattern, "'%s'") === false)
- ) $_SESSION['alert'][] = 'message:lehet hiba?:db_query/'.$SET['fv'].':'.$SET['modul'].':'.$q_pattern;
-
- if ($SET['log']===true) mayorLogger(10,'mysql',$q,_USERACCOUNT);
- if (MYSQLI_ENABLED===true)
- $r = mysqli_query($lr,$q);
- else
- $r = @mysql_query($q, $lr);
- define(MYSQL_LOGGER,false);
- if (MYSQL_LOGGER === true) {
- $filename = '/tmp/mysql.log';
- $fp = fopen($filename, "a+");
- fputs ($fp, $q."\n");
- fclose ($fp);
- }
- /* WARNING HANDLER */
-// if ((isset($SET['debug']) && $SET['debug']===true) || (defined('__DEBUG') &&__DEBUG === true) || (defined('__DETAILED') && __DETAILED===true)) {
- if ((isset($SET['debug']) && $SET['debug']===true) || (defined('__DEBUG') &&__DEBUG === true)) {
- if (MYSQLI_ENABLED===true)
- $warningCountResult = mysqli_query($lr,"SELECT @@warning_count");
- else
- $warningCountResult = mysql_query("SELECT @@warning_count",$lr);
- if ($warningCountResult) {
- if (MYSQLI_ENABLED===true)
- $warningCount = mysqli_fetch_row($lr,$warningCountResult);
- else
- $warningCount = mysql_fetch_row($warningCountResult);
- if ($warningCount[0] > 0) {
- //Have warnings
- if (MYSQLI_ENABLED===true)
- $warningDetailResult = mysqli_query($lr, "SHOW WARNINGS");
- else
- $warningDetailResult = mysql_query("SHOW WARNINGS",$lr);
- if ($warningDetailResult ) {
- if (MYSQLI_ENABLED===true)
- while ($warning = mysqli_fetch_assoc($lr, $warningDetailResult)) {dump($warning); mayorLogger(2,'mysql',$q.' '.$warning,_USERACCOUNT);}
- else
- while ($warning = mysql_fetch_assoc($warningDetailResult)) {dump($warning); mayorLogger(2,'mysql',$q.' '.$warning,_USERACCOUNT);}
- }
- }//Else no warnings
- }
- }
- /* WARNING HANDLER */
- if (!$r) {
- // if ($SET['detailed'] === true || __DETAILED) $_SESSION['alert'][] = 'message:sql_query_failure:'.$SET['fv'].':'.':'.$q;
- if ($SET['detailed'] === true || __DETAILED) {
- if (MYSQLI_ENABLED===true) {
- $_SESSION['alert'][] = 'message:sql_query_failure:mysqli:'.$SET['fv'].':'.mysqli_error($lr).':'.$q;
- } else {
- $_SESSION['alert'][] = 'message:sql_query_failure:mysql:'.$SET['fv'].':'.mysql_error($lr).':'.$q;
- }
- } else {
- $_SESSION['alert'][] = 'message:sql_query_failure:'.$SET['fv'];
- }
- if ($SET['rollback'] === true) db_rollback($lr, $SET['fv']);
- if (!isset($olr)) db_close($lr);
- return false;
- }
-
- if (MYSQLI_ENABLED === true) {
-
- if (in_array(substr(strtolower($q),0,4), array('sele','show','expl','(sel'))) {
- $RESULT = array();
- switch($SET['result']) {
- case 'indexed':
- while ($A = mysqli_fetch_assoc($r)) $RESULT[] = $A;
- break;
- case 'assoc':
- while ($A = mysqli_fetch_assoc($r)) $RESULT[$A[$SET['keyfield']]] = $A;
- break;
- case 'multiassoc':
- while ($A = mysqli_fetch_assoc($r)) $RESULT[$A[$SET['keyfield']]][] = $A;
- break;
- case 'idonly':
- while ($A = mysqli_fetch_row($r)) $RESULT[] = $A[0];
- break;
- case 'value':
- if (mysqli_num_rows($r) > 0) {
- $A = mysqli_fetch_row($r); $RESULT = $A[0];
- } else { $RESULT = null; }
- break;
- case 'record':
- if (mysqli_num_rows($r) > 0) {
- $A = mysqli_fetch_assoc($r); $RESULT = $A;
- } else { $RESULT = null; }
- break;
- case 'keyvaluepair':
- while ($A = mysqli_fetch_row($r)) $RESULT[$A[0]] = $A[1];
- break;
- case 'keyvalues':
- while ($A = mysqli_fetch_row($r)) $RESULT[$A[0]][] = $A[1];
- break;
- }
- } elseif ($SET['result'] == 'insert' && (substr(strtolower($q),0,6) == 'insert' || substr(strtolower($q),0,7) == 'replace')) {
- $RESULT = mysqli_insert_id($lr);
- mayorLogger(1,'mysql',$q,_USERACCOUNT);
- } elseif ($SET['result'] == 'affected rows') {
- $RESULT = mysqli_affected_rows($lr);
- mayorLogger(1,'mysql',$q,_USERACCOUNT);
- } else { // create, insert, de nem olyan resulttal...
- $RESULT = $r;
- mayorLogger(1,'mysql',$q,_USERACCOUNT);
- }
- } else { // OLD DRIVER
-
- if (in_array(substr(strtolower($q),0,4), array('sele','show','expl','(sel'))) {
- $RESULT = array();
- switch($SET['result']) {
- case 'indexed':
- while ($A = mysql_fetch_assoc($r)) $RESULT[] = $A;
- break;
- case 'assoc':
- while ($A = mysql_fetch_assoc($r)) $RESULT[$A[$SET['keyfield']]] = $A;
- break;
- case 'multiassoc':
- while ($A = mysql_fetch_assoc($r)) $RESULT[$A[$SET['keyfield']]][] = $A;
- break;
- case 'idonly':
- while ($A = mysql_fetch_row($r)) $RESULT[] = $A[0];
- break;
- case 'value':
- if (mysql_num_rows($r) > 0) {
- $A = mysql_fetch_row($r); $RESULT = $A[0];
- } else { $RESULT = null; }
- break;
- case 'record':
- if (mysql_num_rows($r) > 0) {
- $A = mysql_fetch_assoc($r); $RESULT = $A;
- } else { $RESULT = null; }
- break;
- case 'keyvaluepair':
- while ($A = mysql_fetch_row($r)) $RESULT[$A[0]] = $A[1];
- break;
- case 'keyvalues':
- while ($A = mysql_fetch_row($r)) $RESULT[$A[0]][] = $A[1];
- break;
- }
- } elseif ($SET['result'] == 'insert' && (substr(strtolower($q),0,6) == 'insert' || substr(strtolower($q),0,7) == 'replace')) {
- $RESULT = mysql_insert_id($lr);
- mayorLogger(1,'mysql',$q,_USERACCOUNT);
- } elseif ($SET['result'] == 'affected rows') {
- $RESULT = mysql_affected_rows($lr);
- mayorLogger(1,'mysql',$q,_USERACCOUNT);
- } else { // create, insert, de nem olyan resulttal...
- $RESULT = $r;
- mayorLogger(1,'mysql',$q,_USERACCOUNT);
- }
- } // DRIVER
-
- if (!isset($olr)) db_close($lr);
- return $RESULT;
-
- }
-
-//-----------------------------------------------------------------------//
-
- function db_start_trans($lr) {
- if ($lr != '')
- if (MYSQLI_ENABLED === true)
- mysqli_query($lr, "START TRANSACTION");
- else
- mysql_query("START TRANSACTION", $lr);
- }
-
- function db_commit($lr) {
- if ($lr != '')
- if (MYSQLI_ENABLED === true)
- mysqli_query($lr, "COMMIT");
- else
- mysql_query("COMMIT", $lr);
- }
-
- function db_rollback($lr, $msg = '') {
- if ($lr != '') {
- $_SESSION['alert'][] = 'message:rollback:'.$msg;
- if (MYSQLI_ENABLED === true)
- mysqli_query($lr, "ROLLBACK");
- else
- mysql_query("ROLLBACK", $lr);
- }
- }
-
-//---------------------------------------------------------------------//
-
- function db_escape_string($str, $olr = null) {
-
- if (isset($olr)) $lr = $olr;
- else $lr = db_connect('login');
-
- if (!$lr) return false;
-
- if(get_magic_quotes_gpc()) {
- $return = mysql_real_escape_string(stripslashes($str), $lr);
- } else {
- if (MYSQLI_ENABLED===true)
- $return = mysqli_real_escape_string($lr, $str);
- else
- $return = mysql_real_escape_string($str, $lr);
- }
- if (!isset($olr)) db_close($lr);
-
- return $return;
- }
-
-?>