node操作数据库

• node.js操作数据库

//下载相关的文件
npm init -y
npm  install  mysql --save
npm  install  express --save
npm  install  body-parser --save

• 查询数据

/*
    数据库基本操作步骤
*/
const mysql = require('mysql');

// 创建数据库连接
let connection = mysql.createConnection({
    host: 'localhost', //数据库所在的服务器域名或者IP
    user: 'root', //用户名
    password: '', //密码
    database: 'book' //数据库名称
});

// 执行连接动作
connection.connect();

// 执行数据库操作
let sql = 'select * from user';

connection.query(sql, (err, rows, fields) => {
    if (err) throw err;
    console.log('The solution is: ', rows[0].username);
});

// 关闭数据库
connection.end();

/*
    数据库基本操作步骤-查询操作
*/
const mysql = require('mysql');
// 创建数据库连接
let connection = mysql.createConnection({
    host: 'localhost', //数据库所在的服务器域名或者IP
    user: 'root', //用户名
    password: '', //密码
    database: 'book' //数据库名称
});
// 执行连接动作
connection.connect();
// 执行数据库操作
let sql = 'select * from user where id=?';
let data = [1];

connection.query(sql,data, (err, rows, fields) => {
    if (err) throw err;
    console.log('The solution is: ', rows[0]);
});

// 关闭数据库
connection.end();

• 增加数据

/*
    数据库基本操作步骤-插入操作
*/
const mysql = require('mysql');
// 创建数据库连接
let connection = mysql.createConnection({
    host: 'localhost', //数据库所在的服务器域名或者IP
    user: 'root', //用户名
    password: '', //密码
    database: 'book' //数据库名称
});
// 执行连接动作
connection.connect();
// 执行数据库操作
let sql = 'insert into user set ?';

let data = {
    username : 'lisi',
    password : '111',
    age : 12
}
connection.query(sql,data,(err, rows, fields) => {
    if (err) throw err;
    console.log('The solution is: ', rows.affectedRows);
});
// 关闭数据库
connection.end();

• 删除数据

/*
    数据库基本操作步骤-删除操作
*/
const mysql = require('mysql');
// 创建数据库连接
let connection = mysql.createConnection({
    host: 'localhost', //数据库所在的服务器域名或者IP
    user: 'root', //用户名
    password: '', //密码
    database: 'book' //数据库名称
});
// 执行连接动作
connection.connect();
// 执行数据库操作
let sql = 'delete from user where id=?';
let data = [10];

connection.query(sql,data,(err, rows, fields) => {
    if (err) throw err;
    console.log('The solution is: ', rows.affectedRows);
});
// 关闭数据库
connection.end();

• 修改数据

/*
    数据库基本操作步骤-更新操作
*/
const mysql = require('mysql');
// 创建数据库连接
let connection = mysql.createConnection({
    host: 'localhost', //数据库所在的服务器域名或者IP
    user: 'root', //用户名
    password: '', //密码
    database: 'book' //数据库名称
});
// 执行连接动作
connection.connect();

// 执行数据库操作
let sql = 'update user set username=?,password=?,age=? where id=?';

let data = ['zhangsan','123456',15,9];

connection.query(sql,data,(err, rows, fields) => {
    if (err) throw err;
    console.log('The solution is: ', rows.affectedRows);
});
// 关闭数据库
connection.end();