Node verbindet sich mit MySQL und kapselt dessen Implementierungscode zum Hinzufügen, Löschen, Ändern und Prüfen

npm installiert MySQL

    const mysql = erfordern('mysql');
    
    let Verbindung = mysql.createConnection({
        Host: "localhost",
        Benutzer: 'root', 
        Passwort: "Passwort",
        Datenbank: „Test“
    });
 
Verbindung.Verbinden(Funktion(Fehler) {
  wenn (Fehler) {
    console.error('Verbindung fehlgeschlagen: ' + err.stack);
    zurückkehren;
  }
 
  console.log('Verbindung erfolgreich hergestellt, ID ' + connection.threadId);
});

Verbindung.Abfrage('SELECT * FROM t_user WHERE username = "whg"', (err, results, fields) => {
    wenn(fehler){
        console.log(fehler);
    }
    console.log(Ergebnisse);
})

Verbindung.Abfrage('INSERT INTO t_user(Benutzername, Passwort) VALUES(?, ?)',['whg', '123'], (err, Ergebnisse) => {
    wenn(fehler){
        console.log(fehler);
    }
    console.log(Ergebnisse);
})

Verbindung.Abfrage('LÖSCHEN VON t_user WHERE id = 1', (err, Ergebnisse) => {
    wenn(fehler){
        console.log(fehler);
    }
    console.log(Ergebnisse);
})

Verbindung.Abfrage('UPDATE t_user SET pass = "321" WHERE username = "whg"', (err, results) => {
    wenn(fehler){
        console.log(fehler);
    }
    console.log(Ergebnisse);
})

Verbindung.Ende(Funktion(Fehler) {
  
});
Verbindung.zerstören();

//Konfigurieren Sie die Parameter der Linkdatenbank module.exports = {
    Host: "localhost",
    Port: 3306, //Portnummer Datenbank: „nodetest“, //Datenbankname Benutzer: „root“, //Datenbankbenutzername Passwort: „123456“ //Datenbankpasswort };

let mysql = require('mysql'); //MySQL-Modul einführen var databaseConfig = require('./mysql.config'); //Daten im Datenbankkonfigurationsmodul einführen //Methode verfügbar machen module.exports = {
    Abfrage: Funktion (SQL, Parameter, Rückruf) {
        //Sie müssen bei jeder Verwendung eine Verbindung erstellen und die Verbindung schließen, nachdem der Datenvorgang abgeschlossen ist. var connection = mysql.createConnection(databaseConfig);        
        Verbindung.Verbinden(Funktion(Fehler){
            wenn(fehler){
                console.log('Datenbankverbindung fehlgeschlagen');
                Fehler machen;
            }
         //Datenoperation starten//Drei Parameter übergeben, der erste Parameter ist die SQL-Anweisung, der zweite Parameter sind die in der SQL-Anweisung erforderlichen Daten und der dritte Parameter ist die Rückruffunktion connection.query( sql, params, function(err,results,fields ){
           wenn(fehler){
                console.log('Datenvorgang fehlgeschlagen');
                Fehler machen;
            }
            //Gib die abgefragten Daten an die Rückruffunktion zurück callback && callback(results, fields);
            //Ergebnisse sind das Ergebnis der Datenoperation, Felder sind einige Felder der Datenbankverbindung //Um die Verbindung zur Datenbank zu beenden, müssen Sie die Anweisung abfragen, andernfalls wird die Verbindung direkt beendet, sobald diese Methode aufgerufen wird, und die Datenoperation schlägt fehl connection.end(function(err){
                  wenn(fehler){
                      console.log('Datenbankverbindung konnte nicht geschlossen werden!');
                      Fehler machen;
                  }
              });
           });
       });
    }
};

var db = erfordern('../model/mysql.js');
// Abfragebeispiel db.query('select * from t_user', [],function(result,fields){
    console.log('Abfrageergebnisse:');
    console.log(Ergebnis);
});
//Instanz hinzufügen var addSql = 'INSERT INTO websites(username,password) VALUES(?,?)';
var addSqlParams =['Herr Gulu', '666'];
db.query(addSql,addSqlParams,Funktion(Ergebnis,Felder){
    console.log('Erfolgreich hinzugefügt')
})