mysql数据库操作类。
配置文件:
<?php
$db_config["hostname"] = "localhost"; //服务器地址
$db_config["username"] = "root"; //数据库用户名
$db_config["password"] = "123"; //数据库密码
$db_config["database"] = "test"; //数据库名称
$db_config["charset"] = "utf8";//数据库编码
$db_config["pconnect"] = 1;//开启持久连接
$db_config["log"] = 1;//开启日志
$db_config["logfilepath"] = './';//开启日志
?>
mysql操作类:
<?php
Class DB {
private $link_id;
private $handle;
private $is_log;
private $time;
//构造函数
public function __construct() {
$this->time = $this->microtime_float();
require_once("config.db.php");
$this->connect($db_config["hostname"], $db_config["username"], $db_config["password"], $db_config["database"], $db_config["pconnect"]);
$this->is_log = $db_config["log"];
if($this->is_log){
$handle = fopen($db_config["logfilepath"]."dblog.txt", "a+");
$this->handle=$handle;
}
}
//数据库连接
public function connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect = 0,$charset='utf8') {
if( $pconnect==0 ) {
$this->link_id = @mysql_connect($dbhost, $dbuser, $dbpw, true);
if(!$this->link_id){
$this->halt("数据库连接失败");
}
} else {
$this->link_id = @mysql_pconnect($dbhost, $dbuser, $dbpw);
if(!$this->link_id){
$this->halt("数据库持久连接失败");
}
}
if(!@mysql_select_db($dbname,$this->link_id)) {
$this->halt('数据库选择失败');
}
@mysql_query("set names ".$charset);
}
//查询
public function query($sql) {
$this->write_log("查询 ".$sql);
$query = mysql_query($sql,$this->link_id);
if(!$query) $this->halt('Query Error: ' . $sql);
return $query;
}
//获取一条记录(MYSQL_ASSOC,MYSQL_NUM,MYSQL_BOTH)
public function get_one($sql,$result_type = MYSQL_ASSOC) {
$query = $this->query($sql);
$rt =& mysql_fetch_array($query,$result_type);
$this->write_log("获取一条记录 ".$sql);
return $rt;
}
//获取全部记录
public function get_all($sql,$result_type = MYSQL_ASSOC) {
$query = $this->query($sql);
$i = 0;
$rt = array();
while($row =& mysql_fetch_array($query,$result_type)) {
$rt[$i]=$row;
$i++;
}
$this->write_log("获取全部记录 ".$sql);
return $rt;
}
//插入
public function insert($table,$dataArray) {
$field = "";
$value = "";
if( !is_array($dataArray) || count($dataArray)<=0) {
$this->halt('没有要插入的数据');
return false;
}
while(list($key,$val)=each($dataArray)) {
$field .="$key,";
$value .="'$val',";
}
$field = substr( $field,0,-1);
$value = substr( $value,0,-1);
$sql = "insert into $table($field) values($value)";
$this->write_log("插入 ".$sql);
if(!$this->query($sql)) return false;
return true;
}
//更新
public function update( $table,$dataArray,$condition="") {
if( !is_array($dataArray) || count($dataArray)<=0) {
$this->halt('没有要更新的数据');
return false;
}
$value = "";
while( list($key,$val) = each($dataArray))
$value .= "$key = '$val',";
$value .= substr( $value,0,-1);
$sql = "update $table set $value where 1=1 and $condition";
$this->write_log("更新 ".$sql);
if(!$this->query($sql)) return false;
return true;
}
//删除
public function delete( $table,$condition="") {
if( empty($condition) ) {
$this->halt('没有设置删除的条件');
return false;
}
$sql = "delete from $table where 1=1 and $condition";
$this->write_log("删除 ".$sql);
if(!$this->query($sql)) return false;
return true;
}
//返回结果集
public function fetch_array($query, $result_type = MYSQL_ASSOC){
$this->write_log("返回结果集");
return mysql_fetch_array($query, $result_type);
}
//获取记录条数
public function num_rows($results) {
if(!is_bool($results)) {
$num = mysql_num_rows($results);
$this->write_log("获取的记录条数为".$num);
return $num;
} else {
return 0;
}
}
//释放结果集
public function free_result() {
$void = func_get_args();
foreach($void as $query) {
if(is_resource($query) && get_resource_type($query) === 'mysql result') {
return mysql_free_result($query);
}
}
$this->write_log("释放结果集");
}
//获取最后插入的id
public function insert_id() {
$id = mysql_insert_id($this->link_id);
$this->write_log("最后插入的id为".$id);
return $id;
}
//关闭数据库连接
protected function close() {
$this->write_log("已关闭数据库连接");
return @mysql_close($this->link_id);
}
//错误提示
private function halt($msg='') {
$msg .= "\r\n".mysql_error();
$this->write_log($msg);
die($msg);
}
//析构函数
public function __destruct() {
$this->free_result();
$use_time = ($this-> microtime_float())-($this->time);
$this->write_log("完成整个查询任务,所用时间为".$use_time);
if($this->is_log){
fclose($this->handle);
}
}
//写入日志文件
public function write_log($msg=''){
if($this->is_log){
$text = date("Y-m-d H:i:s")." ".$msg."\r\n";
fwrite($this->handle,$text);
}
}
//获取毫秒数
public function microtime_float() {
list($usec, $sec) = explode(" ", microtime());
return ((float)$usec + (float)$sec);
}
}
?>
分享到:
相关推荐
php实现MySQL数据库操作类
mysql 数据库操作类
php中mysql数据库操作类
今天刚做的一个MySQL操作类,基本功能已经完成,支持连贯操作,支持基本的增改删差,查询条件和数据插入支持数组方式。自动缓存管理,可以选择文件缓存,或者memcache(也可以很方便的扩展其他缓存方式)。 使用...
新手学习,php7中mysql数据库操作类实例,非常清晰易懂
数据库操作类是所有程序都可以实现的一个功能,下面来分享一个PHP mysql数据库操作类,这个数据库操作类的特点是对所有保存到数据库的内容进入了过滤,可以很好的处理sql注入了。
讲述了PHP实现PDO的mysql数据库操作类,dbconfig类负责配置数据库访问信息,包括:服务器地址、端口、数据库实例名、用户名、用户密码、字符集等。 dbtemplate类集合了对数据库的访问操作,主要有以下几...
php中mysql数据库操作类
和sqlhelper一样使用的mysql数据库操作类
MySQL数据库操作类的实现与应用C++源代码程序小实例visual studio.net
讲述了PHP实现PDO的mysql数据库操作类,dbconfig类负责配置数据库访问信息,包括:服务器地址、端口、数据库实例名、用户名、用户密码、字符集等。 dbtemplate类集合了对数据库的访问操作,主要有以下几个操作: 1. ...
易语言MySql数据库操作类V1.0模块源码,MySql数据库操作类V1.0模块,MySql数据库连接类_测试子程序,置连接选项,连接,关闭,是否已连接,取连接句柄,置连接句柄,执行SQL,引擎版本,最后错误,取错误代码,选择库,创建库,删除...
MySql数据库打开、读取、关闭、执行Sql语句的操作类 自己写的以应用于项目中
php操作mysql数据库操作类,包括数据库连接及操作
PHPmysql数据库操作类扫描.pdf
C# MySQL 数据库操作类 (包含MySql.Data.Dll文件) 常用方法二三十多个 最近项目中用到的就写了个