Fastify 如何使用 PostgreSQL 数据库

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 还提供了事务支持,可以方便地进行多个查询的原子操作。

---------------------- ----- --------- ------ -- -
  ----- - ----- ----- - - ------------
  ----- ------ - ----- --------------------
  --- -
    ----- ---------------------
    ----- - ---- - - ----- -------------------- ---- ----- ------ ------ ------ ---- --- --------- ---- ------ -------
    ----- - -- - - -------
    ----- -------------------- ---- --------- --------- ------ ------ -----
    ----- ----------------------
    ------------ --- ----- ----- --
  - ----- ----- -
    ----- ------------------------
    ----- ---
  - ------- -
    ----------------
  -
--

这里使用 BEGINCOMMIT 语句来开启和提交事务,使用 ROLLBACK 语句来回滚事务。需要注意的是,需要手动获取和释放连接,以确保事务的正确性。

总结

本文介绍了如何在 Fastify 中使用 PostgreSQL 数据库。首先需要安装依赖,然后建立数据库连接。可以使用 query 方法执行简单的查询,也可以使用参数化查询防止 SQL 注入攻击。对于多个查询的原子操作,可以使用事务来确保数据的一致性。希望本文对大家有所帮助。

来源:JavaScript中文网 ,转载请注明来源 本文地址:https://www.javascriptcn.com/post/663ed431d3423812e4d1137f