<?php
/*
* OIDplus 2.0
* Copyright 2019 Daniel Marschall, ViaThinkSoft
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
define('OIDPLUS_MYSQL_QUERYLOG', false);
if (OIDPLUS_MYSQL_QUERYLOG) {
function CallingFunctionName() {
$ex = new Exception();
$trace = $ex->getTrace();
if (!isset($trace[2])) return '(main)'; $final_call = $trace[2];
return $final_call['file'].':'.$final_call['line'].'/'.$final_call['function'].'()';
}
}
class OIDplusDataBasePluginMySQLi extends OIDplusDataBasePlugin {
private $mysqli;
private $last_query;
private $prepare_cache = array();
public static function getPluginInformation() {
$out['name'] = 'MySQLi';
$out['author'] = 'ViaThinkSoft';
$out['version'] = null;
$out['descriptionHTML'] = null;
return $out;
}
public static function name() {
return "MySQL";
}
public function query($sql, $prepared_args=null) {
$this->last_query = $sql;
if (OIDPLUS_MYSQL_QUERYLOG
) file_put_contents("query.log", "$sql <== ".CallingFunctionName
()."\n", FILE_APPEND
); } else {
throw new Exception("'prepared_args' must be either NULL or an ARRAY.");
}
if (isset($this->prepare_cache[$sql])) { $ps = $this->prepare_cache[$sql];
} else {
$ps = $this->mysqli->prepare($sql);
if (!$ps) {
throw new Exception("Cannot prepare statement '$sql'");
}
$this->prepare_cache[$sql] = $ps;
}
bind_placeholder_vars($ps,$prepared_args);
if (!$ps->execute()) return false;
$res = MYSQLND_AVAILABLE ? $ps->get_result() : iimysqli_stmt_get_result($ps);
if ($res === false) return true; // A non-SELECT statement does not give a result-set, but it is still successful
return $res;
}
}
public function num_rows($res) {
throw new Exception("num_rows called on non object. Last query: ".$this->last_query);
} else {
return (get_class($res)=='mysqli_result') || MYSQLND_AVAILABLE ?
$res->num_rows : $res->num_rows(); }
}
public function fetch_array($res) {
throw new Exception("fetch_array called on non object. Last query: ".$this->last_query);
} else {
return (get_class($res)=='mysqli_result') || MYSQLND_AVAILABLE ?
$res->fetch_array(MYSQLI_BOTH
) : $res->fetch_array(); }
}
public function fetch_object($res) {
throw new Exception("fetch_object called on non object. Last query: ".$this->last_query);
} else {
return (get_class($res)=='mysqli_result') || MYSQLND_AVAILABLE ?
$res->fetch_object("stdClass") : $res->fetch_object(); }
}
public function insert_id() {
return $this->mysqli->insert_id;
}
public function error() {
return !empty($this->mysqli->connect_error) ?
$this->mysqli->connect_error : $this->mysqli->error; }
public function connect() {
$html = OIDPLUS_HTML_OUTPUT;
// Try connecting to the database
list($hostname,$port) = explode(':', OIDPLUS_MYSQL_HOST
.':'.ini_get("mysqli.default_port")); $this->mysqli = @new mysqli
($hostname, OIDPLUS_MYSQL_USERNAME
, base64_decode(OIDPLUS_MYSQL_PASSWORD
), OIDPLUS_MYSQL_DATABASE
, $port); if (!empty($this->mysqli->connect_error) || ($this->mysqli->connect_errno != 0)) { if ($html) {
echo "<h1>Error</h1><p>Database connection failed! (".$this->error().")</p>";
if (is_dir(__DIR__
.'/../../../setup')) { echo '<p>If you believe that the login credentials are wrong, please run <a href="setup/">setup</a> again.</p>';
}
} else {
echo "Error: Database connection failed! (".$this->error().")";
if (is_dir(__DIR__
.'/../../../setup')) { echo ' If you believe that the login credentials are wrong, please run setup again.';
}
}
}
$this->query("SET NAMES 'utf8'");
$this->afterConnect($html);
$this->connected = true;
}
private $intransaction = false;
public function transaction_begin() {
if ($this->intransaction) throw new Exception("Nested transactions are not supported by this database plugin.");
$this->mysqli->autocommit(true);
$this->intransaction = true;
}
public function transaction_commit() {
$this->mysqli->commit();
$this->mysqli->autocommit(false);
$this->intransaction = false;
}
public function transaction_rollback() {
$this->mysqli->rollback();
$this->mysqli->autocommit(false);
$this->intransaction = false;
}
}
function bind_placeholder_vars(&$stmt,$params,$debug=0) {
// Credit to: Dave Morgan
// Code ripped from: http://www.devmorgan.com/blog/2009/03/27/dydl-part-3-dynamic-binding-with-mysqli-php/
// https://stackoverflow.com/questions/17219214/how-to-bind-in-mysqli-dynamically
if ($params != null) {
$types = ''; //initial sting with types
foreach ($params as $param) { //for each element, determine type and add
$types .= 'i'; //integer
$types .= 'd'; //double
$types .= 's'; //string
} else {
$types .= 'b'; //blob and unknown
}
}
$bind_names[] = $types; //first param needed is the type string
// eg: 'issss'
for ($i=0; $i<count($params);$i++) { //go through incoming params and added em to array $bind_name = 'bind' . $i; //give them an arbitrary name
$$bind_name = $params[$i]; //add the parameter to the variable variable
$bind_names[] = &$$bind_name; //now associate the variable as an element in an array
}
if ($debug) {
echo "\$bind_names:<br />\n";
echo "<br />\n";
}
//error_log("better_mysqli has params ".print_r($bind_names, 1));
//call the function bind_param with dynamic params
return true;
}else{
return false;
}
}
function bind_result_array($stmt, &$row) {
// Credit to: Dave Morgan
// Code ripped from: http://www.devmorgan.com/blog/2009/03/27/dydl-part-3-dynamic-binding-with-mysqli-php/
$meta = $stmt->result_metadata();
while ($field = $meta->fetch_field()) {
$params[] = &$row[$field->name];
}
return true;
}
if (!MYSQLND_AVAILABLE) {
class iimysqli_result {
// Source: https://www.php.net/manual/de/mysqli-stmt.get-result.php#113398
public $stmt, $nCols;
function fetch_array() {
// https://stackoverflow.com/questions/10752815/mysqli-get-result-alternative , modified
$stmt = $this->stmt;
$stmt->store_result();
$thisName = "";
if ($stmt->num_rows==0) return false;
for ( $i = 0; $i < $stmt->num_rows; $i++ ) {
$metadata = $stmt->result_metadata();
while ( $field = $metadata->fetch_field() ) {
$thisName = $field->name;
$resultkeys[] = $thisName;
}
}
$code = "return mysqli_stmt_bind_result(\$this->stmt ";
for ($i=0; $i<$this->nCols; $i++) {
$ret[$i] = NULL;
$theValue = $resultkeys[$i];
$code .= ", \$ret['$theValue']";
}
$code .= ");";
return NULL;
}
// This should advance the "$stmt" cursor.
return NULL;
}
// Return the array we built.
return $ret;
}
public function num_rows() {
$this->stmt->store_result();
return $this->stmt->num_rows;
}
public function fetch_object() {
$obj = new stdClass;
$ary = $this->fetch_array();
if (!$ary) return false;
foreach ($ary as $name => $val) {
$obj->$name = $val;
}
return $obj;
}
}
function iimysqli_stmt_get_result($stmt) {
// Source: https://www.php.net/manual/de/mysqli-stmt.get-result.php#113398
/** EXPLANATION:
* We are creating a fake "result" structure to enable us to have
* source-level equivalent syntax to a query executed via
* mysqli_query().
*
* $stmt = mysqli_prepare($conn, "");
* mysqli_bind_param($stmt, "types", ...);
*
* $param1 = 0;
* $param2 = 'foo';
* $param3 = 'bar';
* mysqli_execute($stmt);
* $result _mysqli_stmt_get_result($stmt);
* [ $arr = _mysqli_result_fetch_array($result);
* || $assoc = _mysqli_result_fetch_assoc($result); ]
* mysqli_stmt_close($stmt);
* mysqli_close($conn);
*
* At the source level, there is no difference between this and mysqlnd.
**/
$ret = new iimysqli_result;
if (!$ret) return NULL;
return $metadata;
}
$ret->stmt = $stmt;
return $ret;
}
}