• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号
登陆 注册

php数据库操作类

原作者: [db:作者] 来自: [db:来源] 收藏 邀请
<?php
002 Class DB {
003   
004     private $link_id;
005     private $handle;
006     private $is_log;
007     private $time;
008   
009     //构造函数
010     public function __construct() {
011         $this->time = $this->microtime_float();
012         require_once("config.db.php");
013         $this->connect($db_config["hostname"], $db_config["username"], $db_config["password"], $db_config["database"], $db_config["pconnect"]);
014         $this->is_log = $db_config["log"];
015         if($this->is_log){
016             $handle = fopen($db_config["logfilepath"]."dblog.txt", "a+");
017             $this->handle=$handle;
018         }
019     }
020       
021     //数据库连接
022     public function connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect = 0,$charset='utf8') {
023         if( $pconnect==0 ) {
024             $this->link_id = @mysql_connect($dbhost, $dbuser, $dbpw, true);
025             if(!$this->link_id){
026                 $this->halt("数据库连接失败");
027             }
028         } else {
029             $this->link_id = @mysql_pconnect($dbhost, $dbuser, $dbpw);
030             if(!$this->link_id){
031                 $this->halt("数据库持久连接失败");
032             }
033         }
034         if(!@mysql_select_db($dbname,$this->link_id)) {
035             $this->halt('数据库选择失败');
036         }
037         @mysql_query("set names ".$charset);
038     }
039       
040     //查询 
041     public function query($sql) {
042         $this->write_log("查询 ".$sql);
043         $query = mysql_query($sql,$this->link_id);
044         if(!$query) $this->halt('Query Error: ' . $sql);
045         return $query;
046     }
047       
048     //获取一条记录（MYSQL_ASSOC，MYSQL_NUM，MYSQL_BOTH）              
049     public function get_one($sql,$result_type = MYSQL_ASSOC) {
050         $query = $this->query($sql);
051         $rt =& mysql_fetch_array($query,$result_type);
052         $this->write_log("获取一条记录 ".$sql);
053         return $rt;
054     }
055   
056     //获取全部记录
057     public function get_all($sql,$result_type = MYSQL_ASSOC) {
058         $query = $this->query($sql);
059         $i = 0;
060         $rt = array();
061         while($row =& mysql_fetch_array($query,$result_type)) {
062             $rt[$i]=$row;
063             $i++;
064         }
065         $this->write_log("获取全部记录 ".$sql);
066         return $rt;
067     }
068       
069     //插入
070     public function insert($table,$dataArray) {
071         $field = "";
072         $value = "";
073         if( !is_array($dataArray) || count($dataArray)<=0) {
074             $this->halt('没有要插入的数据');
075             return false;
076         }
077         while(list($key,$val)=each($dataArray)) {
078             $field .="$key,";
079             $value .="'$val',";
080         }
081         $field = substr( $field,0,-1);
082         $value = substr( $value,0,-1);
083         $sql = "insert into $table($field) values($value)";
084         $this->write_log("插入 ".$sql);
085         if(!$this->query($sql)) return false;
086         return true;
087     }
088   
089     //更新
090     public function update( $table,$dataArray,$condition="") {
091         if( !is_array($dataArray) || count($dataArray)<=0) {
092             $this->halt('没有要更新的数据');
093             return false;
094         }
095         $value = "";
096         while( list($key,$val) = each($dataArray))
097         $value .= "$key = '$val',";
098         $value .= substr( $value,0,-1);
099         $sql = "update $table set $value where 1=1 and $condition";
100         $this->write_log("更新 ".$sql);
101         if(!$this->query($sql)) return false;
102         return true;
103     }
104   
105     //删除
106     public function delete( $table,$condition="") {
107         if( empty($condition) ) {
108             $this->halt('没有设置删除的条件');
109             return false;
110         }
111         $sql = "delete from $table where 1=1 and $condition";
112         $this->write_log("删除 ".$sql);
113         if(!$this->query($sql)) return false;
114         return true;
115     }
116   
117     //返回结果集
118     public function fetch_array($query, $result_type = MYSQL_ASSOC){
119         $this->write_log("返回结果集");
120         return mysql_fetch_array($query, $result_type);
121     }
122   
123     //获取记录条数
124     public function num_rows($results) {
125         if(!is_bool($results)) {
126             $num = mysql_num_rows($results);
127             $this->write_log("获取的记录条数为".$num);
128             return $num;
129         } else {
130             return 0;
131         }
132     }
133   
134     //释放结果集
135     public function free_result() {
136         $void = func_get_args();
137         foreach($void as $query) {
138             if(is_resource($query) && get_resource_type($query) === 'mysql result') {
139                 return mysql_free_result($query);
140             }
141         }
142         $this->write_log("释放结果集");
143     }
144   
145     //获取最后插入的id
146     public function insert_id() {
147         $id = mysql_insert_id($this->link_id);
148         $this->write_log("最后插入的id为".$id);
149         return $id;
150     }
151   
152     //关闭数据库连接
153     protected function close() {
154         $this->write_log("已关闭数据库连接");
155         return @mysql_close($this->link_id);
156     }
157   
158     //错误提示
159     private function halt($msg='') {
160         $msg .= "\r\n".mysql_error();
161         $this->write_log($msg);
162         die($msg);
163     }
164   
165     //析构函数
166     public function __destruct() {
167         $this->free_result();
168         $use_time = ($this-> microtime_float())-($this->time);
169         $this->write_log("完成整个查询任务,所用时间为".$use_time);
170         if($this->is_log){
171             fclose($this->handle);
172         }
173     }
174       
175     //写入日志文件
176     public function write_log($msg=''){
177         if($this->is_log){
178             $text = date("Y-m-d H:i:s")." ".$msg."\r\n";
179             fwrite($this->handle,$text);
180         }
181     }
182       
183     //获取毫秒数
184     public function microtime_float() {
185         list($usec, $sec) = explode(" ", microtime());
186         return ((float)$usec + (float)$sec);
187     }
188 }
189   
190 ?>

[代码] config.db.php

view source
?
01 <?php 
02     $db_config["hostname"] = "localhost"; //服务器地址
03     $db_config["username"] = "root"; //数据库用户名
04     $db_config["password"] = "123"; //数据库密码
05     $db_config["database"] = "test"; //数据库名称
06     $db_config["charset"] = "utf8";//数据库编码
07     $db_config["pconnect"] = 1;//开启持

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
DokuWiki开源框架PHPDokuWiki发布时间：2022-07-10
下一篇：
CentOS7环境下MySQL5.7PHP7的安装发布时间：2022-07-10
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap