如何在单个查询中返回 node.js mysql 中的嵌套 json

Posted 2023-02-24

【中文标题】如何在单个查询中返回 node.js mysql 中的嵌套 json

【英文标题】：How to return a nested json in node.js mysql in a single query

【发布时间】：2017-05-19 17:59:03

【问题描述】：

我正在尝试创建一个将返回嵌套 json 的 api，来自两个相关的表 student 和 studentSubjects

[
   id:"1",
   name: "John",
   subjects: [
                id:"1",
                subject: "Math"
              ,
              
                id:"2",
                subject: "English"
              
             ]
 ,
 
   id:"2",
   name: "Peter",
   subjects: [
                id:"1",
                subject: "Math"
              ,
              
                id:"2",
                subject: "English"
              
             ]
]

我的代码如下所示：

this.get = function(res)
    db.acquire(function(err, con)                  
        con.query('SELECT * FROM students', function(err, results) 

            if (err)                   
                res.send(status: 0, message: 'Database error');
            else                  
                res.send(status: 1, data: results);                   
                                                   
        )  
        con.release()           
    )

我知道查询应该有连接，但它只返回单行。我也试着做一个循环，它不会工作，因为它是异步的

感谢您的帮助！！

【参考方案1】：

您不能从 mysql 查询创建嵌套 JSON，因为它总是返回一个平面结果。

无论如何，要创建嵌套 JSON，您应该创建多个查询并在需要的地方插入相应的数组对象。

您应该真正考虑使用 Promises 来创建嵌套查询，因为它允许您背靠背地进行异步操作。 如果任何查询发生错误，下面的代码也会关闭连接。

PS：我在下面的代码中解释了cmets中的每个步骤

想象有一个名为“School”的数据库和三个名为“Student”、“Subject”和“Link_student_subject”的表。

// Instantiate mysql datase variables
const mysql = require( 'mysql' );
const config = 
    host     : 'localhost',
    user     : 'root',
    password : 'root',
    database : 'school'
  
var connection;

// Instantiate express routing variables 
const express = require('express');
const router = express.Router();
module.exports = router;

// Wrapper class for MySQL client
// - Constructor creates MySQL connection
// - Connection opened when query is done
// - Promise is resolved when executing
// - Promise returns reject in case of error
// - If promise resolved rows will be the result
class Database 
    constructor( config ) 
        this.connection = mysql.createConnection( config );
    
    query( sql, args ) 
        return new Promise( ( resolve, reject ) => 
            this.connection.query( sql, args, ( err, rows ) => 
                if ( err )
                    return reject( err );
                resolve( rows );
             );
         );
    
    close() 
        return new Promise( ( resolve, reject ) => 
            this.connection.end( err => 
                if ( err )
                    return reject( err );
                resolve();
             );
         );
    


// Function that will execute a query
// - In case of an error: ensure connection is always closed
// - In case of succes: return result and close connection afterwards
Database.execute = function( config, callback ) 
  const database = new Database( config );
  return callback( database ).then(
      result => database.close().then( () => result ),
      err => database.close().then( () =>  throw err;  )
  );
;

// Instantiate Database
var database = new Database(config);

// Express routing
router.get('/students', function (req, res) 

  // Variables - Rows from Students & Subjects & Link_student_subject
  let rows_Students, rows_Subjects, rows_Link_Student_Subject;

  // Create a Promise chain by
  // executing two or more asynchronous operations back to back, 
  // where each subsequent operation starts when the previous operation succeeds, 
  // with the result from the previous step
  Database.execute( config,
      database => database.query( "select a.*, null as subjects from student a" )
      .then( rows => 
        rows_Students = rows;
        return database.query( "select * from subject" )
       )
      .then( rows => 
        rows_Subjects = rows;
        return database.query( "select * from link_student_subject" )
       )
      .then( rows => 
        rows_Link_Student_Subject = rows;
       )
  ).then( () => 
      // Create your nested student JSON by looping on Students
      // and inserting the corresponding Subjects array
      for (let i = 0; i < rows_Students.length; i++) 
        let arraySubjects = [];
        for (let x = 0; x < rows_Link_Student_Subject.length; x++) 
            if(rows_Students[i].id == rows_Link_Student_Subject[x].id_student)
                arraySubjects.push(searchObjInArray(rows_Subjects, "id", rows_Link_Student_Subject[x].id_subject));
            
        
        rows_Students[i].subjects = arraySubjects;
      
      res.send(JSON.stringify(rows_Students));
   ).catch( err => 
      // handle the error
      res.send(err);
  );

);

// Function - search if object in array has a value and return that object
function searchObjInArray(array, arrayProp, searchVal)
    let result = null;
    let obj = array.find((o, i) => 
        if (o[arrayProp] == searchVal) 
        result = array[i];
        return true; // stop find function
        
    );
    return result;

如果您使用节点运行此代码并转到“127.0.0.1/students”，它将返回与您的问题完全相同的 JSON。

关于 MySQL 和承诺的所有学分和额外信息 - https://codeburst.io/node-js-mysql-and-promises-4c3be599909b

【讨论】：

这不是真的。 MySQL 5.7+ 有一个“JSON”数据类型。

【参考方案2】：

MySQL 5.7+ 具有 JSON 数据类型，您可以将其用于“主题”字段。这是一个关于如何使用它的很棒的教程：

https://www.sitepoint.com/use-json-data-fields-mysql-databases/

【讨论】：

这不是所要求的。 @Dondon Abion 想知道他如何使用来自 mysql 的原始查询接收嵌套的 json 响应