在WEB应用程序开发数据库操作类是一个必不可少的东西了,当然大家可以直接连接数据库进行查询,但这样维护不方便,下面我整理了一个不错的PHP数据库处理类与各位分享.

最近在看后盾网的php视频,主要内容是相关制作一个博客系统,感觉还是很有收获,简单的数据库处理类,下面是其中讲到的一个简单的数据库处理类,请见源码:

1. <?php 
2.     /** 
3.     * Created by JetBrains PhpStorm. 
4.     * User: YangLiu 
5.     * Date: 2013-7-12 
6.     * Time: 下午6:19 
7.     * Description:这是一个简单的数据库操作类，便于快速向数据库插入数据、删除数据，更新数据 
8.     */ 
9.     class db { 
10.     //数据库连接 
11.     protected $mysqli; 
12.     //表名 
13.     protected $table; 
14.     //选项 
15.     protected $opt; 
16.     /*** 
17.     * 构造方法 
18.     * @param $tab_name 
19.     */ 
20.     function __construct($tab_name){ 
21.     $this->config($tab_name); 
22.     } 
23.       
24.     // 配置方法 
25.     protected function config($tab_name){ 
26.     $this->db=new mysqli(DBHOST,DBUSER,DBPWD,DBNAME); 
27.     //DBFIX为数据库表前缀 
28.     $this->table = DBFIX.$tab_name; 
29.     if(mysqli_connect_errno()){ 
30.     echo "数据库连接错误".mysqli_connect_errno(); 
31.     exit(); 
32.     } 
33.     $this->db->query("SET NAMES 'GBK'"); 
34.       
35.     //给opt数组设置初始值 
36.     $this->opt['field'] = '*'; 
37.     $this->opt['where']=$this->opt['order']=$this->opt['limit']=$this->opt['group'] = ''; 
38.     } 
39.       
40.     // 获得当前表字段 
41.     function tbFields(){ 
42.     $result = $this->db->query("DESC {$this->table}"); 
43.     $fieldArr = array(); 
44.     while(($row = $result->fetch_assoc())!=false){ 
45.     $fieldArr[] = $row['Field']; 
46.     } 
47.     return $fieldArr; 
48.     } 
49.       
50.     // 获得查询字段 
51.     function field($field){ 
52.     $fieldArr = is_string($field)?explode(",",$field):$field; 
53.     if(is_array($fieldArr)){ 
54.     $field = ''; 
55.     foreach($fieldArr as $v){ 
56.     $field.='`' . $v. '`' . ','; 
57.     } 
58.     } 
59.     return rtrim($field,','); 
60.     } 
61.       
62.     // SQL条件方法 
63.     function where($where){ 
64.     $this->opt['where'] = is_string($where) ?"WHERE " . $where : ''; 
65.     return $this; 
66.     } 
67.       
68.     //limit方法 
69.     function limit($limit){ 
70.     $this->opt['limit'] = is_string($limit) ? "LIMIT ".$limit : ''; 
71.     return $this; 
72.     } 
73.       
74.     //排序方法 
75.     function order($order){ 
76.     $this->opt['order'] = is_string($order) ? "ORDER BY ".$order:''; 
77.     return $this; 
78.     } 
79.       
80.     // 分组GROUP BY 
81.     function group($group){ 
82.     $this->opt['group'] = is_string($group) ? 'GROUP BY'.$group : ''; 
83.     return $this; 
84.     } 
85.       
86.     //SELECT 
87.     function select(){ 
88.     $sql = "SELECT {$this->opt['field']} FROM {$this->table} 
89.     {$this->opt['where']} {$this->opt['group']} {$this->opt['limit']} 
90.     {$this->opt['order']} "; 
91.     return $this->sql($sql); 
92.     } 
93.       
94.     //DELETE方法 
95.     function delete($id=''){ 
96.     if($id == '' && emptyempty($this->opt['where'])){ 
97.     die('查询条件不能为空'); 
98.     } 
99.     if($id != ''){ 
100.     if(is_array($id)){ 
101.     $id = implode(',',$id); 
102.     } 
103.     $this->opt['where'] = "WHERE id IN (" .$id. ")"; 
104.     } 
105.     $sql = "DELETE FROM {$this->table} {$this->opt['where']} {$this->opt['limit']}"; 
106.     //echo $sql."<br/>"; 
107.     return $this->query($sql); 
108.     } 
109.       
110.     //查阅单条记录 
111.     function find($id){ 
112.     $sql = "SELECT {$this->opt['field']} FROM {$this->table} WHERE `id` = {$id}"; 
113.     //echo $sql.'<br>'; 
114.     return $this->sql($sql); 
115.     } 
116.       
117.     // 添加数据 
118.     function insert($args){ 
119.     is_array($args) or die('参数非数组'); 
120.     $fields = $this->field(array_keys($args)); 
121.     $values = $this->values(array_values($args)); 
122.     $sql = "INSERT INTO {$this->table} ({$fields}) VALUES($values)"; 
123.     if($this->query($sql)>0){ 
124.     return $this->db->insert_id; 
125.     } 
126.     return false; 
127.     } 
128.       
129.     // 更新UPDATE 
130.     function update($args){ 
131.     is_array($args) or die("参数非数组"); 
132.     if(emptyempty($this->opt['where'])) die("条件不能为空"); 
133.     $set = ''; 
134.     $gpc = get_magic_quotes_gpc(); 
135.     while(list($k,$v) = each($args)){ 
136.     $v = !$gpc?addslashes($v):$v; 
137.     $set.="`{$k}`='".$v."',"; 
138.     } 
139.     $set = rtrim($set,','); 
140.     $sql = "UPDATE {$this->table} SET $set {$this->opt['where']}"; 
141.     return $this->query($sql); 
142.     } 
143.       
144.     // 统计所有记录数 
145.     function count($tabname=''){ 
146.     $tabname = $tabname==''?$this->table:$tabname; 
147.     $sql = "SELECT `id` FROM {$tabname} {$this->opt['where']}"; 
148.     //echo $sql.'<br/>'; 
149.     return $this->query($sql); 
150.     } 
151.       
152.     // 数据数组转为字符串格式，同时进行转议 
153.     protected function values($value) { 
154.     if (! get_magic_quotes_gpc ()) { 
155.     $strValue = ''; 
156.     foreach ( $value as $v ) { 
157.     $strValue .= "'" . addslashes ( $v ) . "',"; 
158.     } 
159.     } else { 
160.     foreach ( $value as $v ) { 
161.     $strValue .= "'$v',"; 
162.     } 
163.     } 
164.     return rtrim ( $strValue, ',' ); 
165.     } 
166.       
167.     // 获得结果集 
168.     function sql($sql) { 
169.     $result = $this->db->query($sql) or die($this->dbError()); 
170.     $resultArr = array(); 
171.     while(($row = $result->fetch_assoc())!=false){ 
172.     $resultArr[] = $row; 
173.     } 
174.     return $resultArr; 
175.     } 
176.       
177.     // 没有结果集的SQL 
178.     function query($sql){ 
179.     $this->db->query($sql) or die($this->dbError()); 
180.     return $this->db->affected_rows; 
181.     }//开源代码phpfensi.com 
182.       
183.     // 返回错误 
184.     function dbError(){ 
185.     return $this->db->error; 
186.     } 
187.     } 
188.     ?>  

以上是一个简单的PHP数据库处理类，就它的使用特地做个说明,下面对以上代码中的部分相常量和变量作以说明:

$mysqli：对当前数据库的链接引用

$table：当前数据库的表名

$opt：当前数据库的表的所有字段名

DBFIX：数据库配置中的常量“表前缀”

DBHOST：数据库主机

DBFIX：数据库用户名

DBPWD：数据库密码

DBNAME：数据库名称

数据库处理类的使用方法,配置数据库处理类,在使用数据库处理类之前,你必须有一个相关的配置文件,下面我就写一个connect.php文件,文件内容如下所示:

1. <?php 
2.     /** 
3.     * Created by JetBrains PhpStorm. 
4.     * User: YangLiu 
5.     * Date: 2013-7-14 
6.     * Time: 下午2:15 
7.     * Description:数据库配置文件 
8.     */ 
9.     define("DBHOST",'localhost'); //定义数据库服务器连接地址 
10.     define("DBUSER",'root'); //数据库用户名 
11.     define("DBPWD",''); //数据库密码 
12.     define("DBNAME",'blog'); //定义数据库名 
13.     define("DBFIX",'blog_'); //定义数据库表的前缀 
14. ?> 

为了让您更简单的理解,我就没有建立更多的目录,把所有的文件全部放在同一目录,如果您觉得不好,也可以自行建立目录,并重新根据情况来调整文件位置.

数据库处理类的使用,使用数据库,你要先引用connect.php和db.class.php文件,下面举一个demo.php文件为例:

1. <?php 
2.     /** 
3.     * Created by JetBrains PhpStorm. 
4.     * User: LiuYang 
5.     * Date: 2013-9-15 
6.     * Time: 下午10:39 
7.     * Description:演示DEMO文件 
8.     */ 
9.     include './config.php'; //加载配置文件 
10.     include './page.class.php'; //加载数据库处理类 
11.       
12.     $db = $db = new db('blog'); //链接数据库的表blog_blog 
13.       
14.     ?> 

输出数据库表的字段名,输出数据库表的字段名,用的tbFields方法,代码如下:

$tbField = $db->tbFields();var_dump($tbField);

其输出结果如下:

1. array (size=5) 
2.   0 => string 'id' (length=2) 
3.   1 => string 'btitle' (length=6) 
4.   2 => string 'content' (length=7) 
5.   3 => string 'status' (length=6) 
6.   4 => string 'cid' (length=3) 

下面,再介绍一个数据库处理类中的相关的另一个方法:

echo $db->field($tbFields);

最后的输出结果：`id`,`btitle`,`content`,`status`,`cid`

统计所有记录数,数据库类中还有一个方法,用来统计数据的所有条数count方法,在我们的分页处理中,它也就会显示得重要了,代码如下:

echo $db->count('blog'); 

注意:以上代码是根据id来查阅,其中count方法代码如下:

1. // 统计所有记录数 
2.     function count($tabname=''){ 
3.     $tabname = $tabname==''?$this->table:$tabname; 
4.     $sql = "SELECT `id` FROM {$tabname} {$this->opt['where']}"; 
5.     return $this->query($sql); 
6.     } 

数据库的增、删、改、查

数据库的相关操作无外乎就是增、删、改、查,下面对其作以简单介绍.

插入数据

insert方法向数据库中插入数据，其中传入的参数为一个数组，如array('btitle'=>'www.phpfensi.com','content'=>'小天地，大世界是一个技术交流博客')。其中数组的键名即为表的字段名，而键值即为想要插入的内容,请看下面的示例:

$inserArr = array('btitle'=>'www.phpfensi.com','content'=>'小天地，大世界是一个技术交流博客');$db->insert($inserArr);

删除数据

delete方法是专门来删除数据,为了防止数据被误删,数据删除必须存在一定的限制,比如说通过where、limit方法来作一定的限制,或者你可以直接传入要删除数据的id,你可以查看下面的示例:

1. //删除id为3的数据 
2.     $db->delete(3); 
3.       
4.     //删除id>5的数据 
5.     $db->where('id>5')->delete(); 
6.       
7.     //删除从20起后的10条数据 
8.     $db->where('id>5')->limit('20,10')->delete();  

更新数据

数据添加了,有时发现错误,就得高法来更改数据,update方法用来更新数据,update方法与insert方法类似,都接受一个数组参数,数组的键名为表的字段名,对应的键值为要插入的内容,下面的内容就是把id为29的数据更新为array中的数据,代码如下:

1. $db->where('id=29')->update(array('btitle'=>'www.phpfensi.com','content'=>'小天地，大世界是一个技术交流博客')); 
2.   //更新id>35的所有数据 
3.   $db->where('id>29')->update(array('btitle'=>'www.phpfensi.com','content'=>'小天地，大世界是一个技术交流博客'));  

查找数据

数据库处理类中提供了select方法,可以很方便的进行数据的查找,结合着where、limit方法,就可以查找相应的数据,具体的使用方法请见下例:

1. $db->select(); //查找所有数据 
2.     
3.   $db->where('id=0')->select(); //查找指定数据 
4.     
5.   $db->where('id>9')->select(); //查找id大于9的数据集合 
6.     
7.   $db->limit('10,9')->select(); //从查找数据第10条以后的9条数据 
8.     
9.   $db->where('id>50')->limit('10,9')->select();  

其它方法:除了以上几种方法之外,数据库处理类还提供了如下的方法.

order方法：主要是来更改查找数据排序方式

group方法：数组方法

find方法：查找单条记录

sql方法：直接执行数据SQL语句,并返回处数据集

query方法：也可以执行数据SQL语句,但不返回数据集,而是返回受影响的记录条数.

关于数据库处理类,最后说明一点,此数据库处理类是后盾网PHP视频中所讲,有助于像我这样的新手来学习,故特地整理.

Tags: PHP数据库处理类 PHP数据库

分享到：