Как выполнить асинхронную функцию синхронно?

Question

[ince]

Как я понял - функция connection.execute - асинхронная. Сначала интерпретатор проходит по моему циклу forEach, а уже после начинает выполнять запросы connection.execute
Как сделать, чтобы запросы connection.execute исполнялись по мере исполнения кода?

// massive-of-json-to-db

var oracledb = require('oracledb');     // To DB
var moment = require('moment');     
const fs = require("fs");               // FS

var FILEIN  = 'avgprice_bd-prepared.json';
var YEAR    = 2019;
var QUARTERNUMBER = 1;
var locationId;

var fileContent = fs.readFileSync(FILEIN, "utf8");     // File with massive of objects
var maxId = 0;  // !!

// Date-time locale initial
moment.locale('ru');

var dateOptions = {
    year:   'numeric',
    month:  'long',
    day:    'numeric',
    hour:   'numeric',
    minute: 'numeric',
    second: 'numeric'
};


// Check hyphen, replace to null
var replaceHyphen = (element) => ( element == '-'? null : element );

////////////////////////////////////////////

oracledb.getConnection(
  {
    user          : "system",
    password      : "test",
    connectString : "localhost/test"     
  },
  function(err, connection) {

        if (err) {
        console.error(err.message);
        return;
        } 

        var arr = fileStringToMassiveOfObjects(fileContent);
        
        // Passage through the array
        arr.forEach(function(item, i, arr) {

                    var now = new Date();

                    if (i<100) {
 

                            var d = moment().format('L');
                            d += " " + moment().format('LTS');   
                            
                            console.log(`d = ${d}`);
 
                            connection.execute(
                                 `INSERT INTO TEMP_AVG_PRICE (ID_CRE_RECORD, DATETIME, QUARTER, 
                                 "YEAR", state, locality
                                 ) VALUES 
                                (:id, TO_timestamp(:dt, 'DD.MM.YYYY HH24:MI:SS'), :qu, :y, :st, :loc
                                )`, 
                                {   id: maxId+1, dt: d, qu: QUARTERNUMBER, y: YEAR, 
                                    st:  replaceHyphen(arr[i]['Регион (субъект РФ)']), 
                                    loc: replaceHyphen(arr[i]['Населенный пункт (район)'])
                                },

                                // {autoCommit: true},
                                function(err, result) {
                                    if (err) {
                                        //console.error(err.message);
                                        //console.error('Error?');
                                        doRelease(connection);
                                        return;

                                    };
                                        console.log("Rows inserted " + result.rowsAffected);  
                                        connection.commit();                              
                                        //console.log(result.rows);
                                        doRelease(connection);
                                });

                            maxId++;

           
                        };      

        });   

        connection.commit();
        doRelease(connection);

  });


function doRelease(connection) {
  connection.close(
    function(err) {
      if (err)
        console.error(err.message);
    });
};


// From file-string to massive of objects
function fileStringToMassiveOfObjects(fileContent){     

    var arr = fileContent.split('},');    

    arr[0] = arr[0].substr(1);                                // Del first char [
    arr[arr.length - 1] = arr[arr.length - 1].slice(0, -1);   // Del end   char ]
   

    arr.forEach(function(item, i, arr) {

        if (i != (arr.length - 1)){
            item += '}';   // Add char } to the end of element   
        };             
        arr[i] = JSON.parse(item);

    });  

    return arr;

};

Answer 1

[Кирилл Кудрявцев]

Async/await так же и for await

Answer 2

[Draek Nelson]

Тебе надо создать async function foo (connection,...) И внутри нее вызвать цикл forEach, в котором делаешь await connection.execute, вместо connection.execute.
Или передать async function(err, connection) {} как колбек в getConnection.