루프 내 약속 연결

Question

DB를 쿼리하고 데이터를 삽입하는 동안 배열 periods을 반복하는 데 어려움을 겪고 있습니다. 내가 직면하고있는 문제는 마지막 줄에서 5 번째로 볼 수 있습니다. 최종 db.queryPromise이 호출되지 않습니다.

문제가있는 곳의 하단에서 5 줄을 참조하십시오.

// db.js 

const mysql = require('mysql'); 

const connection = mysql.createConnection({ 
    host  : 'localhost', 
    user  : ****, 
    password : ****, 
    database : ****, 
}); 

module.exports = connection; 

module.exports.queryPromise = function (args) { 
    return new Promise((resolve, reject) => { 
    connection.query(args, (err, rows, fields) => { 
     if (err) return reject(err); 
     resolve(rows); 
    }); 
    }); 
}; 

module.exports.connectPromise = new Promise((resolve, reject) => { 
    connection.connect(err => { 
    if (err) reject(err); 
    resolve(); 
    }); 
}); 

// app.js 
const db = require('../config/db'); 

const periods = ['1h','12h','24h','1w','1m','3m','1y','all']; 
const sqlCarIds = `SELECT id FROM car_models ORDER BY id DESC LIMIT 200;`; 

return db.queryPromise(sqlCarIds) 
.then((rows) => { 
    const car_ids = []; 
    for (let i = rows.length - 1; i >= 0; i--) { 
    car_ids.push(rows[i].car_id); 
    }; 

    for (let i = periods.length - 1; i >= 0; i--) { 

    const sqlSnapshot = `SELECT price FROM car_models;`; 

    db.queryPromise(sqlSnapshot) 
    .then(([row]) => { 
     if (!row) { 
     throw new Error('API call found nothin'); 
     } 

     const highPrice = row.high; 
     const sqlInsert = `INSERT into price_cache (high) VALUES (` + highPrice` +)`;` 

     console.log(sqlInsert); // logs correctly formed query 
     db.queryPromise(sqlInsert) 
     .then(() => { 
     console.log('this should fire'); // doesn't fire 
     }); 
    }); 
    } 
}); 

Answer 1

sqlInsert에 대한 SQL 구문이 유효하지 않습니다. 다음 예제와 같이 작성해야합니다. 표현식의 값을 "Template String"에 추가하려면 ${expression} 리터럴을 사용해야합니다. promise은 거부하는 오류가 있으므로 해결되지 않습니다.

const sqlInsert = `INSERT into price_cache (high) VALUES (${highPrice})`;