Node.js连接Mysql

安装 mysql 驱动：npm install mysql

//请求 mysql

var mysql = req ui re(‘mysql‘);

//设置连接信息

var connection = mysql.createConn e c t i on({

host : ‘local host‘,

user : ‘root‘,

password : ‘123456’,

port: ‘3306’,

database : ‘数据库名’

});

//连接数据库

connection.connect();

//操作数据库，sql 语句为函数参数

connection.query(‘SELECT 1 + 1 AS sum‘, function (error, result s, fi el ds) {

抛出错误：

if (error) throw error;

//打印结果

console.log(‘The sum is: ‘, results[0].sum);

});

查询数据：

var mysql = req ui re(‘mysql‘);

var connection = mysql.createConnection({

host : ‘local host‘,

user : ‘root‘,

password : ‘123456’,

port: ‘3306’,

database: ‘数据库名’

});

connection.connect();

//创建查询的sql 语句

var sql = ‘SELECT * FROM 表名‘;

connection.query(sql,function (err, result) {

//打印错误信息

if(err){

console.lo g(‘[SELECT ERROR] – ‘,err.messa ge);

return;

}

//打印查询结果

console.log(result);

});

//断开连接

connection.end();

插入数据：

var mysql = req ui re(‘mysql‘);

var connection = mysql.createConnection({

host : ‘local h ost’,

user : ‘root‘,

password : ‘123456’,

port: ‘3306’,

database: ‘数据库名’

});

connection.connect();

//创建增加的sql语句

var addSql = ‘INSERT INTO 表名(Id,字段1,字段2) VALUES(0,?,?)’;

//创建数据

var addSqlPa rams = [‘数据1′, ‘数据2′];

connection.query(addSql,addSqlPar a ms,function (err, result) {

//打印插入数据的id

console.log(‘INSERT ID:’,res ult.insertId);

});

co nnection.end();

更新数据：

var mysql = req ui re(‘mysql‘);

v ar co nnection = mysql.createConnection({

host : ‘localhost’,

user : ‘root‘,

password : ‘123456’,

port: ‘3306’,

database: ‘数据库名’

});

co nnection.co nnect();

//创建修改数据的sql语句

v ar modSql = ‘UPDATE 表名 SET 字段1 = ?,字段2 = ? WHERE Id = ?’;

//创建数据

v a r modSqlPa r a ms = [‘数据1’, ‘数据2’,id序号];

co nnection.query(modSql,modSqlPa r a ms,function (err, result) {

//打印更新数据的条数

console.log(‘UPDATE affe cte dRows‘,result.affectedRows);

});

co nnection.end();

删除数据：

var mysql = req ui re(‘mysql‘);

var connection = mysql.createConnection({

host : ‘localhost’,

user : ‘root’,

password : ‘123456’,

port: ‘3306’,

database: ‘数据库名’

});

connection.connect();

//创建删除数据的sql语句

var d elSql = ‘DELETE FROM 表名 where id=id序号’;

connection.que ry(d elSql,function (err, result) {

//打印删除数据的条数

console.log(‘DELETE affectedRows‘,result.affectedRows);

});

connection.end();