使用标准节点 Oracledb 设置获取 GET，为什么我会收到“来自 HTTP 参数的未经处理的输入流入发送”？

Question

我当前的环境使用 Angular 前端和 Node 后端。

标记的行在控制器代码的下方。

 res.send(rows);

我们的数据库是 Oracle，所以我们使用包：https://www.npmjs.com/package/oracledb

来自前端的 GET 请求示例

  getJobResult(id): Observable<JobResult[]> {
    const url = environment.hosturl + "job";
    const httpOptions = {
      headers: new HttpHeaders({
        "Access-Control-Allow-Origin": "*",
        "Content-Type": "application/json",
      }),
      withCredentials: true,
      params: {
        id: id,
      },
    };
        return this._http.get(url, httpOptions).pipe(
      map((res) => {
        if (res[0] && JSON.stringify(res[0]).includes("ERROR_MSG")) {
          // Error in GET Result
          this.router.navigate(["/error"]);
        }
        
        return <JobResult[]>res;
      })
    );
  }

API 后端示例控制器

const job = require('../db_apis/job.js');


async function get(req, res, next) {
  try {
    const context = {};
    context.id = req.query.id;


    const rows = await job.find(context);

    res.send(rows);
    
    } catch (err) { 
res.sendStatus(404);
    next(err);
  }
}

module.exports.get = get;

res.send(rows) 上面的行是标记错误的内容。

API 的 DB API 文件示例

const database = require('../services/database.js');

async function find(context) {

  let query = `SELECT  * FROM JOB WHERE JOB_ID = :V_ID`
  
console.log(query);
const binds = {
  V_ID: Number(context.id)
};
const result = await database.simpleExecute(query, binds, clientdetails);
  return result.rows;
}

module.exports.find = find;

simpleExecute 运行的函数

async function simpleExecute(query, binds = [],clientdetails = [], opts = {}) {
  let conn;
  // Set Pool based on User
  let alias = 'client1';
  let simpleResult;
  console.log('Action for Client: ' + alias)

  opts.outFormat = oracledb.OBJECT;
  opts.autoCommit = true;

  try {
    // Get Connection
    conn = await oracledb.getConnection(alias);
    conn.callTimeout = 500 * 1000; // Reduced the timeout to 50 secs
    // Execute Statement
    simpleResult = await conn.execute(query, binds, opts);
  } catch (err) {
    console.error("Oracle Error ==>", err, "<== THIS IS WHERE THE ORACLE ERROR WILL SHOW!"); 
  } finally {
    // Finally close the connection
    if (conn) {
      try {
        await conn.close();
        console.log('Connection Closed.')
      } catch (err) {
        console.log('Error in close: ' + err);
      }
      // return the result
      console.log('Result Returned.');
      return simpleResult
    }
  } 
}

module.exports.simpleExecute = simpleExecute;

任何帮助将不胜感激！

Answer 1

看起来从 job.find 方法返回的行不可序列化为 JSON。如果数据包含循环引用、函数或其他不可序列化的数据类型，就会发生这种情况。

试着检查一下。如果是这样，您可以使用像“lodash”或“underscore”这样的库来深度克隆数据并删除任何不可序列化的属性。