如何用PHP连接数据库并进行查询操作？

PHP连接数据库查询

在现代Web开发中，数据库是不可或缺的一部分，PHP作为一种广泛使用的服务器端脚本语言，经常需要与数据库进行交互，本文将详细讲解如何使用PHP连接到MySQL数据库并进行查询操作。

1. 准备工作

1 安装MySQL和PHP

确保你已经安装了MySQL数据库和PHP环境，如果没有，可以参考以下步骤：

1、安装MySQL:

下载并安装MySQL社区版。

启动MySQL服务，并创建一个新数据库，使用命令行工具：

     mysql u root p
     create database mydatabase;
     exit;

2、安装PHP:

下载并安装PHP。

确保PHP的MySQL扩展已启用，编辑php.ini文件，取消注释以下行：

     extension=mysqli

2 创建数据库和表

在MySQL中创建一个示例数据库和表，假设我们创建一个名为users的表：

CREATE DATABASE mydatabase;
USE mydatabase;
CREATE TABLE users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100),
    email VARCHAR(100)
);
INSERT INTO users (name, email) VALUES ('John Doe', 'john@example.com');
INSERT INTO users (name, email) VALUES ('Jane Smith', 'jane@example.com');

2. PHP连接数据库

1 通过mysqli扩展连接

使用PHP的mysqli扩展来连接MySQL数据库：

<?php
$servername = "localhost";
$username = "root";
$password = ""; // 你的MySQL密码
$dbname = "mydatabase";
// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);
// 检查连接
if ($conn>connect_error) {
    die("连接失败: " . $conn>connect_error);
}
echo "连接成功";
?>

2 通过PDO扩展连接

使用PHP的PDO（PHP Data Objects）扩展来连接MySQL数据库：

<?php
$servername = "localhost";
$username = "root";
$password = ""; // 你的MySQL密码
$dbname = "mydatabase";
try {
    $conn = new PDO("mysql:host=$servername;dbname=$dbname", $username, $password);
    // 设置PDO错误模式为异常
    $conn>setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    echo "连接成功"; 
} catch(PDOException $e) {
    echo "连接失败: " . $e>getMessage();
}
?>

3. 执行查询

1 简单查询

使用mysqli扩展

<?php
$sql = "SELECT id, name, email FROM users";
$result = $conn>query($sql);
if ($result>num_rows > 0) {
    // 输出每行数据
    while($row = $result>fetch_assoc()) {
        echo "id: " . $row["id"]. " Name: " . $row["name"]. " Email: " . $row["email"]. "<br>";
    }
} else {
    echo "0 结果";
}
$conn>close();
?>

使用PDO扩展

<?php
$sql = "SELECT id, name, email FROM users";
$stmt = $conn>query($sql);
while ($row = $stmt>fetch(PDO::FETCH_ASSOC)) {
    echo "id: " . $row['id'] . " Name: " . $row['name'] . " Email: " . $row['email'] . "<br>";
}
?>

2 参数化查询

为了防止SQL注入，建议使用参数化查询，以下是使用PDO扩展的示例：

<?php
$username = "John";
$sql = "SELECT * FROM users WHERE name = :name";
$stmt = $conn>prepare($sql);
$stmt>bindParam(':name', $username);
$stmt>execute();
$result = $stmt>fetchAll(PDO::FETCH_ASSOC);
foreach ($result as $row) {
    echo "id: " . $row['id'] . " Name: " . $row['name'] . " Email: " . $row['email'] . "<br>";
}
?>

4. 插入数据

1 使用mysqli扩展插入数据

<?php
$sql = "INSERT INTO users (name, email) VALUES ('Alice', 'alice@example.com')";
if ($conn>query($sql) === TRUE) {
    echo "新记录插入成功";
} else {
    echo "Error: " . $sql . "<br>" . $conn>error;
}
$conn>close();
?>

2 使用PDO扩展插入数据

<?php
$sql = "INSERT INTO users (name, email) VALUES (:name, :email)";
$stmt = $conn>prepare($sql);
$stmt>bindParam(':name', 'Alice');
$stmt>bindParam(':email', 'alice@example.com');
if ($stmt>execute()) {
    echo "新记录插入成功";
} else {
    echo "Error: " . $stmt>errorInfo()[2];
}
?>

5. 更新数据

1 使用mysqli扩展更新数据

<?php
$sql = "UPDATE users SET email='updatedemail@example.com' WHERE name='John Doe'";
if ($conn>query($sql) === TRUE) {
    echo "记录更新成功";
} else {
    echo "Error: " . $sql . "<br>" . $conn>error;
}
$conn>close();
?>

2 使用PDO扩展更新数据

<?php
$sql = "UPDATE users SET email = :email WHERE name = :name";
$stmt = $conn>prepare($sql);
$stmt>bindParam(':email', 'updatedemail@example.com');
$stmt>bindParam(':name', 'John Doe');
if ($stmt>execute()) {
    echo "记录更新成功";
} else {
    echo "Error: " . $stmt>errorInfo()[2];
}
?>

6. 删除数据

1 使用mysqli扩展删除数据

<?php
$sql = "DELETE FROM users WHERE name='John Doe'";
if ($conn>query($sql) === TRUE) {
    echo "记录删除成功";
} else {
    echo "Error: " . $sql . "<br>" . $conn>error;
}
$conn>close();
?>

2 使用PDO扩展删除数据

<?php
$sql = "DELETE FROM users WHERE name = :name";
$stmt = $conn>prepare($sql);
$stmt>bindParam(':name', 'John Doe');
if ($stmt>execute()) {
    echo "记录删除成功";
} else {
    echo "Error: " . $stmt>errorInfo()[2];
}
?>

相关问题与解答栏目

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

答：为了防止SQL注入，应使用参数化查询或准备好的语句，这些方法可以确保用户输入的数据被正确处理，避免恶意代码的执行，使用PDO的绑定参数功能：

$sql = "SELECT * FROM users WHERE name = :name";
$stmt = $conn>prepare($sql);
$stmt>bindParam(':name', $username);
$stmt>execute();

通过这种方式，可以有效防止SQL注入攻击。

问题2：如何在PHP中处理数据库连接错误？

答：在PHP中处理数据库连接错误的方法有多种，可以使用trycatch块捕获PDO异常，或者使用mysqli的错误处理函数。

try {
    $conn = new PDO("mysql:host=$servername;dbname=$dbname", $username, $password);
    // set the PDO error mode to exception
    $conn>setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    echo "连接成功"; 
} catch(PDOException $e) {
    echo "连接失败: " . $e>getMessage();
}

对于mysqli，可以使用以下方式：

$conn = new mysqli($servername, $username, $password, $dbname);
if ($conn>connect_error) {
    die("连接失败: " . $conn>connect_error);
} 
echo "连接成功";