pdo = new PDO(...array_values($config));
$this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
} catch (Exception $e) {
// Rethrow to hide connection details, through the original
// exception to view all connection details.
//throw $e;
throw new PDOException("Could not connect to database, hiding details.");
}
}
/**
* Do SELECT with optional parameters and return a resultset.
*
* @param string $sql statement to execute
* @param array $param to match ? in statement
*
* @return array with resultset
*/
public function executeFetchAll($sql, $param = [])
{
$sth = $this->execute($sql, $param);
$res = $sth->fetchAll();
if ($res === false) {
$this->statementException($sth, $sql, $param);
}
return $res;
}
/**
* Do SELECT with optional parameters and return the first row.
*
* @param string $sql statement to execute
* @param array $param to match ? in statement
*
* @return array with first row as resultset
*/
public function executeFetch($sql, $param = [])
{
$sth = $this->execute($sql, $param);
$res = $sth->fetch();
return $res;
}
/**
* Execute a select-query with arguments and insert the results into
* a new object of the class.
*
* @param string $sql statement to execute
* @param array $param the params array
* @param string $class the class to create an object of and insert into
*
* @return array with resultset
*/
public function executeFetchClass($sql, $param, $class = null)
{
if (!$class) {
$class = $param;
$param = [];
}
$sth = $this->execute($sql, $param);
$sth->setFetchMode(\PDO::FETCH_CLASS, $class);
return $sth->fetch();
}
/**
* Execute a select-query with arguments and insert the results into
* an existing object.
*
* @param string $sql statement to execute
* @param array $params the params array
* @param string $object the existing object to insert into
*
* @return array with resultset
*/
public function executeFetchInto($sql, $param, $object = null)
{
if (!$object) {
$object = $param;
$param = [];
}
$sth = $this->execute($sql, $param);
$sth->setFetchMode(\PDO::FETCH_INTO, $object);
return $sth->fetch();
}
/**
* Do INSERT/UPDATE/DELETE with optional parameters.
*
* @param string $sql statement to execute
* @param array $param to match ? in statement
*
* @return PDOStatement
*/
public function execute($sql, $param = [])
{
$sth = $this->pdo->prepare($sql);
if (!$sth) {
$this->statementException($sth, $sql, $param);
}
$status = $sth->execute($param);
if (!$status) {
$this->statementException($sth, $sql, $param);
}
return $sth;
}
/**
* Through exception with detailed message.
*
* @param PDOStatement $sth statement with error
* @param string $sql statement to execute
* @param array $param to match ? in statement
*
* @return void
*
* @throws Exception
*/
public function statementException($sth, $sql, $param)
{
throw new Exception(
$sth->errorInfo()[2]
. "
SQL ("
. substr_count($sql, "?")
. " params):
$sql
PARAMS ("
. count($param)
. "):
"
. implode($param, "\n")
. ""
. ((count(array_filter(array_keys($param), 'is_string')) > 0)
? "WARNING your params array has keys, should only have values."
: null)
);
}
/**
* Return last insert id from an INSERT.
*
* @return void
*/
public function lastInsertId()
{
return $this->pdo->lastInsertId();
}
}