Не обновляются данные при добавлении в базу данных Mysql через PhpMyAdmin в NodeJS?

Question

[sportik174]

Подскажите пожалуйста как сделать так чтобы при изменении данных в базе Mysql (например добавлении, удалении и редактировании), эти изменения отображались без перезагрузки сервера Nodejs. Вот код моего приложения

var express = require('express');
var mysql = require('mysql');
var bodyParser = require('body-parser');
var app = express();
var transliterate = require('transliteration');

app.set('view engine', 'ejs');

var urlencodedParser = bodyParser.urlencoded({ extended: false });
//Коннект к базе данных
var connection = mysql.createConnection({
	host: 'localhost',
	user: 'root',
	password: '',
	database: 'social'
});
//END Коннект к базе данных

connection.connect();

	var query = connection.query('SELECT * FROM `users` ', function(error, result){
		if(error) throw error;

		app.get('/users', function(req, res){
			res.render('users', { users:result});
		});

		app.get('/users/:id', function(req, res){
			var user = result[req.params.id-1];
			res.render('user', { user:user});
		});
	});

connection.end();





app.get('/', function(req, res){
	//res.sendFile(__dirname + "/index.html");
	res.render('index');
});

app.get('/form', function(req, res){
	//res.sendFile(__dirname + "/index.html");
	res.render('form');
});

app.post('/form', urlencodedParser, function(req, res){
	console.log(req.body);
	//res.sendFile(__dirname + "/index.html");
	res.render('spasibo', {name:req.body.name});
});

Answer 1

[Pavel Shvedov]

запрос в бд нужно делать при каждом запросе к /users или /users/:id

Comments

[sportik174]

Переписал код так. Теперь при первой загрузке страницы все нормально. А при перезагрузке выдает ошибку

var express = require('express');
var mysql = require('mysql');
var bodyParser = require('body-parser');
var app = express();
var transliterate = require('transliteration');

app.set('view engine', 'ejs');

var urlencodedParser = bodyParser.urlencoded({ extended: false });
//Коннект к базе данных
var connection = mysql.createConnection({
	host: 'localhost',
	user: 'root',
	password: '',
	database: 'social'
});
//END Коннект к базе данных




app.get('/users', function(req, res){
	
	connection.connect();
	var query = connection.query('SELECT * FROM `users` ', function(error, result){
		//if(error) throw error;
		var user = result[req.params.id-1];
		res.render('users', { users:result});
	});
	connection.end();
	
});


app.get('/users/:id', function(req, res){

	connection.connect();
	var query = connection.query('SELECT * FROM `users` ', function(error, result){
		//if(error) throw error;
		var user = result[req.params.id-1];
		res.render('user', { user:user});
	});
	
	connection.end();


});




app.get('/', function(req, res){
	//res.sendFile(__dirname + "/index.html");
	res.render('index');
});

app.get('/form', function(req, res){
	//res.sendFile(__dirname + "/index.html");
	res.render('form');
});

app.post('/form', urlencodedParser, function(req, res){
	console.log(req.body);
	//res.sendFile(__dirname + "/index.html");
	res.render('spasibo', {name:req.body.name});
});


// app.get('/news', function(req, res){
// 	res.sendFile(__dirname + "/news.html");
// });





app.listen(3000, function(){
	console.log('Сервер запущен на порту 3000');
});

[sportik174]

Вот сама ошибка

[Pavel Shvedov]

sportik174, Во-первых: query вызывается асинхронно, не блокируя выполнение обработчика запроса, поэтому идущий дальше код выполнится НЕ после получения результата обращения к базе, а недожидаясь его, во-вторых: не нужно коннектиться к базе на каждый запрос, нужно создать подключение (или пул) один раз при старте приложения, сделать connect(), а end() вызывать в конце работы всего приложения, а в обработчиках запросов только делать обращения к БД с помощью query и тд

[sportik174]

Pavel Shvedov, Можете пример написать? Не могу понять как правильно сделать.