一.mysqli数据库操作
1.连接数据库设置字符编码
config.php文件内容
实例
<?php $db_host='127.0.0.1'; $db_user='root'; $db_pass='root'; $db_name='phpcn'; $db_charset='utf8';
运行实例 »
点击 "运行实例" 按钮查看在线实例
实例
<?php
require 'config.php';
error_reporting(E_ALL ^E_WARNING);
//创立链接对象
$mysqli=new mysqli($db_host,$db_user,$db_pass,$db_name);
//判断是否链接成功
if($mysqli->connect_errno){
die('连接错误'.$mysqli->connect_errno.':'.$mysqli->error_error);
}
echo '数据库连接成功';
$mysqli->set_charset('$db_charset');运行实例 »
点击 "运行实例" 按钮查看在线实例
二.数据库增加记录预定义操作
插入数据的几种语句
INSERT IGNORE 与INSERT INTO的区别
INSERT IGNORE 与INSERT INTO的区别就是INSERT IGNORE会忽略数据库中已经存在 的数据，如果数据库没有数据，就插入新的数据，如果有数据的话就跳过这条数据。这样就可以保留数据库中已经存在数据，达到在间隙中插入数据的目的。
eg: insert ignore into table(name) select name from table2
mysql中常用的三种插入数据的语句:
insert into表示插入数据，数据库会检查主键（PrimaryKey），如果出现重复会报错；
replace into表示插入替换数据，需求表中有PrimaryKey，或者unique索引的话，如果数据库已经存在数据，则用新数据替换，如果没有数据效果则和insert into一样；
REPLACE语句会返回一个数，来指示受影响的行的数目。该数是被删除和被插入的行数的和。如果对于一个单行REPLACE该数为1，则一行被插入，同时没有行被删除。如果该数大于1，则在新行被插入前，有一个或多个旧行被删除。如果表包含多个唯一索引，并且新行复制了在不同的唯一索引中的不同旧行的值，则有可能是一个单一行替换了多个旧行。
insert ignore表示，如果中已经存在相同的记录，则忽略当前新数据；
实例
<?php
//连接数据库
require 'linkPhpcnDatabase.php';
//准备sql语句,带有占位符
$sql= "INSERT IGNORE `staff` SET `name`=?, `salary`=?; "; //这里的不是单引号
//创建一个sql语句的预处理对象
$stmt=$mysqli->prepare($sql);
//绑定参数,对应的占位符的位置
$name='严晓明';
$salary=10000;
// $stmt->bind_param('si',$name,$salary);//si第一个参数string,第二个参数int
$stmt->bind_param('si',$name, $salary);
//执行sql语句
if($stmt->execute()){
if($stmt->affected_rows>0){
echo '插入数据成功'.$stmt->affected_rows.'条记录,新增主键:'.$stmt->insert_id;
}else{
echo '没有新总的记录';
}
}else{
exit($stmt->errno.':'.$stmt->error);
}运行实例 »
点击 "运行实例" 按钮查看在线实例
二.pdo数据库的操作
1,连接数据库插入绑定数据
实例
<?php
/**
* 新增记录
*/
//连接数据库
$pdo = new PDO('mysql:host=127.0.0.1;dbname=phpcn','root','root');
//准备SQL语句,占位符我们不再用?,用"命名占位符"
$sql = "INSERT `user` SET `user_name`= :name , `email`= :email, `password`= sha1(:password)";
//创建预处理对象
$stmt = $pdo->prepare($sql);
//绑定参数
$data = ['name'=>'杨过','email'=>'yg@php.cn','password'=>'123'];
$stmt->bindParam(':name',$data['name'],PDO::PARAM_STR);
$stmt->bindParam(':email',$data['email'],PDO::PARAM_STR);
$stmt->bindParam(':password',$data['password'],PDO::PARAM_STR);
if ($stmt->execute()) {
// rowCount(): 返回受影响的记录数量
echo '<h3>成功添加了'.$stmt->rowCount().'条记录</h3>';
} else {
echo '<h3>添加失败</h3>';
print_r($stmt->errorInfo());
exit();
}
$stmt = null;
// 关闭连接
$pdo = null;运行实例 »
点击 "运行实例" 按钮查看在线实例
2.简化pdo插入操作
实例
<?php
/**
* 新增记录
*/
//1连接数据库
$pdo = new PDO('mysql:host=127.0.0.1;dbname=php','root','root');
//2创建预处理对象
$stmt = $pdo->prepare("INSERT `user` SET `name`= :name , `email`= :email, `password`= sha1(:password)");
//3.执行添加
$stmt->execute(['name'=>'金轮法王1','email'=>'yzp@php.cn','password'=>'123']);
$stmt->execute(['name'=>'金轮法王2','email'=>'yzp@php.cn','password'=>'123']);
$stmt->execute(['name'=>'金轮法王3','email'=>'yzp@php.cn','password'=>'123']);
$stmt->execute(['name'=>'金轮法王4','email'=>'yzp@php.cn','password'=>'123']);
$stmt->execute(['name'=>'金轮法王5','email'=>'yzp@php.cn','password'=>'123']);
echo '<h3>成功添加了'.$stmt->rowCount().'条记录</h3>';运行实例 »
点击 "运行实例" 按钮查看在线实例
3.pdo查询 操作
实例
<?php
/**
* PDO 预处理查询
*/
//连接数据库
$pdo = new PDO('mysql:host=127.0.0.1;dbname=php','root','root');
//准备SQL语句,占位符我们不再用?,用"命名占位符"
$sql = "SELECT `name`,`email` FROM `user` WHERE `id` < :id";
//创建预处理对象
$stmt = $pdo->prepare($sql);
//执行查询
$stmt->execute(['id'=>5]);
// 一次性取出
//$rows = $stmt->fetchAll();
//foreach ($rows as $row) {
// echo 'name: ',$row['name'],', email: ',$row['email'],'<br>';
//}
while($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
echo var_export($row),'<br>';
}运行实例 »
点击 "运行实例" 按钮查看在线实例
4.pdo 更新记录
实例
<?php
/**
* 更新记录
*/
//连接数据库
$pdo = new PDO('mysql:host=127.0.0.1;dbname=php','root','root');
//准备SQL语句,占位符我们不再用?,用"命名占位符"
$sql = "UPDATE `user` SET `email`= :email WHERE `id`= :id";
//创建预处理对象
$stmt = $pdo->prepare($sql);
$stmt->execute(['email'=>'yzf@qq.com','id'=>5]);
echo '<h3>成功更新了'.$stmt->rowCount().'条记录</h3>';
$stmt = null;
// 关闭连接
$pdo = null;运行实例 »
点击 "运行实例" 按钮查看在线实例
5.删除记录
实例
<?php
/**
* 删除记录
*/
//连接数据库
$pdo = new PDO('mysql:host=127.0.0.1;dbname=php','root','root');
//准备SQL语句,占位符我们不再用?,用"命名占位符"
$sql = "DELETE FROM `user` WHERE `id`= :id";
//创建预处理对象
$stmt = $pdo->prepare($sql);
if ($stmt->execute(['id'=>11])) {
// rowCount(): 返回受影响的记录数量
echo '<h3>成功删除了'.$stmt->rowCount().'条记录</h3>';
} else {
echo '<h3>无删除</h3>';
print_r($stmt->errorInfo());
exit();
}
$stmt = null;
// 关闭连接
$pdo = null;运行实例 »
点击 "运行实例" 按钮查看在线实例
6.帮结果集绑定的变量上
实例
<?php
/**
* PDO 预处理查询
*/
//连接数据库
$pdo = new PDO('mysql:host=127.0.0.1;dbname=php','root','root');
//准备SQL语句,占位符我们不再用?,用"命名占位符"
$sql = "SELECT `name`,`email` FROM `user` WHERE `id` < :id";
//创建预处理对象
$stmt = $pdo->prepare($sql);
//执行查询
$stmt->execute(['id'=>5]);
//将结果集中的列绑定到变量上
$stmt->bindColumn('name', $name);
$stmt->bindColumn('email', $email);
//用列变量来遍历结果集
while ($stmt->fetch(PDO::FETCH_BOUND)) {
echo '姓名: ',$name, ', 邮箱: ', $email, '<br>';
}运行实例 »
点击 "运行实例" 按钮查看在线实例
7.统计查询结果行数
实例
<?php
/**
* PDO 预处理查询
*/
//连接数据库
$pdo = new PDO('mysql:host=127.0.0.1;dbname=php','root','root');
//准备SQL语句,占位符我们不再用?,用"命名占位符"
$sql = "SELECT `id`,`name`,`email` FROM `user` WHERE `id` < :id";
//创建预处理对象
$stmt = $pdo->prepare($sql);
//执行查询
$stmt->execute(['id'=>5]);
//获取一行一列,无法获取同一行其它列
//echo $stmt->fetchColumn(0),'<br>';
//指针自动下移，获取二行２列
//echo $stmt->fetchColumn(1),'<br>';
$stmt = $pdo->prepare("select * from staff where salary > :salary");
$stmt->execute(['salary'=>6000]);
// 结果看上去是正确的，但是是有问题的，不要这样做
echo '工资大于6000的人数: '. $stmt->rowCount();
echo '<hr>';
$stmt = $pdo->prepare("select count(*) from staff where salary > :salary");
$stmt->execute(['salary'=>6000]);
echo '工资大于6000的人数: '. $stmt->fetchColumn();运行实例 »
点击 "运行实例" 按钮查看在线实例