Node.js 流写入文件

1、使用 fs 模块的 createWriteStream 方法创建一个可写流。

2、将数据通过管道传输到可写流中。

3、监听可写流的 ‘finish’ 事件，表示数据已经全部写入文件。

4、监听可写流的 ‘error’ 事件，处理写入过程中的错误。

示例代码：

const fs = require('fs');
const readable = getReadableStream(); // 获取可读流，例如从数据库读取数据
const writeStream = fs.createWriteStream('output.txt');
readable.pipe(writeStream);
writeStream.on('finish', () => {
  console.log('数据已全部写入文件');
});
writeStream.on('error', (err) => {
  console.error('写入文件过程中发生错误：', err);
});

Node.js 读取数据库（以 MySQL 为例）

1、安装 mysql 模块：npm install mysql

2、创建连接对象，设置数据库连接信息。

3、使用连接对象的 query 方法执行 SQL 查询语句。

4、监听查询结果的 ‘result’ 事件，获取查询结果集。

5、遍历结果集，处理每一行数据。

6、关闭查询结果集和连接对象。

示例代码：

const mysql = require('mysql');
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'your_password',
  database: 'your_database'
});
connection.connect();
const query = 'SELECT * FROM your_table';
connection.query(query, (err, results, fields) => {
  if (err) {
    console.error('查询过程中发生错误：', err);
    return;
  }
  results.forEach((row, index) => {
    console.log(第 ${index + 1} 行数据：, row);
  });
});
connection.end();