node.js mysql probleem geen errors en weet niet waarom

[wessel1512]

Mijn vraag
ik ben net begonnen met het programmeren van mysql in node.js Mijn programma zegt dat het werkt alleen als ik de mysql server check staat er geen data op de server. Krijg vederrest geen errors. Ik denk dat het een simpel probleem is alleen door mijn onervarenheid krijg ik het niet opgelost

De code

code:

async function Nu(message) {
    try {
        let feed = await parser.parseURL('https://www.nu.nl/rss/Algemeen');
        console.log(feed.title);
        feed.items.forEach(item => {
            message.channel.send('testing')
            let post = {title: item.title, link: item.link};
            let sql = 'INSERT INTO nu SET ?';
            let query = db.query(sql, post, (err, results) => {
                if (err) throw err;
                console.log(results);
            });
            console.log(post);
        });
    } catch (err) {
        return console.log(err);
    }
}

De logs

code:

{
  title: 'Autoriteiten vrezen dat dodental (70) aardbeving Sulawesi verder oploopt',
  link: 'https://www.nu.nl/buitenland/6102466/autoriteiten-vrezen-dat-dodental-70-aardbeving-sulawesi-verder-oploopt.html'
}
OkPacket {
  fieldCount: 0,
  affectedRows: 1,
  insertId: 0,
  serverStatus: 2,
  warningCount: 0,
  message: '',
  protocol41: true,
  changedRows: 0
}

software in gebruik
"@discordjs/opus": "^0.1.0",
"date-and-time": "^0.14.2",
"discord.js": "^11.5.1",
"ffmpeg-static": "^4.0.1",
"line-reader": "^0.4.0",
"mysql": "^2.18.1",
"node-cron": "^2.0.3",
"rss-parser": "^3.7.5",
"sleep": "^6.1.0",
"snekfetch": "^4.0.4"

[koppie]

Ik ben geen ster in Javascript, maar changedRows lijkt dat er niets gewijzigd is. Stomme vraag, moet je geen commit doen?

Oh ja is het niet met INSTERT INTO xxxx VALUES.. https://www.w3schools.com/sql/sql_insert.asp

[ Voor 28% gewijzigd door koppie op 17-01-2021 18:29 ]

[wessel1512]

Geen idee ik heb wat example code waar ik dit van af heb gebaseerd. En daar kan ik niets in vinden.

code:

const express = require('express');
const mysql = require('mysql');

// Create connection
const db = mysql.createConnection({
    host     : 'localhost',
    user     : 'root',
    password : '123456',
    database : 'nodemysql'
});

// Connect
db.connect((err) => {
    if(err){
        throw err;
    }
    console.log('MySql Connected...');
});

const app = express();

// Create DB
app.get('/createdb', (req, res) => {
    let sql = 'CREATE DATABASE nodemysql';
    db.query(sql, (err, result) => {
        if(err) throw err;
        console.log(result);
        res.send('Database created...');
    });
});

// Create table
app.get('/createpoststable', (req, res) => {
    let sql = 'CREATE TABLE posts(id int AUTO_INCREMENT, title VARCHAR(255), body VARCHAR(255), PRIMARY KEY(id))';
    db.query(sql, (err, result) => {
        if(err) throw err;
        console.log(result);
        res.send('Posts table created...');
    });
});

// Insert post 1
app.get('/addpost1', (req, res) => {
    let post = {title:'Post One', body:'This is post number one'};
    let sql = 'INSERT INTO posts SET ?';
    let query = db.query(sql, post, (err, result) => {
        if(err) throw err;
        console.log(result);
        res.send('Post 1 added...');
    });
});

// Insert post 2
app.get('/addpost2', (req, res) => {
    let post = {title:'Post Two', body:'This is post number two'};
    let sql = 'INSERT INTO posts SET ?';
    let query = db.query(sql, post, (err, result) => {
        if(err) throw err;
        console.log(result);
        res.send('Post 2 added...');
    });
});

// Select posts
app.get('/getposts', (req, res) => {
    let sql = 'SELECT * FROM posts';
    let query = db.query(sql, (err, results) => {
        if(err) throw err;
        console.log(results);
        res.send('Posts fetched...');
    });
});

// Select single post
app.get('/getpost/:id', (req, res) => {
    let sql = `SELECT * FROM posts WHERE id = ${req.params.id}`;
    let query = db.query(sql, (err, result) => {
        if(err) throw err;
        console.log(result);
        res.send('Post fetched...');
    });
});

// Update post
app.get('/updatepost/:id', (req, res) => {
    let newTitle = 'Updated Title';
    let sql = `UPDATE posts SET title = '${newTitle}' WHERE id = ${req.params.id}`;
    let query = db.query(sql, (err, result) => {
        if(err) throw err;
        console.log(result);
        res.send('Post updated...');
    });
});

// Delete post
app.get('/deletepost/:id', (req, res) => {
    let newTitle = 'Updated Title';
    let sql = `DELETE FROM posts WHERE id = ${req.params.id}`;
    let query = db.query(sql, (err, result) => {
        if(err) throw err;
        console.log(result);
        res.send('Post deleted...');
    });
});

app.listen('3000', () => {
    console.log('Server started on port 3000');
});

[Cartman!]

Gokje; je wacht niet tot je promises worden geresolved waardoor er uiteindelijk dus niks gebeurt omdat je functie stopt.

[wessel1512]

Dan zou je toch geen serverStatus moeten krijgen

[thlst]

Table name "nu" vs "posts" ?

Krijg je wel een error als je het direct in de mysql client probeert ?

(En gebruik altijd query parameterization)

[ Voor 18% gewijzigd door thlst op 17-01-2021 23:13 ]

[Verwijderd]

Affected rows is 1 dus hij doet wel wat. Misschien is een id toevoegen een idee. Kijken of die vult

[wessel1512]

ik heb het probleem gevonden mijn db viewer was niet aan het updaten

de code werkt gewoon 🙄

bedankt voor alle moeiten