node.js连接mysql简单步骤,如下:
安装mysql驱动:npm install mysql
连接数据库:
//请求mysql
var mysql = require('mysql');
//设置连接信息
var connection = mysql.createConnection({
host : 'localhost',
user : 'root',
password : '123456',
port: '3306',
database : '数据库名'
});
//连接数据库
connection.connect();
//操作数据库,sql语句为函数参数
connection.query('SELECT 1 + 1 AS sum', function (error, results, fields) {
抛出错误:
if (error) throw error;
//打印结果
console.log('The sum is: ', results[0].sum);
});
查询数据:
var mysql = require('mysql');
var connection = mysql.createConnection({
host : 'localhost',
user : 'root',
password : '123456',
port: '3306',
database: '数据库名'
});
connection.connect();
//创建查询的sql语句
var sql = 'SELECT * FROM 表名';
connection.query(sql,function (err, result) {
//打印错误信息
if(err){
console.log('[SELECT ERROR] - ',err.message);
return;
}
//打印查询结果
console.log(result);
});
//断开连接
connection.end();
插入数据:
var mysql = require('mysql');
var connection = mysql.createConnection({
host : 'localhost',
user : 'root',
password : '123456',
port: '3306',
database: '数据库名'
});
connection.connect();
//创建增加的sql语句
var addSql = 'INSERT INTO 表名(Id,字段1,字段2) VALUES(0,?,?)';
//创建数据
var addSqlParams = ['数据1', '数据2'];
connection.query(addSql,addSqlParams,function (err, result) {
//打印插入数据的id
console.log('INSERT ID:',result.insertId);
});
connection.end();
更新数据:
var mysql = require('mysql');
var connection = mysql.createConnection({
host : 'localhost',
user : 'root',
password : '123456',
port: '3306',
database: '数据库名'
});
connection.connect();
//创建修改数据的sql语句
var modSql = 'UPDATE 表名 SET 字段1 = ?,字段2 = ? WHERE Id = ?';
//创建数据
var modSqlParams = ['数据1', '数据2',id序号];
connection.query(modSql,modSqlParams,function (err, result) {
//打印更新数据的条数
console.log('UPDATE affectedRows',result.affectedRows);
});
connection.end();
删除数据:
var mysql = require('mysql');
var connection = mysql.createConnection({
host : 'localhost',
user : 'root',
password : '123456',
port: '3306',
database: '数据库名'
});
connection.connect();
//创建删除数据的sql语句
var delSql = 'DELETE FROM 表名 where id=id序号';
connection.query(delSql,function (err, result) {
//打印删除数据的条数
console.log('DELETE affectedRows',result.affectedRows);
});
connection.end();
获取精确数据:result[索引].变量名或者result.变量名
以上为node.js连接mysql的知识点。