“Node.js:操作mysql数据库“

Node.js中操作mysql数据库

mysql模块是托管于npm的第三方模块,它提供了Node.js项目中连接和操作mysql数据库的能力。

在项目中操作数据库的步骤

(1).安装mysql数据库的第三方模块(mysql)

npm install mysql

(2).通过mysql模块连接到mysql数据库

mysql.createPool()

(3).通过mysql模块执行sql语句

db.query()

1.操作mysql数据库

// 1.导入mysql模块
const mysql = require('mysql')
// 2.创建与mysql数据库的连接
const db = mysql.createPool({

    host: '127.0.0.1',          // 数据库的ip地址
    user: 'root',               // 登录数据库的账号
    password: 'pancc',          // 登录数据库的密码
    database: 'my_db_01'        // 指定要操作的数据库
})

// 测试mysql模块能否正常运行
// 3.执行sql语句 
db.query('SELECT 1', (err, results) => {

    if (err) return console.log(err.message)
    console.log(results)        // [ RowDataPacket { '1': 1 } ] 说明数据库连接正常
})

db.query()用来执行sql语句
sql执行成功,err默认为null,results为返回的数据

2.查询数据

select 字段1,字段2 from 表名

const mysql = require('mysql')
const db = mysql.createPool({

    host: '127.0.0.1',
    user: 'root',
    password: 'pancc',
    database: 'my_db_01'
})
// 查询user表的所有数据
const sqlStr = 'select * from users'
db.query(sqlStr, (err, results) => {

    // 查询失败
    if (err) return console.log(err.message)
    // 查询成功 
    console.log(results)
})

注意: 如果执行的是select查询语句,则results是数组

3.插入数据

insert into 表名 (字段1,字段2) values(值1,值2)

const mysql = require('mysql')
const db = mysql.createPool({

    host: '127.0.0.1',
    user: 'root',
    password: 'pancc',
    database: 'my_db_01'
})
// 待新增的数据
const user = { username: '马超', password: '000000' }
// 待执行的sql语句
const sqlStr = 'insert into users (username,password) values(?,?)'
// 执行sql语句    
db.query(sqlStr, [user.username, user.password], (err, results) => {  // 

    if (err) return console.log(err.message)
    if (results.affectedRows === 1) {
        console.log('插入数据成功！')
    }
})

sql中英文?为占位符,使用数组的形式,依次为?占位符指定具体的值
注意: 如果执行的是insert插入语句,则results是一个对象
可以通过results的affectedRows属性来判断是否插入数据成功

插入数据的简便方式

const mysql = require('mysql')
const db = mysql.createPool({

    host: '127.0.0.1',
    user: 'root',
    password: 'pancc',
    database: 'my_db_01'
})
// 待新增的数据
const user = { username: '马超', password: '000000' }
// 待执行的sql语句
const sqlStr = 'insert into users set ?'
// 执行sql语句    
db.query(sqlStr, [user.username, user.password], (err, results) => {  // 

    if (err) return console.log(err.message)
    if (results.affectedRows === 1) {
        console.log('插入数据成功！')
    }
})

向表中新增数据时,如果数据对象的每个属性和数据表字段一一对应,就可以以便捷的方式插入数据

4.更新数据

update 表名 set 字段1=值1,字段2= 值2

const mysql = require('mysql')
const db = mysql.createPool({

    host: '127.0.0.1',
    user: 'root',
    password: 'pancc',
    database: 'my_db_01'
})

// 更新的数据对象
const user = { id: 4, username: '张辽', password: '888888' }
// sql语句
const sqlStr = 'update users set username=?,password=? where id=?'
// 执行sql语句
db.query(sqlStr, [user.username, user.password, user.id], (err, results) => {

    if (err) return console.log(err.message)
    if (results.affectedRows === 1) {
        console.log('更新数据成功!')
    }
})

注意: 如果执行的是update更新语句,则results是一个对象

更新数据的简便方式

const mysql = require('mysql')
const db = mysql.createPool({

    host: '127.0.0.1',
    user: 'root',
    password: 'pancc',
    database: 'my_db_01'
})
// 更新的数据对象
const user = { id: 4, username: '陆逊', password: '777777' }
// sql语句
const sqlStr = 'update users set ? where id=?'
// 执行sql
db.query(sqlStr, [user, user.id], (err, results) => {

    if (err) return console.log(err.message)
    if (results.affectedRows === 1) {

        console.log('更新数据成功!')
    }
})

向表中更新数据时,如果数据对象的每个属性和数据表字段一一对应,就可以以便捷的方式插入数据

5.删除数据

delete from 表名

const mysql = require('mysql')
const db = mysql.createPool({

    host: '127.0.0.1',
    user: 'root',
    password: 'pancc',
    database: 'my_db_01'
})

// sql语句
const sqlStr = 'delete from users where id=?'
// 执行sql
db.query(sqlStr, 17, (err, results) => {

    if (err) return console.log(err.message)
    // 注意: 执行delete语句的时候,结果results也是一个对象
    if (results.affectedRows === 1) {

        console.log('删除数据成功!')
    }
})

在删除数据时,推荐根据id这样的唯一标识,来删除对应的数据
如果sql语句中只有一个占位符,为?占位符指定具体的值,可以省略数组形式
注意: 执行delete语句的时候,结果results也是一个对象

6.标记删除

const mysql = require('mysql')
const db = mysql.createPool({

    host: '127.0.0.1',
    user: 'root',
    password: 'pancc',
    database: 'my_db_01'
})
// 标记删除: 使用update语句替代delete语句;只更新数据的状态,并没有真正删除
const sqlStr = 'update users set status=? where id=?'
db.query(sqlStr, [1, 4], (err, results) => {

    if (err) return console.log(err.message)
    if (results.affectedRows === 1) {

        console.log('标记删除成功!')
    }
})