在PHP中与MySQL数据库交互,通常有两种主要方式:直接连接和使用中间件。以下是这两种方式的详细说明:
直接连接是指PHP代码直接与MySQL数据库进行通信。这是最常见的方式,通常使用MySQLi或PDO扩展来实现。
MySQLi(MySQL Improved)是PHP的一个扩展,提供了面向对象和面向过程两种方式来与MySQL数据库交互。
示例代码:
<?php
// 数据库连接参数
$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "myDB";
// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);
// 检查连接
if ($conn->connect_error) {
die("连接失败: " . $conn->connect_error);
}
// 执行查询
$sql = "SELECT id, firstname, lastname FROM MyGuests";
$result = $conn->query($sql);
if ($result->num_rows > 0) {
// 输出数据
while($row = $result->fetch_assoc()) {
echo "id: " . $row["id"]. " - Name: " . $row["firstname"]. " " . $row["lastname"]. "<br>";
}
} else {
echo "0 结果";
}
// 关闭连接
$conn->close();
?>
PDO(PHP Data Objects)是PHP的一个数据库访问抽象层,支持多种数据库,包括MySQL。
示例代码:
<?php
// 数据库连接参数
$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "myDB";
try {
// 创建连接
$conn = new PDO("mysql:host=$servername;dbname=$dbname", $username, $password);
// 设置 PDO 错误模式为异常
$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
// 执行查询
$stmt = $conn->prepare("SELECT id, firstname, lastname FROM MyGuests");
$stmt->execute();
// 设置结果集为关联数组
$result = $stmt->setFetchMode(PDO::FETCH_ASSOC);
foreach($stmt->fetchAll() as $row) {
echo "id: " . $row["id"]. " - Name: " . $row["firstname"]. " " . $row["lastname"]. "<br>";
}
} catch(PDOException $e) {
echo "错误: " . $e->getMessage();
}
// 关闭连接
$conn = null;
?>
通过中间件连接是指PHP代码通过一个中间层(如ORM、API网关、微服务等)与数据库进行交互。这种方式通常用于大型应用或分布式系统中,以提高系统的可维护性和扩展性。
ORM(如Doctrine、Eloquent)可以将数据库表映射为PHP对象,使得开发者可以使用面向对象的方式来操作数据库。
示例代码(使用Eloquent ORM):
<?php
require 'vendor/autoload.php';
use Illuminate\Database\Capsule\Manager as Capsule;
$capsule = new Capsule;
$capsule->addConnection([
'driver' => 'mysql',
'host' => 'localhost',
'database' => 'myDB',
'username' => 'username',
'password' => 'password',
'charset' => 'utf8',
'collation' => 'utf8_unicode_ci',
'prefix' => '',
]);
// 设置全局静态访问
$capsule->setAsGlobal();
// 启动Eloquent
$capsule->bootEloquent();
// 定义模型
class User extends Illuminate\Database\Eloquent\Model {}
// 查询数据
$users = User::all();
foreach ($users as $user) {
echo $user->name;
}
?>
在微服务架构中,PHP应用可能通过RESTful API或GraphQL与中间件(如API网关)通信,中间件再与MySQL数据库交互。
示例代码(使用Guzzle HTTP客户端调用API):
<?php
require 'vendor/autoload.php';
use GuzzleHttp\Client;
$client = new Client([
'base_uri' => 'http://api.example.com',
]);
$response = $client->request('GET', '/users');
$users = json_decode($response->getBody(), true);
foreach ($users as $user) {
echo $user['name'] . "<br>";
}
?>
选择哪种方式取决于具体的应用场景和需求。