我想在 Node.js 中使用 postgresql bytea 存储 PDF答案

【问题标题】：I want to store PDF using postgresql bytea in Node.js我想在 Node.js 中使用 postgresql bytea 存储 PDF
【发布时间】：2021-03-17 11:36:29
【问题描述】：

我想在 Node.js 中使用 PostgreSQL bytea 存储 PDF

如何将 PDF 转换为数据类型 bytea ？

我的代码是：

request.get('https://www.cbconnexus.com/upload/settings/black/data.pdf', function (error, response, body) {
    if (!error && response.statusCode == 200) {
        data = "data:" + response.headers["content-type"] + ";base64," + Buffer.from(body).toString('base64');
        console.log(data);
    }
});

【问题讨论】：

标签： node.js postgresql bytea

【解决方案1】：

节点 http 服务器接受 PDF 的帖子并将其存储在 postgresql 表中。默认监听固定 IP 地址 192.168.1.3，端口 8888，但您可以指定端口作为第一个参数。使用pg和强大。

var myArgs = process.argv.slice(2);
var http = require('http');
var fs = require('fs');
var port = 8888;

const { IncomingForm } = require('formidable');

const { Client } = require('pg');
const dbc = new Client({
    host: '127.0.0.1',
    user: 'ghp',
    password: 'zevrepdm',
    database: 'ghp',
    port: 5434,
  });
dbc.connect();

if (myArgs[0]) {
  port = myArgs[0];
}

http.createServer(function (req, res) {
  const chunks = [];

  if (req.url === '/' && req.method.toLowerCase() === 'post') {
      const form = new IncomingForm({ multiples: true });
      form.parse(req, (err, fields, files) => {
        if (files.userfile.type == "application/pdf") {
          var rawData = fs.readFileSync(files.userfile.path) ;
          dbc
            .query(
              'insert into files(name,type,size,data) values ($1,$2,$3,$4)'
              + ' returning name',
              [ files.userfile.name, files.userfile.type, files.userfile.size,
                rawData ]
            ).then(res => {
                var insMessage = 'file ' + res.rows[0].name + ' inserted' ;
                console.log( insMessage );
            }).catch(err => {
                var insMessage = 'Error inserting file ' + files.userfile.name ;
                console.error( insMessage );
                console.error( err.stack );
            });
        }
      });
  }
  req.on('data', chunk => chunks.push(chunk));
  req.on('end', () => {
    res.writeHead(200, [['Content-Type', 'text/html'],
                      ['Cache-Control', 'maxage=120, s-maxage=60, public'],
                      ['X-Accel-Expires', '86400'],
                      ['X-BEVar', req.url] ]);
    res.write('Hello ' + req.headers['user-agent'] + '!<br>');
    res.write('<br>I\'m the one listening on port ' + port + '!<br>');
    res.write("  <FORM ACTION='");
    res.write(req.url);
    res.write("' METHOD='post' enctype='multipart/form-data'> \
                  <input type='hidden' name='MAX_FILE_SIZE' value='128000000'> \
                  <input name='userfile' type='file' size='50'> \
                  <input type='submit' value='Send File'> \
                 </FORM>");
    res.end('Do you know it\'s already ' + Date() + '?');
  })
}).listen(port,"192.168.1.3");

【讨论】：