fluentpdo入门

告别枯燥的SQL查询！使用FluentPDO简化数据库操作

您是否也厌倦了编写SQL查询？尤其是在时间紧迫的情况下。如果您和我一样，那么今天我们将学习一个非常酷炫的工具：FluentPDO。如果您不熟悉“PDO”这个术语，也不用担心。它是一个非常简单的概念：在PHP世界中，PDO代表持久化数据对象（Persistent Data Object），它帮助您抽象化一些基本的数据库操作（如插入、更新、删除等）。它是您与数据库之间的一层抽象层。

结果呢？不再需要编写SQL查询了！这可能不是您见到的第一个这样的项目：市面上有很多类似的项目，每个项目都有其关键特性。FluentPDO的关键特性在于其强大的JOIN查询构建器。

关键要点

• FluentPDO是一个PHP SQL查询构建器，它抽象化了基本的数据库操作，无需再编写SQL查询。其关键特性是一个强大的JOIN查询构建器。
• FluentPDO的安装通过Composer完成，无需任何额外配置。通过将PDO对象作为参数传递给FluentPDO对象的构造函数来实例化它。
• FluentPDO为基本的SELECT操作提供了简单易读的语法，包括设置表、过滤结果和指定比较运算符的方法。它还允许选择特定字段、设置LIMIT和OFFSET参数，以及使用“HAVING”、“GROUP BY”和“ORDER BY”指令。
• FluentPDO还支持使用INSERT、UPDATE和DELETE操作类进行数据操作。这些操作需要使用execute()方法来运行查询并更改数据库。
• FluentPDO的高级特性包括JOIN查询构建器（简化了JOIN查询的代码）和内置的调试器系统（用于测试和检查查询）。

我们的FluentPDO测试项目

首先，我们需要一个示例项目来进行操作。让我们考虑一下……一个简单的多用户愿望清单怎么样？

会有很多用户，每个用户都有自己喜欢的产品。对于每个用户，我们将存储其名字、姓氏和注册日期。对于每个商品，我们将存储其名称、品牌、价格和相关的用户ID。

我将使用一个简单的MySQL数据库。以下是我们的数据结构：

以下是SQL转储（包含一些虚拟数据）：

CREATE TABLE IF NOT EXISTS items (   
        id int(11) NOT NULL AUTO_INCREMENT,   
        name varchar(100) NOT NULL,   
        brand varchar(100) NOT NULL,   
        price decimal(10,2) NOT NULL,   
        user_id int(10) unsigned NOT NULL,   
        PRIMARY KEY (id),   
        KEY user_id (user_id) ) ENGINE=InnoDB  
        DEFAULT CHARSET=utf8 AUTO_INCREMENT=5 ;

    INSERT INTO items (id, name, brand, price, user_id) 
    VALUES 
    (1, 'Last Awesome Phone', 'Awesome Brand', '550.00', 1), 
    (2, 'Last Awesome TV', 'Awesome Brand', '1200.00', 1), 
    (3, 'Fantastic E-Car', 'E-Cars Inc.', '80000.00', 2), 
    (4, 'Fantastic E-Bike', 'E-Bikes Co. Ltd.', '16000.00', 2);

    CREATE TABLE IF NOT EXISTS users (
        id int(10) unsigned NOT NULL AUTO_INCREMENT,   
        first_name varchar(100) NOT NULL,   
        last_name varchar(100) NOT NULL,   
        signup_date datetime NOT NULL,   
        PRIMARY KEY (id) ) ENGINE=InnoDB  
        DEFAULT CHARSET=utf8 AUTO_INCREMENT=3;

    INSERT INTO users (id, first_name, last_name, signup_date) 
    VALUES 
    (1, 'Francesco', 'Malatesta', '2014-06-29 13:00:00'), 
    (2, 'John', 'Foo Bar', '2014-06-20 11:16:39');

    ALTER TABLE items   ADD CONSTRAINT items_ibfk_1 FOREIGN KEY (user_id) REFERENCES users (id);

注意：正如您很容易想象的那样，这不是一个“完整的”项目。我们只是在尝试FluentPDO，所以我们不会涵盖诸如登录、注册或应用程序结构之类的内容。

安装

您可以使用Composer安装FluentPDO，将其作为依赖项包含在内：

"require": {
        ...
        "lichtner/fluentpdo": "dev-master"  
    }

完成后，您需要像这样实例化它：

CREATE TABLE IF NOT EXISTS items (   
        id int(11) NOT NULL AUTO_INCREMENT,   
        name varchar(100) NOT NULL,   
        brand varchar(100) NOT NULL,   
        price decimal(10,2) NOT NULL,   
        user_id int(10) unsigned NOT NULL,   
        PRIMARY KEY (id),   
        KEY user_id (user_id) ) ENGINE=InnoDB  
        DEFAULT CHARSET=utf8 AUTO_INCREMENT=5 ;

    INSERT INTO items (id, name, brand, price, user_id) 
    VALUES 
    (1, 'Last Awesome Phone', 'Awesome Brand', '550.00', 1), 
    (2, 'Last Awesome TV', 'Awesome Brand', '1200.00', 1), 
    (3, 'Fantastic E-Car', 'E-Cars Inc.', '80000.00', 2), 
    (4, 'Fantastic E-Bike', 'E-Bikes Co. Ltd.', '16000.00', 2);

    CREATE TABLE IF NOT EXISTS users (
        id int(10) unsigned NOT NULL AUTO_INCREMENT,   
        first_name varchar(100) NOT NULL,   
        last_name varchar(100) NOT NULL,   
        signup_date datetime NOT NULL,   
        PRIMARY KEY (id) ) ENGINE=InnoDB  
        DEFAULT CHARSET=utf8 AUTO_INCREMENT=3;

    INSERT INTO users (id, first_name, last_name, signup_date) 
    VALUES 
    (1, 'Francesco', 'Malatesta', '2014-06-29 13:00:00'), 
    (2, 'John', 'Foo Bar', '2014-06-20 11:16:39');

    ALTER TABLE items   ADD CONSTRAINT items_ibfk_1 FOREIGN KEY (user_id) REFERENCES users (id);

您必须在PDO构造函数方法中指定您的连接详细信息。在第一个参数中，在dbname=部分之后键入您的数据库名称，然后将您的用户名和密码分别作为第二个和第三个参数写入。

然后，您将PDO对象作为参数传递给FluentPDO对象的构造函数。

就是这样，FluentPDO不需要任何其他东西即可工作。无需额外配置。

基本的SELECT操作

我们已经有一些虚拟数据了。让我们从SQL查询的“Hello World”开始。一个简单的SELECT，带有一个WHERE子句，以及用户主键ID作为参数来检索基本信息。

"require": {
        ...
        "lichtner/fluentpdo": "dev-master"  
    }

这里没有什么难理解的。FluentPDO具有良好且易读的语法，因此很容易理解我们在做什么。

from()方法用于设置正确的表。where()方法用于使用相同的名称子句过滤我们的结果。默认情况下，在where()方法中，您只需指定字段名称和值。“=”是隐含的。当然，您也可以使用不同的比较运算符。在这种情况下，您必须将它们写在字段名称之后。

$pdo = new PDO("mysql:dbname=wishlist", "root", "password");
    $fpdo = new FluentPDO($pdo);

获取结果非常容易：它们存储在我们刚刚使用的$query对象中。您可以使用foreach循环迭代它，如示例所示。

在这种特定情况下（按主键ID搜索项目），我们也可以在from()方法中使用快捷方式：

$user_id = 1;

    $query = $fpdo->from('users')->where('id', $user_id);

    foreach($query as $row){
        echo 'Hello, ' . $row['first_name'] . ' ' . $row['last_name'] . '!';    
    }

让我们看看比这更复杂的东西。

选择特定字段

如果需要，您可以使用from()之后的select()方法选择特定字段。您只需使用数组告诉FluentPDO您想要选择哪些字段即可。

这是一个示例：

$fpdo->from('items')->where('price >', 1000);

LIMIT和OFFSET

设置LIMIT和OFFSET参数以仅从数据库中检索一定数量的行非常容易。您可以像这样使用limit()和offset()方法。

$query = fpdo->from('users', $user_id);

    // 将与...相同
    $query = $fpdo->from('users')->where('id', $user_id);

这两个方法的唯一参数是一个整数，指定所需的值（对于limit()，是项目的数量；对于offset()，是要跳过的项目的数量）。

HAVING、GROUP BY和ORDER BY

还提供了用于“HAVING”、“GROUP BY”和“ORDER BY”指令的方法。

让我们用一些例子来看看它们。

ORDER BY

orderBy()方法用于根据特定条件对结果进行排序。让我们举个例子：以下是按价格（从便宜到贵）对结果进行排序的方法。

$query = $fpdo->from('users')->select(array('first_name', 'last_name'))->where('id', $user_id);

如果要反转顺序（从最贵到最便宜获取结果），只需在选择的列之后添加“DESC”即可。

// 选择前十个结果...
    $query = $fpdo->from('users')->where('id', $user_id)->limit(10)->offset(0);

HAVING

having()方法具有非常简单的语法。在下面的示例中，我们过滤价格低于2000美元的每个商品。

$query = $fpdo->from('items')->orderBy('price');

非常简单。

您可以使用所需的任何比较运算符。

GROUP BY

使用groupBy()方法，您可以使用特定字段作为条件对结果进行分组。这里我们显示每个品牌的商品数量。

CREATE TABLE IF NOT EXISTS items (   
        id int(11) NOT NULL AUTO_INCREMENT,   
        name varchar(100) NOT NULL,   
        brand varchar(100) NOT NULL,   
        price decimal(10,2) NOT NULL,   
        user_id int(10) unsigned NOT NULL,   
        PRIMARY KEY (id),   
        KEY user_id (user_id) ) ENGINE=InnoDB  
        DEFAULT CHARSET=utf8 AUTO_INCREMENT=5 ;

    INSERT INTO items (id, name, brand, price, user_id) 
    VALUES 
    (1, 'Last Awesome Phone', 'Awesome Brand', '550.00', 1), 
    (2, 'Last Awesome TV', 'Awesome Brand', '1200.00', 1), 
    (3, 'Fantastic E-Car', 'E-Cars Inc.', '80000.00', 2), 
    (4, 'Fantastic E-Bike', 'E-Bikes Co. Ltd.', '16000.00', 2);

    CREATE TABLE IF NOT EXISTS users (
        id int(10) unsigned NOT NULL AUTO_INCREMENT,   
        first_name varchar(100) NOT NULL,   
        last_name varchar(100) NOT NULL,   
        signup_date datetime NOT NULL,   
        PRIMARY KEY (id) ) ENGINE=InnoDB  
        DEFAULT CHARSET=utf8 AUTO_INCREMENT=3;

    INSERT INTO users (id, first_name, last_name, signup_date) 
    VALUES 
    (1, 'Francesco', 'Malatesta', '2014-06-29 13:00:00'), 
    (2, 'John', 'Foo Bar', '2014-06-20 11:16:39');

    ALTER TABLE items   ADD CONSTRAINT items_ibfk_1 FOREIGN KEY (user_id) REFERENCES users (id);

注意：您可以像在经典SQL中一样为字段指定别名。

获取方法

fetch

使用foreach不是获取结果的唯一方法。如果我们只想从集合中检索第一个结果怎么办？

只需使用fetch()方法：

"require": {
        ...
        "lichtner/fluentpdo": "dev-master"  
    }

您还可以获取单个列，方法是指定其名称作为参数。

$pdo = new PDO("mysql:dbname=wishlist", "root", "password");
    $fpdo = new FluentPDO($pdo);

fetchPairs

使用fetchPairs()，您可以将结果作为关联数组检索。使用以下语法：

$user_id = 1;

    $query = $fpdo->from('users')->where('id', $user_id);

    foreach($query as $row){
        echo 'Hello, ' . $row['first_name'] . ' ' . $row['last_name'] . '!';    
    }

您将获得如下输出：

$fpdo->from('items')->where('price >', 1000);

这是一个示例，使用用户唯一ID和名字。

$query = fpdo->from('users', $user_id);

    // 将与...相同
    $query = $fpdo->from('users')->where('id', $user_id);

fetchAll

最后但并非最不重要的是fetchAll()方法。

以下是语法：

$query = $fpdo->from('users')->select(array('first_name', 'last_name'))->where('id', $user_id);

使用fetchAll()，我们可以完全控制从结果中获取的内容。第一个参数$index是用作索引的字段，$selectOnly用于指定要选择的字段。

这是一个示例：

// 选择前十个结果...
    $query = $fpdo->from('users')->where('id', $user_id)->limit(10)->offset(0);

注意：用作索引的列（在本例中为id）也包含在最终数组中。

好了，关于SELECT操作就足够了。让我们看看其他CRUD操作。

INSERT、UPDATE和DELETE

FluentPDO不仅仅是关于选择东西。它还具有以简单方式操作数据的类。

让我们从INSERT操作开始。

INSERT

$query = $fpdo->from('items')->orderBy('price');

insertInto()方法用于指定要用于操作的表。然后，您必须使用values()方法分配所需的值（在本例中，它们存储在$values关联数组中）。

最后一步将是execute()方法，它将返回新记录的主键。

如果需要，也可以使用此快捷方式：

$query = $fpdo->from('items')->orderBy('price DESC');

UPDATE

UPDATE方法非常相似。让我们看一个例子。

$query = $fpdo->from('items')->having('price <', 2000);

使用set()方法，您可以为UPDATE操作指定新值。

使用where()方法，我们过滤受影响的行。还有一个快捷方式，如前所述。

DELETE

DELETE操作更简单。这是一个快速示例。

$query = $fpdo->from('items')->select('brand, COUNT(*) AS c')->groupBy('brand');

如果要删除知道其主键的记录，可以使用上面的deleteFrom()快捷方式。

注意：正如您从这里的示例中看到的，您必须使用execute()方法来运行DELETE查询。如果不这样做，您将不会更改数据库中的任何内容。INSERT和UPDATE也是如此。请记住这一点。

高级特性

正如我之前告诉您的那样，这类项目都有其独特的特性。FluentPDO也不例外：我们将分析其中的两个特性：JOIN查询构建器和调试器。

JOIN查询构建器

可能是FluentPDO最重要的独特特性。如果要简化工作并编写更少的代码，构建器非常有用。让我们看看如何使用它。

我们将从使用FluentPDO编写的“经典”JOIN查询开始。

类似这样：

$query = $fpdo->from('users');
    $row = $query->fetch();

    var_dump($row);
    // 将输出：
    // array(4) { ["id"]=> string(1) "1" ["first_name"]=> string(9) "Francesco" ["last_name"]=> string(9) "Malatesta" ["signup_date"]=> string(19) "2014-06-29 13:00:00" }

好的：我们在特殊的leftJoin()方法中使用经典语法。还不错。

但是，我们可以做得更好。如果在表结构中使用约定，则可以使用此代码：

CREATE TABLE IF NOT EXISTS items (   
        id int(11) NOT NULL AUTO_INCREMENT,   
        name varchar(100) NOT NULL,   
        brand varchar(100) NOT NULL,   
        price decimal(10,2) NOT NULL,   
        user_id int(10) unsigned NOT NULL,   
        PRIMARY KEY (id),   
        KEY user_id (user_id) ) ENGINE=InnoDB  
        DEFAULT CHARSET=utf8 AUTO_INCREMENT=5 ;

    INSERT INTO items (id, name, brand, price, user_id) 
    VALUES 
    (1, 'Last Awesome Phone', 'Awesome Brand', '550.00', 1), 
    (2, 'Last Awesome TV', 'Awesome Brand', '1200.00', 1), 
    (3, 'Fantastic E-Car', 'E-Cars Inc.', '80000.00', 2), 
    (4, 'Fantastic E-Bike', 'E-Bikes Co. Ltd.', '16000.00', 2);

    CREATE TABLE IF NOT EXISTS users (
        id int(10) unsigned NOT NULL AUTO_INCREMENT,   
        first_name varchar(100) NOT NULL,   
        last_name varchar(100) NOT NULL,   
        signup_date datetime NOT NULL,   
        PRIMARY KEY (id) ) ENGINE=InnoDB  
        DEFAULT CHARSET=utf8 AUTO_INCREMENT=3;

    INSERT INTO users (id, first_name, last_name, signup_date) 
    VALUES 
    (1, 'Francesco', 'Malatesta', '2014-06-29 13:00:00'), 
    (2, 'John', 'Foo Bar', '2014-06-20 11:16:39');

    ALTER TABLE items   ADD CONSTRAINT items_ibfk_1 FOREIGN KEY (user_id) REFERENCES users (id);

很棒，对吧？好吧，快速确实很酷……但是智能呢？

看看这里：

"require": {
        ...
        "lichtner/fluentpdo": "dev-master"  
    }

它变得更好了。

实际上，FluentPDO理解您想要做什么，并使用您在select()方法中提供的带有table.fieldname格式字符串的数据自动构建查询。

您可以在这里阅读最后一个示例的最终构建查询：

$pdo = new PDO("mysql:dbname=wishlist", "root", "password");
    $fpdo = new FluentPDO($pdo);

这看起来确实不错。

如果需要，当然可以为字段创建别名：

$user_id = 1;

    $query = $fpdo->from('users')->where('id', $user_id);

    foreach($query as $row){
        echo 'Hello, ' . $row['first_name'] . ' ' . $row['last_name'] . '!';    
    }

调试器

FluentPDO带有一个内置的调试器系统，您可以使用它来测试查询并检查它们。

它使用简单的闭包系统。如果要使用调试，只需在连接代码之后放置此代码即可。

$fpdo->from('items')->where('price >', 1000);

您可以根据需要自定义闭包，只需记住将$BaseQuery对象作为参数即可。

$BaseQuery对象是BaseQuery类的实例。

结论

FluentPDO是一个小型简单的项目。它绝对不适合每个项目，并且可以改进——尤其是在它已经休眠了六个月的情况下——但是对于小型/中型应用程序来说，它可能是一个不错的选择，以防您不想在游戏中引入大型框架。由于它的一些特性，例如JOIN查询构建器，它是一个不错的折衷方案。

关于FluentPDO入门常见问题解答 (FAQs)

什么是FluentPDO，为什么我应该使用它？

FluentPDO是一个使用PDO的PHP SQL查询构建器。它为创建SQL查询提供了一个简单易用的界面，使开发人员更容易与数据库交互。FluentPDO对于那些不习惯编写原始SQL查询或想要加快开发过程的人特别有用。它支持所有SQL函数，并提供了一种安全的方法来防止SQL注入攻击。

如何安装FluentPDO？

FluentPDO可以使用Composer（PHP的依赖项管理器）安装。您可以通过运行命令composer require envms/fluentpdo来安装它。运行此命令后，Composer将把FluentPDO及其依赖项下载并安装到您的项目中。

如何使用FluentPDO连接到数据库？

要使用FluentPDO连接到数据库，您需要创建一个新的FluentPDO类实例。您可以通过将PDO实例传递给FluentPDO构造函数来实现。这是一个示例：

$query = fpdo->from('users', $user_id);

    // 将与...相同
    $query = $fpdo->from('users')->where('id', $user_id);

如何使用FluentPDO执行SELECT查询？

FluentPDO提供了一个简单的界面来执行SELECT查询。您可以使用from方法指定表，并使用select方法指定列。这是一个示例：

$query = $fpdo->from('users')->select(array('first_name', 'last_name'))->where('id', $user_id);

如何使用FluentPDO执行INSERT查询？

要执行INSERT查询，您可以使用insertInto方法指定表，并使用values方法指定值。这是一个示例：

CREATE TABLE IF NOT EXISTS items (   
        id int(11) NOT NULL AUTO_INCREMENT,   
        name varchar(100) NOT NULL,   
        brand varchar(100) NOT NULL,   
        price decimal(10,2) NOT NULL,   
        user_id int(10) unsigned NOT NULL,   
        PRIMARY KEY (id),   
        KEY user_id (user_id) ) ENGINE=InnoDB  
        DEFAULT CHARSET=utf8 AUTO_INCREMENT=5 ;

    INSERT INTO items (id, name, brand, price, user_id) 
    VALUES 
    (1, 'Last Awesome Phone', 'Awesome Brand', '550.00', 1), 
    (2, 'Last Awesome TV', 'Awesome Brand', '1200.00', 1), 
    (3, 'Fantastic E-Car', 'E-Cars Inc.', '80000.00', 2), 
    (4, 'Fantastic E-Bike', 'E-Bikes Co. Ltd.', '16000.00', 2);

    CREATE TABLE IF NOT EXISTS users (
        id int(10) unsigned NOT NULL AUTO_INCREMENT,   
        first_name varchar(100) NOT NULL,   
        last_name varchar(100) NOT NULL,   
        signup_date datetime NOT NULL,   
        PRIMARY KEY (id) ) ENGINE=InnoDB  
        DEFAULT CHARSET=utf8 AUTO_INCREMENT=3;

    INSERT INTO users (id, first_name, last_name, signup_date) 
    VALUES 
    (1, 'Francesco', 'Malatesta', '2014-06-29 13:00:00'), 
    (2, 'John', 'Foo Bar', '2014-06-20 11:16:39');

    ALTER TABLE items   ADD CONSTRAINT items_ibfk_1 FOREIGN KEY (user_id) REFERENCES users (id);

如何使用FluentPDO执行UPDATE查询？

要执行UPDATE查询，您可以使用update方法指定表，使用set方法指定新值，并使用where方法指定条件。这是一个示例：

"require": {
        ...
        "lichtner/fluentpdo": "dev-master"  
    }

如何使用FluentPDO执行DELETE查询？

要执行DELETE查询，您可以使用deleteFrom方法指定表，并使用where方法指定条件。这是一个示例：

$pdo = new PDO("mysql:dbname=wishlist", "root", "password");
    $fpdo = new FluentPDO($pdo);

如何处理FluentPDO中的错误？

当发生错误时，FluentPDO会抛出异常。您可以使用try-catch块捕获这些异常并相应地处理它们。这是一个示例：

$user_id = 1;

    $query = $fpdo->from('users')->where('id', $user_id);

    foreach($query as $row){
        echo 'Hello, ' . $row['first_name'] . ' ' . $row['last_name'] . '!';    
    }

如何在FluentPDO中使用事务？

FluentPDO提供了启动、提交和回滚事务的方法。您可以分别使用beginTransaction、commit和rollBack方法。这是一个示例：

$fpdo->from('items')->where('price >', 1000);

如何使用FluentPDO连接表？

FluentPDO提供了一个简单的界面来连接表。您可以使用join方法指定表和条件。这是一个示例：

$query = fpdo->from('users', $user_id);

    // 将与...相同
    $query = $fpdo->from('users')->where('id', $user_id);

以上是fluentpdo入门的详细内容。更多信息请关注PHP中文网其他相关文章！