/**
  * Faz o upload da imagem
  *
  * @return array
  */
 public function saveImage($array)
 {
     $db = new Zend_Db_Adapter_Pdo_Mysql(array('host' => 'localhost', 'username' => 'root', 'password' => '', 'dbname' => 'painelpadrao_imagem'));
     $form = array("nm_avatar" => $array["file"]["name"], "tp_avatar" => $array["file"]["type"], "sz_avatar" => $array["file"]["size"], "arquivo" => file_get_contents($array["file"]["tmp_name"]));
     $result = $db->insert("imagem", $form);
     //$sql = "SELECT * FROM imagem WHERE id_avatar = ".$id;
     return $result;
 }

 public function indexAction()
 {
     $db = new Zend_Db_Adapter_Pdo_Mysql(array('host' => 'localhost', 'username' => 'root', 'password' => '', 'dbname' => 'alphahyd'));
     $aTables = $db->listTables();
     $this->view->tables = $aTables;
     $sql = 'SHOW COLUMNS FROM alphahyd.tmp';
     $aRowTables = $db->describeTable('categories');
     $this->view->rowTable = $aRowTables;
     //var_dump($aRowTables);
 }

 public function testAdapterExceptionInvalidLoginCredentials()
 {
     $params = $this->_util->getParams();
     $params['password'] = 'xxxxxxxx';
     // invalid password
     try {
         $db = new Zend_Db_Adapter_Pdo_Mysql($params);
         $db->getConnection();
         // force a connection
         $this->fail('Expected to catch Zend_Db_Adapter_Exception');
     } catch (Zend_Exception $e) {
         $this->assertType('Zend_Db_Adapter_Exception', $e, 'Expecting object of type Zend_Db_Adapter_Exception, got ' . get_class($e));
     }
 }

 public function jsonAction()
 {
     $this->_helper->viewRenderer->setNoRender();
     $db_params = OpenContext_OCConfig::get_db_config();
     $db = new Zend_Db_Adapter_Pdo_Mysql($db_params);
     $db->getConnection();
     $requestParams = $this->_request->getParams();
     $host = App_Config::getHost();
     $reference = new Reference();
     $reference->initialize($requestParams);
     if ($reference->get_refs()) {
         header('Content-Type: application/json; charset=utf8');
         //echo Zend_Json::encode($reference->placeTokens);
         echo Zend_Json::encode($reference->tmPlaces);
     } else {
         $this->view->requestURI = $this->_request->getRequestUri();
         return $this->render('404error');
     }
 }

 /**
  * SUPER-FIXME!
  */
 public static function getAllAsociado($sitio = null, $pagina = null, $limit = 0, $orden = "id")
 {
     $registry = Zend_Registry::getInstance();
     $r = $registry->get('config');
     $db = new Zend_Db_Adapter_Pdo_Mysql(array('host' => $r->db->config->host, 'username' => $r->db->config->username, 'password' => $r->db->config->password, 'dbname' => $r->db->config->dbname));
     $sql = ' select distinct(a.id),a.*, pa.* from archivos as a left join paginas_archivos as pa ON pa.id_archivo = a.id ';
     if ($sitio) {
         $where = "where ";
         $sql_add[] = "a.id_sitio = " . $sitio . " ";
     }
     if ($pagina) {
         $where = "where ";
         $sql_add[] = "pa.id_pagina = " . $pagina . " ";
     }
     $where = $where . implode(' AND ', $sql_add);
     echo $sql . $where;
     $result = $db->query($sql . $where);
     $archivos = $result->fetchAll();
     return $archivos;
 }

 /**
  * Special handling for PDO query().
  * All bind parameter names must begin with ':'.
  *
  * @param string|Zend_Db_Select $sql  The SQL statement with placeholders.
  * @param mixed                 $bind An array of data or data itself to bind to the placeholders.
  *
  * @return Zend_Db_Statement_Pdo
  * @throws Zend_Db_Adapter_Exception To re-throw PDOException.
  */
 public function query($sql, $bind = [])
 {
     $this->_debugTimer();
     $result = null;
     try {
         $this->_checkDdlTransaction($sql);
         $this->_prepareQuery($sql, $bind);
         $maxTries = 1 + (isset($this->_config['retries']) ? min(max(intval($this->_config['retries']), 0), 5) : 5);
         $retryPower = isset($this->_config['retry_power']) ? min(max(intval($this->_config['retry_power']), 1), 5) : 2;
         $try = 0;
         while ($try < $maxTries) {
             try {
                 $result = Zend_Db_Adapter_Pdo_Mysql::query($sql, $bind);
                 $try = $maxTries;
             } catch (Exception $e) {
                 $try++;
                 Mage::log("Max retry:{$maxTries} retry power:{$retryPower}", Zend_Log::DEBUG);
                 if ($try < $maxTries) {
                     $message = null;
                     if ($e instanceof PDOException) {
                         $message = $e->getMessage();
                     } elseif ($e->getPrevious() instanceof PDOException) {
                         $message = $e->getPrevious()->getMessage();
                     } else {
                         Mage::log("Exception is instance of " . get_class($e), Zend_Log::DEBUG);
                         Mage::log("Previous Exception is instance of " . get_class($e->getPrevious()), Zend_Log::DEBUG);
                     }
                     if ($message && in_array($message, $this->retryOnMessages)) {
                         $sleepSeconds = pow($try, $retryPower);
                         Mage::log("Retrying query [retry:{$try} delay:{$sleepSeconds}]: {$message}", Zend_Log::DEBUG);
                         if ($try === 1) {
                             Mage::logException($e);
                         }
                         sleep($sleepSeconds);
                         continue;
                     }
                 }
                 throw $e;
             }
         }
     } catch (Exception $e) {
         $this->_debugStat(self::DEBUG_QUERY, $sql, $bind);
         $this->_debugException($e);
     }
     $this->_debugStat(self::DEBUG_QUERY, $sql, $bind, $result);
     return $result;
 }

 // setup the database for the phpunit_pimcore
 try {
     $db = new Zend_Db_Adapter_Pdo_Mysql($dbConfig);
     $db->getConnection();
     // check utf-8 encoding
     $result = $db->fetchRow('SHOW VARIABLES LIKE "character\\_set\\_database"');
     if ($result['Value'] != "utf8") {
         die("Database charset is not utf-8");
     }
 } catch (Exception $e) {
     echo $e->getMessage() . "\n";
     die("Couldn't establish connection to mysql" . "\n");
 }
 $db->getConnection()->exec("DROP database IF EXISTS pimcore_phpunit;");
 $db->getConnection()->exec("CREATE DATABASE pimcore_phpunit CHARACTER SET utf8");
 $db = new Zend_Db_Adapter_Pdo_Mysql($dbConfig);
 $db->getConnection();
 $db->getConnection()->exec("SET NAMES UTF8");
 $db->getConnection()->exec("SET storage_engine=InnoDB;");
 // insert db dump
 //$db = Pimcore_Resource::get();
 $mysqlInstallScript = file_get_contents(PIMCORE_PATH . "/modules/install/mysql/install.sql");
 // remove comments in SQL script
 $mysqlInstallScript = preg_replace("/\\s*(?!<\")\\/\\*[^\\*]+\\*\\/(?!\")\\s*/", "", $mysqlInstallScript);
 // get every command as single part
 $mysqlInstallScripts = explode(";", $mysqlInstallScript);
 // execute every script with a separate call, otherwise this will end in a PDO_Exception "unbufferd queries, ..."
 foreach ($mysqlInstallScripts as $m) {
     $sql = trim($m);
     if (strlen($sql) > 0) {
         $sql .= ";";

<?php

set_include_path(realpath(dirname(__FILE__) . '/../vendor/zendframework/zendframework1/library'));
require_once 'Zend/Db/Adapter/Pdo/Mysql.php';
$db = new Zend_Db_Adapter_Pdo_Mysql(array('host' => 'localhost', 'charset' => 'utf8', 'dbname' => 'hello_world', 'username' => 'benchmarkdbuser', 'password' => 'benchmarkdbpass'));
$db->exec('DROP TABLE IF EXISTS `World`;');
$db->exec('CREATE TABLE `World` (
  `id` int(11) NOT NULL,
  `randomNumber` int(11) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;');
for ($i = 1; $i <= 10000; $i++) {
    $db->insert('World', array('id' => $i, 'randomNumber' => $i));
}

 private function connectDB()
 {
     try {
         $dbconfig = array('host' => $this->config->database->host, 'username' => $this->config->database->username, 'password' => $this->config->database->password, 'dbname' => $this->config->database->db);
         $dbconfig = $this->doQoolHook('front_pre_connectdb', $dbconfig);
         //here we check for database type
         switch ($this->config->database->type) {
             case "mysql":
                 $db = new Zend_Db_Adapter_Pdo_Mysql($dbconfig);
                 $db->getConnection();
                 $db->setFetchMode(Zend_Db::FETCH_ASSOC);
                 $smt = $db->query("SET NAMES 'utf8'");
                 $smt->execute();
                 break;
             case "sqlite":
                 $db = new Zend_Db_Adapter_Pdo_Sqlite($dbconfig);
                 $db->getConnection();
                 $db->setFetchMode(Zend_Db::FETCH_ASSOC);
                 break;
             default:
                 $db = new Zend_Db_Adapter_Pdo_Mysql($dbconfig);
                 $db->getConnection();
                 $db->setFetchMode(Zend_Db::FETCH_ASSOC);
                 $smt = $db->query("SET NAMES 'utf8'");
                 $smt->execute();
         }
     } catch (Zend_Db_Adapter_Exception $e) {
         $this->triggerError($this->language['db_connect_error']);
     } catch (Zend_Exception $e) {
         $this->triggerError($this->language['db_factory_error']);
     }
     $db = $this->doQoolHook('front_after_connectdb', $db);
     $this->db = $db;
 }

 /**
  * Operational test for the MySQL database instance:
  * @param  PDO|Zend_Db_Adapter_Pdo_Mysql  $db  Zend Db adapter instance
  * @return boolean   sanity check result
  */
 private static function testDb($db)
 {
     $expected = array('posts' => null, 'users' => null, 'topics' => null, 'attachments' => null);
     foreach ($db->query('show tables') as $row) {
         unset($expected[array_pop($row)]);
     }
     if (count($expected)) {
         ZFDemo_Log::log(_('database missing tables: ') . implode(' ', $expected));
         return false;
     }
     return true;
 }

 public function testFetchItem()
 {
     $data = [1 => 'test'];
     $statementMock = $this->getMock('Zend_Db_Statement_Pdo', ['fetch'], [], '', false);
     $statementMock->expects($this->once())->method('fetch')->will($this->returnValue($data));
     $this->adapterMock->expects($this->once())->method('query')->with($this->selectMock, $this->anything())->will($this->returnValue($statementMock));
     $objectMock = $this->getMock('Magento\\Framework\\Model\\AbstractModel', ['setData'], [], '', false);
     $objectMock->expects($this->once())->method('setData')->with($data);
     $this->entityFactoryMock->expects($this->once())->method('create')->with('Magento\\Review\\Model\\Review\\Summary')->will($this->returnValue($objectMock));
     $item = $this->collection->fetchItem();
     $this->assertEquals($objectMock, $item);
     $this->assertEquals('id', $item->getIdFieldName());
 }

 /**
  * Connects to the database.
  *
  */
 protected function _connect()
 {
     parent::_connect();
     if (!$this->_initialized) {
         $this->_initialized = true;
         if ($this->_config['timezone']) {
             // Requires PHP 5.2+
             $dtz = new DateTimeZone($this->_config['timezone']);
             $offset = $dtz->getOffset(new DateTime('NOW')) / 60 / 60;
             if ($offset > 0) {
                 $offset = "+" . $offset;
             }
             /*
             echo "location: ".$dtz->getLocation()."<br />";
             echo "offset: ".$dtz->getOffset(new DateTime('NOW'))."<br />";
             echo "offset 2: ". $offset."<br />";
             echo "SET time_zone = '$offset:00'"."<br />";
             */
             $this->query("SET time_zone = '{$offset}:00';");
             //sprintf("SET time_zone = '%d:00'", $offset));
             /*
                             $timezone = new DateTimeZone($this->_config['timezone']);
                             $minutes = $timezone->getOffset(new DateTime('NOW')) / 60 / 60;
                             
                             
                             
                             //$offset = sprintf("SET time_zone = '%d:%2d'", $minutes / 60, $minutes % 60);
                             $offset = sprintf("SET time_zone = '%d:00'", $offset);
             *
             */
         }
     }
 }

 function rollBack()
 {
     $this->_transaction_depth--;
     if ($this->shouldEmulateNesting()) {
         return;
     }
     return parent::rollBack();
 }

 public function rollback()
 {
     if ($this->_transactionLevel === 1) {
         return parent::rollback();
     }
     $this->_transactionLevel--;
     return $this;
 }

 /**
  * Inserts a table row with specified data.
  *
  * @param mixed $table The table to insert data into.
  * @param array $bind Column-value pairs.
  * @return int The number of affected rows.
  */
 public function insert($table = null, array $bind = null)
 {
     if (is_null($table) && is_null($bind)) {
         return new Harmoni_Db_Insert($this);
     } else {
         return parent::insert($table, $bind);
     }
 }

 /**
  * Checks if the required options have been provided into the $config array
  *
  * @param array $config configuration options
  * @return void
  * @throws Streamwide_Db_Adapter_Exception
  */
 protected function _checkRequiredOptions(array $config)
 {
     if (!array_key_exists('host', $config)) {
         require_once 'Zend/Db/Adapter/Exception.php';
         throw new Zend_Db_Adapter_Exception("Configuration array must have a key for 'host' naming the hostname or ip of the database server");
     }
     parent::_checkRequiredOptions($config);
 }

 protected function _connect()
 {
     // if we already have a PDO object, no need to re-connect.
     if ($this->_connection) {
         return;
     }
     parent::_connect();
     // set connection to utf8
     $this->query('SET NAMES utf8');
 }

 /**
  * add single role rights 
  *
  * @param   int $_roleId
  * @param   int $_applicationId
  * @param   string $_right
  */
 public function addSingleRight($_roleId, $_applicationId, $_right)
 {
     // check if already in
     $select = $this->_roleRightsTable->select();
     $select->where($this->_db->quoteInto($this->_db->quoteIdentifier('role_id') . ' = ?', $_roleId))->where($this->_db->quoteInto($this->_db->quoteIdentifier('right') . ' = ?', $_right))->where($this->_db->quoteInto($this->_db->quoteIdentifier('application_id') . ' = ?', $_applicationId));
     if (!($row = $this->_roleRightsTable->fetchRow($select))) {
         $data = array('role_id' => $_roleId, 'application_id' => $_applicationId, 'right' => $_right);
         $this->_roleRightsTable->insert($data);
     }
 }

 /**
  * Creates a PDO object and connects to the database.
  *
  * @return void
  * @throws Zend_Db_Adapter_Exception
  */
 protected function _connect()
 {
     if ($this->_connection) {
         return;
     }
     if (!empty($this->_config['timeout'])) {
         $this->_config['driver_options'][PDO::ATTR_TIMEOUT] = $this->_config['timeout'];
     }
     parent::_connect();
 }

 /**
  * Rollback DB transaction
  *
  * @return App_Zend_Db_Adapter_Mysqli
  */
 public function rollback()
 {
     if ($this->_txLevel === 1) {
         //        error_log("rollback tx for real");
         parent::rollback();
     } else {
         //        error_log("rollback tx " . $this->_txLevel-1);
     }
     $this->_txLevel--;
     return $this;
 }