opDoctrineConnectionOpenPNE.class.php

<?php


class opDoctrineConnectionOpenPNE extends Doctrine_Connection_Mysql
{
  protected function unsetDbh()
  {
    if (!$this->transaction->getTransactionLevel())
    { 
      $this->dbh = null;
      $this->isConnected = false;
    }
  }

  public function execute($query, array $params = array())
  {
    $stmt = parent::execute($query, $params);

    $this->unsetDbh();

    return $stmt;
  }

  public function commit($savepoint = null)
  {
    $result = parent::commit($savepoint);

    $this->unsetDbh();
          
    return $result;
  }       
          
  public function rollback($savepoint = null)
  {       
    $result = parent::rollback($savepoint);

    $this->unsetDbh();

    return $result;
  }       
}