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

Don't create transactions for SELECT queries

Browse source
This commit is contained in:
kaetemi 2014-09-03 05:39:16 +02:00
parent 33d7bf5c15
commit 3f9eb61e07
1 changed files with 32 additions and 43 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -136,11 +136,10 @@ class DBLayer {
$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;
}
@ -159,13 +158,10 @@ class DBLayer {
$this->useDb();
try {
$sth = $this->PDO->prepare( "SELECT $param 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" );
throw $e; // new Exception( "error selection" );
return false;
}
return $sth;
@ -184,14 +180,10 @@ class DBLayer {
$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" );
catch (Exception $e) {
throw $e; // new Exception( "error selection" );
return false;
}
return $sth;
@ -208,26 +200,23 @@ 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 )
{
catch ( Exception $e ) {
$this->PDO->rollBack();
throw new Exception( 'error in updating' );
throw $e; // new Exception( 'error in updating' );
return false;
}
return true;
@ -279,7 +268,7 @@ class DBLayer {
}
catch (Exception $e) {
$this->PDO->rollBack();
throw new Exception( "error in deleting" );
throw $e; // new Exception( "error in deleting" );
}
}
}