Fastify 是一个快速且低开销的 Web 框架,它提供了许多优秀的功能,如请求和响应的处理、路由、中间件等。同时,Fastify 也支持与各种数据库进行交互,其中包括 PostgreSQL。本文将介绍如何在 Fastify 中使用 PostgreSQL 数据库。
安装依赖
在开始之前,需要安装以下依赖:
- Fastify
- Fastify-postgres
可以使用 npm 或 yarn 安装它们:
--- ------- ------- ----------------
或者
---- --- ------- ----------------
连接数据库
在使用 Fastify-postgres 之前,需要先建立数据库连接。可以使用 fastify-postgres
提供的 register
方法来注册插件,并在插件选项中指定连接信息。
----- ------- - -------------------- ------- ---- -- ----- --------------- - --------------------------- --------------------------------- - ----------------- ---------------------------------------------- --
这里需要将 connectionString
替换为你实际使用的连接字符串。如果需要进行更高级的配置,可以使用其他选项,例如:
ssl
: 是否启用 SSL 连接,默认为false
native
: 是否使用原生的 PostgreSQL 客户端,默认为false
connectionTimeoutMillis
: 连接超时时间,默认为0
,即不限制
更多选项可以参考官方文档:https://github.com/fastify/fastify-postgres#options
执行查询
建立数据库连接之后,就可以在路由处理程序中使用 fastify-postgres
提供的 query
方法执行查询了。
--------------------- ----- --------- ------ -- - ----- - ---- - - ----- ------------------------ - ---- ------- ---------------- --
这里使用 query
方法执行了一条简单的查询语句,并将结果集返回给客户端。需要注意的是,query
方法返回的是一个 Promise,需要使用 async/await
或 .then()
来处理结果。
参数化查询
在实际使用中,我们往往需要执行带有参数的查询语句。这时候就需要使用参数化查询来防止 SQL 注入攻击。
------------------------- ----- --------- ------ -- - ----- - -- - - -------------- ----- - ---- - - ----- ------------------------ - ---- ----- ----- -- - ---- ----- ------------------- --
这里使用 $1
作为占位符,表示第一个参数的位置。在数组中指定实际参数的值,Fastify-postgres 会自动进行参数类型转换和转义,确保查询语句的安全性。
使用事务
Fastify-postgres 还提供了事务支持,可以方便地进行多个查询的原子操作。
---------------------- ----- --------- ------ -- - ----- - ----- ----- - - ------------ ----- ------ - ----- -------------------- --- - ----- --------------------- ----- - ---- - - ----- -------------------- ---- ----- ------ ------ ------ ---- --- --------- ---- ------ ------- ----- - -- - - ------- ----- -------------------- ---- --------- --------- ------ ------ ----- ----- ---------------------- ------------ --- ----- ----- -- - ----- ----- - ----- ------------------------ ----- --- - ------- - ---------------- - --
这里使用 BEGIN
和 COMMIT
语句来开启和提交事务,使用 ROLLBACK
语句来回滚事务。需要注意的是,需要手动获取和释放连接,以确保事务的正确性。
总结
本文介绍了如何在 Fastify 中使用 PostgreSQL 数据库。首先需要安装依赖,然后建立数据库连接。可以使用 query
方法执行简单的查询,也可以使用参数化查询防止 SQL 注入攻击。对于多个查询的原子操作,可以使用事务来确保数据的一致性。希望本文对大家有所帮助。
来源:JavaScript中文网 ,转载请注明来源 本文地址:https://www.javascriptcn.com/post/663ed431d3423812e4d1137f