Nodejs之ORM框架

NodeJs 关系数据库ORM库：Bookshelf.js
bookshelf.js是基于knex的一个关系型数据库的ORM库。简单易用，内置了Promise的支持。这里主要罗列一些使用的例子，例子就是最好的教程。下面就是用mysql作为实例数据库表明bookshelf如何使用。其他的几个关系型数据库使用上基本一致，只是配置等地方需要使用的名称各自不同。为了更加贴近实际全部的例子都会放在Express打造的RESTful服务里。
安装bookshelf和knex
首先需要安装库knex和bookshelf，其次还需要安装你的数据库对应的包：

npm install knex --save
npm install bookshelf --save
接下来，安装对应于你要使用的数据库的driver包。下面列出了三个比较典型的，只需要选择一个安装就可以。

npm install pg --save       // PostgreSQL
npm install mysql --save    // MySQL
npm install sqlite3 --save  // SQLite
连接数据库
连接数据库就是非常的简单的，只需要传入一个JSON格式的配置：

var knex        = require('knex'),
    db;    // 数据库连接

// 数据库连接配置
var config = {
    client: 'mysql',        // 其他可以是pg、sqlite3
    connection: {
        host: 'localhost',
        user: 'root',
        password: '123456',
        database: 'petshop', // 数据库名称
        charset: 'utf8'
    }
};

// 保证数据库连接只初始化一次。
if (!db) {
    db = knex(config);
}
接下来就该让bookshelf出马了：

var bookshelf = require('bookshelf')(db);

Express打造的RESTful服务代码：

var Promise     = require('bluebird'),
    express     = require('express'),
    bodyParser  = require('body-parser'),
    session     = require('express-session');

var app = express();

app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: true}));

app.use(session({
    secret: 'abcdefghijklmnopqrstuvwxyz1234567890',
    resave: false,
    saveUninitialized: true
    // cookie: {secure: true}
}));

var models = require('./bookshelf');
var router = express.Router();

router.get('/', function(req, res) {
    res.send('Hello bookshelf');
});

/**
 * 添加
 */
router.route('/add').post(function(req, res) {
    // ...
});

/** 
 * 更新
 */
router.route('/update').post(function(req, res) {
    // ...
});

app.use('/bookshelf', router);

app.listen(4000, function(){
    console.log('express is running on http://localhost:4000');
});
为了正常使用还需要安装某些包body-parser，这个包用来解析post发送上来的数据。bluebird和express-session什么的可以选择不装，不影响。
## Model

ORM，这model是必须不可以少的。如何让model来对应于数据库的table呢：


var Pet = bookshelf.Model.extend({
    tableName: 'pet',
});



现在就可以使用`Pet`来处理pet表的数据了。

上面是理论上的。回到本例中。首先在根目录下创建一个文件夹*bookshelf*，然后添加文件*model.js*。

### 添加数据

给表添加一条记录：


new Pet({
    name: 'King',
    type: 1, // 1: dog, 2: cat...
    quantity: 10,
    userId: 123456
}).save().then(function(model){
    console.log(model);
}).catch(function(err) {
    console.log(err);
});



放在RESTful API里：


router.route('/add').post(function(req, res) {
    var pet = new models.Pet({
        name: req.body.name,
        type: req.body.type,
        quantity: req.body.quantity,
        userId: req.body.userId
    });

    pet.save().then(function(model){
        res.json({message:'done', data: pet});
    }).catch(function(err){
        res.json({message: 'error', data: err});
    });
});



在处理数据的时候可以使用bookshelf提供的很多“静态方法”。上面的`extend`就是这些静态方法中的一个。创建新的model的时候就可以是用静态方法里的一个`forge`，这样就不用new的方式了。


    models.Pet.forge({
        name: req.body.name,
        type: req.body.type,
        quantity: req.body.quantity,
        userId: req.body.userId
    }).save().then(function(pet){
        res.json({message:'done', data: pet});
    }).catch(function(err){
        res.json({message: 'error', data: err});
    });



### 查找数据

添加了数据就可以查找出来了。

#### 查找全部

查找全部的数据：

router.route('/findall').get(function(req, res) {
    models.Pet.forge().fetchAll().then(function(pets) {
        res.json({message: 'done', data: pets});
    }).catch(function(err) {
        res.json({message: 'error', data: err});
    });
});



在浏览器里输入地址：[http://localhost:4000/bookshelf/findall可以查找出全部的pet数据。](http://localhost:4000/bookshelf/findall%E5%8F%AF%E4%BB%A5%E6%9F%A5%E6%89%BE%E5%87%BA%E5%85%A8%E9%83%A8%E7%9A%84pet%E6%95%B0%E6%8D%AE%E3%80%82)

#### 查找某一个Pet


router.route('/find/:petId').get(function(req, res) {
    models.Pet.forge({
        petId: req.params.petId
    }).fetch().then(function(pet) {
        res.json({message: 'done', data: pet});
    }).catch(function(err) {
        res.json({message: 'error', data: err});
    });
});



在浏览器里输入地址：[http://localhost:4000/bookshelf/find/1可以查找出petId为1的数据。](http://localhost:4000/bookshelf/find/1%E5%8F%AF%E4%BB%A5%E6%9F%A5%E6%89%BE%E5%87%BApetId%E4%B8%BA1%E7%9A%84%E6%95%B0%E6%8D%AE%E3%80%82)

我们在上一个例子中已经创建了一条记录，所以现在可以搜出来一条记录。

更多的更复杂的查找可以使用方法`query`，查看[这里](http://bookshelfjs.org/#Model-instance-query)了解更多。

### 更新数据

更新和创建一条新纪录，在写法上没什么太大的区别。只不过你需要在`save`方法里设置需要更新的数据。但是有一个限制条件，就是需要在forge方法里给出`id`，必须是这个词`i`和`d`。如果你的Primary key不是这个名称，那么就稍微复杂一点了。必须给出`where`条件，比如：


router.route('/update/:petId').post(function(req, res) {
    models.Pet.forge()
    .where('petId', '=', req.params.petId)
    .save({
        name: req.body.name,
        type: req.body.type,
        quantity: req.body.quantity,
        userId: req.body.userId
    }, {patch: true}).then(function(pet) {
        res.json({message: 'done', data: pet});
    }).catch(function(err) {
        res.json({message: 'error', data: err});
    });
});



更多关于`where`内容可以查看[这里](http://bookshelfjs.org/#Model-instance-where)。

### 删除记录

最后可以删除记录。


router.route('/delete/:petId').get(function(req, res) {
    models.Pet.forge()
    .where('petId', '=', req.params.petId)
    .destroy()
    .then(function(pet) {
        res.json({message: 'done', data: pet});
    })
    .catch(function(err) {
        res.json({message: 'error', data: err});
    });
});

https://toscode.gitee.com/cc032191/mysql-ithm