先安装npm模块项目

npm init

安装mysql

npm install mysql --save

Nodejs 连接msyql

// 导入mysqlconst mysql = require('mysql');// 连接mysqlconst connection = mysql.createConnection({    host: '127.0.0.1',    user: 'root',    password: 'password',    port: '3306',    database: 'test'});connection.connect();// 结束连接connection.end();

增

// 引入mysqlconst mysql = require('mysql');// 连接myqlconst connection = mysql.createConnection({    host: '127.0.0.1',    user: 'root',    password: 'password',    port: '3306',    database: 'test',});connection.connect();// 插入语句let addSql = "insert into article (title, author, date) values (?, ?, now())";let addSqlParams = ['Today is noce', 'Bob'];// 执行插入语句connection.query(addSql, addSqlParams, (err, result) => {    if (err) {        throw err;    }    // 插入成功输出    console.log('插入成功');    console.log(result);});// 断开连接msyqlconnection.end();

删

// 引入mysqlconst mysql = require('mysql');// 连接mysqlconst connection = mysql.createConnection({    host: '127.0.0.1',    user: 'root',    password: 'password',    port: '3306',    database: 'test'});connection.connect();// 删除语句let sql = "delete from article where id = 10";// 执行删除语句connection.query(sql, (err, data) => {    if (err) {        throw err;    }    // 执行成功    console.log('delete success!');    console.log(data);});// 断开连接msyqlconnection.end();

改

// 导入mysqlconst mysql = require('mysql');// 连接mysqlconst connection = mysql.createConnection({    host: '127.0.0.1',    user: 'root',    password: 'password',    port: '3306',    database: 'test'});connection.connect();// 更新语句let modSql = "update article set title = ?, author = ? where id like ?";let modSqlParams = ['今晚学习nodejs', '一波万波', 12];// 执行更新语句connection.query(modSql, modSqlParams, (err, data) => {    if (err) {        throw err;    }    console.log('upload success!');    console.log(data)});connection.end();

查

// 导入mysqlconst mysql = require('mysql');// 连接mysqlconst connection = mysql.createConnection({    host: '127.0.0.1',    user: 'root',    password: 'password',    port: '3306',    database: 'test',});connection.connect();// 查询语句let sql = 'SELECT * FROM article';// 执行查询语句connection.query(sql, (err, data) => {    if (err) {        console.log('[SELECT ERROR] - ', err.message);        return;    }    // 查询成功    console.log(data);});connection.end();