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); } /** * * @param string $sql * @return \Phacil\Framework\Databases\Object\ResultInterface|true * @throws \Phacil\Framework\Exception */ public function query($sql) { $stid = \oci_parse($this->connection, $sql); \oci_execute($stid); if (!$this->connection) { \oci_fetch_all($stid, $res); $result = new \Phacil\Framework\Databases\Object\Result(); $result->setNumRows(\oci_num_rows($stid)); $result->setRow(isset($res[0]) ? $res[0] : []); $result->setRows($res); return $result; } else { throw new \Phacil\Framework\Exception('Error: ' . oci_error() . '
' . $sql); } } public function escape($value) { return str_replace("'", "", $value); } public function countAffected() { return NULL; } public function getLastId() { return NULL; } public function isConnected() { return $this->connection; } public function __destruct() { \oci_close($this->connection); } /** * Execute a prepared statement with parameters * * @param string $sql SQL query with named placeholders * @param array $params Associative array of parameters * @return \Phacil\Framework\Databases\Object\ResultInterface|true * @throws \Phacil\Framework\Exception */ 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); $resultObj = new \Phacil\Framework\Databases\Object\Result(); $resultObj->setNumRows(\oci_num_rows($stid)); $resultObj->setRow(isset($res[0]) ? $res[0] : []); $resultObj->setRows($res); 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 $placeholder) { $sql = str_replace($placeholder, ':' . $placeholder, $sql); } return $sql; } }