true, \PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION ); $this->connection = new \PDO($dsn, $username, $password, $options); } catch (\PDOException $e) { throw new \Phacil\Framework\Exception('Failed to connect to database. Reason: \'' . $e->getMessage() . '\''); } $this->connection->exec("SET NAMES 'utf8'"); $this->connection->exec("SET CHARACTER SET utf8"); $this->connection->exec("SET CHARACTER_SET_CONNECTION=utf8"); $this->connection->exec("SET SQL_MODE = ''"); $this->rowCount = 0; } public function prepare($sql) { $this->statement = $this->connection->prepare($sql); } public function bindParam($parameter, $variable, $data_type = \PDO::PARAM_STR, $length = 0) { if ($length) { $this->statement->bindParam($parameter, $variable, $data_type, $length); } else { $this->statement->bindParam($parameter, $variable, $data_type); } } public function query($sql, $params = array()) { $this->statement = $this->connection->prepare($sql); $result = false; try { if ($this->statement && $this->statement->execute($params)) { $data = array(); $this->rowCount = $this->statement->rowCount(); if ($this->rowCount > 0) { try { $data = $this->statement->fetchAll(\PDO::FETCH_ASSOC); } catch (\Exception $ex) { } } // free up resources $this->statement->closeCursor(); $this->statement = null; $result = new \Phacil\Framework\Databases\Object\Result(); $result->row = (isset($data[0]) ? $data[0] : array()); $result->rows = $data; $result->num_rows = $this->rowCount; } } catch (\PDOException $e) { throw new \Phacil\Framework\Exception('Error: ' . $e->getMessage() . ' Error Code : ' . $e->getCode() . '
' . $sql); } if ($result) { return $result; } else { $result = new \Phacil\Framework\Databases\Object\Result(); $result->row = array(); $result->rows = array(); $result->num_rows = 0; return $result; } } public function escape($value) { return str_replace(array("\\", "\0", "\n", "\r", "\x1a", "'", '"'), array("\\\\", "\\0", "\\n", "\\r", "\Z", "\'", '\"'), $value); } public function countAffected() { if ($this->statement) { return $this->statement->rowCount(); } else { return $this->rowCount; } } public function getLastId() { return $this->connection->lastInsertId(); } public function isConnected() { if ($this->connection) { return true; } else { return false; } } public function __destruct() { unset($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 = []) { try { $stmt = $this->connection->prepare($sql); if ($stmt === false) { throw new \Phacil\Framework\Exception('Error preparing query: ' . implode(', ', $this->connection->errorInfo())); } // Bind parameters if there are any if (!empty($params)) { foreach ($params as $placeholder => &$param) { $stmt->bindParam($placeholder, $param, $this->getParamType($param)); } } $stmt->execute(); if ($stmt->columnCount()) { $data = new \Phacil\Framework\Databases\Object\Result(); $data->setNumRows($stmt->rowCount()); $data->setRows($stmt->fetchAll(\PDO::FETCH_ASSOC)); //$data->setRow(isset($data->rows[0]) ? $data->rows[0] : null); $stmt->closeCursor(); return $data; } else { $this->rowCount = $stmt->rowCount(); $stmt->closeCursor(); return true; } } catch (\PDOException $exception) { throw new \Phacil\Framework\Exception($exception->getMessage()); } } /** * * @param mixed $param * @return int */ private function getParamType(&$param) { $paramType = gettype($param); switch ($paramType) { case 'boolean': $paramType = \PDO::PARAM_BOOL; break; case 'integer': $paramType = \PDO::PARAM_INT; break; case 'double': case 'float': $paramType = \PDO::PARAM_STR; break; case 'NULL': $paramType = \PDO::PARAM_NULL; break; default: $paramType = \PDO::PARAM_STR; break; } return $paramType; } }