php实现Mysql简易操作类
自己封装的Mysql简易操作类，已塞在Ben框架中，基于PDO来写的，代码风格上有些无厘头。。。
mysql.class.php
<?php
classmysqlextendsPDO{
public$server;
public$database;
public$user;
public$password;
public$sql;
publicfunction__construct($server,$database,$user,$password,$port=3306){
$this->server=$server;
$this->database=$database;
$this->user=$user;
$this->password=$password;
parent::__construct("mysql:host=$server;port=$port;dbname=$database",$user,$password);
$this->query('SETNAMESutf8');
}
publicfunctiondrop($table){
$sql='DROPTABLE'.$table.';';
$re=$this->query($sql);
if($re){
returntrue;
}else{
returnfalse;
}
}
publicfunctioninsert($table,$name,$value=null){
$sql="INSERTINTO".$table.'(';
if($value==null){
$arrname=array_keys($name);
$arrvalue=array_values($name);
}else{
$arrname=explode('|',$name);
$arrvalue=explode('|',$value);
}
for($i=0;$i<count($arrname);$i++){
if($i==count($arrname)-1){
$sql=$sql.$arrname[$i];
}else{
$sql=$sql.$arrname[$i].",";
}
}
$sql=$sql.")VALUES(";
for($i=0;$i<count($arrvalue);$i++){
if($i==count($arrvalue)-1){
$sql=$sql."'".$arrvalue[$i]."'";
}else{
$sql=$sql."'".$arrvalue[$i]."',";
}
}
$sql.=");";
$re=$this->query($sql);
if($re){
returntrue;
}else{
returnfalse;
}
}
publicfunctiondelete($table,$Conditionsname,$Conditionsvalue=null){
if($Conditionsvalue!=null){
$sql="DELETEFROM".$table."WHERE".$Conditionsname."='".$Conditionsvalue."';";
}else{
$sql="DELETEFROM".$table."WHERE";
$arrname=array_keys($Conditionsname);
$arrvalue=array_values($Conditionsname);
for($i=0;$i<count($arrname);$i++){
if($i==count($arrname)-1){
$sql.=$arrname[$i].'='."'".$arrvalue[$i]."'";
}else{
$sql.=$arrname[$i].'='."'".$arrvalue[$i]."',";
}
}
$sql.=';';
}
$re=$this->query($sql);
if($re){
returntrue;
}else{
returnfalse;
}
}
publicfunctionselect($table,$name,$Conditionsname,$Conditionsvalue=null){
if($Conditionsvalue!=null){
$sql="SELECT".$name."FROM".$table."WHERE".$Conditionsname."='".$Conditionsvalue."';";
}else{
$sql="SELECT".$name."FROM".$table."WHERE";
$arrname=array_keys($Conditionsname);
$arrvalue=array_values($Conditionsname);
for($i=0;$i<count($arrname);$i++){
if($i==count($arrname)-1){
$sql.=$arrname[$i].'='."'".$arrvalue[$i]."'";
}else{
$sql.=$arrname[$i].'='."'".$arrvalue[$i]."'and";
}
}
$sql.=';';
}
$re=$this->query($sql);
$row=$re->fetch();
return$row[$name];
}
publicfunctionupdate($table,$name,$value,$Conditionsname,$Conditionsvalue=null){
if($Conditionsvalue!=null){
$sql="UPDATE".$table."SET".$name."='".$value."'WHERE".$Conditionsname."='".$Conditionsvalue."';";
}else{
$sql="UPDATE".$table."SET".$name."='".$value."'WHERE";
$arrname=array_keys($Conditionsname);
$arrvalue=array_values($Conditionsname);
for($i=0;$i<count($arrname);$i++){
if($i==count($arrname)-1){
$sql.=$arrname[$i].'='."'".$arrvalue[$i]."'";
}else{
$sql.=$arrname[$i].'='."'".$arrvalue[$i]."'and";
}
}
$sql.=';';
}
$re=$this->query($sql);
if($re){
returntrue;
}else{
returnfalse;
}
}
publicfunctiongroup($table,$name){
$sql="SELECT".$name."FROM".$table.";";
$return=array();
$re=$this->query($sql);
while($row=$re->fetch(PDO::FETCH_ASSOC)){
array_push($return,$row[$name]);
}
return$return;
}
publicfunctionfetchall($sql){
$return=array();
$re=$this->query($sql);
while($row=$re->fetch(PDO::FETCH_ASSOC)){
array_push($return,$row);
}
return$return;
}
}