PHP数据库操作

操作数据库

1. 链接数据库

• mysql数据库使用mysqli_connect函数进行链接
• 语法格式：mysqli_connect（‘数据库地址’,用户名，密码，数据库名）
• 函数有返回值说明链接成功

function getmysql(){
    $link= mysqli_connect('localhost','root','123456','mydb01');
    return $link;
}

//判断是否链接成功
if($link) echo '<br/>数据库链接成功';
else exit('<br/>数据库链接失败');

2. 编写sql语句

$sql="INSERT INTO user(name,password,addtime,type) VALUE('张三', 123, '2022-10-15', 1000)";

3. 执行sql语句 使用mysqli_query函数执行sql语句
   语法：mysqli_query(链接数据库返回值,sql语句)

$result=mysqli_query($link,$sql);

4. 判断是否执行成功
5. 关闭数据库

$link->close();

添加INSERT

echo '这是新增数据界面';
//链接数据库
require ('commentmysql.php');
$link=getmysql();
//判断是否链接成功
if($link) echo '<br/>数据库链接成功';
else exit('<br/>数据库链接失败');
//编写新增的sql语句
$sql="INSERT INTO user(name,password,addtime,type) VALUE('张三', 123, '2022-10-15', 1000)";
//发送sql语句
$result=mysqli_query($link,$sql);
//判断是否新增成功
//mysqli_insert_id($link)返回插入完成后的自增id
echo $result;
if($result && mysqli_insert_id($link))echo '<br/>新增成功'.mysqli_insert_id($link);
else echo '<br/>新增失败';
echo json_encode($result);
die();

删除 delete

echo '这是执行删除操作<br/>';
echo '获取到的id'.$_GET['id'];
//链接数据库
require ('commentmysql.php');
$link=getmysql();
//判断是否链接成功
if($link)echo '<br/>链接数据库成功';
else exit('<br/>链接数据库失败');
//编写SQL语句
$sql='delete from user where id='.$_GET['id'];
//发送sql语句
$result=mysqli_query($link,$sql);
//判断是否执行成功
//执行删除时返回布尔值 为true表示删除成功
//同时结果具有受影响的行数返回
//受影响的行数可用 mysqli_stmt_affected_rows($link))接收
if($result && mysqli_affected_rows($link))echo '<br/>删除成功';
else echo '<br/>删除失败';
$link->close();

更新 update

echo '这是执行更新操作<br/>';
echo '获取到的id'.$_GET['id'];
$id=$_GET['id'];
//链接数据库
require ('commentmysql.php');
$link=getmysql();
//判断是否链接成功
if($link)echo '<br/>数据库链接成功';
else echo '<br/>数据库链接失败';
//编写sql语句
$sqlselect='select * from user where id='.$_GET['id'];
//执行查找的sql语句
$res=mysqli_query($link,$sqlselect);
$rows=mysqli_fetch_assoc($res);
if($rows)var_dump($rows);
else exit('没有查询到该条数据');
$sqlupdate="update user set name='王五' where id=$id";
echo $sqlupdate;
$result=mysqli_query($link,$sqlupdate);
if($result && mysqli_affected_rows($link))echo '更新成功';
else echo '更新失败';
//操作完成关闭数据库
$link->close();

用户登录

$username=$_GET['username'];
$password=$_GET['password'];
//echo "接收到的数据$username  $password";
//////链接数据库
require ('commentmysql.php');
$link=getmysql();
//////检查链接状态
if(!$link) exit('数据库链接失败');
////编写SQL语句
$sql="select * from user where name='$username'";
////执行sql语句
$res=mysqli_query($link,$sql);

if (!$res) {
    printf("Error: %s\n", mysqli_error($link));
}
$msg=array('msg'=>'用户名或密码错误','code'=>500);
if(mysqli_num_rows($res)!==1) exit(json_encode($msg));
$result=mysqli_fetch_array($res);
if($result['password']==$password){
    $msg['msg']='登录成功';
    $msg['code']=200;
    echo json_encode($msg);
}else  echo json_encode($msg);
////执行完毕关闭数据库
$link->close();