简单的PHP数据库处理类
在WEB应用程序开发数据库操作类是一个必不可少的东西了, 当然大家可以直接连接数据库进行查询,但这样维护不方便,下面我整理了一个不错的PHP数据库处理类与各位分享
最近在看后盾网的php视频,主要内容是相关制作一个博客系统,感觉还是很有收获。
简单的数据库处理类
下面是其中讲到的一个简单的数据库处理类,请见源码:
<?php
/**
* Created by JetBrains PhpStorm.
* User: YangLiu
* Date: 2013-7-12
* Time: 下午6:19
* Description:这是一个简单的数据库操作类,便于快速向数据库插入数据、删除数据,更新数据
*/
class db {
//数据库连接
protected $mysqli;
//表名
protected $table;
//选项
protected $opt;
/***
* 构造方法
* @param $tab_name
*/
function __construct($tab_name) {
$this->config($tab_name);
}
// 配置方法
protected function config($tab_name) {
$this->db = new mysqli(DBHOST, DBUSER, DBPWD, DBNAME);
//DBFIX为数据库表前缀
$this->table = DBFIX . $tab_name;
if (mysqli_connect_errno()) {
echo "数据库连接错误" . mysqli_connect_errno();
exit();
}
$this->db->query("SET NAMES 'GBK'");
//给opt数组设置初始值
$this->opt['field'] = '*';
$this->opt['where'] = $this->opt['order'] = $this->opt['limit'] = $this->opt['group'] = '';
}
// 获得当前表字段
function tbFields() {
$result = $this->db->query("DESC {$this->table}");
$fieldArr = array();
while (($row = $result->fetch_assoc()) != false) {
$fieldArr[] = $row['Field'];
}
return $fieldArr;
}
// 获得查询字段
function field($field) {
$fieldArr = is_string($field) ? explode(",", $field) : $field;
if (is_array($fieldArr)) {
$field = '';
foreach ($fieldArr as $v) {
$field.= '`' . $v . '`' . ',';
}
}
return rtrim($field, ',');
}
// SQL条件方法
function where($where) {
$this->opt['where'] = is_string($where) ? "WHERE " . $where : '';
return $this;
}
//limit方法
function limit($limit) {
$this->opt['limit'] = is_string($limit) ? "LIMIT " . $limit : '';
return $this;
}
//排序方法
function order($order) {
$this->opt['order'] = is_string($order) ? "ORDER BY " . $order : '';
return $this;
}
// 分组GROUP BY
function group($group) {
$this->opt['group'] = is_string($group) ? 'GROUP BY' . $group : '';
return $this;
}
//SELECT
function select() {
$sql = "SELECT {$this->opt['field']} FROM {$this->table}
{$this->opt['where']} {$this->opt['group']} {$this->opt['limit']}
{$this->opt['order']} ";
return $this->sql($sql);
}
//DELETE方法
function delete($id = '') {
if ($id == '' && empty($this->opt['where'])) {
die('查询条件不能为空');
}
if ($id != '') {
if (is_array($id)) {
$id = implode(',', $id);
}
$this->opt['where'] = "WHERE id IN (" . $id . ")";
}
$sql = "DELETE FROM {$this->table} {$this->opt['where']} {$this->opt['limit']}";
//echo $sql."<br/>";
return $this->query($sql);
}
//查阅单条记录
function find($id) {
$sql = "SELECT {$this->opt['field']} FROM {$this->table} WHERE `id` = {$id}";
//echo $sql.'<br>';
return $this->sql($sql);
}
// 添加数据
function insert($args) {
is_array($args) or die('参数非数组');
$fields = $this->field(array_keys($args));
$values = $this->values(array_values($args));
$sql = "INSERT INTO {$this->table} ({$fields}) VALUES($values)";
if ($this->query($sql) > 0) {
return $this->db->insert_id;
}
return false;
}
// 更新UPDATE
function update($args) {
is_array($args) or die("参数非数组");
if (empty($this->opt['where'])) die("条件不能为空");
$set = '';
$gpc = get_magic_quotes_gpc();
while (list($k, $v) = each($args)) {
$v = !$gpc ? addslashes($v) : $v;
$set.= "`{$k}`='" . $v . "',";
}
$set = rtrim($set, ',');
$sql = "UPDATE {$this->table} SET $set {$this->opt['where']}";
return $this->query($sql);
}
// 统计所有记录数
function count($tabname = '') {
$tabname = $tabname == '' ? $this->table : $tabname;
$sql = "SELECT `id` FROM {$tabname} {$this->opt['where']}";
//echo $sql.'<br/>';
return $this->query($sql);
}
// 数据数组转为字符串格式,同时进行转议
protected function values($value) {
if (!get_magic_quotes_gpc()) {
$strValue = '';
foreach ($value as $v) {
$strValue.= "'" . addslashes($v) . "',";
}
} else {
foreach ($value as $v) {
$strValue.= "'$v',";
}
}
return rtrim($strValue, ',');
}
// 获得结果集
function sql($sql) {
$result = $this->db->query($sql) or die($this->dbError());
$resultArr = array();
while (($row = $result->fetch_assoc()) != false) {
$resultArr[] = $row;
}
return $resultArr;
}
// 没有结果集的SQL
function query($sql) {
$this->db->query($sql) or die($this->dbError());
return $this->db->affected_rows;
}
// 返回错误
function dbError() {
return $this->db->error;
}
}
?>以上是一个简单的PHP数据库处理类,就它的使用特地??乱幌拢?/p>
下面对以上代码中的部分相常量和变量作以说明:
$mysqli:对当前数据库的链接引用
$table:当前数据库的表名
$opt:当前数据库的表的所有字段名
DBFIX:数据库配置中的常量"表前缀"
DBHOST:数据库主机
DBFIX:数据库用户名
DBPWD:数据库密码
DBNAME:数据库名称
数据库处理类的使用方法
配置数据库处理类
在使用数据库处理类之前,你必须有一个相关的配置文件,下面我就写一个connect.php文件。文件内容如下所示:
<?php
/**
* Created by JetBrains PhpStorm.
* User: YangLiu
* Date: 2013-7-14
* Time: 下午2:15
* Description:数据库配置文件
*/
define("DBHOST", 'localhost'); //定义数据库服务器连接地址
define("DBUSER", 'root'); //数据库用户名
define("DBPWD", ''); //数据库密码
define("DBNAME", 'blog'); //定义数据库名
define("DBFIX", 'blog_'); //定义数据库表的前缀
?>为了让您更简单的理解,我就没有建立更多的目录,把所有的文件全部放在同一目录。如果您觉得不好,也可以自行建立目录,并重新根据情况来调整文件位置。
数据库处理类的使用
使用数据库,你要先引用connect.php和db.class.php文件。下面举一个demo.php文件为例:
<?php
/**
* Created by JetBrains PhpStorm.
* User: LiuYang
* Date: 2013-9-15
* Time: 下午10:39
* Description:演示DEMO文件
*/
include './config.php'; //加载配置文件
include './page.class.php'; //加载数据库处理类
$db = $db = new db('blog'); //链接数据库的表blog_blog
?>输出数据库表的字段名
输出数据库表的字段名,用的tbFields方法。代码如下:
$tbField = $db->tbFields(); var_dump($tbField); //其输出结果如下: array (size=5) 0 => string 'id' (length=2) 1 => string 'btitle' (length=6) 2 => string 'content' (length=7) 3 => string 'status' (length=6) 4 => string 'cid' (length=3)
下面,再介绍一个数据库处理类中的相关的另一个方法:
echo $db->field($tbFields);
最后的输出结果:`id`,`btitle`,`content`,`status`,`cid`
统计所有记录数
数据库类中还有一个方法,用来统计数据的所有条数count方法。在我们的分页处理中,它也就会显示得重要了。
echo $db->count('blog');注意:以上代码是根据id来查阅。其中count方法代码如下:
// 统计所有记录数
function count($tabname=''){
$tabname = $tabname==''?$this->table:$tabname;
$sql = "SELECT `id` FROM {$tabname} {$this->opt['where']}";
return $this->query($sql);
}数据库的增、删、改、查
数据库的相关操作无外乎就是增、删、改、查。下面对其作以简单介绍:
插入数据
insert方法向数据库中插入数据,其中传入的参数为一个数组,如array('btitle'=>'www.phprm.com','content'=>'小天地,大世界是一个技术交流博客')。其中数组的键名即为表的字段名,而键值即为想要插入的内容。请看下面的示例:
$inserArr = array('btitle'=>'www.phprm.com','content'=>'小天地,大世界是一个技术交流博客');
$db->insert($inserArr);删除数据
delete方法是专门来删除数据。为了防止数据被误删,数据删除必须存在一定的限制。比如说通过where、limit方法来作一定的限制,或者你可以直接传入要删除数据的id。你可以查看下面的示例:
//删除id为3的数据
$db->delete(3);
//删除id>5的数据
$db->where('id>5')->delete();
//删除从20起后的10条数据
$db->where('id>5')->limit('20,10')->delete();更新数据
数据添加了,有时发现错误,就得高法来更改数据。update方法用来更新数据。update方法与insert方法类似,都接受一个数组参数:数组的键名为表的字段名,对应的键值为要插入的内容。下面的内容就是把id为29的数据更新为array中的数据。
$db->where('id=29')->update(array('btitle'=>'www.phprm.com','content'=>'小天地,大世界是一个技术交流博客'));
//更新id>35的所有数据
$db->where('id>29')->update(array('btitle'=>'www.phprm.com','content'=>'小天地,大世界是一个技术交流博客'));查找数据
数据库处理类中提供了select方法,可以很方便的进行数据的查找。结合着where、limit方法,就可以查找相应的数据。具体的使用方法请见下例:
$db->select(); //查找所有数据
$db->where('id=0')->select(); //查找指定数据
$db->where('id>9')->select(); //查找id大于9的数据集合
$db->limit('10,9')->select(); //从查找数据第10条以后的9条数据
$db->where('id>50')->limit('10,9')->select();其它方法
除了以上几种方法之外,数据库处理类还提供了如下的方法。
order方法:主要是来更改查找数据排序方式
group方法:数组方法
find方法:查找单条记录
sql方法:直接执行数据SQL语句,并返回处数据集
query方法:也可以执行数据SQL语句,但不返回数据集,而是返回受影响的记录条数
关于数据库处理类
最后说明一点,此数据库处理类是后盾网PHP视频中所讲,有助于像我这样的新手(也就是我)来学习,故特地整理。
本文地址:http://www.phprm.com/database/56620.html
转载随意,但请附上文章地址:-)