[大数据] node.js学习day03 通过node.js连接数据库实现增删改查

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 大数据 -> node.js学习day03 通过node.js连接数据库实现增删改查 -> 正文阅读

[大数据]node.js学习day03 通过node.js连接数据库实现增删改查

通过node.js连接mysql数据库实现增删改查

1. npm i?mysql 导入mysql模块

2.熟悉数据库增删改查

3.建立连接通过mysql.createPool

4.案例

const mysql = require('mysql')

//建立连接
const db = mysql.createPool({
    host:'127.0.0.1',
    user:'root',
    password:'root',
    database:'my_db_01',
})

//测试mysql模块
// db.query('select 1',(err,results) =>{
//     if(err) return console.log(err.message)
//     console.log(results)
// })

//应用 查询users表中所有数据
// const sqStr = 'select *from users'
// db.query(sqStr,(err,results)=>{
//     if (err) return err.message
//     //查询成功
//     console.log(results)
// })

//向users表中新增一条数据
// const user= {username:'赵六',password:'123'}
// //定义待执行sql语句
// const sqlStr = 'insert into users (username,password) values (?,?)'
// //执行sql语句
// db.query(sqlStr,[user.username,user.password],(err,results)=>{
//     //执行失败
//     if(err) return err.message
//     //如果执行insert into 插入语句，则results是一个对象
//     //可以通过affectedRows 属性，来判断是否插入数据成功
//     if(results.affectedRows ===1) return console.log("chenggong ")
// })

// const user= {username:'李七',password:'123'}
// //定义待执行sql语句
// const sqlStr = 'insert into users set ?'
// //执行sql语句
// db.query(sqlStr,user,(err,results)=>{
//     //执行失败
//     if(err) return console.log(err.message)
//     //如果执行insert into 插入语句，则results是一个对象
//     //可以通过affectedRows 属性，来判断是否插入数据成功
//     if(results.affectedRows ===1) return console.log(" 插入成功 ")
// })

// //更新数据
// const user = {id:6,username :'xxs',password:'1234'}
// const sqlStr = 'update users set username=?,password=? where id=6'

// //执行sql语句
// db.query(sqlStr,[user.username,user.password,user.id],(err,results)=>{
//     if(err) return console.log(err.message)
//     if(results.affectedRows ===1) return console.log('更新成功')
// })

// 简单更新数据
// const user = {id:6,username :'xxss',password:'123'}
// 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) return console.log('更新成功')
// })


//删除操作
//要执行的sql
// const sqlStr = 'DELETE FROM users where id=?'
// //调用db.query()执行sql语句的同时，为占位符指定具体的值
// //注意如果sql语句中有多个占位符，则必须使用数组为每个占位符制定具体的值
// //如果sql语句只有一个占位符，则可以省略数组
// db.query(sqlStr,4,(err,results)=>{
//     if(err) return console.log(err.message)
//     if(results.affectedRows ===1) return console.log("删除成功")

// })

//标记删除
const sqlStr = 'update users set status=? where id=?'
db.query(sqlStr,[1,5],(err,results)=>{
    if(err) return console.log(err.message)
    if(results.affectedRows ===1) return console.log("删除成功")
})