如何使用PHP中的mysqli_query()函数执行SQL查询?
发布时间:2023-06-02 16:51:14
在 PHP 中执行 SQL 查询可以使用 mysqli_query() 函数。它接收两个参数: 个是连接到数据库的 mysqli 对象,第二个是要执行的 SQL 查询字符串。
下面是一个示例,将查询结果保存在 $result 变量中:
// 创建 mysqli 对象
$conn = new mysqli("localhost", "username", "password", "dbname");
// 检查连接是否成功
if ($conn->connect_error) {
die("连接失败: " . $conn->connect_error);
}
// 执行查询
$sql = "SELECT * FROM customers";
$result = mysqli_query($conn, $sql);
// 处理查询结果
if (mysqli_num_rows($result) > 0) {
while($row = mysqli_fetch_assoc($result)) {
echo "id: " . $row["id"]. " - Name: " . $row["name"]. " - Email: " . $row["email"]. "<br>";
}
} else {
echo "0 结果";
}
// 关闭连接
mysqli_close($conn);
上面的代码首先创建了一个 mysqli 对象,然后检查连接是否成功。接下来,它执行一个查询,将结果保存在 $result 变量中。最后,它处理查询结果并输出它们,然后关闭连接。
需要注意的是,mysqli_query() 函数也可以用来执行 INSERT、UPDATE、DELETE 等 SQL 语句,但它不会返回结果集,而是返回布尔值,指示操作是否成功。例如:
// 执行 INSERT
$sql = "INSERT INTO customers (name, email) VALUES ('John Doe', 'john@example.com')";
if (mysqli_query($conn, $sql)) {
echo "新记录插入成功";
} else {
echo "Error: " . $sql . "<br>" . mysqli_error($conn);
}
// 执行 UPDATE
$sql = "UPDATE customers SET email='johndoe@example.com' WHERE name='John Doe'";
if (mysqli_query($conn, $sql)) {
echo "记录更新成功";
} else {
echo "Error: " . $sql . "<br>" . mysqli_error($conn);
}
// 执行 DELETE
$sql = "DELETE FROM customers WHERE name='John Doe'";
if (mysqli_query($conn, $sql)) {
echo "记录删除成功";
} else {
echo "Error: " . $sql . "<br>" . mysqli_error($conn);
}
总之,mysqli_query() 函数是在 PHP 中执行 SQL 查询、插入、更新、删除等操作的基本函数。它接收一个连接对象和需要执行的 SQL 语句,返回一个查询结果集或操作是否成功的布尔值。
