PHP如何连接SQLite数据库_PHP SQLite数据库连接与操作教程

<?php
// 定义数据库文件路径。我个人喜欢把数据库文件放在项目根目录下的一个data文件夹里，
// 但这里为了演示方便，就直接放在当前脚本同级了。
$databaseFile = 'my_application.sqlite';
$pdo = null; // 初始化PDO对象，方便在finally块中关闭

try {
    // 建立SQLite数据库连接。PDO的构造函数接收一个DSN（数据源名称），
    // 对于SQLite，DSN格式是 "sqlite:path/to/database.sqlite"。
    $pdo = new PDO("sqlite:" . $databaseFile);

    // 这一步非常关键：设置错误模式为异常。这意味着当数据库操作失败时，
    // PDO会抛出一个PDOException，我们就可以用try-catch块来优雅地处理错误，
    // 而不是让PHP默默地失败或者返回一个布尔值。
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    echo "成功连接到SQLite数据库：{$databaseFile}\n";

    // 创建一个表（如果它不存在的话）。这里我创建了一个简单的`products`表，
    // 包含ID、名称、价格和库存。注意`INTEGER PRIMARY KEY AUTOINCREMENT`，
    // 这是SQLite中自增主键的标准写法。
    $pdo->exec("CREATE TABLE IF NOT EXISTS products (
        id INTEGER PRIMARY KEY AUTOINCREMENT,
        name TEXT NOT NULL,
        price REAL NOT NULL,
        stock INTEGER DEFAULT 0
    )");
    echo "表 'products' 创建或已存在。\n";

    // 插入数据。我强烈建议使用预处理语句（prepared statements）来插入或更新数据。
    // 这不仅能防止SQL注入攻击，还能提高重复执行相同查询的效率。
    $name = "智能手机";
    $price = 699.99;
    $stock = 150;

    $stmt = $pdo->prepare("INSERT INTO products (name, price, stock) VALUES (:name, :price, :stock)");
    // 绑定参数，确保数据类型正确并进行安全转义
    $stmt->bindParam(':name', $name);
    $stmt->bindParam(':price', $price);
    $stmt->bindParam(':stock', $stock);
    $stmt->execute();
    echo "数据插入成功：'{$name}'。\n";

    // 再插入一条，演示重复操作
    $name = "无线耳机";
    $price = 129.00;
    $stock = 300;
    $stmt->execute(); // 再次执行预处理语句，参数已经绑定，可以直接执行
    echo "数据插入成功：'{$name}'。\n";

    // 查询数据。同样，对于动态查询，也应该考虑预处理。
    // 这里我们查询所有产品，并按价格降序排列。
    echo "\n查询所有产品（按价格降序）：\n";
    $queryStmt = $pdo->query("SELECT id, name, price, stock FROM products ORDER BY price DESC");
    while ($row = $queryStmt->fetch(PDO::FETCH_ASSOC)) {
        // fetch(PDO::FETCH_ASSOC) 返回关联数组，键是列名
        echo "ID: {$row['id']}, 名称: {$row['name']}, 价格: {$row['price']}, 库存: {$row['stock']}\n";
    }

    // 更新数据示例
    $newPrice = 649.99;
    $productId = 1; // 假设我们要更新ID为1的产品
    $updateStmt = $pdo->prepare("UPDATE products SET price = :newPrice WHERE id = :productId");
    $updateStmt->bindParam(':newPrice', $newPrice);
    $updateStmt->bindParam(':productId', $productId);
    $updateStmt->execute();
    echo "\n产品ID {$productId} 的价格已更新为 {$newPrice}。\n";

} catch (PDOException $e) {
    // 捕获所有PDO相关的异常，输出错误信息。在生产环境中，你可能需要记录到日志文件，
    // 而不是直接输出给用户。
    echo "数据库操作失败: " . $e->getMessage() . "\n";
} finally {
    // 无论是否发生异常，确保PDO连接被关闭。虽然PHP脚本结束时会自动关闭，
    // 但显式地将$pdo设置为null是一个好习惯，特别是在长生命周期的应用中。
    $pdo = null;
    echo "\n数据库连接已关闭。\n";
}
?>

<?php
// 假设 $pdo 已经是一个有效的SQLite连接
try {
    $pdo->beginTransaction(); // 开启事务

    // 示例：从一个账户扣款，同时给另一个账户加款
    // 这里我们假设有一个 accounts 表，有 id 和 balance 字段
    // 先扣除用户A的余额
    $stmt1 = $pdo->prepare("UPDATE accounts SET balance = balance - :amount WHERE id = :from_account_id");
    $stmt1->bindParam(':amount', $amount);
    $stmt1->bindParam(':from_account_id', $fromAccountId);
    $stmt1->execute();

    // 然后增加用户B的余额
    $stmt2 = $pdo->prepare("UPDATE accounts SET balance = balance + :amount WHERE id = :to_account_id");
    $stmt2->bindParam(':amount', $amount);
    $stmt2->bindParam(':to_account_id', $toAccountId);
    $stmt2->execute();

    $pdo->commit(); // 所有操作都成功，提交事务
    echo "转账成功，事务已提交。\n";
} catch (PDOException $e) {
    $pdo->rollBack(); // 任何一步失败，回滚事务
    echo "转账失败，事务已回滚: " . $e->getMessage() . "\n";
}
?>

<?php
// 假设 $pdo 已经是一个有效的SQLite连接

// 假设我们有一个 users 表，经常需要根据 email 字段来查询用户
// 为 email 字段创建索引。如果索引已存在，IF NOT EXISTS 会避免报错。
$pdo->exec("CREATE INDEX IF NOT EXISTS idx_users_email ON users (email)");
echo "索引 'idx_users_email' 创建或已存在。\n";

// 如果我们经常需要根据 name 和 age 组合查询，可以创建复合索引
$pdo->exec("CREATE INDEX IF NOT EXISTS idx_users_name_age ON users (name, age)");
echo "复合索引 'idx_users_name_age' 创建或已存在。\n";
?>