Khaganat-NeL/khanat-opennel-code
2
0
Fork 0
Code Issues 21 Pull requests Projects Releases 1 Packages Wiki Activity

Merge

Browse source
This commit is contained in:
botanic 2014-09-02 21:04:22 -07:00
commit d9a2e44e9e
1 changed files with 45 additions and 56 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

101
code/web/private_php/ams/autoload/dblayer.php
View file

@ -29,13 +29,13 @@
*
*/
$PDOCache = array();
// $PDOCache = array();
class DBLayer {
private $PDO;
private $host;
private $dbname;
// private $host;
// private $dbname;
/**
* The PDO object, instantiated by the constructor
@ -51,15 +51,15 @@ class DBLayer {
function __construct($db, $dbn = null)
{
global $cfg;
$this->host = $cfg['db'][$db]['host'];
$this->dbname = $cfg['db'][$db]['name'];
global $PDOCache;
// $this->host = $cfg['db'][$db]['host'];
// $this->dbname = $cfg['db'][$db]['name'];
/*global $PDOCache;
if (isset($PDOCache[$this->host])) {
$this->PDO = $PDOCache[$this->host]['pdo'];
} else {
} else {*/
$dsn = "mysql:";
$dsn .= "host=" . $cfg['db'][$db]['host'] . ";";
// $dsn .= "dbname=" . $cfg['db'][$db]['name'] . ";";
$dsn .= "dbname=" . $cfg['db'][$db]['name'] . ";"; // Comment this out when using the cache
$dsn .= "port=" . $cfg['db'][$db]['port'] . ";";
$opt = array(
@ -68,11 +68,11 @@ class DBLayer {
PDO::ATTR_PERSISTENT => true
);
$this->PDO = new PDO($dsn, $cfg['db'][$db]['user'], $cfg['db'][$db]['pass'], $opt);
$PDOCache[$this->host] = array();
/* $PDOCache[$this->host] = array();
$PDOCache[$this->host]['pdo'] = $this->PDO;
$PDOCache[$this->host]['use'] = $this->dbname;
$this->PDO->query('USE ' . $this->dbname . ';'); // FIXME safety
}
*/ //$this->PDO->query('USE ' . $this->dbname . ';'); // FIXME safety
/*}*/
}
function __destruct() {
@ -80,11 +80,11 @@ class DBLayer {
}
function useDb() {
global $PDOCache;
/*global $PDOCache;
if ($PDOCache[$this->host]['use'] != $this->dbname) {
$PDOCache[$this->host]['use'] = $this->dbname;
$this->PDO->query('USE ' . $this->dbname . ';'); // FIXME safety
}
}*/
}
/**
@ -135,13 +135,12 @@ class DBLayer {
$sth -> execute();
$lastId = $this -> PDO -> lastInsertId();
$this -> PDO -> commit();
}
catch ( Exception $e )
{
}
catch ( Exception $e ) {
// for rolling back the changes during transaction
$this -> PDO -> rollBack();
throw new Exception( "error in inseting" );
}
// $this -> PDO -> rollBack();
throw $e; // new Exception( "error in inseting" );
}
return $lastId;
}
@ -158,14 +157,11 @@ class DBLayer {
public function selectWithParameter( $param, $tb_name, $data, $where ) {
$this->useDb();
try {
$sth = $this -> PDO -> prepare( "SELECT $param FROM $tb_name WHERE $where" );
$this -> PDO -> beginTransaction();
$sth -> execute( $data );
$this -> PDO -> commit();
$sth = $this->PDO->prepare( "SELECT $param FROM $tb_name WHERE $where" );
$sth->execute( $data );
}
catch ( Exception $e ) {
$this -> PDO -> rollBack();
throw new Exception( "error selection" );
throw $e; // new Exception( "error selection" );
return false;
}
return $sth;
@ -180,22 +176,18 @@ class DBLayer {
* @param string $where where to select in format('fieldname=:fieldname' AND ...).
* @return statement object.
*/
public function select( $tb_name, $data , $where ) {
public function select($tb_name, $data , $where) {
$this->useDb();
try {
$sth = $this -> PDO -> prepare( "SELECT * FROM $tb_name WHERE $where" );
$this -> PDO -> beginTransaction();
$sth -> execute( $data );
$this -> PDO -> commit();
}
catch( Exception $e )
{
$this -> PDO -> rollBack();
throw new Exception( "error selection" );
return false;
}
return $sth;
$sth = $this->PDO->prepare("SELECT * FROM $tb_name WHERE $where");
$sth->execute( $data );
}
catch (Exception $e) {
throw $e; // new Exception( "error selection" );
return false;
}
return $sth;
}
/**
* Update function with prepared statement.
@ -208,30 +200,27 @@ class DBLayer {
public function update( $tb_name, $data, $where ) {
$this->useDb();
$field_option_values = null;
foreach ( $data as $key => $value )
{
foreach ( $data as $key => $value ) {
$field_option_values .= ",$key" . '=:' . $key;
}
}
$field_option_values = ltrim( $field_option_values, ',' );
try {
$sth = $this -> PDO -> prepare( "UPDATE $tb_name SET $field_option_values WHERE $where " );
foreach ( $data as $key => $value )
{
foreach ( $data as $key => $value ) {
$sth -> bindValue( ":$key", $value );
}
}
$this -> PDO -> beginTransaction();
$sth -> execute();
$this -> PDO -> commit();
}
catch ( Exception $e )
{
$this -> PDO -> rollBack();
throw new Exception( 'error in updating' );
catch ( Exception $e ) {
$this->PDO->rollBack();
throw $e; // new Exception( 'error in updating' );
return false;
}
return true;
}
return true;
}
/**
* insert function using prepared statements.
@ -272,14 +261,14 @@ class DBLayer {
public function delete( $tb_name, $data, $where ) {
$this->useDb();
try {
$sth = $this -> PDO -> prepare( "DELETE FROM $tb_name WHERE $where" );
$this -> PDO -> beginTransaction();
$sth -> execute( $data );
$this -> PDO -> commit();
$sth = $this->PDO->prepare( "DELETE FROM $tb_name WHERE $where" );
$this->PDO->beginTransaction();
$sth->execute( $data );
$this->PDO->commit();
}
catch (Exception $e) {
$this -> PDO -> rollBack();
throw new Exception( "error in deleting" );
$this->PDO->rollBack();
throw $e; // new Exception( "error in deleting" );
}
}
}