面向过程的方式
musqli扩展库操作mysql数据库步骤：
1.获取连接并选择数据库
//语法 mysqli_connect(host,username,password,dbname,port,socket); $conn=mysqli_connect("127.0.0.1",'root','','user'); if (!$conn) { die("链接失败"); }
2.设置操作编码
// 语法：mysqli_set_charset(connection,charset); // 修改数据库连接字符集为 utf8 mysqli_set_charset($conn,"utf-8") ;
3.发送sql指令（分为ddl语句和dml语句、dql语句、dtl语句）
- ddl语句：数据定义语句
- dml语句：数据操作语句（update’、insert、delete）
- dql语句：（select）
- dtl语句：数据事务语句（rollback、commit）
查询数据（dml语句）:返回的是一个结果集
//查询语句 $sql="select * from user1"; //执行sql语句 $res=mysqli_query($conn,$sql); //打印返回结果为一个结果集 var_dump($res); 结果集：object(mysqli_result)#2 (5) { // ["current_field"]=> int(0) // ["field_count"]=> int(5) //["lengths"]=> NULL //["num_rows"]=>int(6) //["type"]=> int(0) //} echo "<br/>"; echo "----".$res->num_rows; //取结果集的数据 while ($obj = mysqli_fetch_object($res)) { var_dump($obj); foreach ($obj as $key => $value) { echo "$key------$value"; echo "<br/>"; } echo "<br/>"; }
| 函数名 | 说明 |
|---|---|
| mysqli_fetch_assoc($result) | 查询到的一条数据以关联数组形式返回 [key]=>value |
| mysqli_fetch_row($result) 依次取出$res结果集的下一行数据 | 查询到的一条数据以索引数组形式返回 [0]=>value |
| mysqli_fetch_array($result) | 查询到的一条数据以索引数组和关联数组的混合形式返回[key]=>valuec/[0]=>value |
| mysqli_fetch_object($result) | 查询到的一条数据以对象属性的形式返回 object{[key]=>value} |
| mysqli_fetch_array($result) | 查询到的一条数据以索引数组和关联数组的混合形式返回 |
| mysqli_fetch_array($result,MYSQLI_BOTH) | 查询到的一条数据以索引数组和关联数组的混合形式返回 |
| mysqli_fetch_array($result,MYSQLI_ASSOC) | 查询到的一条数据以关联数组的混合形式返回 |
| mysqli_fetch_array($result,MYSQLI_ROW) | 查询到的一条数据以索引数组的混合形式返回 |
增删改（dml语句）：返回的是一个布尔值
$sql="INSERT INTO user1(name,password,email,age)VALUES ('haha',MD5('123456'),'test@qq.com',16);"; $res=mysqli_query($conn,$sql) or die("执行失败"); var_dump($res); //返回的是一个布尔值 if (!$res) { echo "删除失败"; } echo "受影响的行数: " . mysqli_affected_rows($conn); if(mysqli_affected_rows($conn)>0){ echo "添加成功"; }else{ echo "没有影响的行数"; }
4.释放资源
注意：释放结果集和关闭连接内填的资源不一样
// 释放结果集 mysqli_free_result($res); // 函数关闭先前打开的数据库连接 mysqli_close($conn);
封装cuid工具
sqltool.class.php
<?php class sqltool{ private $conn; private $host="localhost"; private $user='root'; private $password=''; private $db='user'; // 构造方法，初始化连接数据库及设置字符编码 function __construct(){ $this->conn=mysqli_connect($this->host,$this->user,$this->password,$this->db); if (!$this->conn) { die("连接失败".mysqli_error()); } mysqli_set_charset($this->conn,"utf8"); } // 执行dml语句，并返回值 function excute_dml($sql){ $res=mysqli_query($this->conn,$sql) or die("shiai").mysqli_error(); if (!$res) { return 0; }else{ // mysqli_affected_rows：并影响的行数 if (mysqli_affected_rows($this->conn)>0) { return 1; }else{ return 2; } } } // 执行dql语句，并返回值 function excute_dql($sql){ $res=mysqli_query($this->conn,$sql) or die("shibai"); //var_dump($res); return $res; } }
testsql.php
<?php require "sqltool.class.php"; //$sql="insert into user1(name,password,email,age) values('hhhhhh',md5('123'),'qq@163.com',22)"; $sql="delete from user1 where name='qq'"; $sqltool=new sqltool(); // 调用dml $res=$sqltool->excute_dml($sql); if ($res==0) { echo "执行失败<br/>"; }else if ($res==1) { echo "执行成功<br/>"; }else if ($res==2) { echo "没有影响到行数<br/>"; } $sql1="select * from user1"; // 调用dql $res1=$sqltool->excute_dql($sql1); //var_dump($res1); if ($res1->num_rows>0) { while ($row=mysqli_fetch_row($res1)) { //var_dump($row); //echo "<br/>"; foreach ($row as $key => $value) { echo "---$value"; } echo "<br/>"; } } ?>
面向对象的编程
mysqlitest.php
<?php //面向对象 $conn=new mysqli("127.0.0.1","root","","test"); if ($conn->connect_errno) { echo $conn->connect_error; } $sql="select * from user1"; $res=$conn->query($sql); while ($row=$res->fetch_row()) { foreach ($row as $key => $value) { echo "<br/>".$value; } } $res->free(); $conn->close(); ?>
封装
sqliconnection.class.php
<?php class sqlconnect{ private $mysqli; private static $host="127.0.0.1"; private static $user="root"; private static $password=""; private static $database="test"; //构造函数 function __construct(){ $this->mysqli=new MySQLi(self::$host,self::$user,self::$password,self::$database); if (!$this->mysqli) { die("数据库链接失败".$this->mysqli->connect_error); } $this->mysqli->query("set names utf8"); } //查询 public function excete_dql($sql){ $res=$this->mysqli->query($sql) or die("数据库查询失败".$this->mysqli->error); return $res; } public function excete_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; } } } } ?>
sqlitest.php
<?php require "sqliconnection.class.php"; $sqlconnect=new sqlconnect(); //插入记录 $sql1="INSERT INTO user1(name,Password,Email,age)VALUES('asd','555','asd@qq.com','23');"; $res1=$sqlconnect->excete_dml($sql1); if ($res1=="0") { echo "失败<br/>"; }elseif ($res1=="1") { echo "成功<br/>"; }elseif ($res1=='2') { echo "没有影响到行数<br/>"; } // 查询记录 $sql="select * from user1"; $res=$sqlconnect->excete_dql($sql); while ($row=$res->fetch_row()) { foreach ($row as $key => $value) { echo "---$value"; } echo "<br/>"; } $res->free(); // $sqlconnect->close(); ?>