node操作mysql資料庫例項

const koa = require("koa");

const router = require("koa-router");
//要引入promise類
const mysql = require("mysql2/promise");
koa();
const router = new
router();
//實現實現對users表增刪改查
//使用promise
(async () =>);
//adduser
router.get("/adduser", async (ctx) => =ctx.query;
console.log(name, age);
let sql = `insert into users (id,name,age) values (0,?,?)`;
let [row] = await connection.execute(sql, [name, +age]);
if(row.affectedrows) 
else ctx.body = "add user fail";
});//
deluser
router.get("/deluser", async (ctx) => =ctx.query;
let sql = "delete from users where id=?";
let [row] =await connection.execute(sql, [id]);
if (row.affectedrows) ctx.body = "del user seccuss";
else ctx.body = "del user fail";
});//
updateuser
router.get("/updateuser", async (ctx) => =ctx.query;
let sql = `update users set age=? where id=?`;
let [row] =await connection.execute(sql, [age, id]);
if (row.affectedrows) ctx.body = "update user seccuss";
else ctx.body = "update user fail";
});//
finduser
router.get("/finduser", async (ctx) => =ctx.query;
let sql=`select * from users where id=?`;
let [row]=await connection.execute(sql,[id]);
ctx.body=row;
});//
findeusers
router.get('/findusers',async (ctx)=>=ctx.query;
let sql=`select * from users where age>? order by age limit ?,?`;
let [row]=await connection.execute(sql,[age,ofset,limit]);
ctx.body=row;
})})();
console.log("建立成功,埠：8080");
});

學習一下orm 運算元據庫

const  = require("sequelize");

//使用orm 物件關係型資料庫
const getusermodel = require("./user_model");
//連線mysql 資料庫
const sequelize = new
sequelize();
//獲取user model 物件
var usermodel =getusermodel(sequelize);
//物件初始化到資料庫表
sequelize.sync(); //
同步，如果表發生變化不會同步過去
//同步，強制同步

建立user_model.js

const =require('sequelize');
class usermodel extends model
module.exports=(sequelize)=>,
name:,
age:
},)return
usermodel;
}

改造mysql2運算元據庫通過sequelize物件實現

建立

let row =await usermodel.create();
ctx.body =row;
刪除let row =await usermodel.destroy(,});
修改let row =await usermodel.update(,}
);查詢let row = await usermodel.findbypk(+id); //
通過主鍵id查詢
多條件查詢 
let row =await usermodel.findall(,
},order: [["age", "desc"]],
offset: +ofset,
limit: +limit,
});

node 操作mysql資料庫

node 操作mysql 1 安裝 cnpm install s mysql 2 引入 var mysql require mysql 3 建立連線 var 返回物件 mysql.createconnection 返回物件.connect 4 運算元據庫 返回物件.query sql語句 funct...

node操作mongodb資料庫

一 鏈結資料庫 2 引入mongodb模組 const mongodb require mongodb 3 鏈結資料庫 const mongodb require mongodb const mongoclient mongodb.mongoclient function connect err,c...

node對資料庫的操作

想要運算元據庫，首先就要建立且連線它 1.匯入mysql模組 var mysql require mysql 2建立資料庫連線物件，配置相關資訊 var connection mysql.createconnection 3建立資料庫連線，可以省略 connection.connect 4修改資料 ...