// 1. 導(dǎo)入 mysql 模塊
const mysql = require('mysql')
// 2. 建立與 MySQL 數(shù)據(jù)庫(kù)的連接關(guān)系
const db = mysql.createPool({
  host: '127.0.0.1', // 數(shù)據(jù)庫(kù)的 IP 地址
  user: 'root', // 登錄數(shù)據(jù)庫(kù)的賬號(hào)
  password: '123456', // 登錄數(shù)據(jù)庫(kù)的密碼
  database: 'mydb01', // 指定要操作哪個(gè)數(shù)據(jù)庫(kù)
})

// 測(cè)試 mysql 模塊能否正常工作
 db.query('select 1', (err, results) => {
  // mysql 模塊工作期間報(bào)錯(cuò)了
  if(err) return console.log(err.message)
  // 能夠成功的執(zhí)行 SQL 語(yǔ)句
  console.log(results)
}) 

// 查詢(xún) user 表中所有的數(shù)據(jù)
 const sqlStr = 'select * from user'
db.query(sqlStr, (err, results) => {
  // 查詢(xún)數(shù)據(jù)失敗
  if (err) return console.log(err.message)
  // 查詢(xún)數(shù)據(jù)成功
  // 注意：如果執(zhí)行的是 select 查詢(xún)語(yǔ)句，則執(zhí)行的結(jié)果是數(shù)組
  console.log(results)
})

// 向 user 表中，新增一條數(shù)據(jù)，其中 username 的值為 Spider-Man，password 的值為 pcc123,status為0
const userdata = { username: 'Spider-Man', password: 'pcc123',status:"0" }
// 定義待執(zhí)行的 SQL 語(yǔ)句,?為占位符
const sqlStr = 'insert into user (username, password,status) values (?, ?,?)'
// 執(zhí)行 SQL 語(yǔ)句，使用數(shù)組的形式依次為？占位符指定具體的值
db.query(sqlStr, [userdata.username, userdata.password,userdata.status], (err, results) => {
  // 執(zhí)行 SQL 語(yǔ)句失敗了
  if (err) return console.log(err.message)
  // 成功了
  // 注意：如果執(zhí)行的是 insert into 插入語(yǔ)句，則 results 是一個(gè)對(duì)象
  // 可以通過(guò) affectedRows 屬性，來(lái)判斷是否插入數(shù)據(jù)成功
  if (results.affectedRows === 1) {
    console.log('插入數(shù)據(jù)成功!')
  }
})

// 演示插入數(shù)據(jù)的便捷方式
const userdata = { username: 'Spider-Man2', password: 'pcc4321',status:'0'}
// 定義待執(zhí)行的 SQL 語(yǔ)句
const sqlStr = 'insert into user set ?'
// 執(zhí)行 SQL 語(yǔ)句
db.query(sqlStr, userdata, (err, results) => {
  if (err) return console.log(err.message)
  if (results.affectedRows === 1) {
    console.log('插入數(shù)據(jù)成功')
  }
}) 

// 演示如何更新用戶(hù)的信息
const userdata = { id: 15, username: 'aaa', password: '000' }
// 定義 SQL 語(yǔ)句
const sqlStr = 'update user set username=?, password=? where id=?'
// 執(zhí)行 SQL 語(yǔ)句
db.query(sqlStr, [userdata.username, userdata.password, userdata.id], (err, results) => {
  if (err) return console.log(err.message)
  // 注意：執(zhí)行了 update 語(yǔ)句之后，執(zhí)行的結(jié)果，也是一個(gè)對(duì)象，可以通過(guò) affectedRows 判斷是否更新成功
  if (results.affectedRows === 1) {
    console.log('更新成功')
  }
})

// 演示更新數(shù)據(jù)的便捷方式
const userdata = { id: 6, username: 'aaaa', password: '0000' }
// 定義 SQL 語(yǔ)句
const sqlStr = 'update users set ? where id=?'
// 執(zhí)行 SQL 語(yǔ)句
db.query(sqlStr, [userdata, userdata.id], (err, results) => {
  if (err) return console.log(err.message)
  if (results.affectedRows === 1) {
    console.log('更新數(shù)據(jù)成功')
  }
}) 

// 刪除 id 為 5 的用戶(hù)
const sqlStr = 'delete from user where id=?'
db.query(sqlStr, 5, (err, results) => {
  if (err) return console.log(err.message)
  // 注意：執(zhí)行 delete 語(yǔ)句之后，結(jié)果也是一個(gè)對(duì)象，也會(huì)包含 affectedRows 屬性
  if (results.affectedRows === 1) {
    console.log('刪除數(shù)據(jù)成功')
  }
})

// 標(biāo)記刪除
const sqlStr = 'update user set status=? where id=?'
db.query(sqlStr, [1, 6], (err, results) => {
  if (err) return console.log(err.message)
  if (results.affectedRows === 1) {
    console.log('標(biāo)記刪除成功')
  }
})