告别枯燥的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中文网其他相关文章!

长URL(通常用关键字和跟踪参数都混乱)可以阻止访问者。 URL缩短脚本提供了解决方案,创建了简洁的链接,非常适合社交媒体和其他平台。 这些脚本对于单个网站很有价值

Laravel使用其直观的闪存方法简化了处理临时会话数据。这非常适合在您的应用程序中显示简短的消息,警报或通知。 默认情况下,数据仅针对后续请求: $请求 -

这是有关用Laravel后端构建React应用程序的系列的第二个也是最后一部分。在该系列的第一部分中,我们使用Laravel为基本的产品上市应用程序创建了一个RESTFUL API。在本教程中,我们将成为开发人员

Laravel 提供简洁的 HTTP 响应模拟语法,简化了 HTTP 交互测试。这种方法显着减少了代码冗余,同时使您的测试模拟更直观。 基本实现提供了多种响应类型快捷方式: use Illuminate\Support\Facades\Http; Http::fake([ 'google.com' => 'Hello World', 'github.com' => ['foo' => 'bar'], 'forge.laravel.com' =>

PHP客户端URL(curl)扩展是开发人员的强大工具,可以与远程服务器和REST API无缝交互。通过利用Libcurl(备受尊敬的多协议文件传输库),PHP curl促进了有效的执行

您是否想为客户最紧迫的问题提供实时的即时解决方案? 实时聊天使您可以与客户进行实时对话,并立即解决他们的问题。它允许您为您的自定义提供更快的服务

2025年的PHP景观调查调查了当前的PHP发展趋势。 它探讨了框架用法,部署方法和挑战,旨在为开发人员和企业提供见解。 该调查预计现代PHP Versio的增长

在本文中,我们将在Laravel Web框架中探索通知系统。 Laravel中的通知系统使您可以通过不同渠道向用户发送通知。今天,我们将讨论您如何发送通知OV


热AI工具

Undresser.AI Undress
人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

AI Hentai Generator
免费生成ai无尽的。

热门文章

热工具

适用于 Eclipse 的 SAP NetWeaver 服务器适配器
将Eclipse与SAP NetWeaver应用服务器集成。

EditPlus 中文破解版
体积小,语法高亮,不支持代码提示功能

Dreamweaver Mac版
视觉化网页开发工具

记事本++7.3.1
好用且免费的代码编辑器

VSCode Windows 64位 下载
微软推出的免费、功能强大的一款IDE编辑器