1
复制代码

npm install mysql
复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
复制代码

const mysql = require('mysql');let connection = mysql.createConnection({host : 'localhost',user : 'root', password : 'password',database : 'test'
});connection.connect(function(err) {if (err) {console.error('连接失败: ' + err.stack);return;}console.log('连接成功 id ' + connection.threadId);
});
复制代码

1
2
3
4
5
6
复制代码

connection.query('SELECT * FROM t_user WHERE username = "whg"', (err, results, fields) => {if(err){console.log(err);}console.log(results);
})
复制代码

1
2
3
4
5
6
复制代码

connection.query('INSERT INTO t_user(username, pass) VALUES(?, ?)',['whg', '123'], (err, results) => {if(err){console.log(err);}console.log(results);
})
复制代码

1
2
3
4
5
6
复制代码

connection.query('DELETE FROM t_user  WHERE id = 1', (err, results) => {if(err){console.log(err);}console.log(results);
})
复制代码

1
2
3
4
5
6
复制代码

connection.query('UPDATE t_user SET pass = "321" WHERE username = "whg"', (err, results) => {if(err){console.log(err);}console.log(results);
})
复制代码

1
2
3
4
复制代码

connection.end(function(err) {});
connection.destroy();
复制代码

1
2
3
4
5
6
7
8
复制代码

//配置链接数据库参数
module.exports = {host : 'localhost',port : 3306,//端口号database : 'nodetest',//数据库名user : 'root',//数据库用户名password : '123456'//数据库密码
};
复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
复制代码

let mysql = require('mysql');//引入mysql模块
var databaseConfig = require('./mysql.config');  //引入数据库配置模块中的数据//向外暴露方法
module.exports = {query : function(sql,params,callback){//每次使用的时候需要创建链接，数据操作完成之后要关闭连接var connection = mysql.createConnection(databaseConfig);        connection.connect(function(err){if(err){console.log('数据库链接失败');throw err;}//开始数据操作//传入三个参数，第一个参数sql语句，第二个参数sql语句中需要的数据，第三个参数回调函数connection.query( sql, params, function(err,results,fields ){if(err){console.log('数据操作失败');throw err;}//将查询出来的数据返回给回调函数callback && callback(results, fields);//results作为数据操作后的结果，fields作为数据库连接的一些字段//停止链接数据库，必须再查询语句后，要不然一调用这个方法，就直接停止链接，数据操作就会失败connection.end(function(err){if(err){console.log('关闭数据库连接失败！');throw err;}});});});}
};
复制代码

1
2
3
4
5
6
7
8
9
10
11
12
复制代码

var db=require('../model/mysql.js');
// 查询实例
db.query('select * from t_user', [],function(result,fields){console.log('查询结果：');console.log(result);
});
//添加实例
var  addSql = 'INSERT INTO websites(username,password) VALUES(?,?)';
var  addSqlParams =['咕噜先森', '666'];
db.query(addSql,addSqlParams,function(result,fields){console.log('添加成功')
})
复制代码