Node.js Postgres 教程

浅浅的花香味﹌ 2023-09-29 10:44 2阅读 0赞

Node Postgres教程展示了如何在JavaScript中使用Node-postgres的PostgreSQL数据库。

### The node-postgres ###

node-postgres是Node.js模块的集合，用于与PostgreSQL数据库接口。它支持回调、承诺、异步/等待、连接池、预准备语句、游标和流式处理结果。

在我们的示例中，我们还使用 Ramda 库。有关详细信息，请参阅 Ramda 教程。

### 设置 node-postgres ###

首先，我们安装node-postgres。

$ npm init -y

我们启动了一个新的 Node 应用程序。

$ npm i pg

我们用 .`nmp i pg`

$ npm i ramda

此外，我们安装了Ramda，以便对数据进行漂亮的工作。

汽车.sql

DROP TABLE IF EXISTS cars;
    
    CREATE TABLE cars(id SERIAL PRIMARY KEY, name VARCHAR(255), price INT);
    INSERT INTO cars(name, price) VALUES('Audi', 52642);
    INSERT INTO cars(name, price) VALUES('Mercedes', 57127);
    INSERT INTO cars(name, price) VALUES('Skoda', 9000);
    INSERT INTO cars(name, price) VALUES('Volvo', 29000);
    INSERT INTO cars(name, price) VALUES('Bentley', 350000);
    INSERT INTO cars(name, price) VALUES('Citroen', 21000);
    INSERT INTO cars(name, price) VALUES('Hummer', 41400);
    INSERT INTO cars(name, price) VALUES('Volkswagen', 21600);

在一些示例中，我们使用此表。`cars`

### node-postgres 第一个示例 ###

在第一个示例中，我们连接到 PostgreSQL 数据库并返回一个简单的 SELECT 查询结果。

第一.js

const pg = require('pg');
    const R = require('ramda');
    
    const cs = 'postgres://postgres:s$cret@localhost:5432/ydb';
    
    const client = new pg.Client(cs);
    client.connect();
    
    client.query('SELECT 1 + 4').then(res => {
    
        const result = R.head(R.values(R.head(res.rows)));
    
        console.log(result);
    }).finally(() => client.end());

该示例连接到数据库并发出 SELECT 语句。

const pg = require('pg');
    const R = require('ramda');

我们包括 和 模块。`pg``ramda`

const cs = 'postgres://postgres:s$cret@localhost:5432/ydb';

这是 PostgreSQL 连接字符串。它用于构建与数据库的连接。

const client = new pg.Client(cs);
    client.connect();

将创建一个客户端。我们使用 连接到数据库。`connect`

client.query('SELECT 1 + 4').then(res => {
    
        const result = R.head(R.values(R.head(res.rows)));
    
        console.log(result);
    }).finally(() => client.end());

我们发出一个简单的 SELECT 查询。我们获取结果并将其输出到控制台。是对象的数组;我们使用 Ramda 来获取返回的标量值。最后，我们关闭与 的连接。`res.rows``end`

$ node first.js
    5

### 节点-postgres 列名 ###

在下面的示例中，我们获取数据库的列名。

column\_names.js

使用属性检索列名。我们还使用子句来输出潜在的错误。`res.fields``catch`

$ node column_names.js
    [ 'id', 'name', 'price' ]

输出显示表的三个列名。`cars`

### 选择所有行 ###

在下一个示例中，我们从数据库表中选择所有行。

all\_rows.js

该示例输出表中的所有行和汽车价格的排序列表。`cars`

$ node all_rows.js
    all data
    Id: 1 Name: Audi Price: 52642
    Id: 2 Name: Mercedes Price: 57127
    Id: 3 Name: Skoda Price: 9000
    Id: 4 Name: Volvo Price: 29000
    Id: 5 Name: Bentley Price: 350000
    Id: 6 Name: Citroen Price: 21000
    Id: 7 Name: Hummer Price: 41400
    Id: 8 Name: Volkswagen Price: 21600
    Sorted prices:
    [ 9000, 21000, 21600, 29000, 41400, 52642, 57127, 350000 ]

### The node-postgres parameterized query ###

参数化查询使用占位符，而不是直接将值写入语句。参数化查询可提高安全性和性能。

参数化.js

const pg = require('pg');
    
    const cs = 'postgres://postgres:s$cret@localhost:5432/ydb';
    
    const client = new pg.Client(cs);
    
    client.connect();
    
    const sql = 'SELECT * FROM cars WHERE price > $1';
    const values = [50000];
    
    client.query(sql, values).then(res => {
    
        const data = res.rows;
    
        data.forEach(row => console.log(row));
    
    }).finally(() => {
        client.end()
    });

该示例在简单的 SELECT 语句中使用参数化查询。

const sql = 'SELECT * FROM cars WHERE price > $1';

这是 SELECT 查询。是一个占位符，稍后以安全的方式将其替换为值。`$1`

const values = [50000];

这些是要插入到参数化查询中的值。

client.query(sql, values).then(res => {

这些值将作为第二个参数传递给方法。`query`

$ node parameterized.js
    { id: 1, name: 'Audi', price: 52642 }
    { id: 2, name: 'Mercedes', price: 57127 }
    { id: 5, name: 'Bentley', price: 350000 }

### 带有异步/等待的 node-postgres ###

Node Postgres 支持 async/await 语法。

async\_await.js

该示例使用异步/等待输出查询的结果。`SELECT now`

$ node async_await.js
    2019-02-17T11:53:01.447Z

### 节点-postgres 行模式 ###

默认情况下，node-postgres 将数据作为对象数组返回。我们可以告诉node-postgres将数据作为数组返回。

row\_mode.js

该示例显示表中的所有行。它启用数组行模式。`cars`

const query = {
        text: 'SELECT * FROM cars',
        rowMode: 'array'
    };

我们使用将 设置为 的配置对象。`rowMode``array`

console.log('all data');
    data.forEach(row => {
        console.log(`Id: ${row[0]} Name: ${row[1]} Price: ${row[2]}`);
    })

现在我们循环访问一个数组数组。

$ node row_mode.js
    all data
    Id: 1 Name: Audi Price: 52642
    Id: 2 Name: Mercedes Price: 57127
    Id: 3 Name: Skoda Price: 9000
    Id: 4 Name: Volvo Price: 29000
    Id: 5 Name: Bentley Price: 350000
    Id: 6 Name: Citroen Price: 21000
    Id: 7 Name: Hummer Price: 41400
    Id: 8 Name: Volkswagen Price: 21600
    Sorted prices:
    [ 9000, 21000, 21600, 29000, 41400, 52642, 57127, 350000 ]

### 节点后聚合池示例 ###

连接池可提高数据库应用程序的性能。它是特别有用的Web应用程序。

池化.js

该示例演示如何设置使用连接池的示例。完成查询后，我们调用该方法以将连接返回到池。`client.release`

}).finally(() => pool.end());

将排出所有活动客户端的池，断开它们，并关闭池中的任何内部计时器。这在诸如此示例的脚本中使用。在Web应用程序中，我们可以在Web服务器关闭时调用它，或者根本不调用它。`pool.end`

在本教程中，我们曾经在 Node.js 中与 PostgreSQL 进行交互。`node-postgres`