1、在PHP中 使用MysqLi扩展库对MysqL 的dql操作
代码如下:
PHP
header("Content-type: text/html;charset=utf-8");
//MysqLi操作MysqL数据库(面向对象方式)
//1、创建MysqLi对象
$MysqLi =new MysqLi("localhost","root","test");
if($MysqLi->connect_error){
die("连接失败".$MysqLi->connect_error);
}
//2、操作数据库(发送sql)
$sql="select *from user1";
//3、处理结果
$res =$MysqLi->query($sql);
//var_dump($res);
//fetch_assoc \fetch_array \fetch_object
while($row=$res->fetch_row()){
var_dump($row);
/* foreach($row as $val){
echo '--'.$val;
}
echo '
';*/
}
//4、关闭资源
$res->free();
$MysqLi->close();
?>
header("Content-type: text/html;charset=utf-8");
//MysqLi操作MysqL数据库(面向对象方式)
//1、创建MysqLi对象
$MysqLi =new MysqLi("localhost","root","test");
if($MysqLi->connect_error){
die("连接失败".$MysqLi->connect_error);
}
//2、操作数据库(发送sql)
$sql="select *from user1";
//3、处理结果
$res =$MysqLi->query($sql);
//var_dump($res);
//fetch_assoc \fetch_array \fetch_object
while($row=$res->fetch_row()){
var_dump($row);
/* foreach($row as $val){
echo '--'.$val;
}
echo '
';*/
}
//4、关闭资源
$res->free();
$MysqLi->close();
?>
下面是面向过程的
代码如下:
PHP
header("Content-type: text/html;charset=utf-8"); $MysqLi=MysqLi_connect("localhost","test");
if(!$MysqLi){
die("连接失败".MysqLi_connect_error());
}
$sql="select *from user1";
$res=MysqLi_query($MysqLi,$sql);
//var_dump($res);
while($row=MysqLi_fetch_row($res)){ foreach ($row as $val){ echo '-'.$val;
}
echo '
';
}
//释放内存
MysqLi_free_result($res);
MysqLi_close($MysqLi);
?>
header("Content-type: text/html;charset=utf-8"); $MysqLi=MysqLi_connect("localhost","test");
if(!$MysqLi){
die("连接失败".MysqLi_connect_error());
}
$sql="select *from user1";
$res=MysqLi_query($MysqLi,$sql);
//var_dump($res);
while($row=MysqLi_fetch_row($res)){ foreach ($row as $val){ echo '-'.$val;
}
echo '
';
}
//释放内存
MysqLi_free_result($res);
MysqLi_close($MysqLi);
?>
2、在PHP中 使用MysqLi扩展库对MysqL 的dml操作
代码如下:
PHP //使用MysqLi 扩展库对MysqL的crud 操作
header("Content-type: text/html;charset=utf-8");
$MysqLi = new MysqLi("localhost","test");
if($MysqLi->connect_error){
die("连接失败".$MysqL->connect_error);
}
//增加一条记录
//$sql="insert into user1 (name,password,email,age) values ('lucy',md5('lucy'),'lucy@163.com',17)";
//删除一条记录
//$sql="delete from user1 where id =80";
//更新一条记录
$sql="update user1 set age=20 where id=7";
$res=$MysqLi->query($sql);
if(!$res){
echo "操作失败".$MysqLi->error;
}else{
if($MysqLi->affected_rows>0){
echo "成功";
}else{
echo "没有行受影响";
}
}
//关闭资源
$MysqLi->close();
?>
header("Content-type: text/html;charset=utf-8");
$MysqLi = new MysqLi("localhost","test");
if($MysqLi->connect_error){
die("连接失败".$MysqL->connect_error);
}
//增加一条记录
//$sql="insert into user1 (name,password,email,age) values ('lucy',md5('lucy'),'lucy@163.com',17)";
//删除一条记录
//$sql="delete from user1 where id =80";
//更新一条记录
$sql="update user1 set age=20 where id=7";
$res=$MysqLi->query($sql);
if(!$res){
echo "操作失败".$MysqLi->error;
}else{
if($MysqLi->affected_rows>0){
echo "成功";
}else{
echo "没有行受影响";
}
}
//关闭资源
$MysqLi->close();
?>
3、进行封装
代码如下:
class sqlHelper{ private $MysqLi;
//这里先写死,以后写死的东西用一个文件来配置
private static $host="localhost";
private static $user="root";
private static $pwd="root";
private static $db="test";
public function __construct(){ $this->MysqLi=new MysqLi(self::$host,self::$user,self::$pwd,self::$db);
if($this->MysqLi->connect_error){
die("连接失败".$this->MysqLi->connect_error);
}
//设置字符集
$this->MysqLi->query("set names utf8");
}
//dql operate
function execute_dql($sql){
$res =$this->MysqLi->query($sql) or die($this->MysqLi->error);
return $res;
}
//dml operate
function execute_dml($sql){
$res =$this->MysqLi->query($sql) or die($this->MysqLi->error); if(!$res){
return 0;//失败
}else{
if($this->MysqLi->affected_rows>0){
return 1;//成功
}else{
return 2;//没有行到影响
}
}
}
}
?>