node.js如何连接mysql数据库并且如何操作增、删、改、查

一、切换到你node.js安装路径下，

cd /lnmmpa/nodejs

二、安装mysql扩展

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 (isarray@0.0.1, inherits@2.0.1, string_decoder@0.10.31, core-util-is@1.0.1)

三、测试数据库连接，编辑存储文件testdatabase.js

var mysql  = require('mysql');  //调用MySQL模块

//创建一个connection
var connection = mysql.createConnection({
host     : '127.0.0.1',       //主机
user     : 'root',               //MySQL认证用户名
password : '123456',        //MySQL认证用户密码
port: '3306',                   //端口号
});
//创建一个connection
connection.connect(function(err){
if(err){
console.log('[query] - :'+err);
return;
}
console.log('[connection connect]  succeed!');
});
//执行SQL语句
connection.query('SELECT 1 + 1 AS solution', function(err, rows, fields) {
if (err) {
console.log('[query] - :'+err);
return;
}
console.log('The solution is: ', rows[0].solution);
});
//关闭connection
connection.end(function(err){
if(err){
return;
}
console.log('[connection end] succeed!');
});

四、执行上面文件

node testdatabase.js

提示如下信息代表连接成功

[connection connect] succeed!

The solution is: 2

[connection end] succeed!

五、查询

var mysql  = require('mysql');

var connection = mysql.createConnection({
host     : '127.0.0.1',       //主机
user     : 'root',               //MySQL认证用户名
password : '123456',        //MySQL认证用户密码
port: '3306',                   //端口号
database: 'cnlink_boss',
});

connection.connect();

var  userGetSql = 'SELECT * FROM cnlink_pjob_innermessage';
//查
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();

六、插入

var mysql  = require('mysql');

var connection = mysql.createConnection({
host     : '',       //主机
user     : '',               //MySQL认证用户名
password : '',        //MySQL认证用户密码
port: '3306',                   //端口号
database: 'cnlink_boss',
});

connection.connect();

var  userGetSql = 'SELECT * FROM cnlink_pjob_innermessage';
//查
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();

七、修改

var mysql  = require('mysql');

var connection = mysql.createConnection({
host     : '',       //主机
user     : '',               //MySQL认证用户名
password : '',        //MySQL认证用户密码
port: '3306',                   //端口号
database: 'cnlink_boss',
});

connection.connect();

var userModSql = 'UPDATE cnlink_pjob_innermessage SET INMES_CONTENT = ?,SEND_TIME = ? WHERE INMES_ID = ?';
var data = ['钟qwrewre23ds 儿的我的慰', '5678',5];
//改
connection.query(userModSql,data,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();

八、删除

var mysql  = require('mysql');

var connection = mysql.createConnection({
host     : '',       //主机
user     : '',               //MySQL认证用户名
password : '',        //MySQL认证用户密码
port: '3306',                   //端口号
database: 'cnlink_boss',
});

connection.connect();

var  userDelSql = 'DELETE FROM cnlink_pjob_innermessage WHERE INMES_ID = ?';
var data = [4];
//删
connection.query(userDelSql,data,function (err, result) {
if(err){
console.log('[DELETE ERROR] - ',err.message);
return;
}

console.log('--------------------------DELETE----------------------------');
console.log('DELETE affectedRows',result.affectedRows);
console.log('-----------------------------------------------------------------');
});

connection.end();