如何实现PHP与MySQL的连接查询？

PHP与MySQL连接查询

一、简介

PHP是一种广泛使用的开源服务器端脚本语言，特别适用于Web开发，它能够生成动态网页内容，并支持多种数据库，其中最常用的就是MySQL，MySQL是一个关系型数据库管理系统，以其高性能、可靠性和易用性而广受欢迎，本文将详细介绍如何在PHP中连接到MySQL数据库并进行数据查询。

二、环境准备

安装PHP

要运行PHP代码，你需要在你的服务器上安装PHP，你可以从[PHP官方网站](https://www.php.net/)下载适合你操作系统的版本。

安装MySQL

同样地，你需要在服务器上安装MySQL，可以从[MySQL官方网站](https://www.mysql.com/)下载并安装。

安装MySQLi扩展

PHP提供了多种方式来连接MySQL数据库，其中最常用的是MySQLi扩展，确保你的PHP安装包含了MySQLi扩展。

三、连接MySQL数据库

1. 使用mysqli_connect()函数

mysqli_connect()函数用于打开一个到MySQL数据库的连接，它需要四个参数：主机名、用户名、密码和数据库名。

<?php
$servername = "localhost"; // 服务器地址
$username = "username"; // 数据库用户名
$password = "password"; // 数据库密码
$dbname = "myDB"; // 数据库名
// 创建连接
$conn = mysqli_connect($servername, $username, $password, $dbname);
// 检查连接是否成功
if (!$conn) {
    die("Connection failed: " . mysqli_connect_error());
}
echo "Connected successfully";
?>

使用PDO连接

PHP Data Objects (PDO) 提供了一个一致的接口来访问多种数据库，以下是如何使用PDO连接到MySQL数据库的例子。

<?php
$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "myDB";
try {
    $conn = new PDO("mysql:host=$servername;dbname=$dbname", $username, $password);
    // 设置错误模式为异常
    $conn>setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    echo "Connected successfully"; 
} catch(PDOException $e) {
    echo "Connection failed: " . $e>getMessage();
}
?>

四、执行SQL查询

1. 使用mysqli_query()函数

mysqli_query()函数用于执行SQL查询，它需要两个参数：连接对象和SQL查询字符串。

<?php
$sql = "SELECT id, firstname, lastname FROM MyGuests";
$result = mysqli_query($conn, $sql);
if (mysqli_num_rows($result) > 0) {
    // 输出数据
    while($row = mysqli_fetch_assoc($result)) {
        echo "id: " . $row["id"]. " Name: " . $row["firstname"]. " " . $row["lastname"]. "<br>";
    }
} else {
    echo "0 results";
}
mysqli_close($conn);
?>

2. 使用PDO的prepare()和execute()方法

PDO的prepare()方法用于准备SQL语句，而execute()方法则用于执行这些语句。

<?php
$stmt = $conn>prepare("SELECT id, firstname, lastname FROM MyGuests");
$stmt>execute();
// 设置结果集为关联数组
$result = $stmt>setFetchMode(PDO::FETCH_ASSOC);
foreach($stmt>fetchAll() as $k=>$v) {
    echo $v['id']." ".$v['firstname']." ".$v['lastname']."<br>";
}
?>

五、插入、更新和删除数据

插入数据

<?php
$sql = "INSERT INTO MyGuests (firstname, lastname, email) VALUES ('John', 'Doe', 'john@example.com')";
if (mysqli_query($conn, $sql)) {
    echo "New record created successfully";
} else {
    echo "Error: " . $sql . "<br>" . mysqli_error($conn);
}
mysqli_close($conn);
?>

更新数据

<?php
$sql = "UPDATE MyGuests SET lastname='Smith' WHERE id=2";
if (mysqli_query($conn, $sql)) {
    echo "Record updated successfully";
} else {
    echo "Error: " . $sql . "<br>" . mysqli_error($conn);
}
mysqli_close($conn);
?>

删除数据

<?php
$sql = "DELETE FROM MyGuests WHERE id=3";
if (mysqli_query($conn, $sql)) {
    echo "Record deleted successfully";
} else {
    echo "Error: " . $sql . "<br>" . mysqli_error($conn);
}
mysqli_close($conn);
?>

六、常见问题与解答栏目

问题1：如何防止SQL注入攻击？

解答：为了防止SQL注入攻击，你应该始终使用预处理语句和参数化查询，使用PDO的prepare()和execute()方法，或者使用mysqli的prepare()和bind_param()方法，这样可以确保用户输入的数据被正确地处理，从而避免恶意代码的注入。