nodeJS连接数据库并进行增删改查等操作

nodeJS连接数据库并进行增删改查等操作

1、创建一个空的文件夹执行命令

npm init

2、创建一个app.js文件

const express = require('express')
const app = express()  // 实例化express对象
const mysql = require('mysql')// 创建连接
const db = ateConnection({host: 'localhost',user: 'root',password: '123456',database:'nodemysql'
})// 使用db.connect()方法连接，这个方法接收一个参数，有错误就报错
db.connect((err) => {if(err) {throw err;console.log('连接成功');}
})// 创建数据库
('/createdb', (req, res) => {let sql = 'CREATE DATABASE nodemysql';db.query(sql, (err,result) => {if(err) {console.log(err)}else {console.log(result);res.send('Datebase ')}})
})// 创建数据库-posts表
('/createpoststable', (req, res) => {// let sql = 'CREATE DATABASE nodemysql';let sql = 'CREATE TABLE posts(id int AUTO_INCREMENT,title VARCHAR(255),body VARCHAR(255),PRIMARY KEY(ID))';db.query(sql, (err,result) => {if(err) {console.log(err)}else {console.log(result);res.send('postsTABELE ')}})
})// 插入数据
('/addpost1', (req, res) => {let post = {title: 'post one',body: 'easth'};let sql = 'INSERT INTO posts SET ?';db.query(sql, post, (err,result) => {if(err) {console.log(err)}else {console.log(result);res.send(' ')}})
})// 查询数据
('/getposts', (req,res) => {let sql = 'SELECT * FROM posts';db.query(sql, (err, result) => {if(err) {console.log(err)} else {console.log(result)res.json(result)}})
})// 更新数据
('/updatepost/:id', (req, res) => {let mewTitle = '赵赫';let sql = `UPDATE posts SET title = '${mewTitle}' WHERE id = ${req.params.id}`;db.query(sql, (err, result) => {if (err) {console.log(err)} else {console.log(result);res.send(`update ${req.params.id} `)}})
})// 删除数据
('/deletepost/:id', (req, res) => {let sql = `DELETE FROM posts WHERE id = ${req.params.id}`;db.query(sql, (err, result) => {if (err) {console.log(err)} else {console.log(result);res.send("删除成功。。。。")}})
})// 开启一个服务器
app.listen(3000, () => {console.log('服务器开启在3000端口....');}
)

3、输入命令启动服务：

node app.js

4、在浏览器中查看：

127.0.0.1:3000/deletepost/1