connection = \oci_connect($username, $password, $hostname.":".$port."/".$database, $charset); if (!$this->connection) { $e = \oci_error(); $this->error = $e; throw new \Phacil\Framework\Exception((htmlentities($e['message'], ENT_QUOTES))); } \oci_set_client_info($this->connection, "Administrator"); //oci_set_module_name($this->connection, $module); //oci_set_client_identifier($this->connection, $cid); } /** * {@inheritdoc} */ public function query($sql) { $stid = \oci_parse($this->connection, $sql); \oci_execute($stid); if (!$this->connection) { \oci_fetch_all($stid, $res); /** @var \Phacil\Framework\Databases\Api\Object\ResultInterface */ $result = \Phacil\Framework\Registry::getInstance()->create("Phacil\Framework\Databases\Api\Object\ResultInterface", [$res]); $result->setNumRows(\oci_num_rows($stid)); return $result; } else { throw new \Phacil\Framework\Exception('Error: ' . oci_error() . '
' . $sql); } } /** * {@inheritdoc} */ public function escape($value) { return str_replace("'", "", $value); } /** {@inheritdoc} */ public function countAffected() { return NULL; } /** {@inheritdoc} */ public function getLastId() { return NULL; } /** {@inheritdoc} */ public function isConnected() { return $this->connection; } /** * {@inheritdoc} */ public function execute($sql, array $params = []) { // Verificar se há parâmetros e fazer o bind if (!empty($params)) { //$sql = $this->replacePlaceholders($sql, array_keys($params)); $stid = \oci_parse($this->connection, $sql); foreach ($params as $placeholder => &$param) { \oci_bind_by_name($stid, $placeholder, $param); } $result_exec = \oci_execute($stid); if ($result_exec === false) { $e = \oci_error($stid); throw new \Phacil\Framework\Exception('Error executing query: ' . htmlentities($e['message'], ENT_QUOTES)); } // Processar resultados se for um SELECT $res = []; \oci_fetch_all($stid, $res); /** @var \Phacil\Framework\Databases\Api\Object\ResultInterface */ $resultObj = \Phacil\Framework\Registry::getInstance()->create("Phacil\Framework\Databases\Api\Object\ResultInterface", [$res]); $resultObj->setNumRows(\oci_num_rows($stid)); return $resultObj; } else { // Se não há parâmetros, executar diretamente sem consulta preparada $query = $this->query($sql); return $query; } } /** * Replace placeholders in the SQL query with named placeholders * * @param string $sql SQL query with named placeholders * @param array $placeholders Array of named placeholders * @return string SQL query with named placeholders */ private function replacePlaceholders($sql, $placeholders) { foreach ($placeholders as $key => $placeholder) { $sql = str_replace($placeholder, ':' . ($key + 1), $sql); } return $sql; } /** * {@inheritdoc} */ public function getDBType() { return self::DB_TYPE; } /** * {@inheritdoc} */ public function getDBTypeId() { return self::DB_TYPE_ID; } }