168 lines
3.3 KiB
PHP
Executable File
168 lines
3.3 KiB
PHP
Executable File
<?php /** @file */
|
|
|
|
function dba_factory($server, $port,$user,$pass,$db,$install = false) {
|
|
$dba = null;
|
|
|
|
if(class_exists('mysqli')) {
|
|
if (is_null($port)) $port = ini_get("mysqli.default_port");
|
|
require_once('include/dba/dba_mysqli.php');
|
|
$dba = new dba_mysqli($server, $port,$user,$pass,$db,$install);
|
|
}
|
|
else {
|
|
if (is_null($port)) $port = "3306";
|
|
require_once('include/dba/dba_mysql.php');
|
|
$dba = new dba_mysql($server, $port,$user,$pass,$db,$install);
|
|
}
|
|
|
|
return $dba;
|
|
}
|
|
|
|
|
|
abstract class dba_driver {
|
|
|
|
protected $debug = 0;
|
|
protected $db;
|
|
public $connected = false;
|
|
public $error = false;
|
|
|
|
abstract function connect($server, $port, $user,$pass,$db);
|
|
abstract function q($sql);
|
|
abstract function escape($str);
|
|
abstract function close();
|
|
|
|
function __construct($server, $port, $user,$pass,$db,$install = false) {
|
|
if(($install) && (! $this->install($server, $port, $user,$pass,$db))) {
|
|
return;
|
|
}
|
|
$this->connect($server, $port, $user,$pass,$db);
|
|
}
|
|
|
|
|
|
function install($server,$user,$pass,$db) {
|
|
if (!(strlen($server) && strlen($user))){
|
|
$this->connected = false;
|
|
$this->db = null;
|
|
return false;
|
|
}
|
|
|
|
if(strlen($server) && ($server !== 'localhost') && ($server !== '127.0.0.1')) {
|
|
if(! dns_get_record($server, DNS_A + DNS_CNAME + DNS_PTR)) {
|
|
$this->error = sprintf( t('Cannot locate DNS info for database server \'%s\''), $server);
|
|
$this->connected = false;
|
|
$this->db = null;
|
|
return false;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
|
|
function dbg($dbg) {
|
|
$this->debug = $dbg;
|
|
}
|
|
|
|
function __destruct() {
|
|
if($this->db && $this->connected) {
|
|
$this->close();
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
function printable($s) {
|
|
$s = preg_replace("~([\x01-\x08\x0E-\x0F\x10-\x1F\x7F-\xFF])~",".", $s);
|
|
$s = str_replace("\x00",'.',$s);
|
|
if(x($_SERVER,'SERVER_NAME'))
|
|
$s = escape_tags($s);
|
|
return $s;
|
|
}
|
|
|
|
// Procedural functions
|
|
|
|
function dbg($state) {
|
|
global $db;
|
|
if($db)
|
|
$db->dbg($state);
|
|
}
|
|
|
|
|
|
function dbesc($str) {
|
|
global $db;
|
|
if($db && $db->connected)
|
|
return($db->escape($str));
|
|
else
|
|
return(str_replace("'","\\'",$str));
|
|
}
|
|
|
|
|
|
|
|
// Function: q($sql,$args);
|
|
// Description: execute SQL query with printf style args.
|
|
// Example: $r = q("SELECT * FROM `%s` WHERE `uid` = %d",
|
|
// 'user', 1);
|
|
|
|
|
|
function q($sql) {
|
|
|
|
global $db;
|
|
$args = func_get_args();
|
|
unset($args[0]);
|
|
|
|
if($db && $db->connected) {
|
|
$stmt = vsprintf($sql,$args);
|
|
if($stmt === false)
|
|
logger('dba: vsprintf error: ' . print_r(debug_backtrace(),true));
|
|
return $db->q($stmt);
|
|
}
|
|
|
|
/**
|
|
*
|
|
* This will happen occasionally trying to store the
|
|
* session data after abnormal program termination
|
|
*
|
|
*/
|
|
logger('dba: no database: ' . print_r($args,true));
|
|
return false;
|
|
|
|
}
|
|
|
|
/**
|
|
*
|
|
* Raw db query, no arguments
|
|
*
|
|
*/
|
|
|
|
|
|
function dbq($sql) {
|
|
|
|
global $db;
|
|
if($db && $db->connected)
|
|
$ret = $db->q($sql);
|
|
else
|
|
$ret = false;
|
|
return $ret;
|
|
}
|
|
|
|
|
|
// Caller is responsible for ensuring that any integer arguments to
|
|
// dbesc_array are actually integers and not malformed strings containing
|
|
// SQL injection vectors. All integer array elements should be specifically
|
|
// cast to int to avoid trouble.
|
|
|
|
|
|
|
|
function dbesc_array_cb(&$item, $key) {
|
|
if(is_string($item))
|
|
$item = dbesc($item);
|
|
}
|
|
|
|
|
|
|
|
function dbesc_array(&$arr) {
|
|
if(is_array($arr) && count($arr)) {
|
|
array_walk($arr,'dbesc_array_cb');
|
|
}
|
|
}
|