1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507 |
- <?php
- require_once 'PEAR.php';
- define('DB_OK', 1);
- define('DB_ERROR', -1);
- define('DB_ERROR_SYNTAX', -2);
- define('DB_ERROR_CONSTRAINT', -3);
- define('DB_ERROR_NOT_FOUND', -4);
- define('DB_ERROR_ALREADY_EXISTS', -5);
- define('DB_ERROR_UNSUPPORTED', -6);
- define('DB_ERROR_MISMATCH', -7);
- define('DB_ERROR_INVALID', -8);
- define('DB_ERROR_NOT_CAPABLE', -9);
- define('DB_ERROR_TRUNCATED', -10);
- define('DB_ERROR_INVALID_NUMBER', -11);
- define('DB_ERROR_INVALID_DATE', -12);
- define('DB_ERROR_DIVZERO', -13);
- define('DB_ERROR_NODBSELECTED', -14);
- define('DB_ERROR_CANNOT_CREATE', -15);
- define('DB_ERROR_CANNOT_DROP', -17);
- define('DB_ERROR_NOSUCHTABLE', -18);
- define('DB_ERROR_NOSUCHFIELD', -19);
- define('DB_ERROR_NEED_MORE_DATA', -20);
- define('DB_ERROR_NOT_LOCKED', -21);
- define('DB_ERROR_VALUE_COUNT_ON_ROW', -22);
- define('DB_ERROR_INVALID_DSN', -23);
- define('DB_ERROR_CONNECT_FAILED', -24);
- define('DB_ERROR_EXTENSION_NOT_FOUND', -25);
- define('DB_ERROR_ACCESS_VIOLATION', -26);
- define('DB_ERROR_NOSUCHDB', -27);
- define('DB_ERROR_CONSTRAINT_NOT_NULL', -29);
- define('DB_PARAM_SCALAR', 1);
- define('DB_PARAM_OPAQUE', 2);
- define('DB_PARAM_MISC', 3);
- define('DB_BINMODE_PASSTHRU', 1);
- define('DB_BINMODE_RETURN', 2);
- define('DB_BINMODE_CONVERT', 3);
- define('DB_FETCHMODE_DEFAULT', 0);
- define('DB_FETCHMODE_ORDERED', 1);
- define('DB_FETCHMODE_ASSOC', 2);
- define('DB_FETCHMODE_OBJECT', 3);
- define('DB_FETCHMODE_FLIPPED', 4);
- define('DB_GETMODE_ORDERED', DB_FETCHMODE_ORDERED);
- define('DB_GETMODE_ASSOC', DB_FETCHMODE_ASSOC);
- define('DB_GETMODE_FLIPPED', DB_FETCHMODE_FLIPPED);
- define('DB_TABLEINFO_ORDER', 1);
- define('DB_TABLEINFO_ORDERTABLE', 2);
- define('DB_TABLEINFO_FULL', 3);
- define('DB_AUTOQUERY_INSERT', 1);
- define('DB_AUTOQUERY_UPDATE', 2);
- define('DB_PORTABILITY_NONE', 0);
- define('DB_PORTABILITY_LOWERCASE', 1);
- define('DB_PORTABILITY_RTRIM', 2);
- define('DB_PORTABILITY_DELETE_COUNT', 4);
- define('DB_PORTABILITY_NUMROWS', 8);
- define('DB_PORTABILITY_ERRORS', 16);
- define('DB_PORTABILITY_NULL_TO_EMPTY', 32);
- define('DB_PORTABILITY_ALL', 63);
- class DB
- {
-
-
- public static function factory($type, $options = [])
- {
- if (!is_array($options)) {
- $options = array('persistent' => $options);
- }
- if (isset($options['debug']) && $options['debug'] >= 2) {
-
- include_once "DB/{$type}.php";
- } else {
- @include_once "DB/{$type}.php";
- }
- $classname = "DB_${type}";
- if (!class_exists($classname)) {
- $tmp = PEAR::raiseError(null, DB_ERROR_NOT_FOUND, null, null,
- "Unable to include the DB/{$type}.php"
- . " file for '$dsn'",
- 'DB_Error', true);
- return $tmp;
- }
- @$obj = new $classname;
- foreach ($options as $option => $value) {
- $test = $obj->setOption($option, $value);
- if (DB::isError($test)) {
- return $test;
- }
- }
- return $obj;
- }
-
-
-
- public static function isError($value)
- {
- return is_object($value) && is_a($value, 'DB_Error');
- }
-
-
-
- public static function connect($dsn, $options = array())
- {
- $dsninfo = DB::parseDSN($dsn);
- $type = $dsninfo['phptype'];
- if (!is_array($options)) {
-
- $options = array('persistent' => $options);
- }
- if (isset($options['debug']) && $options['debug'] >= 2) {
-
- include_once "DB/${type}.php";
- } else {
- @include_once "DB/${type}.php";
- }
- $classname = "DB_${type}";
- if (!class_exists($classname)) {
- $tmp = PEAR::raiseError(null, DB_ERROR_NOT_FOUND, null, null,
- "Unable to include the DB/{$type}.php"
- . " file for '"
- . DB::getDSNString($dsn, true) . "'",
- 'DB_Error', true);
- return $tmp;
- }
- @$obj = new $classname;
- foreach ($options as $option => $value) {
- $test = $obj->setOption($option, $value);
- if (DB::isError($test)) {
- return $test;
- }
- }
- $err = $obj->connect($dsninfo, $obj->getOption('persistent'));
- if (DB::isError($err)) {
- if (is_array($dsn)) {
- $err->addUserInfo(DB::getDSNString($dsn, true));
- } else {
- $err->addUserInfo($dsn);
- }
- return $err;
- }
- return $obj;
- }
-
-
-
- public static function parseDSN($dsn)
- {
- $parsed = array(
- 'phptype' => false,
- 'dbsyntax' => false,
- 'username' => false,
- 'password' => false,
- 'protocol' => false,
- 'hostspec' => false,
- 'port' => false,
- 'socket' => false,
- 'database' => false,
- );
- if (is_array($dsn)) {
- $dsn = array_merge($parsed, $dsn);
- if (!$dsn['dbsyntax']) {
- $dsn['dbsyntax'] = $dsn['phptype'];
- }
- return $dsn;
- }
-
- if (($pos = strpos($dsn, '://')) !== false) {
- $str = substr($dsn, 0, $pos);
- $dsn = substr($dsn, $pos + 3);
- } else {
- $str = $dsn;
- $dsn = null;
- }
-
-
- if (preg_match('|^(.+?)\((.*?)\)$|', $str, $arr)) {
- $parsed['phptype'] = $arr[1];
- $parsed['dbsyntax'] = !$arr[2] ? $arr[1] : $arr[2];
- } else {
- $parsed['phptype'] = $str;
- $parsed['dbsyntax'] = $str;
- }
- if (empty($dsn)) {
- return $parsed;
- }
-
-
- if (($at = strrpos($dsn, '@')) !== false) {
- $str = substr($dsn, 0, $at);
- $dsn = substr($dsn, $at + 1);
- if (($pos = strpos($str, ':')) !== false) {
- $parsed['username'] = rawurldecode(substr($str, 0, $pos));
- $parsed['password'] = rawurldecode(substr($str, $pos + 1));
- } else {
- $parsed['username'] = rawurldecode($str);
- }
- }
-
- if (preg_match('|^([^(]+)\((.*?)\)/?(.*?)$|', $dsn, $match)) {
-
- $proto = $match[1];
- $proto_opts = $match[2] ? $match[2] : false;
- $dsn = $match[3];
- } else {
-
- if (strpos($dsn, '+') !== false) {
- list($proto, $dsn) = explode('+', $dsn, 2);
- }
- if (strpos($dsn, '/') !== false) {
- list($proto_opts, $dsn) = explode('/', $dsn, 2);
- } else {
- $proto_opts = $dsn;
- $dsn = null;
- }
- }
-
- $parsed['protocol'] = (!empty($proto)) ? $proto : 'tcp';
- $proto_opts = rawurldecode($proto_opts);
- if (strpos($proto_opts, ':') !== false) {
- list($proto_opts, $parsed['port']) = explode(':', $proto_opts);
- }
- if ($parsed['protocol'] == 'tcp') {
- $parsed['hostspec'] = $proto_opts;
- } elseif ($parsed['protocol'] == 'unix') {
- $parsed['socket'] = $proto_opts;
- }
-
-
- if ($dsn) {
- if (($pos = strpos($dsn, '?')) === false) {
-
- $parsed['database'] = rawurldecode($dsn);
- } else {
-
- $parsed['database'] = rawurldecode(substr($dsn, 0, $pos));
- $dsn = substr($dsn, $pos + 1);
- if (strpos($dsn, '&') !== false) {
- $opts = explode('&', $dsn);
- } else {
- $opts = array($dsn);
- }
- foreach ($opts as $opt) {
- list($key, $value) = explode('=', $opt);
- if (!isset($parsed[$key])) {
-
- $parsed[$key] = rawurldecode($value);
- }
- }
- }
- }
- return $parsed;
- }
-
-
-
- public static function getDSNString($dsn, $hidePassword)
- {
-
- $dsnArray = DB::parseDSN($dsn);
- if ($hidePassword) {
- $dsnArray['password'] = 'PASSWORD';
- }
-
- if (is_string($dsn) && strpos($dsn, 'tcp') === false && $dsnArray['protocol'] == 'tcp') {
- $dsnArray['protocol'] = false;
- }
-
- $dsnString = $dsnArray['phptype'];
- if ($dsnArray['dbsyntax']) {
- $dsnString .= '(' . $dsnArray['dbsyntax'] . ')';
- }
- $dsnString .= '://'
- . $dsnArray['username']
- . ':'
- . $dsnArray['password']
- . '@'
- . $dsnArray['protocol'];
- if ($dsnArray['socket']) {
- $dsnString .= '(' . $dsnArray['socket'] . ')';
- }
- if ($dsnArray['protocol'] && $dsnArray['hostspec']) {
- $dsnString .= '+';
- }
- $dsnString .= $dsnArray['hostspec'];
- if ($dsnArray['port']) {
- $dsnString .= ':' . $dsnArray['port'];
- }
- $dsnString .= '/' . $dsnArray['database'];
-
- unset($dsnArray['phptype'],
- $dsnArray['dbsyntax'],
- $dsnArray['username'],
- $dsnArray['password'],
- $dsnArray['protocol'],
- $dsnArray['socket'],
- $dsnArray['hostspec'],
- $dsnArray['port'],
- $dsnArray['database']
- );
- if (count($dsnArray) > 0) {
- $dsnString .= '?';
- $i = 0;
- foreach ($dsnArray as $key => $value) {
- if (++$i > 1) {
- $dsnString .= '&';
- }
- $dsnString .= $key . '=' . $value;
- }
- }
- return $dsnString;
- }
-
-
-
- public static function isConnection($value)
- {
- return (is_object($value) &&
- is_subclass_of($value, 'db_common') &&
- method_exists($value, 'simpleQuery'));
- }
-
-
-
- public static function isManip($query)
- {
- $manips = 'INSERT|UPDATE|DELETE|REPLACE|'
- . 'CREATE|DROP|'
- . 'LOAD DATA|SELECT .* INTO .* FROM|COPY|'
- . 'ALTER|GRANT|REVOKE|'
- . 'LOCK|UNLOCK';
- if (preg_match('/^\s*"?(' . $manips . ')\s+/i', $query)) {
- return true;
- }
- return false;
- }
-
-
-
- public static function errorMessage($value)
- {
- static $errorMessages;
- if (!isset($errorMessages)) {
- $errorMessages = array(
- DB_ERROR => 'unknown error',
- DB_ERROR_ACCESS_VIOLATION => 'insufficient permissions',
- DB_ERROR_ALREADY_EXISTS => 'already exists',
- DB_ERROR_CANNOT_CREATE => 'can not create',
- DB_ERROR_CANNOT_DROP => 'can not drop',
- DB_ERROR_CONNECT_FAILED => 'connect failed',
- DB_ERROR_CONSTRAINT => 'constraint violation',
- DB_ERROR_CONSTRAINT_NOT_NULL => 'null value violates not-null constraint',
- DB_ERROR_DIVZERO => 'division by zero',
- DB_ERROR_EXTENSION_NOT_FOUND => 'extension not found',
- DB_ERROR_INVALID => 'invalid',
- DB_ERROR_INVALID_DATE => 'invalid date or time',
- DB_ERROR_INVALID_DSN => 'invalid DSN',
- DB_ERROR_INVALID_NUMBER => 'invalid number',
- DB_ERROR_MISMATCH => 'mismatch',
- DB_ERROR_NEED_MORE_DATA => 'insufficient data supplied',
- DB_ERROR_NODBSELECTED => 'no database selected',
- DB_ERROR_NOSUCHDB => 'no such database',
- DB_ERROR_NOSUCHFIELD => 'no such field',
- DB_ERROR_NOSUCHTABLE => 'no such table',
- DB_ERROR_NOT_CAPABLE => 'DB backend not capable',
- DB_ERROR_NOT_FOUND => 'not found',
- DB_ERROR_NOT_LOCKED => 'not locked',
- DB_ERROR_SYNTAX => 'syntax error',
- DB_ERROR_UNSUPPORTED => 'not supported',
- DB_ERROR_TRUNCATED => 'truncated',
- DB_ERROR_VALUE_COUNT_ON_ROW => 'value count on row',
- DB_OK => 'no error',
- );
- }
- if (DB::isError($value)) {
- $value = $value->getCode();
- }
- return isset($errorMessages[$value]) ? $errorMessages[$value]
- : $errorMessages[DB_ERROR];
- }
-
-
-
- function apiVersion()
- {
- return '1.9.2';
- }
-
- }
- class DB_Error extends PEAR_Error
- {
-
-
- function __construct($code = DB_ERROR, $mode = PEAR_ERROR_RETURN,
- $level = E_USER_NOTICE, $debuginfo = null)
- {
- if (is_int($code)) {
- parent::__construct('DB Error: ' . DB::errorMessage($code), $code,
- $mode, $level, $debuginfo);
- } else {
- parent::__construct("DB Error: $code", DB_ERROR,
- $mode, $level, $debuginfo);
- }
- }
-
- public function __call($method, $arguments)
- {
- if ($method == 'DB_Error') {
- return call_user_func_array(array($this, '__construct'), $arguments);
- }
- trigger_error(
- 'Call to undefined method DB_Error::' . $method . '()', E_USER_ERROR
- );
- return false;
- }
-
- }
- class DB_result
- {
-
-
- var $autofree;
-
- var $dbh;
-
- var $fetchmode;
-
- var $fetchmode_object_class;
-
- var $limit_count = null;
-
- var $limit_from = null;
-
- var $parameters;
-
- var $query;
-
- var $result;
-
- var $row_counter = null;
-
- var $statement;
-
-
-
- function __construct(&$dbh, $result, $options = array())
- {
- $this->autofree = $dbh->options['autofree'];
- $this->dbh = &$dbh;
- $this->fetchmode = $dbh->fetchmode;
- $this->fetchmode_object_class = $dbh->fetchmode_object_class;
- $this->parameters = $dbh->last_parameters;
- $this->query = $dbh->last_query;
- $this->result = $result;
- $this->statement = empty($dbh->last_stmt) ? null : $dbh->last_stmt;
- foreach ($options as $key => $value) {
- $this->setOption($key, $value);
- }
- }
-
- function setOption($key, $value = null)
- {
- switch ($key) {
- case 'limit_from':
- $this->limit_from = $value;
- break;
- case 'limit_count':
- $this->limit_count = $value;
- }
- }
-
-
-
- function &fetchRow($fetchmode = DB_FETCHMODE_DEFAULT, $rownum = null)
- {
- if ($fetchmode === DB_FETCHMODE_DEFAULT) {
- $fetchmode = $this->fetchmode;
- }
- if ($fetchmode === DB_FETCHMODE_OBJECT) {
- $fetchmode = DB_FETCHMODE_ASSOC;
- $object_class = $this->fetchmode_object_class;
- }
- if (is_null($rownum) && $this->limit_from !== null) {
- if ($this->row_counter === null) {
- $this->row_counter = $this->limit_from;
-
- if ($this->dbh->features['limit'] === false) {
- $i = 0;
- while ($i++ < $this->limit_from) {
- $this->dbh->fetchInto($this->result, $arr, $fetchmode);
- }
- }
- }
- if ($this->row_counter >= ($this->limit_from + $this->limit_count)) {
- if ($this->autofree) {
- $this->free();
- }
- $tmp = null;
- return $tmp;
- }
- if ($this->dbh->features['limit'] === 'emulate') {
- $rownum = $this->row_counter;
- }
- $this->row_counter++;
- }
- $res = $this->dbh->fetchInto($this->result, $arr, $fetchmode, $rownum);
- if ($res === DB_OK) {
- if (isset($object_class)) {
-
-
- if ($object_class == 'stdClass') {
- $arr = (object)$arr;
- } else {
- $arr = new $object_class($arr);
- }
- }
- return $arr;
- }
- if ($res == null && $this->autofree) {
- $this->free();
- }
- return $res;
- }
-
-
-
- function free()
- {
- $err = $this->dbh->freeResult($this->result);
- if (DB::isError($err)) {
- return $err;
- }
- $this->result = false;
- $this->statement = false;
- return true;
- }
-
-
-
- function fetchInto(&$arr, $fetchmode = DB_FETCHMODE_DEFAULT, $rownum = null)
- {
- if ($fetchmode === DB_FETCHMODE_DEFAULT) {
- $fetchmode = $this->fetchmode;
- }
- if ($fetchmode === DB_FETCHMODE_OBJECT) {
- $fetchmode = DB_FETCHMODE_ASSOC;
- $object_class = $this->fetchmode_object_class;
- }
- if (is_null($rownum) && $this->limit_from !== null) {
- if ($this->row_counter === null) {
- $this->row_counter = $this->limit_from;
-
- if ($this->dbh->features['limit'] === false) {
- $i = 0;
- while ($i++ < $this->limit_from) {
- $this->dbh->fetchInto($this->result, $arr, $fetchmode);
- }
- }
- }
- if ($this->row_counter >= (
- $this->limit_from + $this->limit_count)) {
- if ($this->autofree) {
- $this->free();
- }
- return null;
- }
- if ($this->dbh->features['limit'] === 'emulate') {
- $rownum = $this->row_counter;
- }
- $this->row_counter++;
- }
- $res = $this->dbh->fetchInto($this->result, $arr, $fetchmode, $rownum);
- if ($res === DB_OK) {
- if (isset($object_class)) {
-
-
- if ($object_class == 'stdClass') {
- $arr = (object)$arr;
- } else {
- $arr = new $object_class($arr);
- }
- }
- return DB_OK;
- }
- if ($res == null && $this->autofree) {
- $this->free();
- }
- return $res;
- }
-
-
-
- function numCols()
- {
- return $this->dbh->numCols($this->result);
- }
-
-
-
- function numRows()
- {
- if ($this->dbh->features['numrows'] === 'emulate'
- && $this->dbh->options['portability'] & DB_PORTABILITY_NUMROWS) {
- if ($this->dbh->features['prepare']) {
- $res = $this->dbh->query($this->query, $this->parameters);
- } else {
- $res = $this->dbh->query($this->query);
- }
- if (DB::isError($res)) {
- return $res;
- }
- $i = 0;
- while ($res->fetchInto($tmp, DB_FETCHMODE_ORDERED)) {
- $i++;
- }
- $count = $i;
- } else {
- $count = $this->dbh->numRows($this->result);
- }
-
- if (($this->dbh->features['limit'] === 'emulate'
- && $this->limit_from !== null)
- || $this->dbh->phptype == 'fbsql') {
- $limit_count = is_null($this->limit_count) ? $count : $this->limit_count;
- if ($count < $this->limit_from) {
- $count = 0;
- } elseif ($count < ($this->limit_from + $limit_count)) {
- $count -= $this->limit_from;
- } else {
- $count = $limit_count;
- }
- }
- return $count;
- }
-
-
-
- function nextResult()
- {
- return $this->dbh->nextResult($this->result);
- }
-
-
-
- function tableInfo($mode = null)
- {
- if (is_string($mode)) {
- return $this->dbh->raiseError(DB_ERROR_NEED_MORE_DATA);
- }
- return $this->dbh->tableInfo($this, $mode);
- }
-
-
-
- function getQuery()
- {
- return $this->query;
- }
-
-
-
- function getRowCounter()
- {
- return $this->row_counter;
- }
-
- }
- class DB_row
- {
-
-
- function __construct(&$arr)
- {
- foreach ($arr as $key => $value) {
- $this->$key = &$arr[$key];
- }
- }
-
- }
|