從零搭建我的博客網站(三)-使用 Sequelize 操做 mySql

時間 2020-04-17

原文原文鏈接

安裝依賴

npm install sequelize mysql2 --save
複製代碼

數據庫配置

新建 config.js 文件配置好 mysql 一些基本配置mysql

module.exports = {
    environment: 'dev',
    database: {
        dbName: 'island',
        host: 'localhost',
        port: 3306,
        user: 'root',
        password: 'root'
    }
}
複製代碼

初始化 Sequelize

const Sequelize = require('sequelize')

const { dbName, host, port, user, password } = require('../config').database

const sequelize = new Sequelize(dbName, user, password, {
    port,
    host,
    dialect: 'mysql',
    pool: {
        max: 5,
        min: 0,
        acquire: 30000,
        idle: 10000,
    },
    dialectOptions: {
        // 字符集
        charset: "utf8mb4",
        collate: "utf8mb4_unicode_ci",
        supportBigNumbers: true,
        bigNumberStrings: true
    },
    timezone: '+08:00' //時區轉換
})
複製代碼

測試鏈接

sequelize.authenticate().
    then(() => console.log('連接正常')).
    catch(err => console.log('連接失敗', err))
複製代碼

定義一個測試數據模型

const { Model, Sequelize } = require('sequelize')
const { sequelize } = require('../../core/db')
class Test extends Model {

}

Test.init(
    {
        id: {
            type: Sequelize.INTEGER,
            primaryKey: true,
            autoIncrement: true
        },
        userName: {
            type: Sequelize.STRING,
            allowNull: false,
            //自定義校驗
            validate: { min: 1, max: 100 }
        },
        password: {
            type: Sequelize.STRING,
            set(val) {
                //生成鹽
                //const salt = bcryptjs.genSaltSync(10);
                //加密密碼
                //const pwd = bcryptjs.hashSync(val, salt);
                this.setDataValue('password', val + 123)
            }
        }
    },
    {
        // 不要添加時間戳屬性 (updatedAt, createdAt)
        timestamps: true,
        // 不實際刪除數據 而是設置一個新 deletedAt 屬性，其值爲當前日期 timestamps 啓用時
        //paranoid: true,
        // 不須要 `createdAt`
        createdAt: false,
        // 須要 `updatedAt`，但列名爲"updateTime"
        updatedAt: 'updateTime',
        // 自動設置字段爲蛇型命名規則
        underscored: true,
        // 定義表名
        tableName: 'test',
        // 添加註釋
        comment: '我是測試表',
        sequelize,
        // 若是指定的表名稱本就是複數形式則不變
        freezeTableName: true
    }
)

module.exports = Test
複製代碼

其中 primaryKey 爲主鍵, 咱們設置 autoIncrement 進行自增, Sequelize 默認的 createdAt 和 updatedAt 咱們能夠不顯示或者進行改字段名sql

同步數據結構到數據庫

當模型定義後，須要在數據庫中創建對應的數據表，這時候須要作結構的同步，能夠使用如下方法進行同步:數據庫

sequelize.sync()
複製代碼

若是數據庫中已經存在該模型對應的表，則咱們能夠不進行結構同步：npm

sequelize.sync({
    force: false
})
複製代碼

定義 Controller 使用 Model 進行操做

新建 TestController.js 文件,咱們來編寫一個簡單的增刪改查 RESTful API 接口數據結構

const Test = require('../models/test')
const { Faild } = require('../../core/httpException')

class TestController {

}
複製代碼

新增數據

static async add(obj) {
    const res = await Test.create(obj)
    if (!res) {
        throw new Faild('添加失敗')
    }
    return res
}
複製代碼

修改數據

static async update(obj) {
    const res = await Test.update(obj, {
        where: {
            id: obj.id
        }
    })
    if (!res) {
        throw new Faild('修改失敗')
    }
    return res
}
複製代碼

查詢列表

static async findAll(obj) {
    et res= await Test.findAll()

    if (!res) {
        throw new Faild('修改失敗')
    }
    return res
}
複製代碼

查詢單個

static async find(id) {
    let data = await Test.findByPk(id)
    // 或者
    // Test.findOne({
    // where:{
    // id
    // }
    // })
    if (!data) {
        throw new Faild('查找失敗')
    }
    return data
}
複製代碼

刪除數據

static async dele(id) {
    const res = await Test.destroy({
        where: {
            id
        }
    })
    if (!res) {
        throw new Faild('刪除失敗')
    }
    return res
}
複製代碼

編寫路由接口

const Router = require("koa-router");
const router = new Router()

const testController = require('../controllers/test')

router.get('/test', async (ctx, next) => {

    const data = await testController.findAll(ctx.params.id)

    ctx.body = data
})

router.get('/test/:id', async (ctx, next) => {

    const data = await testController.find(ctx.params.id)

    ctx.body = data
})

router.post('/test', async (ctx, next) => {
    const data = await testController.add(ctx.request.body)
})

router.put('/test', async (ctx, next) => {
    const data = await testController.update(ctx.request.body)
    ctx.body = data
})

router.delete('/test/:id', async (ctx, next) => {
    const data = await testController.dele(ctx.params.id)
    ctx.body = data
})

module.exports = router
複製代碼