修改include/lib/database.php 文件
public static function getInstance() {
if(class_exists('pdo',false))
{
return mysqlPDO::getInstance();
}elseif(class_exists('mysqli', FALSE)) {
return MySqlii::getInstance();
}
else if (class_exists('mysql', FALSE)) {
return MySql::getInstance();
}
else {
emMsg('服务器空间PHP不支持MySql数据库');
}
}
增加mysqlpdo.php 文件，文件放置在include/lib目录下
<?php
class mysqlpdo{
/**
* 内部实例对象
* @var object MySql
*/
private static $instance = null;
/**
* 查询次数
* @var int
*/
private $queryCount = 0;
/**
* 内部数据连接对象
* @var \PDO
*/
private $conn;
/**
* 内部数据结果
*/
private $result;
private function __construct() {
if (!class_exists('PDO')) {
emMsg('服务器空间PHP不支持PDO函数');
}
try {
$dsn = 'mysql:host=' . DB_HOST . ';port=' . DB_PORT . ';dbname=' . DB_NAME;
$options = [];
$dbh = new \PDO($dsn,DB_USER,DB_PASSWD,$options);
$dbh->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION); //设置如果sql语句执行错误则抛出异常，事务会自动回滚
$dbh->setAttribute(\PDO::ATTR_EMULATE_PREPARES, false); //禁用prepared statements的仿真效果(防SQL注入)
$dbh->exec('SET NAMES utf8');
$this->conn = $dbh;
} catch (\PDOException $e) {
emMsg("连接数据库失败，请检查数据库信息。错误原因：" . $e->getMessage());
}
}
/**
* 静态方法，返回数据库连接实例
*/
public static function getInstance() {
if (self::$instance == null) {
self::$instance = new mysqlpdo();
}
return self::$instance;
}
/**
* 关闭数据库连接
*/
function close() {
if (!is_null($this->conn)) $this->conn = null;
}
/**
* 发送查询语句
*/
function query($sql, $ignore_err = FALSE) {
try {
// $result = $this->conn->query($sql);
$this->result = $this->conn->query($sql);
$this->queryCount++;
if (!$ignore_err && 1046 == $this->geterrno()) {
emMsg("连接数据库失败，请填写数据库名");
}
if (!$ignore_err && !$this->result) {
emMsg("SQL语句执行错误: {$sql}<br />" . $this->geterror());
} else {
return $this->result;
}
}catch (\PDOException $e)
{
return $e->getMessage();
}
}
/**
* 从结果集中取得一行作为关联数组/数字索引数组
*/
function fetch_array($query, $type = \PDO::FETCH_ASSOC) {
return $query->fetch($type);
}
/**
* 从结果级中取一行
* @param $sql
* @return mixed
*/
function once_fetch_array($sql) {
try {
$result = $this->conn->query($sql);
$resultDb = $result->fetchAll(\PDO::FETCH_ASSOC);
return $resultDb[0];
}catch (\PDOException $e)
{
emMsg($e->getMessage());
}
}
/**
* 从结果集中取得一行作为数字索引数组
*/
function fetch_row( $query) {
return $query->rowCount();
}
/**
* 取得行的数目
*
*/
function num_rows($query) {
$rows = $query->fetch(PDO::FETCH_NUM);
return isset($rows[0]) ? $rows[0] : 0;
}
/**
* 取得结果集中字段的数目
*/
function num_fields($query) {
return $query->fetchColumn();
// return $query->field_count;
}
/**
* 取得上一步 INSERT 操作产生的 ID
*/
function insert_id() {
return $this->conn->lastInsertId();
}
/**
* 获取mysql错误
*/
function geterror() {
return $this->conn->errorInfo();
}
/**
* 获取mysql错误编码
*/
function geterrno() {
return $this->conn->errorCode();
}
/**
* Get number of affected rows in previous MySQL operation
*/
function affected_rows() {
if($this->result)
{
return $this->result->rowCount();
}
return 0;
}
/**
* 取得数据库版本信息
*/
function getMysqlVersion() {
$result = $this->conn->query('select version()')->fetchColumn();
return $result;
}
/**
* 取得数据库查询次数
*/
function getQueryCount() {
return $this->queryCount;
}
/**
* Escapes special characters
*/
function escape_string($sql) {
return trim($sql);
// return $this->conn->real_escape_string($sql);
}
}
0 赞
or 打赏
喜欢就打赏一点
已有0 条评论，0 个点赞
