要用PHP操作一个数据库很简单,相应入门后的PHPER都可以做到,但是在应对大量的表操作时,我们为许多的MYSQL语句感到厌烦,所以我们急切想要把大量数据库操作封装起来。所以就出现了数据库对象映射。
首先我们新建一个接口。
singleton.class.php
<?php
/**
* @author tomyjohn
* @link
* @license
* @version 1.0
* @copyright Copyright 2010 tomyjohn - tomyjohn.gicp.net
* @package singleton
*/
/**
* 数据库对象
*/
interface singleton{
/**
* 生成数据库对象
* @returns object data object;
* @access public
*/
public static function getInstance();
}
再新建一个抽象类,这个抽象类把所有的数据库都简明地用5个方法来抽象。
db.class.php
<?php
/**
* @author tomyjohn
* @link
* @license
* @version 1.0
* @copyright Copyright 2010 tomyjohn - tomyjohn.gicp.net
* @package db
*/
/**
*抽象DB类
*/
abstract class db{
/**
* 工厂模式
* @param string $type sql type
* @returns object
* @access public
*/
public static function factory($type){
return call_user_func(array($type,'getInstance'));
}
/**
* 执行SQL语句
* @param string $query sql 语句
* @return object resource or false;
* @access public
*/
abstract public function execute($query);
/**
* 获取SQL语句返回的数组
* @param string $query sql 语句
* @return object resource or false;
* @access public
*/
abstract public function get_array($query);
/**
* 获取上一条语句的执行ID
* @param string $query sql 语句
* @return integer number or false;
* @access public
*/
abstract public function insert_get_id($query);
/**
* 转化特殊字符
* @param string $string
* @return string 处理后的字符串
* @access public
*/
abstract public function clean($string);
}
相信看到这里,都会想到那个call_user_func方法该如何使用,别急,往下看
mysql.class.php
<?php
/**
* @author tomyjohn
* @link
* @license
* @version 1.0
* @copyright Copyright 2010 tomyjohn - tomyjohn.gicp.net
* @package db
*/
/**
*MYSQL数据库对象
*/
class mysql extends db implements singleton{
/**
* @var $instance object
* @access current class
*/
protected static $instance = null;
/**
* @var $link resource
* @access current class
*/
protected $link;
/**
* 数据库实例
* @return $self::instance object
*/
public static function getInstance(){
if(is_null(self::$instance)){
self::$instance = new self();
}
return self::$instance;
}
/**
* 构造器
*/
protected function __construct(){
global $current_conf;
$user = $current_conf['DBUSER'];
$pass = $current_conf['DBPWD'];
$host = $current_conf['DBHOST'];
$db = $current_conf['DBNAME'];
$this->link = mysql_connect($host,$user,$pass);
mysql_set_charset($current_conf['DBCHARSET'] , $this->link);
mysql_select_db($db);
}
/**
* 转化特殊字符
* @param string $string
* @return string 处理后的字符串
* @access public
*/
public function clean($string){
return mysql_real_escape_string($string,$this->link);
}
/**
* 执行SQL语句
* @param string $query sql 语句
* @return object resource or false;
* @access public
*/
public function execute($query){
return mysql_query($query,$this->link);
}
/**
* 获取上一条语句的执行ID
* @param string $query sql 语句
* @return integer number or false;
* @access public
*/
public function insert_get_id($query){
$this->execute($query);
return mysql_insert_id($this->link);
}
/**
* 获取SQL语句返回的数组
* @param string $query sql 语句
* @return object resource or false;
* @access public
*/
public function get_array($query){
$result = $this->execute($query);
$return = array();
if($result){
while($row = mysql_fetch_array($result , MYSQL_ASSOC)){
$return[] =$row;
}
}
return $return;
}
}
current_conf 这个数组是我项目里的,其实也可以用你数据库的用户名和密码代替,看完这个我想你们也应该清楚了,继承DB然后实现singleton接口后的这个类,其实也可用到MSSQL,ORACL,以及其他数据库,但是光有这个,我们只能使操作数据库变成这样
$connection = db::factory('mysql');
$sql = "SELECT * FROM table";
$value_array = $connection->get_array($sql);
print_r($value_array);
这样虽然解决了扩展,解决了一些重复的操作,但是还不是很方便,我们应该更进一步,使数据库表用对象表示,即数据库映射
dao.class.php
<?php
class dao{
/**
* @var $values array 存放数据库对象
* @access current class
*/
protected $values = array();
/**
* @var $suffix array 存放数据库对象
* @access public
*/
public $suffix = '';
/**
* 构造器
*/
public function __construct($qualifier = null){
global $current_conf;
$this->suffix = $current_conf['DBSUFFIX'];
if(!is_null($qualifier)){
$conditional = array();
if(is_numeric($qualifier)){
$conditional = array('id'=>$qualifier);
}
else if(is_array($qualifier)){
$conditional = $qualifier;
}
else{
throw new Exception('Invalid type of qualifier given!');
}
$this->populate($conditional);
}
}
public function __set($name , $value){
$this->values[$name] = $value;
}
public function __get($name){
if(isset($this->values[$name])){
return $this->values[$name];
}
else{
return null;
}
}
/**
* 解析实例的参数
* @param $conditional obj
*/
protected function populate($conditional){
$connection = db::factory('mysql');
$sql = "SELECT * FROM {$this->suffix}{$this->table} WHERE ";
$qualifier = '';
foreach($conditional as $column => $value){
if(!empty($qualifier)){
$qualifier .= ' AND ';
}
$qualifier .= "`{$column}`='" . $connection->clean($value) . "' ";
}
$sql .= $qualifier;
$value_array = $connection->get_array($sql);
if(!isset($value_array[0])){
$value_array[0] = array();
}
foreach($value_array[0] as $key => $value){
$this->values[$key] = $value;
}
}
/**
* 保存数据
*/
public function save(){
if(!$this->id){
$this->create();
}
else{
return $this->update();
}
}
/**
* 添加数据
*/
public function create(){
$connection = db::factory('mysql');
$sql = "INSERT INTO {$this->suffix}{$this->table}(`";
$sql .= implode('`, `' , array_keys($this->values));
$sql .="`) VALUES('";
$clean = array();
foreach($this->values as $value){
$clean[] = $connection->clean($value);
}
$sql .= implode("', '" , $clean);
$sql .="')";
$this->id = $connection->insert_get_id($sql);
}
/**
* 更新数据
* @return 返回执行操作的结果
*/
public function update(){
$connection = db::factory('mysql');
$sql = "UPDATE {$this->suffix}{$this->table} set ";
$updates = array();
foreach($this->values as $key=>$value){
if($key!='id'){
$updates[] = "`{$key}`='" . $connection->clean($value) . "'";
}
}
$sql .= implode(',' , $updates);
$sql .= " WHERE id={$this->id}";
return $connection->execute($sql);
}
/**
* 删除数据
* @return 返回执行操作的结果
*/
public function delete(){
$connection = db::factory('mysql');
$sql = "DELETE FROM {$this->suffix}{$this->table} WHERE ";
$qualifier = 'id='.$this->id;
$sql .= $qualifier;
return $connection->execute($sql);
}
/**
* 对象转成数组
* @return array
*/
public function object_to_array(){
return $this->values;
}
}
如果看到这里,我相信大家都会想去继承这个类。 是的,如果继承了这个类,那么每条记录就可以变成对象,就可以用面向对象的方式去处理了。
我写一个
news.dao.class
<?php
class news extends dao{
protected $table = __CLASS__;
}
我们在开发网站的时候,尽量不要使数据操作进入视图,下一节我介绍一个模板类。
分享到:
相关推荐
PHP MYSQL操作类 PHP_DataSet
(1)在需要调用mysql操作类的窗口头文件*.h中引入mysql头文件:#include "mysql.h" (2)在需要调用mysql操作类的窗口头文件*.h中声明mysql对象指针: public: mysql *db; (3)在需要调用mysql操作类的窗口...
新手学习,php7中mysql数据库操作类实例,非常清晰易懂
php中mysql数据库操作类
PHP MYSQL 操作类
一款比较全的mysql操作类,这个是一款包括数据查询,更新,删除,等操作,有需要的小伙伴可以下载学习和参考,也可以自己进行修改操作,达到自己的目的。
php中mysql数据库操作类
一个php使用单例模式实现mysql类,封装mysql操作类,包括连接功能,及查询功能,封装getAll,getRow,getOne,afftect_rows()方法。
php实现MySQL数据库操作类
比较方便的一个类,分享了 比较适合初中级开发人员,比较实用
mysql操作类
java mysql 操作类 用面向对象的思路封装大部分mysql的操作
PHP基于pdo的数据库操作类【可支持mysql、sqlserver及oracle】.docx
php操作mysql数据库操作类,包括数据库连接及操作
mysql数据库操作类很好的哦mysql数据库操作类很好的哦mysql数据库操作类很好的哦
今天刚做的一个MySQL操作类,基本功能已经完成,支持连贯操作,支持基本的增改删差,查询条件和数据插入支持数组方式。自动缓存管理,可以选择文件缓存,或者memcache(也可以很方便的扩展其他缓存方式)。 使用...
自己用php5写的mysql数据库操作类,功能很齐全,前段时间上传了一次,但是发现了一点错误,现在修正过来了,还加了一个管理员判断的功能,自己看吧,反正很好用,我一直在用的。传上来赚点分数,保证你的分花的不亏...
介绍一个简单的php-mysql操作类,数据库连接和设置,执行操作,显示信息,取得数据集的某个值,取得数据集的某个值,取得数据集的行数,循环读取数据,最后一次插入纪录的id值,插入任意数据,修改数据,删除数据,...
MySql数据库的操作类,添加操作类和mysql.dll调用简单
C# 操作MySQL数据库类 非存储过程操作类,如果要用到存储过程的话,自已修改里面的代码,里面的存储过程被我注释了。 至于调用方法,应该不用我说下载者应该也懂得吧,如果是对C#一巧不通的初学者,不懂也不要怪我...