[NODE.JS] Zapytanie do bazy nie działa każdorazowo

Question

Witam. W mojej app'ce wykorzystuje funkcje do pobierania aktualnych wartości dla konkretnego użytkownika. Funkcje którą wykorzystuje wygląda następująco:

function getAccountInfoSQL(identifier, callback){
	pool.query("SELECT * from users WHERE userID = " + pool.escape(identifier), function(err, row) {
		if (err){
			//TODO: ERR mess
			return;
		}
		callback(row[0]);
	});
}

Oczywiście to działa, ale nie pobiera aktualnej wartości która została zaktualizowana

Instrukcja warunkowa 

//if(...){
//nowa wartość
pool.query('UPDATE `users` SET `name` =  '+newname+' WHERE `userID` = '+ID);
//pobranie nowej wartości
getAccountInfoSQL(ID, function(account){
		console.log(account.name)
});                                                                                          

Być może ktoś z obecnych widzi jaki błąd popełniłem.

Answer 1

Nie wiem jakiej libki używasz ale na 99% ignorujesz promise, który jest zreturnowany z pool.query na co wskazuje to

Oczywiście to działa, ale nie pobiera aktualnej wartości która została zaktualizowana

Tutaj

pool.query('UPDATE `users` SET `name` =  '+newname+' WHERE `userID` = '+ID);
//pobranie nowej wartości
getAccountInfoSQL(ID, function(account){
        console.log(account.name)
});                                     

prawdopodobnie pool.query zwraca promise, którego nie obsługujesz i funkcja getAccountInfoSQL jest defacto wywołana zanim pool.query skończy swoje zadanie stąd wynika problem.

Spróbuj tak

pool.query('UPDATE `users` SET `name` =  '+newname+' WHERE `userID` = '+ID)
    .then(() => {
        getAccountInfoSQL(ID, function (account) {
            console.log(account.name)
        });
    });

 

Comments

Wyrzuca mi w konsoli 

pool.query(...).then is not a function

A do łącznia z bazą danych używam standardowej libki (mysql)

Link do libki:

https://www.npmjs.com/package/mysql

 

---

No to masz dokumentacje... Nie zwraca promise tylko trzeba callback funkcje przekazać:

const sql = 'UPDATE `users` SET `name` =  '+newname+' WHERE `userID` = '+ID;
pool.query(sql, (error) => {
        if (error) throw error;
        getAccountInfoSQL(ID, function (account) {
            console.log(account.name)
        });
})

 

---

Właśnie doszedłem do tego. Dzięki za pomoc.

---

Czy za każdym razem powinienem zamykać połączenie?

---

Depends on what are your needs.

Creating a connection takes some time, so if you need to access database frequently it's better to keep the connection open.

Jest taka apka, w której można na tego typu pytania szybko znaleźć odpowiedź - google.com, polecam