php資料庫封裝類

1. 求PHP資料庫封裝類操作代碼

<?php
class MySQL{
private $host; //伺服器地址
private $name; //登錄賬號
private $pwd; //登錄密碼
private $dBase; //資料庫名稱
private $conn; //資料庫鏈接資源
private $result; //結果集
private $msg; //返回結果
private $fields; //返回欄位
private $fieldsNum; //返回欄位數
private $rowsNum; //返回結果數
private $rowsRst; //返回單條記錄的欄位數組
private $filesArray = array(); //返回欄位數組
private $rowsArray = array(); //返回結果數組
private $charset='utf8'; //設置操作的字元集
private $query_count=0; //查詢結果次數
static private $_instance; //存儲對象
//初始化類
private function __construct($host='',$name='',$pwd='',$dBase=''){
if($host != '') $this->host = $host;
if($name != '') $this->name = $name;
if($pwd != '') $this->pwd = $pwd;
if($dBase != '') $this->dBase = $dBase;
$this->init_conn();
}
//防止被克隆
private function __clone(){}
public static function getInstance($host='',$name='',$pwd='',$dBase=''){
if(FALSE == (self::$_instance instanceof self)){
self::$_instance = new self($host,$name,$pwd,$dBase);
}
return self::$_instance;
}
public function __set($name,$value){
$this->$name=$value;
}
public function __get($name){
return $this->$name;
}
//鏈接資料庫
function init_conn(){
$this->conn=@mysql_connect($this->host,$this->name,$this->pwd) or die('connect db fail !');
@mysql_select_db($this->dBase,$this->conn) or die('select db fail !');
mysql_query("set names ".$this->charset);
}
//查詢結果
function mysql_query_rst($sql){
if($this->conn == '') $this->init_conn();
$this->result = @mysql_query($sql,$this->conn);
$this->query_count++;
}
//取得欄位數
function getFieldsNum($sql){
$this->mysql_query_rst($sql);
$this->fieldsNum = @mysql_num_fields($this->result);
}
//取得查詢結果數
function getRowsNum($sql){
$this->mysql_query_rst($sql);
if(mysql_errno() == 0){
return @mysql_num_rows($this->result);
}else{
return '';
}
}
//取得記錄數組（單條記錄）
function getRowsRst($sql,$type=MYSQL_BOTH){
$this->mysql_query_rst($sql);
if(empty($this->result)) return '';
if(mysql_error() == 0){
$this->rowsRst = mysql_fetch_array($this->result,$type);
return $this->rowsRst;
}else{
return '';
}
}
//取得記錄數組（多條記錄）
function getRowsArray($sql,$type=MYSQL_BOTH){
!empty($this->rowsArray) ? $this->rowsArray=array() : '';
$this->mysql_query_rst($sql);
if(mysql_errno() == 0){
while($row = mysql_fetch_array($this->result,$type)) {
$this->rowsArray[] = $row;
}
return $this->rowsArray;
}else{
return '';
}
}
//更新、刪除、添加記錄數
function uidRst($sql){
if($this->conn == ''){
$this->init_conn();
}
@mysql_query($sql);
$this->rowsNum = @mysql_affected_rows();
if(mysql_errno() == 0){
return $this->rowsNum;
}else{
return '';
}
}
//返回最近插入的一條資料庫的id值
function returnRstId($sql){
if($this->conn == ''){
$this->init_conn();
}
@mysql_query($sql);
if(mysql_errno() == 0){
return mysql_insert_id();
}else{
return '';
}
}
//獲取對應的欄位值
function getFields($sql,$fields){
$this->mysql_query_rst($sql);
if(mysql_errno() == 0){
if(mysql_num_rows($this->result) > 0){
$tmpfld = @mysql_fetch_row($this->result);
$this->fields = $tmpfld[$fields];

}
return $this->fields;
}else{
return '';
}
}
//錯誤信息
function msg_error(){
if(mysql_errno() != 0) {
$this->msg = mysql_error();
}
return $this->msg;
}
//釋放結果集
function close_rst(){
mysql_free_result($this->result);
$this->msg = '';
$this->fieldsNum = 0;
$this->rowsNum = 0;
$this->filesArray = '';
$this->rowsArray = '';
}
//關閉資料庫
function close_conn(){
$this->close_rst();
mysql_close($this->conn);
$this->conn = '';
}
//取得資料庫版本
function db_version() {
return mysql_get_server_info();
}
}

2. php跪求封裝好的pdo預處理類,在線等

<?php
//資料庫連接類，不建議直接使用DB，而是對DB封裝一層
//這個類不會被污染，不會被直接調用
classDB{
//pdo對象
private$_pdo=null;
//用於存放實例化的對象
staticprivate$_instance=null;

//公共靜態方法獲取實例化的對象
(){
if(!(self::$_instanceinstanceofself)){
self::$_instance=newself();
}
returnself::$_instance;
}

//私有克隆
privatefunction__clone(){}

//私有構造
privatefunction__construct(){
try{
$this->_pdo=newPDO(DB_DNS,DB_USER,DB_PASS,array(PDO::MYSQL_ATTR_INIT_COMMAND=>'SETNAMES'.DB_CHARSET));
$this->_pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
}catch(PDOException$e){
exit($e->getMessage());
}
}

//新增
protectedfunctionadd($_tables,Array$_addData){
$_addFields=array();
$_addValues=array();
foreach($_addDataas$_key=>$_value){
$_addFields[]=$_key;
$_addValues[]=$_value;
}
$_addFields=implode(',',$_addFields);
$_addValues=implode("','",$_addValues);
$_sql="INSERTINTO$_tables[0]($_addFields)VALUES('$_addValues')";
return$this->execute($_sql)->rowCount();
}

//修改
protectedfunctionupdate($_tables,Array$_param,Array$_updateData){
$_where=$_setData='';
foreach($_paramas$_key=>$_value){
$_where.=$_value.'AND';
}
$_where='WHERE'.substr($_where,0,-4);
foreach($_updateDataas$_key=>$_value){
if(Validate::isArray($_value)){
$_setData.="$_key=$_value[0],";
}else{
$_setData.="$_key='$_value',";
}
}
$_setData=substr($_setData,0,-1);
$_sql="UPDATE$_tables[0]SET$_setData$_where";
return$this->execute($_sql)->rowCount();
}

//驗證一條數據
protectedfunctionisOne($_tables,Array$_param){
$_where='';
foreach($_paramas$_key=>$_value){
$_where.=$_value.'AND';
}
$_where='WHERE'.substr($_where,0,-4);
$_sql="SELECTidFROM$_tables[0]$_whereLIMIT1";
return$this->execute($_sql)->rowCount();
}

//刪除
protectedfunctiondelete($_tables,Array$_param){
$_where='';
foreach($_paramas$_key=>$_value){
$_where.=$_value.'AND';
}
$_where='WHERE'.substr($_where,0,-4);
$_sql="DELETEFROM$_tables[0]$_whereLIMIT1";
return$this->execute($_sql)->rowCount();
}

//查詢
protectedfunctionselect($_tables,Array$_fileld,Array$_param=array()){
$_limit=$_order=$_where=$_like='';
if(Validate::isArray($_param)&&!Validate::isNullArray($_param)){
$_limit=isset($_param['limit'])?'LIMIT'.$_param['limit']:'';
$_order=isset($_param['order'])?'ORDERBY'.$_param['order']:'';
if(isset($_param['where'])){
foreach($_param['where']as$_key=>$_value){
$_where.=$_value.'AND';
}
$_where='WHERE'.substr($_where,0,-4);
}
if(isset($_param['like'])){
foreach($_param['like']as$_key=>$_value){
$_like="WHERE$_keyLIKE'%$_value%'";
}
}
}
$_selectFields=implode(',',$_fileld);
$_table=isset($_tables[1])?$_tables[0].','.$_tables[1]:$_tables[0];
$_sql="SELECT$_selectFieldsFROM$_table$_where$_like$_order$_limit";
$_stmt=$this->execute($_sql);
$_result=array();
while(!!$_objs=$_stmt->fetchObject()){
$_result[]=$_objs;
}
returnTool::setHtmlString($_result);
}

//總記錄
protectedfunctiontotal($_tables,Array$_param=array()){
$_where='';
if(isset($_param['where'])){
foreach($_param['where']as$_key=>$_value){
$_where.=$_value.'AND';
}
$_where='WHERE'.substr($_where,0,-4);
}
$_sql="SELECTCOUNT(*)ascountFROM$_tables[0]$_where";
$_stmt=$this->execute($_sql);
return$_stmt->fetchObject()->count;
}

//得到下一個ID
protectedfunctionnextId($_tables){
$_sql="SHOWTABLESTATUSLIKE'$_tables[0]'";
$_stmt=$this->execute($_sql);
return$_stmt->fetchObject()->Auto_increment;
}


//執行SQL
privatefunctionexecute($_sql){
try{
$_stmt=$this->_pdo->prepare($_sql);
$_stmt->execute();
}catch(PDOException$e){
exit('SQL語句：'.$_sql.'<br/>錯誤信息：'.$e->getMessage());
}
return$_stmt;
}
}
?>

3. php中的pdo是什麼

PDO擴展為PHP訪問資料庫定義了一個輕量級的、一致性的介面，它提供了一個數據訪問抽象層，這樣，無論使用什麼資料庫，都可以通過一致的函數執行查詢和獲取數據。PDO隨PHP5.1發行，在PHP5.0的PECL擴展中也可以使用。

4. PHP 繼承、封裝、多態

-子類只能繼承父類的非私有屬性
-子類繼承父類後，相當於將父類的屬性和方法到子類，可以直接使用$this調用該屬性；
-php只能單繼承，不支持一個類繼承多個類。但是一個類可以進行多層繼承

類實現封裝是為了不讓外面的類隨意修改一個類的成員變數，所以在定義一個類的成員的時候，我們使用private關鍵字設置這個成員的訪問許可權只能被這個類的其他成員方法調用，而不能被其他類中的方法調用，即通過本類中提供的方法來訪問本類中的私有屬性
-所以在該類中我們會提供一個訪問私有屬性的方法
-然後我們一般會定義兩個方法來實現對一個變數的操作，即__get()和__set()方法

一個類被多個子類繼承，如果這個類的某個方法，在多個子類中，表現出不同的功能，我們稱這種行為為多態（同一個類的不同子類表現出不同的形態）
-子類繼承父類->子類重寫父類的方法->父類引用指向子類對象

5. ThinkPHP中怎麼使用自定義的封裝類

1. 類文件都是以.class.php為後綴（這里是指的ThinkPHP內部使用的類庫文件，不代表外部載入的類庫文件），使用駝峰法命名，並且首字母大寫，例如 DbMysql.class.php；

2. 類的命名空間地址和所在的路徑地址一致，例如 HomeControllerUserController類所在的路徑應該是 Application/Home/Controller/UserController.class.php；

3. 確保文件的命名和調用大小寫一致，是由於在類Unix系統上面，對大小寫是敏感的（而ThinkPHP在調試模式下面，即使在Windows平台也會嚴格檢查大小寫）；

4. 類名和文件名一致（包括上面說的大小寫一致），例如 UserController類的文件命名是UserController.class.php， InfoModel類的文件名是InfoModel.class.php， 並且不同的類庫的類命名有一定的規范；

類的導入載入可以參考手冊的命名空間和自動載入，下面是地址：
命名空間：http://document.thinkphp.cn/manual_3_2.html#namespace
自動載入：http://document.thinkphp.cn/manual_3_2.html#autoload

6. PHP訪問MYSQL資料庫封裝類(附函數說明)

復制代碼
代碼如下:
<?php
/*
MYSQL
資料庫訪問封裝類
MYSQL
數據訪問方式，php4支持以mysql_開頭的過程訪問方式，php5開始支持以mysqli_開頭的過程和mysqli面向對象
訪問方式，本封裝類以mysql_封裝
數據訪問的一般流程：
1,連接資料庫
mysql_connect
or
mysql_pconnect
2,選擇資料庫
mysql_select_db
3,執行SQL查詢
mysql_query
4,處理返回的數據
mysql_fetch_array
mysql_num_rows
mysql_fetch_assoc
mysql_fetch_row
etc
*/
class
db_mysql
{
var
$querynum
=
0
;
//當前頁面進程查詢資料庫的次數
var
$dblink
;
//資料庫連接資源
//鏈接資料庫
function
connect($dbhost,$dbuser,$dbpw,$dbname='',$dbcharset='utf-8',$pconnect=0
,
$halt=true)
{
$func
=
empty($pconnect)
?
'mysql_connect'
:
'mysql_pconnect'
;
$this->dblink
=
@$func($dbhost,$dbuser,$dbpw)
;
if
($halt
&&
!$this->dblink)
{
$this->halt("無法鏈接資料庫！");
}
//設置查詢字元集
mysql_query("SET
character_set_connection={$dbcharset},character_set_results={$dbcharset},character_set_client=binary",$this->dblink)
;
//選擇資料庫
$dbname
&&
@mysql_select_db($dbname,$this->dblink)
;
}
//選擇資料庫
function
select_db($dbname)
{
return
mysql_select_db($dbname,$this->dblink);
}
//執行SQL查詢
function
query($sql)
{
$this->querynum++
;
return
mysql_query($sql,$this->dblink)
;
}
//返回最近一次與連接句柄關聯的INSERT，UPDATE
或DELETE
查詢所影響的記錄行數
function
affected_rows()
{
return
mysql_affected_rows($this->dblink)
;
}
//取得結果集中行的數目,只對select查詢的結果集有效
function
num_rows($result)
{
return
mysql_num_rows($result)
;
}
//獲得單格的查詢結果
function
result($result,$row=0)
{
return
mysql_result($result,$row)
;
}
//取得上一步
INSERT
操作產生的
ID,只對表有AUTO_INCREMENT
ID的操作有效
function
insert_id()
{
return
($id
=
mysql_insert_id($this->dblink))
>=
0
?
$id
:
$this->result($this->query("SELECT
last_insert_id()"),
0);
}
//從結果集提取當前行，以數字為key表示的關聯數組形式返回
function
fetch_row($result)
{
return
mysql_fetch_row($result)
;
}
//從結果集提取當前行，以欄位名為key表示的關聯數組形式返回
function
fetch_assoc($result)
{
return
mysql_fetch_assoc($result);
}
//從結果集提取當前行，以欄位名和數字為key表示的關聯數組形式返回
function
fetch_array($result)
{
return
mysql_fetch_array($result);
}
//關閉鏈接
function
close()
{
return
mysql_close($this->dblink)
;
}
//輸出簡單的錯誤html提示信息並終止程序
function
halt($msg)
{
$message
=
"<html>\n<head>\n"
;
$message
.=
"<meta
content='text/html;charset=gb2312'>\n"
;
$message
.=
"</head>\n"
;
$message
.=
"<body>\n"
;
$message
.=
"資料庫出錯：".htmlspecialchars($msg)."\n"
;
$message
.=
"</body>\n"
;
$message
.=
"</html>"
;
echo
$message
;
exit
;
}
}
?>

7. PHP里封裝的一個mysql insert函數，還有一個update函數

談一下個人的幾點認識，供參考：

封裝，網路的解釋：即隱藏對象的屬性和實現細節，僅對外公開介面，控制在程序中屬性的讀和修改的訪問級別；將抽象得到的數據和行為（或功能）相結合，形成一個有機的整體，也就是將數據與操作數據的源代碼進行有機的結合，形成「類」，其中數據和函數都是類的成員。

簡單點說，封裝就是將某塊功能抽取出來，寫到一個函數里，供重復調用。封裝，通常是指類函數、類的成員。

就你上面的代碼，就個人理解，你完全可以將之理解為功能函數，這也算是一種「封裝」（但貌似與面向對象思想里的類的封裝有些區別）。

update 函數，其功能是對資料庫CURD四種基本操作里 U 的實現，其原理是通過對傳入的數組（據判斷，貌似是用「欄位名」為鍵名，修改的值為 Value），通過對數組遍歷，進行組合，進一步得到 SQL 語句（update），並予以執行。

$str.=$sep.$key."='".$val."'";

$sep 是不同資料庫欄位名之間的分隔符，$key 是資料庫欄位名，$val 是修改的值。上面的代碼通過多次循環之後，就會形成合乎 SQL 語法的 Update 數據修改語句，例如：

updatetable1setLastDate='ddd',SssName='ddd'whereUserID="aasdd"

8. php實現mysql封裝類示例

php封裝mysql類
復制代碼
代碼如下:
<?php
class
Mysql
{
private
$host;
private
$user;
private
$pwd;
private
$dbName;
private
$charset;
private
$conn
=
null;
public
function
__construct()
{
$this->host
=
'localhost';
$this->user
=
'root';
$this->pwd
=
'root';
$this->dbName
=
'test';
$this->connect($this->host,$this->user,$this->pwd);
$this->switchDb($this->dbName);
$this->setChar($this->charset);
}
//負責鏈接
private
function
connect($h,$u,$p)
{
$conn
=
mysql_connect($h,$u,$p);
$this->conn
=
$conn;
}
//負責切換資料庫
public
function
switchDb($db)
{
$sql
=
'use'
.
$db;
$this->query($sql);
}
//負責設置字元集
public
function
setChar($char)
{
$sql
=
'set
names'
.
$char;
$this->query($sql);
}
//負責發送sql查詢
public
function
query($sql)
{
return
mysql_query($sql,$this->conn);
}
//負責獲取多行多列的select結果
public
function
getAll($sql)
{
$list
=
array();
$rs
=
$this->query($sql);
if
(!$rs)
{
return
false;
}
while
($row
=
mysql_fetch_assoc($rs))
{
$list[]
=
$row;
}
return
$list;
}
public
function
getRow($sql)
{
$rs
=
$this->query($sql);
if(!$rs)
{
return
false;
}
return
mysql_fetch_assoc($rs);
}
public
function
getOne($sql)
{
$rs
=
$this->query($sql);
if
(!$rs)
{
return
false;
}
return
mysql_fetch_assoc($rs);
return
$row[0];
}
public
function
close()
{
mysql_close($this->conn);
}
}
echo
'<pre>';
$mysql
=
new
Mysql();
print_r($mysql);
$sql
=
"insert
into
stu
values
(4,'wangwu','99998')";
if($mysql->query($sql)){
echo
"query成功";
}else
{
echo
"失敗";
}
echo
"<br
/>";
$sql
=
"select
*
from
stu";
$arr
=
$mysql->getAll($sql);
print_r($arr);
?>

9. php封裝一個用戶類,裡面有登錄注冊方法,這個要怎麼寫

第一步：login.php

//登陸方法
public function login(){
//如果用戶名和密碼為空，則返回登陸頁面
if(empty($_POST['username']) || empty($_POST['password'])){
$data['verifycode'] = rand(1000,9999);//生成一個四位數字的驗證碼
//將驗證碼放入session中,注意：參數是數組的格式
$this->session->set_userdata($data);
//注意：CI框架默認模板引擎解析的模板文件中變數不需要$符號
//$this->parser->parse("admin/login",$data);
//smarty模板變數賦值
$this->tp->assign("verifycode",$data['verifycode']);
//ci框架在模板文件中使用原生態的PHP語法輸出數據
//$this->load->view('login',$data);//登陸頁面，注意：參數2需要以數組的形式出現
//顯示smarty模板引擎設定的模板文件
$this->tp->display("admin/login.php");
}else{
$username = isset($_POST['username'])&&!empty($_POST['username'])?trim($_POST['username']):'';//用戶名
$password = isset($_POST['password'])&&!empty($_POST['password'])?trim($_POST['password']):'';//密碼
$verifycode = isset($_POST['verifycode'])&&!empty($_POST['verifycode'])?trim($_POST['verifycode']):'';//驗證碼

//做驗證碼的校驗
if($verifycode == $this->session->userdata('verifycode')){
//根據用戶名及密碼獲取用戶信息，注意：參數2是加密的密碼
$user_info=$this->user_model->check_user_login($username,md5($password));
if($user_info['user_id'] > 0){
//將用戶id、username、password放入cookie中
//第一種設置cookie的方式：採用php原生態的方法設置的cookie的值
//setcookie("user_id",$user_info['user_id'],86500);
//setcookie("username",$user_info['username'],86500);
//setcookie("password",$user_info['password'],86500);
//echo $_COOKIE['username'];

//第二種設置cookie的方式：通過CI框架的input類庫
$this->input->set_cookie("username",$user_info['username'],3600);
$this->input->set_cookie("password",$user_info['password'],3600);
$this->input->set_cookie("user_id",$user_info['user_id'],3600);
//echo $this->input->cookie("password");//適用於控制器
//echo $this->input->cookie("username");//適用於控制器
//echo $_COOKIE['username'];//在模型類中可以通過這種方式獲取cookie值
//echo $_COOKIE['password'];//在模型類中可以通過這種方式獲取cookie值

//第三種設置cookie的方式：通過CI框架的cookie_helper.php函數庫文件
//這種方式不是很靈驗，建議大家採取第二種方式即可
//set_cookie("username",$user_info['username'],3600);
//echo get_cookie("username");

//session登陸時使用：將用戶名和用戶id存入session中
//$data['username']=$user_info['username'];
//$data['user_id']=$user_info['user_id'];
//$this->session->set_userdata($data);

//跳轉到指定頁面
//注意：site_url()與base_url()的區別，前者帶index.php,後者不帶index.php
header("location:".site_url("index/index"));
}
}else{
//跳轉到登陸頁面
header("location:".site_url("common/login"));
}
}
}
}

第二步：User_model.php

//cookie登陸：檢測用戶是否登陸，如果cookie值失效，則返回false，如果cookie值未失效，則根據cookie中的用戶名和密碼從資料庫中獲取用戶信息，如果能獲取到用戶信息，則返回查詢到的用戶信息，如果沒有查詢到用戶信息，則返回0
public function is_login(){
//獲取cookie中的值
if(empty($_COOKIE['username']) || empty($_COOKIE['password'])){
$user_info = false;
}else{
$user_info=$this->check_user_login($_COOKIE['username'],$_COOKIE['password']);
}
return $user_info;
}

//根據用戶名及加密密碼從資料庫中獲取用戶信息，如果能獲取到，則返回獲取到的用戶信息，否則返回false，注意：密碼為加密密碼
public function check_user_login($username,$password){
//這里大家要注意：$password為md5加密後的密碼
//$this->db->query("select * from ");
//快捷查詢類的使用：能為我們提供快速獲取數據的方法
//此數組為查詢條件
//注意：關聯數組
$arr=array(
'username'=>$username,//用戶名
'password'=>$password,//加密密碼
'status'=>1 //賬戶為開啟狀態
);
//在database.php文件中已經設置了數據表的前綴，所以此時數據表無需帶前綴
$query = $this->db->get_where("users",$arr);
//返回二維數組
//$data=$query->result_array();
//返回一維數組
$user_info=$query->row_array();
if(!empty($user_info)){
return $user_info;
}else{
return false;
}
}

第三步：其它控制器：

public function __construct(){

//調用父類的構造函數
parent::__construct();
$this->load->library('tp'); //smarty模板解析類
$this->load->helper('url'); //url函數庫文件
$this->load->model("user_model");//User_model模型類實例化對象
$this->cur_user=$this->user_model->is_login();
if($this->cur_user === false){
header("location:".site_url("common/login"));
}else{
//如果已經登陸，則重新設置cookie的有效期
$this->input->set_cookie("username",$this->cur_user['username'],3600);
$this->input->set_cookie("password",$this->cur_user['password'],3600);
$this->input->set_cookie("user_id",$this->cur_user['user_id'],3600);
}

$this->load->library('pagination');//分頁類庫
$this->load->model("role_model");//member_model模型類
$this->load->model("operation_model");//引用operation_model模型
$this->load->model("object_model");//引用object_model模型
$this->load->model("permission_model");//引用permission_model模型
}