Hapi+MySql项目实战数据库操作

Posted Armys

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Hapi+MySql项目实战数据库操作相关的知识,希望对你有一定的参考价值。

  • 数据库访问

下面以Node的ORM框架Sequelize来操作数据库,mysql为例。

配置数据库连接信息config/db_config.js:

1 //db_config.js
2 module.exports = {
3     database: ‘h_api‘,//库名
4     username: ‘root‘,//用户名
5     password: ‘123456‘,//密码
6     host: ‘localhost‘,//数据库地址
7     dialect: ‘mysql‘//数据库类型
8 }

  定义用户模型文件modes/user.js,表映射

//user.js
module.exports = function(sequelize, DataTypes) {
    var User = sequelize.define("user", {
        id:{
            type: DataTypes.INTEGER,
            primaryKey:true,
            allowNull:false,
            autoIncrement: true,
        },
        name:DataTypes.STRING,
        sex:DataTypes.BIGINT,
        age:DataTypes.INTEGER,
    },{
        freezeTableName: true, // Model 对应的表名将与model名相同
        timestamps: false
    });

    return User;
};

  创建一个sequelize对象实例,连接数据库models/index.js新增代码如下:

//index.js
const Fs = require("fs");
const Path = require("path");
const Sequelize = require("sequelize");
const Config = require(‘../config/db_config‘);
let db = {};
//创建一个sequelize对象实例,连接数据库
let sequelize = new Sequelize(Config.database, Config.username, Config.password, {
    host: Config.host,
    dialect: Config.dialect,
    pool: {
        max: 5,
        min: 0,
        idle: 30000
    }
});

Fs.readdirSync(__dirname).filter(function (file) {
    return (file.indexOf(".") !== 0) && (file !== "index.js");
}).forEach(function (file) {
    var model = sequelize["import"](Path.join(__dirname, file));
    db[model.name] = model;
});
db.sequelize = sequelize;
module.exports = db;   

  配置server.js,代码如下:

//server.js
const models=require(‘./models‘);
//Connect database
var initDb = function(){
    var sequelize = models.sequelize;
    //Determine if the database connection is successful
     sequelize.sync({force: false}).then(function() {
        console.log("connection database successed");
     }).catch(function(err){
        console.log("connection failed due to error: %s", err);
     });    
};
 initDb();

  配置数据库完毕后,在路由handler中使用这个实例

  routes文件夹下新建login.js,代码如下:

//login.js
const Joi = require(‘joi‘);
const controllers = require(‘../controllers‘);

let login = {
    method: ‘get‘,
    path: ‘/login‘,
    handler: controllers.user.login
};
module.exports = login;

  controllers文件夹新建index.js,遍历指定目录,require()每个文件,并返回一个包含这些模块嵌套的hash结构,代码如下

//index.js
const requireDirectory = require(‘require-directory‘);
module.exports = requireDirectory(module);

  controllers文件夹新建user.js,数据库操作

//user.js
let Models = require(‘../models‘)

module.exports = {
    login: function (request, reply) {
        return Models.user.findAll({
            where: {
                name: request.query.name
            }
        }).then(function (result) {
            let reponseMess = {};
            if (result !== null) {
                reponseMess = {
                    code: 100,
                    message: ‘success‘,
                    data: result
                }
            } else {
                reponseMess = {
                    code: -100,
                    message: ‘fail‘,
                    data: ‘‘
                }
            }
            return reponseMess;
        });
    }
};

  老规矩,配置路由

  输入地址:http://localhost:8090/login?name=1, 数据库自己新增一条name=1的记录

  输出:json

//module.exports = [
    //require(__dirname + ‘/hello.js‘),
    //require(__dirname + ‘/staticfile.js‘),
    require(__dirname + ‘/login.js‘)
//];

以上是关于Hapi+MySql项目实战数据库操作的主要内容,如果未能解决你的问题,请参考以下文章

部署上次的Hapi到Windows+Docker,WindowsDocker

node -- hapi 学习

@hapi/lab 与 lab-transform-typescript 正在返回错误的代码覆盖率结果

Express实战 - 应用案例- realworld-API - 路由设计 - mongoose - 数据验证 - 密码加密 - 登录接口 - 身份认证 - token - 增删改查API(代码片段

廖大python实战项目第四天

二PHP基础——连接msql数据库进行增删改查操作 & 实战:新闻管理项目