我要评论一、在项目中安装mysql 和 express
cnpm install mysql express --save
二、示例代码
const express = require("express");
const app = express();
const mysql = require("mysql");
创建连接
const db = mysql.createconnection({
host:"localhost",
user:"root",
password:"root",
database:"nodemysql"
})
db.connect( (err) => {
if(err) throw err;
console.log('连接成功');
})
创建数据库
app.get("/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 create success...")
}
})
})
创建表
app.get("/createpoststable",(req,res) => {
// 创建表 表名为posts id自增 title字符串长度255 body字符串255 主键是id
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("posts表创建成功....")
}
})
})
插入数据
app.get("/addpost2",(req,res) => {
let post = {title:"post two",body:"weasth"};
let sql = "insert into posts set ?";
db.query(sql,post,(err,result) => {
if(err){
console.log(err);
}else{
console.log(result);
res.send("post2 added....")
}
})
})
查询内容
app.get("/getposts",(req,res) => {
let sql = "select * from posts";
db.query(sql,(err,result) => {
if(err){
console.log(err);
}else{
console.log(result);
// res.send("查询成功")
res.json(result)
}
})
})
查询单条内容
app.get("/getposts/:id",(req,res) => {
let sql = `select * from posts where id = ${req.params.id}`;
db.query(sql,(err,result) => {
if(err){
console.log(err);
}else{
console.log(result);
res.json(result)
}
})
})
更新内容
app.get("/updatepost/:id",(req,res) => {
let newtitle = "update title";
let sql = `update posts set title = '${newtitle}' 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} success....`)
}
})
})
删除内容
app.get("/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端口....");
}) 到此这篇关于node+express连接mysql实现增删改查功能的文章就介绍到这了,更多相关node mysql增删改查内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！
发表评论