PHP資料庫操作基底類別(單例模式)-php教程-PHP中文網

PHP資料庫操作基底類別(單例模式)

WBOY

發布： 2016-07-25 09:09:08

原創

1023 人瀏覽過

自己練習寫的資料庫操作基類,包含最基本的CURD操作.可整合到框架內.

// 設定檔
$db = array(
'host'=>'localhost',
'user'=> 'root',
'password'=>'',
'database'=>'test',
)
?>
//php 類別
class db {
public $conn;
public static $sql;
public static $instance=null;
private function __construct(){
require_once('db. config.php');
$this->conn = mysql_connect($db['host'],$db['user'],$db['password']);
if(!mysql_select_db( $db['database'],$this->conn)){
echo "失敗";
};
mysql_query('set names utf8',$this->conn);
}
public static function getInstance(){
if(is_null(self::$instance)){
self::$instance = new db;
}
return self:: instance;
}
/**
* 查詢資料庫
*/
public function select($table,$condition=array(),$field = array()){
$where='' ;
if(!empty($condition)){
foreach($condition as $k=>$v){
$where.=$k."='".$v ."' 和 ";
}
$where='where '.$where .'1=1';
}
$fieldstr = '';
if(!empty( $field)){
foreach($field as $k=>$v){
$fieldstr.= $v.',';
}
$fieldstr = rtrim( $fieldstr,',');
}else{
$fieldstr = '*';
}
self::$sql = "select {$fieldstr} from {$table} {$ where}";
$result=mysql_query(self::$sql,$this->conn);
$resuleRow = array();
$i = 0;
while($row =mysql_fetch_assoc($result)){
foreach($row as $k=>$v){
$resuleRow[$i][$k] = $v;
}
$i++ ;
}
return $resuleRow;
}
/**
* 新增一筆記錄
*/
public function insert($table,$data){
$values = '';
$datas = '';
foreach($data as $k=>$v){
$values.=$k.',';
$datas.="'$v '".',';
}
$values = rtrim($values,',');
$datas = rtrim($datas,',');
self::$ sql = "INSERT INTO {$table} ({$values}) VALUES ({$datas})";
if(mysql_query(self::$sql)){
return mysql_insert_id();
}else{
return false;
};
}
/**
* 修改一筆記錄
*/
public function update($table,$data,$condition=array()){
$where='';
if(!empty($condition)){
foreach($condition as $k=>$v){
$where.=$k ."='".$v."' 和 ";
}
$where='where '.$where .'1=1';
}
$updatastr = '';
if(!empty($data)){
foreach($data as $k=>$v){
$updatastr.= $k."='".$v."', ";
}
$updatastr = 'set '.rtrim($updatastr,',');
}
self::$sql = "update {$table} {$updatastr} { $where}";
return mysql_query(self::$sql);
}
/**
* 刪除記錄
*/
public function delete($table,$condition){
$where='';
if(!empty($condition)){
foreach($condition as $k=>$v){
$where.=$k."= '".$v."' and ";
}
$where='where '.$where .'1=1';
}
self::$sql = "delete from {$table} {$where}";
return mysql_query(self::$sql);
}
public static function getLastSql(){
echo self:: $sql;
}
}

複製程式碼

$db = array(
'host'=>'localhost',
'user'=>'root',
'password'=>'',
'database'=>'test',
)
?>

複製程式碼

class db {
public $conn;
public static $sql;
public staticic $ require_once('db.config.php');
$this->conn = mysql_connect($db['host'],$db['user'],$db [ ' password']);
if(!mysql_select_db($db['database'],$this->conn)){
echo "失敗";
};
mysql_query( '設定名稱utf8',$this->conn);
}
public static function getInstance(){
if(is_null(self::$instance)){
self::$instance = new db;
}
return self ::$instance;
}
/**
* 查詢資料庫
*/
public function select($table,$condition=array(),$field = array()){
$where ='';
if(!empty($condition)){
foreach($condition as $k=>$v){
$where.=$k."=' " .$v."' 和";
}
$where='where '.$where .'1=1';
}
$fieldstr = '';
if ( !empty($field)){
foreach($field as $k=>$v){
$fieldstr.= $v.',';
}
$fieldstr = rtrim($fieldstr,',');
}else{
$fieldstr = '*';
}
self::$sql = "從{ 選出{$fieldstr} $table } {$where}";
$result=mysql_query(self::$sql,$this->conn);
$resuleRow = array();
$i = 0;
while ($row=mysql_fetch_assoc($result)){
foreach($row as $k=>$v){
$resuleRow[$i][$k] = $v;
}
$i++;
}
return $resuleRow;
}
/**
* 新增一筆記錄
*/
public function insert($table,$data){
$values = '';
$datas = '';
foreach($data as $k=>$v){
$values.=$k.',';
$datas.=" '$v'".',';
}
$values = rtrim($values,',');
$datas = rtrim($datas,',') ;
self ::$sql = "插入{$table} ({$values}) VALUES ({$datas})";
if(mysql_query(self::$sql)){
return mysql_insert_id();
}else{
return false;
};
}
/**
* 修改一筆記錄
*/
public function update($table,$data, $condition=array() ){
$where='';
if(!empty($condition)){
foreach($condition as $k=>$v){
$where.= $k."='".$v."' 和";
}
$where='where '.$where .'1=1';
}
$updatastr = ' ';
if(!empty($data)){
foreach($data as $k=>$v){
$updatastr.= $k." ='".$v." ',";
}
$updatastr = 'set '.rtrim($updatastr,',');
}
self::$sql = " update {$table} {$updatastr } {$where}";
return mysql_query(self::$sql);
}
/**
* 刪除記錄
*/
public function delete( $table,$condition){
$where='';
if(!empty($condition)){
foreach($condition as $k=>$v){
$where.=$k. "='".$v."' 和";
}
$where='where '.$where .'1=1';
}
self::$sql = " From {$table} {$where} 中刪除";
return mysql_query(self::$sql);
}
公用靜態函式getLastSql(){
echo self::$sql;
}
}
$db = db::getInstance();
//$list = $db- >select('demo',array('name'=>'tom','password'=>'ds'),array('name','password')) ;
//echo $db-> insert('demo',array('name'=>'最近你啦','password'=>'123'));
//echo $db->update('demo',array("name "=>'xxx',"密碼"=>'123'),array('id'=>1));
echo $db->delete('demo',array('id'=>' 2'));
db::getLastSql();
echo "
```
";
```
登入後複製
? >

複製程式碼