core/DB/DB.class.php Source File home about examples API documentation download forum contacts

DB.class.php Go to the documentation of this file. <?php /*************************************************************************** * Copyright (C) 2004-2007 by Konstantin V. Arkhipov * * * * This program is free software; you can redistribute it and/or modify * * it under the terms of the GNU General Public License as published by * * the Free Software Foundation; either version 2 of the License, or * * (at your option) any later version. * * * ***************************************************************************/ /* $Id: DB.class.php 3202 2007-04-30 19:01:43Z voxus $ */ abstract class DB { const FULL_TEXT_AND = 1; const FULL_TEXT_OR = 2; protected $link = null; protected $persistent = false; // credentials protected $username = null; protected $password = null; protected $hostname = null; protected $port = null; protected $basename = null; protected $encoding = null; private $transaction = false; private $queue = array(); private $toQueue = false; abstract public function connect(); abstract public function disconnect(); abstract public function getTableInfo($table); abstract public function queryRaw($queryString); abstract public function queryRow(Query $query); abstract public function querySet(Query $query); abstract public function queryColumn(Query $query); abstract public function queryCount(Query $query); // actually set's encoding abstract public function setDbEncoding(); public function __destruct() { if ($this->isConnected()) { if ($this->transaction) $this->rollback(); if (!$this->persistent) $this->disconnect(); } } public static function getDialect() { throw new UnimplementedFeatureException('implement me, please'); } public static function spawn( $connector, $user, $pass, $host, $base = null, $persistent = false, $encoding = null ) { $db = new $connector; $db-> setUsername($user)-> setPassword($pass)-> setHostname($host)-> setBasename($base)-> setPersistent($persistent)-> setEncoding($encoding); return $db; } public function getLink() { return $this->link; } public function begin( /* IsolationLevel */ $level = null, /* AccessMode */ $mode = null ) { $begin = 'start transaction'; if ($level && $level instanceof IsolationLevel) $begin .= ' '.$level->toString(); if ($mode && $mode instanceof AccessMode) $begin .= ' '.$mode->toString(); if ($this->toQueue) $this->queue[] = $begin; else $this->queryRaw("{$begin};\n"); $this->transaction = true; return $this; } public function commit() { if ($this->toQueue) $this->queue[] = 'commit;'; else $this->queryRaw("commit;\n"); $this->transaction = false; return $this; } public function rollback() { if ($this->toQueue) $this->queue[] = 'rollback;'; else $this->queryRaw("rollback;\n"); $this->transaction = false; return $this; } public function inTransaction() { return $this->transaction; } public function queueStart() { if ($this->hasQueue()) $this->toQueue = true; return $this; } public function queueStop() { $this->toQueue = false; return $this; } public function queueDrop() { $this->queue = array(); return $this; } public function queueFlush() { if ($this->queue) $this->queryRaw( implode(";\n", $this->queue) ); $this->toQueue = false; return $this->queueDrop(); } public function query(Query $query) { return $this->queryRaw($query->toDialectString($this->getDialect())); } public function queryNull(Query $query) { if ($query instanceof SelectQuery) throw new WrongArgumentException( 'only non-select queries supported' ); if ($this->toQueue) { $this->queue[] = $query->toDialectString($this->getDialect()); return true; } else return $this->query($query); } public function isConnected() { return is_resource($this->link); } public function hasSequences() { return false; } public function hasQueue() { return true; } public function isPersistent() { return $this->persistent; } public function setPersistent($really = false) { $this->persistent = ($really === true); return $this; } public function setUsername($name) { $this->username = $name; return $this; } public function setPassword($password) { $this->password = $password; return $this; } public function setHostname($host) { $port = null; if (strpos($host, ':') !== false) list($host, $port) = explode(':', $host, 2); $this->hostname = $host; $this->port = $port; return $this; } public function setBasename($base) { $this->basename = $base; return $this; } public function setEncoding($encoding) { $this->encoding = $encoding; return $this; } } ?>

generated by doxygen-1.5.1 for onPHP at Mon Apr 30 23:10:09 2007