richiama se errore socket hang up
This commit is contained in:
@@ -58,11 +58,25 @@ app.post('/query', async (req, res) => {
|
|||||||
res.json({});
|
res.json({});
|
||||||
}
|
}
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.error('Error...', err.message)
|
// se err.messagge === 'socket hang up' allora attendi 2 secondi e richiama sql.query
|
||||||
res.status(500).json({ error: err.message });
|
if (err.message.trim() === 'socket hang up') {
|
||||||
|
await new Promise((resolve) => setTimeout(resolve, 2000));
|
||||||
|
const result = await sql.query(req.body.query);
|
||||||
|
console.log(' ... tornato');
|
||||||
|
if (result) {
|
||||||
|
console.log('Risultato:', result.recordset);
|
||||||
|
res.json(result.recordset);
|
||||||
|
} else {
|
||||||
|
res.json({});
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
console.error('Error...', err.message)
|
||||||
|
res.status(500).json({ error: err.message });
|
||||||
|
}
|
||||||
} finally {
|
} finally {
|
||||||
sql.close();
|
sql.close();
|
||||||
}
|
}
|
||||||
|
|
||||||
});
|
});
|
||||||
|
|
||||||
const PORT = process.env.SERVER_PORT || 3000;
|
const PORT = process.env.SERVER_PORT || 3000;
|
||||||
|
|||||||
Reference in New Issue
Block a user