Node.js连接Mysql

发布于:2023-01-20 ⋅ 阅读:(205) ⋅ 点赞:(0)

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的知识点。 

本文含有隐藏内容,请 开通VIP 后查看

网站公告

今日签到

点亮在社区的每一天
去签到