const mysqlConnection = require('./config/database.js')
const express = require('express');
const bodyparser = require('body-parser');
const PORT = process.env.PORT || process.env.DB_PORT;
var app = express();
app.use(bodyparser.json());
async function start(){
try{
await mysqlConnection.connect((err) =>{
if(!err){
console.log('Подключился к MySQL');
}else{
console.log('НЕТ подключения к MySQL: ' + JSON.stringify(err,undefined,2));
};
app.listen(PORT,()=>{
console.log('Express сервер запущен - работает порт: ' + process.env.DB_PORT);
});
});
}catch(err){
console.log('ОШИБКА ЗАПУСКА СЕРВЕРА: ' + err);
}
}
start();
//простой запрос
app.get('/mbk',(req, res)=>{
mysqlConnection.query('SELECT * FROM table_mf_depo', (err, rows, fields)=>{
if(!err){
res.send(rows);
}else{
console.log(err);
}
})
});
async function sendAndGetData(data) {
let response = await fetch('/', {
method: 'POST',
headers: {
'Content-Type': 'application/json'
},
body: JSON.stringify({
data: data
})
});
response = await response.json;
console.log(`${response.id} / ${response.data}`);
}
let counter = 0;
app.post('/', (req,res) => {
counter += 1;
res.send({
id: counter,
data: `Client data: ${req.body.data} / Query id: ${counter}`
})
})