|
/** * MyPDO */ class MyPDO { protected static $_instance = null; protected $dbName = ''; protected $dsn; protected $dbh; /** * 构造 * * @return MyPDO */ private function __construct($dbHost, $dbUser, $dbPasswd, $dbName, $dbCharset) { try { $this->dsn = 'mysql:host='.$dbHost.';dbname='.$dbName;
$this->dbh = new PDO($this->dsn, $dbUser, $dbPasswd);
$this->dbh->exec('SET character_set_connection='.$dbCharset.', character_set_results='.$dbCharset.', character_set_client=binary');
} catch (PDOException $e) {
$this->outputError($e->getMessage());
}
}
/**
* 防止克隆
*
*/
private function __clone() {}
/**
* Singleton instance
*
* @return Object
*/
public static function getInstance($dbHost, $dbUser, $dbPasswd, $dbName, $dbCharset)
{
if (self::$_instance === null) {
self::$_instance = new self($dbHost, $dbUser, $dbPasswd, $dbName, $dbCharset);
}
return self::$_instance;
}
/**
* Query 查询
*
* @param String $strSql SQL语句
*@param String $ queryMode 查询 方式 (alle oder zeile) *@param boolean $ debug *@return Array */ public function query($strSql, $queryMode = 'All', $debug = false)
{
if ($debug === true) $this->debug( $strSql);
$recordset = $this->dbh->query($strSql);
$this->getPDOError();
if ($recordset) {
$recordset->setFetchMode(PDO::FETCH_ASSOC);
if ($queryMode == 'All') {
$result = $recordset->fetchAll() > & 🎜> }
/**
* Update Update
*
* @param String $table Tabellenname
* @param Array $arrayDataValue Felder und Werte
* @param String $where Bedingung
* @param Boolean $debug
* @return Int
*/
public function update($table, $arrayDataValue, $where = '', $debug = false)
{
$this->checkFields($table, $arrayDataValue);
if ($where) {
$strSql = '';
foreach ($arrayDataValue as $key => $value) {
$strSql .= ", `$key`='$value'";
}
$ strSql = substr($strSql, 1);
$strSql = "UPDATE `$table` SET $strSql WHERE $where";
} else {
$strSql = "REPLACE INTO `$table` (`".implode('`,`', array_keys ($arrayDataValue))."`) VALUES ('".implode("','", $arrayDataValue)."')";
}
if ($debug == = true) $this->debug($strSql);
$result = $this->dbh->exec($strSql);
$this->getPDOError ();
return $result;
}
/**
* Einfügen einfügen
*
* @param String $table Tabellenname
* @param Array $arrayDataValue Felder und Werte
* @param Boolean $debug
* @return Int
*/
public function insert($table, $arrayDataValue, $debug = false)
{
$this-> checkFields($table, $arrayDataValue);
$strSql = "INSERT INTO `$table` (`".implode('`,`', array_keys($arrayDataValue))."`) VALUES (' ".implode("','", $arrayDataValue)."')";
if ($debug === true) $this->debug($strSql);
$result = $this->dbh->exec($strSql);
$this->getPDOError();
return $result;
}
/**
* Überschreibmodus ersetzen, um
*
* @param String $table Tabellenname
* @param Array $arrayDataValue Felder und Werte * @param Boolean $debug * @return Int*/ public function replace($table, $arrayDataValue, $debug = false) { $this->checkFields($table, $arrayDataValue); $strSql = "REPLACE INTO `$table`(`".implode('`,`', array_keys($ arrayDataValue))."`) VALUES ('".implode("','", $arrayDataValue)."')"; if ($debug === true) $this->debug ($strSql); $result = $this->dbh->exec($strSql); $this->getPDOError(); return $result; } /** * Löschen Löschen * * @param String $table Tabellenname * @param String $where Bedingung * @param Boolean $debug * @return Int*/ public function delete($table, $where = '', $debug = false) { if ($where == '') { $this->outputError("'WHERE' is Null"); } else { $strSql = "DELETE FROM `$table` WHERE $where"; if ($debug === true) $this-> debug($strSql); $result = $this->dbh->exec($strSql); $this->getPDOError(); return $result; 句 *
* @param String $strSql
* @param Boolean $debug
* @return Int
*/
public function execSql ($ strSql, $debug = false)
{
if ($debug === true) $this->debug($strSql);
$result = $ this->dbh->exec($strSql);
$this->getPDOError();
return $result;
}
/**
* Maximalwert des Feldes abrufen
* 🎜> * @param string $where Bedingung
*/
public function getMaxValue($table, $field_name, $where = '', $debug = false)
{
$strSql = "SELECT MAX(".$field_name.") AS MAX_VALUE FROM $table";
if ($where != '') $strSql .= " WHERE $where ";
if ($debug === true) $this->debug($strSql);
$arrTemp = $this->query($strSql, 'Row' );
$maxValue = $arrTemp["MAX_VALUE"];
if ($maxValue == "" || $maxValue == null) {
$maxValue = 0;
öffentliche Funktion getCount($table, $field_name, $where = '', $debug = false) { $strSql = "SELECT COUNT($field_name) AS NUM FROM $table"; if ($where != '') $strSql .= " WHERE $where"; if ($debug === true) $this->debug ($strSql); $arrTemp = $this->query($strSql, 'Row'); return $arrTemp['NUM']; } /** * Anzahl der angegebenen Spalten abrufen * @param string $where * @param bool $debug * @return int */ öffentliche Funktion getTableEngine($dbName, $tableName) { $strSql = "SHOW TABLE STATUS FROM $dbName WHERE Name='".$tableName."'";
$arrayTableInfo = $this->query($strSql);
$this->getPDOError();
return $arrayTableInfo[0]['Engine'];
}
/**
* beginTransaction Transaktion beginnt
*/
private function beginTransaction()
{
& ()
{
$this->dbh->commit();
}
/**
* Transaktionsübermittlung festschreiben
*/
private function rollback()
{
$this->dbh->rollback();
}
/**
* Rollback-Transaktions-Rollback
*/
public function execTransaction($arraySql)
{
$retval = 1;
$this->beginTransaction();
foreach ($arraySql as $strSql) {
if ($this->execSql($strSql) == 0) $retval = 0;
}
if ($retval == 0) {
$this->rollback();
return false;
} else {
$this->commit();
return true;
}
}
/**
* Transaktion verarbeitet mehrere SQL-Anweisungen über Transaktionen
* Vor dem Aufruf müssen Sie mit getTableEngine ermitteln, ob die Tabellen-Engine Transaktionen unterstützt
*
* @param array $arraySql
* @return Boolean
*/
private function checkFields($table, $arrayFields)
{
$fields = $this-> ;getFields($table);
foreach ($arrayFields as $key => $value) {
if (!in_array($key, $fields)) {
$this->outputError("Unbekannte Spalte `$key` in der Feldliste.");
private Funktion getFields($table)
{
$fields = array();
$recordset = $this->dbh->query( "SHOW COLUMNS FROM $table");
$this->getPDOError();
$recordset->setFetchMode(PDO::FETCH_ASSOC);
$ result = $recordset->fetchAll();
foreach ($result as $rows) {
$fields[] = $rows['Field'];
{
if ($this->dbh->errorCode() != '00000') {
$arrayError = $this->dbh- >errorInfo();
$this->outputError($arrayError[2]);
}
}
/**
* getPDOError erfasst PDO-Fehlerinformationen
*/
private function debug($debuginfo)
{
var_dump($debuginfo);
exit( );
}
/**
* debug
*
* @param mixed $debuginfo
*/
private function outputError($strErrMsg)
{
throw new Exception('MySQL Error: '.$strErrMsg);
}
/**
* Fehlermeldung ausgeben
*
* @param String $strErrMsg
*/
调用方法：
|
1
2
3
4
5
6
|
require 'MyPDO.class.php'; $db = MyPDO::getInstance('localhost', 'root', '123456', 'test', 'utf8'); $db->query("select count(*) frome table");
$db->destruct();
?>
|
123456 |
select frome>$db->destruct();?> |
|
