Node Postgres 教程

原文： http://zetcode.com/javascript/nodepostgres/

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

Node postgres

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

在我们的示例中，我们还使用 Ramda 库。有关更多信息，请参见 Ramda 教程。

安装`node-postgres`

首先，我们安装node-postgres。

$ node -v
v11.5.0

我们使用 Node 版本 11.5.0。

$ npm init -y

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

$ npm i pg

我们使用nmp i pg安装 node-postgres。

$ npm i ramda

另外，我们安装 Ramda 来处理数据。

cars.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查询结果。

first.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查询。我们得到结果并将其输出到控制台。 res.rows是一个对象数组；我们使用 Ramda 来获取返回的标量值。最后，我们使用end()关闭连接。

$ node first.js
5

这是输出。

`node-postgres`列名称

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

column_names.js

const pg = require('pg');

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

const client = new pg.Client(cs);

client.connect();

client.query('SELECT * FROM cars').then(res => {

    const fields = res.fields.map(field => field.name);

    console.log(fields);

}).catch(err => {
    console.log(err.stack);
}).finally(() => {
    client.end()
});

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

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

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

选择所有行

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

all_rows.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 * FROM cars').then(res => {

    const data = res.rows;

    console.log('all data');
    data.forEach(row => {
        console.log(`Id: ${row.id} Name: ${row.name} Price: ${row.price}`);
    })

    console.log('Sorted prices:');
    const prices = R.pluck('price', R.sortBy(R.prop('price'), data));
    console.log(prices);

}).finally(() => {
    client.end()
});

该示例输出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 ]

这是输出。

`node-postgres`参数化查询

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

parameterized.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 }

这是输出。

使用`async/await`的`node-postgres`

Node Postgres 支持async/await语法。

async_await.js

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

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

async function fetchNow() {

    const client = new pg.Client(cs);

    try {
        await client.connect();

        let result = await client.query('SELECT now()');
        return R.prop('now', R.head(result.rows));
    } finally {
        client.end()
    }
}

fetchNow().then(now => console.log(now));

该示例使用async/await输出SELECT now()查询的结果。

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

这是输出。

`node-postgres`行模式

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

row_mode.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();

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

client.query(query).then(res => {

    const data = res.rows;

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

    console.log('Sorted prices:');

    const prices = data.map(x => x[2]);

    const sorted = R.sort(R.comparator(R.lt), prices);
    console.log(sorted);

}).finally(() => {
    client.end()
});

该示例显示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 ]

这是输出。

`node-postgres`池化示例

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

pooled.js

const pg = require('pg');

var config = {
    user: 'postgres',
    password: 's$cret',
    database: 'ydb'
}

const pool = new pg.Pool(config);

pool.connect()
    .then(client => {
        return client.query('SELECT * FROM cars WHERE id = $1', [1])
            .then(res => {
                client.release();
                console.log(res.rows[0]);
            })
            .catch(e => {
                client.release();
                console.log(e.stack);
            })
  }).finally(() => pool.end());

该示例说明如何设置一个使用连接池的示例。完成查询后，我们将调用client.release()方法将连接返回到池。

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

pool.end()耗尽所有活动客户端的池，断开它们的连接，并关闭该池中的所有内部计时器。在此示例的脚本中使用了此方法。在 Web 应用中，我们可以在 Web 服务器关闭或根本不调用时调用它。

在本教程中，我们使用node-postgres与 Node.js 中的 PostgreSQL 进行交互。

您可能也对以下相关教程感兴趣： Knex.js 教程， Sequelize 教程，从 JavaScript 中的 URL 读取 JSON ， JavaScript 贪食蛇教程， JQuery 教程， Node Sass 教程， Lodash 教程。

我们一直在努力

apachecn/AiLearning

Node Postgres 教程

Node postgres

安装node-postgres

node-postgres第一个示例

node-postgres列名称

选择所有行

node-postgres参数化查询

使用async/await的node-postgres

node-postgres行模式

node-postgres池化示例

安装`node-postgres`

`node-postgres`第一个示例

`node-postgres`列名称

`node-postgres`参数化查询

使用`async/await`的`node-postgres`

`node-postgres`行模式

`node-postgres`池化示例