链接数据库成功 MYSQLi数据库操作类 mysqlii - 博客文档助手
MYSQLi数据库操作类 mysqlii
源码
<?php
/**
* MySQLi数据库操作类
*
* @copyright (c) Emlog All Rights Reserved
*/
class MySqlii {
/**
* 查询次数
* @var int
*/
private $queryCount = 0;
/**
* 内部数据连接对象
* @var mysqli
*/
private $conn;
/**
* 内部数据结果
* @var mysqli_result
*/
private $result;
/**
* 内部实例对象
* @var object MySql
*/
private static $instance = null;
private function __construct() {
if (!class_exists('mysqli')) {
emMsg('服务器空间PHP不支持MySqli函数');
}
@$this->conn = new mysqli(DB_HOST, DB_USER, DB_PASSWD, DB_NAME);
if ($this->conn->connect_error) {
switch ($this->conn->connect_errno) {
case 1044:
case 1045:
emMsg("连接数据库失败,数据库用户名或密码错误");
case 1049:
emMsg("连接数据库失败,未找到您填写的数据库");
case 2003:
emMsg("连接数据库失败,数据库端口错误");
case 2005:
emMsg("连接数据库失败,数据库地址错误或者数据库服务器不可用");
case 2006:
emMsg("连接数据库失败,数据库服务器不可用");
default :
emMsg("连接数据库失败,请检查数据库信息。错误编号:" . $this->conn->connect_errno);
}
}
$this->conn->set_charset('utf8');
}
/**
* 静态方法,返回数据库连接实例
*/
public static function getInstance() {
if (self::$instance == null) {
self::$instance = new MySqlii();
}
return self::$instance;
}
/**
* 关闭数据库连接
*/
function close() {
return $this->conn->close();
}
/**
* 发送查询语句
*/
function query($sql, $ignore_err = FALSE) {
$this->result = $this->conn->query($sql);
$this->queryCount++;
if (!$ignore_err && 1046 == $this->geterrno()) {
emMsg("连接数据库失败,请填写数据库名");
}
if (!$ignore_err && !$this->result) {
emMsg("SQL语句执行错误: {$sql}
" . $this->geterror());
} else {
return $this->result;
}
}
/**
* 从结果集中取得一行作为关联数组/数字索引数组
*/
function fetch_array(mysqli_result $query, $type = MYSQLI_ASSOC) {
return $query->fetch_array($type);
}
function once_fetch_array($sql) {
$this->result = $this->query($sql);
return $this->fetch_array($this->result);
}
/**
* 从结果集中取得一行作为数字索引数组
*/
function fetch_row(mysqli_result $query) {
return $query->fetch_row();
}
/**
* 取得行的数目
*
*/
function num_rows(mysqli_result $query) {
return $query->num_rows;
}
/**
* 取得结果集中字段的数目
*/
function num_fields(mysqli_result $query) {
return $query->field_count;
}
/**
* 取得上一步 INSERT 操作产生的 ID
*/
function insert_id() {
return $this->conn->insert_id;
}
/**
* 获取mysql错误
*/
function geterror() {
return $this->conn->error;
}
/**
* 获取mysql错误编码
*/
function geterrno() {
return $this->conn->errno;
}
/**
* Get number of affected rows in previous MySQL operation
*/
function affected_rows() {
return $this->conn->affected_rows;
}
/**
* 取得数据库版本信息
*/
function getMysqlVersion() {
return $this->conn->server_info;
}
/**
* 取得数据库查询次数
*/
function getQueryCount() {
return $this->queryCount;
}
/**
* Escapes special characters
*/
function escape_string($sql) {
return $this->conn->real_escape_string($sql);
}
}
热门
随机
博客文档助手 - 提供博客主题制作的文档化技术支持