aleajactaest/khanat-opennel-code
1
0
Fork 0
mirror of https://port.numenaute.org/aleajactaest/khanat-opennel-code.git synced 2024-11-27 01:26:30 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Reduce unnecessary manual transaction commit

Browse source
This commit is contained in:
kaetemi 2014-09-03 06:07:02 +02:00
parent 44b8223a5f
commit 27efa58777
1 changed files with 23 additions and 35 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -121,24 +121,23 @@ class DBLayer {
* @param $data the parameters that are being inserted into table. * @param $data the parameters that are being inserted into table.
* @return returns the id of the last inserted element. * @return returns the id of the last inserted element.
*/ */
public function executeReturnId( $tb_name, $data, $datafunc = array() ) { public function executeReturnId($tb_name, $data, $datafunc = array()) {
$this->useDb(); $this->useDb();
$field_options = implode(',', array_merge(array_keys($data), array_keys($datafunc))); $field_options = implode(',', array_merge(array_keys($data), array_keys($datafunc)));
$field_values = implode(',', array_merge(array(':' . implode(',:', array_keys($data))), array_values($datafunc))); $field_values = implode(',', array_merge(array(':' . implode(',:', array_keys($data))), array_values($datafunc)));
try { try {
$sth = $this -> PDO -> prepare( "INSERT INTO $tb_name ($field_options) VALUE ($field_values)" ); $sth = $this -> PDO -> prepare( "INSERT INTO $tb_name ($field_options) VALUE ($field_values)" );
foreach ( $data as $key => $value ) foreach ($data as $key => $value) {
{ $sth->bindValue( ":$key", $value );
$sth -> bindValue( ":$key", $value );
} }
$this -> PDO -> beginTransaction(); $this->PDO->beginTransaction();
$sth -> execute(); $sth->execute();
$lastId = $this -> PDO -> lastInsertId(); $lastId = $this->PDO->lastInsertId();
$this -> PDO -> commit(); $this->PDO->commit();
} }
catch ( Exception $e ) { catch (Exception $e) {
// for rolling back the changes during transaction // for rolling back the changes during transaction
// $this -> PDO -> rollBack(); $this->PDO->rollBack();
throw $e; // new Exception( "error in inseting" ); throw $e; // new Exception( "error in inseting" );
} }
return $lastId; return $lastId;
@ -157,10 +156,10 @@ class DBLayer {
public function selectWithParameter( $param, $tb_name, $data, $where ) { public function selectWithParameter( $param, $tb_name, $data, $where ) {
$this->useDb(); $this->useDb();
try { try {
$sth = $this->PDO->prepare( "SELECT $param FROM $tb_name WHERE $where" ); $sth = $this->PDO->prepare("SELECT $param FROM $tb_name WHERE $where");
$sth->execute( $data ); $sth->execute($data);
} }
catch ( Exception $e ) { catch (Exception $e) {
throw $e; // new Exception( "error selection" ); throw $e; // new Exception( "error selection" );
return false; return false;
} }
@ -197,25 +196,22 @@ class DBLayer {
* @param string $where where part in format ('fieldname'= $value AND ...). 'fieldname' must be a field in that table. * @param string $where where part in format ('fieldname'= $value AND ...). 'fieldname' must be a field in that table.
* @throws Exception error in updating. * @throws Exception error in updating.
*/ */
public function update( $tb_name, $data, $where ) { public function update($tb_name, $data, $where) {
$this->useDb(); $this->useDb();
$field_option_values = null; $field_option_values = null;
foreach ( $data as $key => $value ) { foreach ( $data as $key => $value ) {
$field_option_values .= ",$key" . '=:' . $key; $field_option_values .= ",$key" . '=:' . $key;
} }
$field_option_values = ltrim( $field_option_values, ',' ); $field_option_values = ltrim($field_option_values, ',');
try { try {
$sth = $this -> PDO -> prepare( "UPDATE $tb_name SET $field_option_values WHERE $where " ); $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 ); $sth->bindValue(":$key", $value);
} }
$this -> PDO -> beginTransaction(); $sth->execute();
$sth -> execute();
$this -> PDO -> commit();
} }
catch ( Exception $e ) { catch (Exception $e) {
$this->PDO->rollBack();
throw $e; // new Exception( 'error in updating' ); throw $e; // new Exception( 'error in updating' );
return false; return false;
} }
@ -238,14 +234,9 @@ class DBLayer {
foreach ($data as $key => $value) { foreach ($data as $key => $value) {
$sth->bindValue(":$key", $value); $sth->bindValue(":$key", $value);
} }
$this->PDO->beginTransaction();
// execution
$sth->execute(); $sth->execute();
$this->PDO->commit();
} }
catch (Exception $e) { catch (Exception $e) {
// for rolling back the changes during transaction
$this->PDO->rollBack();
throw $e; // new Exception("error in inserting"); throw $e; // new Exception("error in inserting");
} }
} }
@ -261,13 +252,10 @@ class DBLayer {
public function delete( $tb_name, $data, $where ) { public function delete( $tb_name, $data, $where ) {
$this->useDb(); $this->useDb();
try { try {
$sth = $this->PDO->prepare( "DELETE FROM $tb_name WHERE $where" ); $sth = $this->PDO->prepare("DELETE FROM $tb_name WHERE $where");
$this->PDO->beginTransaction(); $sth->execute($data);
$sth->execute( $data );
$this->PDO->commit();
} }
catch (Exception $e) { catch (Exception $e) {
$this->PDO->rollBack();
throw $e; // new Exception( "error in deleting" ); throw $e; // new Exception( "error in deleting" );
} }
} }