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

数据库访问

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

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

 //db_config.js

 module.exports = {

     database: 'h_api',//库名

     username: 'root',//用户名

     password: '123456',//密码

     host: 'localhost',//数据库地址

     dialect: 'mysql'//数据库类型

 }

　　定义用户模型文件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项目实战数据库操作（四）

数据库访问

最新文章

热门文章