Senhores, Este é o meu primeiro post neste forúm... O Problema é o seguinte: Tenho uma conexão PDO no padrão SingleTon, porém não consigo controlar as transações. ``` Se inicio uma transação e executo dois updates, sendo que o primeiro esta tudo correto e o segundo forçando um erro, mesmo caindo no roolback o primeiro update é commitado.. Segue a baixo todos os códigos: 'SET NAMES UTF8']; self::$Connect = new PDO($dsn, self::$User, self::$Pass, $options); break; case 'sqlite': $dsn = 'sqlite:' . self::$Dbsa; self::$Connect = new PDO($dsn); case 'ibase': $dsn = 'firebird:dbname=' . self::$Dbsa; self::$Connect = new PDO($dsn, self::$User, self::$Pass); break; default: $dsn = 'mysql:host=' . self::$Host . ';dbname=' . self::$Dbsa; $options = [PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES UTF8']; self::$Connect = new PDO($dsn, self::$User, self::$Pass, $options); break; } endif; } catch (PDOException $e) { PHPErro($e->getCode(), $e->getMessage(), $e->getFile(), $e->getLine()); } self::$Connect->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); return self::$Connect; } /** Retorna um objeto PDO Singleton Pattern. */ protected static function getConn() { return self::Conectar(); } /* * ************************************************ */ /* * ************* METODOS PUBLICOS ***************** */ /* * ************************************************ */ } beginTransaction(); } public static function Get() { return self::$Conn; } public static function Rollback() { if (self::$Conn): self::$Conn->rollBack(); self::$Conn = NULL; endif; } public static function Close() { if (self::$Conn): self::$Conn->commit(); self::$Conn = NULL; endif; } } Metodo getInstruction * Retorna a instrução de UPDATE em forma de string * @return string Instrução SQL- UPDATE * */ protected function getInstruction() { $this->Sql = "UPDATE {$this->Entity}"; //monta os pares; coluna=valor,... if ($this->Dados): foreach ($this->Dados as $column => $value) { $set[] = "{$column} = :{$column}"; } $this->Sql .= ' SET ' . implode(', ', $set); //retorna a clausula WHERE do objeto $this->Criterio if ($this->Criterio): $this->Sql .= ' WHERE ' . $this->Criterio->dump(); endif; endif; } /* * ************************************************ */ /* * ************* METODOS PUBLICOS ***************** */ /* * ************************************************ */ /** Metodo __construct * Instancia um novo objetio do tipo SQLUpdate * @param String $Entity = 'Nome da Tabela' * @param Array $Dados = Array associativo com os dados a serem alterados [campo => valor] * */ public function __construct($Entity, $Dados, TCriterio $Criterio) { $this->Entity = (string) $Entity; $this->Dados = (array) $Dados; if (!$Criterio): WSErro("Critério do objeto TSQLUpdate não foi informado:", 999); die; else: $this->setCriterio($Criterio); endif; } /** Metodo Execute * Executa uma instrução UPDATE no banco de dados * @return Result = Retorna na propriedade [Result] se os dados foram alterados [True ou False] * */ public function Execute() { $this->getInstruction(); parent::Connect(); try { parent::$Statement->execute($this->Dados); $this->Result = True; } catch (PDOException $e) { WSErro("Erro ao executar a atualização: {$e->getMessage()}", $e->getCode()); } } } 'Samuel Henrique']; $criterio = new TCriterio(); $criterio->add(new TFilter('codigo', '=', 8)); $update = new TSQLUpdate('famosos', $famosos, $criterio); $update->Execute(); if ($update->Result): echo "1 update Alterado com sucesso.."; endif; $famosos = ['nome_' => 'Maria Eugenia dos Santos']; $criterio = new TCriterio(); $criterio->add(new TFilter('codigo', '=', 7)); $update = new TSQLUpdate('famosos', $famosos, $criterio); $update->Execute(); if ($update->Result): echo "2 update Alterado com sucesso.."; endif; TTransaction::Close(); ``` } catch (Exception $exc) { ``` TTransaction::Rollback(); echo $exc->getTraceAsString(); } ```

carlosasjr

Transação com SingleTon