Connectez-vous à la base de données MySQL dans NodeJS

Install MySQL Driver
Connect MySQL
Examplle: query(sql, callback)

1. Install MySQL Driver

Tout d'abord, vous devez créer un projet NodeJS, par exemple, je crée un projet baptisé NodeJSMySQL.

Puis, vous avez besoin d'installer la bibliothèque MySQL pour votre projet. Ouvrez la fenêtre CMD et CD au répertoire racine du projet et exécutez les commande comme ci-dessous :

npm install mysql

Après l'installation, un répertoire node_modules sera créé dans votre projet. Ce répertoire comprend des bibliothèques nécessaires pour que votre application puisse se connecter à la base de données MySQL :

2. Connect MySQL

Dans l'étape précédente, vous avec créé un projet avec succès et installé les bibliothèques MySQL pour ce projet. Maintenant, créez un petit exemple, connectez- vous à la base de données MySQL. OK, créez un fichier connection-example.js :

connection-example.js

var mysql = require('mysql');

console.log('Get connection ...');

var conn = mysql.createConnection({
  database: 'mytestdb',
  host: "localhost",
  user: "root",
  password: "12345"
});

conn.connect(function(err) {
  if (err) throw err;
  console.log("Connected!");
});

Exécutez l'exemple :

node connection-example.js

Error: ER_NOT_SUPPORTED_AUTH_MODE

Lorsque vous exécutez l'exemple ci-dessus, vous recevrez probablement un message d'erreur comme ci-dessous :

** Error **

E:\NODEJS\NodeJSMySQL\node_modules\mysql\lib\protocol\Parser.js:80
        throw err; // Rethrow non-MySQL errors
        ^

Error: ER_NOT_SUPPORTED_AUTH_MODE: Client does not support authentication protocol requested by server; consider upgrading MySQL client
    at Handshake.Sequence._packetToError (E:\NODEJS\NodeJSMySQL\node_modules\mysql\lib\protocol\sequences\Sequence.js:52:14)
    at Handshake.ErrorPacket (E:\NODEJS\NodeJSMySQL\node_modules\mysql\lib\protocol\sequences\Handshake.js:130:18)
    at Protocol._parsePacket (E:\NODEJS\NodeJSMySQL\node_modules\mysql\lib\protocol\Protocol.js:279:23)
    at Parser.write (E:\NODEJS\NodeJSMySQL\node_modules\mysql\lib\protocol\Parser.js:76:12)
    at Protocol.write (E:\NODEJS\NodeJSMySQL\node_modules\mysql\lib\protocol\Protocol.js:39:16)
    at Socket.<anonymous> (E:\NODEJS\NodeJSMySQL\node_modules\mysql\lib\Connection.js:103:28)
    at emitOne (events.js:116:13)
    at Socket.emit (events.js:211:7)
    at addChunk (_stream_readable.js:263:12)
    at readableAddChunk (_stream_readable.js:250:11)
    --------------------
    at Protocol._enqueue (E:\NODEJS\NodeJSMySQL\node_modules\mysql\lib\protocol\Protocol.js:145:48)
    at Protocol.handshake (E:\NODEJS\NodeJSMySQL\node_modules\mysql\lib\protocol\Protocol.js:52:23)
    at Connection.connect (E:\NODEJS\NodeJSMySQL\node_modules\mysql\lib\Connection.js:130:18)
    at Object.<anonymous> (E:\NODEJS\NodeJSMySQL\connection-example.js:11:6)
    at Module._compile (module.js:652:30)
    at Object.Module._extensions..js (module.js:663:10)
    at Module.load (module.js:565:32)
    at tryModuleLoad (module.js:505:12)
    at Function.Module._load (module.js:497:3)
    at Function.Module.runMain (module.js:693:10)

La cause de l'erreur ci-dessus est que vous utilisez la base de données trop nouvelle MySQL (version> = 8.x). Les anciennes versions de MySQL (5.x) utilisent le plugin d'authentification tel que SHA256_PASSWORD. La version MySQL 8.x utilise le plugin d'authentification tel que SHA2_PASSWORD. La bibliothèque NodeJS MySQL n'a pas encore changé. Il utilise le plugin d'authentification tel que SHA256_PASSWORD et n'a pas supporté SHA2_PASSWORD.

Release	General availability	Latest minor version	Latest release	End of support
5.1	2008-11-14	5.1.73	2013-12-03	December 2013
5.5	2010-12-03	5.5.60	2018-04-19	December 2018
5.6	2013-02-05	5.6.40	2018-04-19	February 2021
5.7	2015-10-21	5.7.22	2018-04-19	October 2023
8.0	2018-04-19	8.0.11	2018-04-19	N/A

Pour résoudre l'erreur ci-dessus, ouvrez la fenêtre "MySQL Command Line Client" et exécutez la commande suivante :

# Syntax:

ALTER USER 'my_username'@'my_host' IDENTIFIED WITH 'mysql_native_password' BY 'my_password';


# Example:

ALTER USER 'root'@'localhost' IDENTIFIED WITH 'mysql_native_password' BY '12345';

Une autre façon est que vous pouvez créer un objet Connection à partir d'une connection_string :

** Create Connection from ConnectionString **

var connString = 'mysql://myuser:mypass@myhost/mdb?charset=utf8_general_ci&timezone=-0700';

var conn = mysql.createConnection(connString);

3. Examplle: query(sql, callback)

Le NodeJS MySQL API utilise la méthode query pour exécuter toutes les actions de la base de données comprenant :

DDL: Create DB, Table, ...
DML: Insert, Update, Query, Call Function, Procedure,...

** query method **

// query method:

query(sql, [values], callback)

// Example:

query(sql, [values], function(err, rows, fields)  {

});

Dans l'exemple ci-dessous, vous vous connectez à la base de données MySQL et implémentez et faites des manipulations avec le code :

Drop le tableau EMPLOYEES s'il existe.
Créez le tableau EMPLOYEES.
Insérez quelques enregistrementss (record) au tableau EMPLOYEES.

first-example.js

var mysql = require('mysql');

var conn = mysql.createConnection({
  database: 'mytestdb',
  host: "localhost",
  user: "root",
  password: "12345"
});


conn.connect(function(err) {
    if (err) {
        throw err;
    }
    console.log("Connected!");

    // Drop EMPLOYEES table if Exists!!
    var sql1 = "DROP TABLE IF EXISTS Employees ";

    conn.query(sql1, function(err, results) {
        if (err) throw err;
        console.log("Table EMPLOYEES dropped");
    });

    // Create EMPLOYEES Table.
    var sql2 = "CREATE TABLE Employees " +
        " (Id INT not null AUTO_INCREMENT, " +
        " Emp_No VARCHAR(20), " +
        " Full_Name VARCHAR(255), " +
        " Hire_Date DATE, " +
        " PRIMARY KEY (Id) )";

    conn.query(sql2, function(err, results) {
        if (err) throw err;
        console.log("Table Employees created");
    });

    var empNos = ["E01", "E02", "E03"];
    var fullNames = ["John", "Smith", "Gates"];
    var hireDates = ["22/10/2001", "11/11/2000", "12/12/1990"];

    // Insert Datas to EMPLOYEES.
    for (var i = 0; i < empNos.length; i++) {
        var sql3 = "Insert into Employees (Emp_No, Full_Name, Hire_Date) " //
            +
            " Values ('" + empNos[i] + "', '" + fullNames[i] + "', STR_TO_DATE('" + hireDates[i] + "', '%d/%m/%Y') )";

        conn.query(sql3, function(err, results) {
            if (err) throw err;
            console.log("Insert a record!");
        });
    }

});

Exécutez l'exemple :

node first-example.js

Phương thức mysql.format(sql, replaces) giúp bạn chuẩn bị một mệnh đề SQL (SQL Statement), nó giúp bạn tạo ra một mênh đề SQL đơn giản và dễ nhìn hơn:

** mysql.format(sql_template, replaces) **

// Select * from EMPLOYEES where HIRE_DATE > STR_TO_DATE( '20/11/1995' , '%d/%m/%Y')
var sql_template = "Select * from ?? where ?? > STR_TO_DATE( ? , '%d/%m/%Y') ";

var replaces = ['EMPLOYEES', 'HIRE_DATE', '20/11/1995'];
sql = mysql.format(sql_template, replaces);

console.log("SQL="+ sql);

Ví dụ:

prepared-query-example.js

var mysql = require('mysql');

var conn = mysql.createConnection({
    database: 'mytestdb',
    host: "localhost",
    user: "root",
    password: "12345"
});


conn.connect(function(err) {
    if (err) throw err;

    console.log("Connected!");

    // Select * from EMPLOYEES where HIRE_DATE > STR_TO_DATE( '20/11/1995' , '%d/%m/%Y')
    var sql_template = "Select * from ?? where ?? > STR_TO_DATE( ? , '%d/%m/%Y') ";

    var replaces = ['EMPLOYEES', 'HIRE_DATE', '20/11/1995'];
    sql = mysql.format(sql_template, replaces);

    console.log("SQL=" + sql);
    console.log(" ************************ ");


    conn.query(sql, function(err, rows, fields) {
        if (err) throw err;
        for (var i = 0; i < rows.length; i++) {
            console.log("\n------ Row " + i + " ---- ");
            console.log(rows[i]);
            console.log("\n");
            console.log("  - Emp_No: " + rows[i].Emp_No)
            console.log("  - Full_Name: " + rows[i].Full_Name);
        }
    });

});

Data of rows:

[ RowDataPacket {
    Id: 1,
    Emp_No: 'E01',
    Full_Name: 'John',
    Hire_Date: 2001-10-21T17:00:00.000Z },

  RowDataPacket {
    Id: 2,
    Emp_No: 'E02',
    Full_Name: 'Smith',
    Hire_Date: 2000-11-10T17:00:00.000Z } ]

Data of fields

[ FieldPacket {
    catalog: 'def',
    db: 'mytestdb',
    table: 'EMPLOYEES',
    orgTable: 'employees',
    name: 'Id',
    orgName: 'Id',
    charsetNr: 63,
    length: 11,
    type: 3,
    flags: 16899,
    decimals: 0,
    default: undefined,
    zeroFill: false,
    protocol41: true },
  FieldPacket {
    catalog: 'def',
    db: 'mytestdb',
    table: 'EMPLOYEES',
    orgTable: 'employees',
    name: 'Emp_No',
    orgName: 'Emp_No',
    charsetNr: 33,
    length: 60,
    type: 253,
    flags: 0,
    decimals: 0,
    default: undefined,
    zeroFill: false,
    protocol41: true },
  FieldPacket {
    catalog: 'def',
    db: 'mytestdb',
    table: 'EMPLOYEES',
    orgTable: 'employees',
    name: 'Full_Name',
    orgName: 'Full_Name',
    charsetNr: 33,
    length: 765,
    type: 253,
    flags: 0,
    decimals: 0,
    default: undefined,
    zeroFill: false,
    protocol41: true },
  FieldPacket {
    catalog: 'def',
    db: 'mytestdb',
    table: 'EMPLOYEES',
    orgTable: 'employees',
    name: 'Hire_Date',
    orgName: 'Hire_Date',
    charsetNr: 63,
    length: 10,
    type: 10,
    flags: 128,
    decimals: 0,
    default: undefined,
    zeroFill: false,
    protocol41: true } ]

Connectez-vous à la base de données MySQL dans NodeJS

1. Install MySQL Driver

2. Connect MySQL

3. Examplle: query(sql, callback)

Tutoriels de programmation NodeJS

Tutoriels de programmation NodeJS

Articles les plus récents