Verwenden Sie Nodejs, um eine Verbindung zu MySQL herzustellen und grundlegende Vorgänge zu implementieren

Dieser Artikel stellt hauptsächlich die Methode vor, mit der NodeJS eine Verbindung zu MySQL herstellt und die Vorgänge zum Hinzufügen, Löschen, Ändern und Abfragen realisiert. Er kombiniert das Beispielformular mit einer detaillierten Analyse der Verbindung von NodeJS zur MySQL-Datenbank und der Erstellung einer MySQL-Datenbank und die Nodejs zum Hinzufügen, Löschen, Ändern und Abfragen von MySQL. Spezifische Implementierungstipps für verwandte Vorgänge finden Freunde in Not unter

In diesem Artikel wird beschrieben, wie Nodejs eine Verbindung zu MySQL herstellt und das Hinzufügen, Löschen, Ändern und Implementieren durchführt Kontrollvorgänge. Teilen Sie es als Referenz mit allen. Die Details lauten wie folgt:

1. Vorbereitung

Nodejs-Tutorials verwenden meist den Betrieb von Mongodb als Beispiel . Mongodb weist jedoch einige Einschränkungen auf, die auf der offiziellen Website angegeben sind. Ich habe vor, MySQL zu verwenden, da ich noch etwas Erfahrung damit habe. Konzentrieren Sie sich zunächst auf die Forschung. node-mysql ist derzeit der beliebteste MySQL-Treiber unter node. Ich habe es ursprünglich verwendet, weil die asynchrone Rückrufmethode wirklich viele Fallstricke hat.

Der Paketname des folgenden Projekts ist mysql und die Version ist mysql@ 2.5.4

Erklären Sie zunächst den unten gezeigten Code und werden nicht erklärt später

rrree

Die Bedeutung des Codes ist sehr einfach. Wenn Sie tiefer gehen möchten, können Sie ihn auf der offiziellen Website oben überprüfen. Konfigurationen wie Host und Benutzer sollten denjenigen klar sein, die MySQL-Datenbankanwendungen geschrieben haben. Bitte ändern Sie die entsprechenden Parameter selbst. Der folgende Code geht davon aus, dass es in der Datenbank „my_news_test“ eine Tabelle mit dem Namen „node_use“ gibt. Die Tabelle hat drei Attribute:

id: automatisch inkrementierter Primärschlüssel
name: Der Name hat eindeutige Einschränkungen
Alter: Alter

MySQL testen MySQL-Version: 5.5

2. Erstellen Sie die Datenbank und 5 Elemente einfügen

var connection = mysql.createConnection({
 host   : '127.0.0.1',
 user   : 'root',
 password : 'root123',
 port: '3306',
 database: 'my_news_test',
});

3. Zuerst die Umgebung testen

1 Paket von nodejs

Source Database    : my_news_test
SET FOREIGN_KEY_CHECKS=0;
-- ----------------------------
-- Table structure for node_user
-- ----------------------------
DROP TABLE IF EXISTS `node_user`;
CREATE TABLE `node_user` (
 `id` int(11) NOT NULL AUTO_INCREMENT,
 `name` varchar(30) DEFAULT NULL,
 `age` int(8) DEFAULT NULL,
 PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of node_user
-- ----------------------------
INSERT INTO `node_user` VALUES ('1', 'admin', '32');
INSERT INTO `node_user` VALUES ('2', 'dans88', '45');
INSERT INTO `node_user` VALUES ('3', '张三', '35');
INSERT INTO `node_user` VALUES ('4', 'ABCDEF', '88');
INSERT INTO `node_user` VALUES ('5', '李小二', '65');

2. Schreiben Sie Code für die Interaktion zwischen nodejs und mysql

D:\User\myappejs4>npm install mysql
mysql@2.5.4 node_modules\mysql
├── require-all@0.0.8
├── bignumber.js@1.4.1
└── readable-stream@1.1.13 (inherits@2.0.1, string_decoder@0.10.31, isarray@0
.0.1, core-util-is@1.0.1)

3. Ausführen von Ergebnissen

4. Node.js kombiniert mit den Add-, Lösch-, Änderungs- und Abfragevorgängen

1. Fügen Sie

//mysql.js
//首先需要安装nodejs 的mysql包
//npm install mysql
//编写nodejs与mysql交互的代码
var mysql = require('mysql');
var TEST_DATABASE = 'my_news_test';
var TEST_TABLE = 'node_user';
//创建连接
var client = mysql.createConnection({
 user: 'root',
 password: 'root123',
});
client.connect();
client.query("use " + TEST_DATABASE);
client.query(
 'SELECT * FROM '+TEST_TABLE,
 function selectCb(err, results, fields) {
  if (err) {
   throw err;
  }
    if(results)
   {
     for(var i = 0; i < results.length; i++)
     {
       console.log("%d\t%s\t%s", results[i].id, results[i].name, results[i].age);
     }
   }
  client.end();
 }
);

hinzu und führen Sie es wie folgt aus

D:\User\myappejs4>node mysqltest.js
1    admin  32
2    dans88 45
3    张三  35
4    ABCDEF  88
5    李小二 65

2. Ändern Sie

var mysql = require('mysql');
var connection = mysql.createConnection({
 host   : '127.0.0.1',
 user   : 'root',
 password : 'root123',
 port: '3306',
 database: 'my_news_test',
});
connection.connect();
var userAddSql = 'INSERT INTO node_user(id,name,age) VALUES(0,?,?)';
var userAddSql_Params = ['Wilson', 55];
//增 add
connection.query(userAddSql,userAddSql_Params,function (err, result) {
    if(err){
     console.log('[INSERT ERROR] - ',err.message);
     return;
    }
    console.log('-------INSERT----------');
    //console.log('INSERT ID:',result.insertId);
    console.log('INSERT ID:',result);
    console.log('#######################');
});
connection.end();

und das Ergebnis ist wie folgt

D:\User\myappejs4>node mysqltestadd.js
-------INSERT----------
INSERT ID: { fieldCount: 0,
 affectedRows: 1,
 insertId: 6,
 serverStatus: 2,
 warningCount: 0,
 message: '',
 protocol41: true,
 changedRows: 0 }
#######################

3. Überprüfen Sie die Operation

var mysql = require('mysql');
var connection = mysql.createConnection({
 host   : '127.0.0.1',
 user   : 'root',
 password : 'root123',
 port: '3306',
 database: 'my_news_test',
});
connection.connect();
var userModSql = 'UPDATE node_user SET name = ?,age = ? WHERE id = ?';
var userModSql_Params = ['Hello World',99,7];
//改 up
connection.query(userModSql,userModSql_Params,function (err, result) {
  if(err){
     console.log('[UPDATE ERROR] - ',err.message);
     return;
  }
 console.log('----------UPDATE-------------');
 console.log('UPDATE affectedRows',result.affectedRows);
 console.log('******************************');
});
connection.end();

Das Ergebnis ist wie folgt:

D:\User\myappejs4>node mysqltest_up.js
----------UPDATE-------------
UPDATE affectedRows 1
******************************

4. Löschvorgang

var mysql = require('mysql');
var connection = mysql.createConnection({
 host   : '127.0.0.1',
 user   : 'root',
 password : 'root123',
 port: '3306',
 database: 'my_news_test',
});
connection.connect();
var userGetSql = 'SELECT * FROM node_user';
//查 query
connection.query(userGetSql,function (err, result) {
    if(err){
     console.log('[SELECT ERROR] - ',err.message);
     return;
    }
    console.log('---------------SELECT----------------');
    console.log(result);
    console.log('$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$');
});
connection.end();

Das Obige habe ich für alle zusammengestellt Ich hoffe, dass es in Zukunft für alle hilfreich sein wird.

Verwandte Artikel:

Wie packe ich statische Ressourcen in Vue

Was sind die Verwendungszwecke von async&await in Koa2?

So implementieren Sie das Klickladen von fünfstufigen Regionen im ganzen Land im zTree-Baum-Plug-in

So implementieren Sie Node+ Express personalisierter Chatroom?

Das obige ist der detaillierte Inhalt vonVerwenden Sie Nodejs, um eine Verbindung zu MySQL herzustellen und grundlegende Vorgänge zu implementieren. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!