完整示例代码

五、数据库增删查改

• 5.1. 查询

首先，我们把think_brand的所有信息显示到首页home/index/index：

View：

<table id="table" cellspacing="0" width="100%">
    <thead>
    <tr>
        <% if(isLogin){ %>
        <th>*</th>
        <% } %>
        <th>Name</th>
        <th>Price</th>
    </tr>
    </thead>
    <tbody>
    <% brand.forEach(function(item) { %>
    <tr>
        <% if(isLogin){ %>
         <td><a href="/admin/index/update?id=<%= item.id %>">修改</a> - <a href="/admin/index/del?id=<%= item.id %>">删除</a></td>
        <% } %>
        <td><a target="_blank" href="<%= item.url %>"><%= item.name %></a></td>
        <td><img src="/upload/<%= item.img %>" alt="<%= item.name %>"/></td>
    </tr>
    <% }); %>
    </tbody>
</table>

Controller:

App/Lib/Controller/Home/IndexController.js

//首页
indexAction: function () {
    //获取登录信息
    var userInfo = this.userInfo;
    var self = this;

    if (!isEmpty(userInfo)) {
        var brandModel = D('Brand');
        var brandData = [];

        //将用户信息赋值到模版变量里，供模版里使用
        brandModel.getBrand().then(function (data) {
            userInfo.name === 'admin' ? brandData = data : brandData = [];

            self.assign({'title': '管理-首页', 'brand': brandData, 'user': userInfo});
            return self.display();
        });
    }
}

• 5.2. 增加

View：

<form id="add-form" action="/admin/index/addBrand" method="POST" enctype="multipart/form-data">
    <h5>新增品牌</h5>
    <div class="form-group">
        <input class="form-control" type="text" id="name" name="name" placeholder="brand name"/>
    </div>
    <div class="form-group">
        <input type="file" name="img" id="img" placeholder="upload brand image"/>
    </div>
    <div class="form-group">
        <input class="form-control" type="text" id="url" name="url" placeholder="brand url"/>
    </div>
    <button class="btn btn-primary" type="submit">Submit</button>
</form>

因为这里需要上传图片，所以form一定不能漏了enctype属性：multipart/form-data，以保证被发送到服务器的数据不会被编码。

Controller：

//添加
addAction: function() {
    var self = this;
    var where = {
        name: ''
    };

    if (self.isPost()) {
        var brandModel = D('Brand');
        var pData = self.post();
        //获取上传的图片文件
        var vBImg = self.file('img');
        //利用上传图片的name和path属性
        var finalFileName = this.utilUploadImg(pData.name, vBImg.path);

        where.name = pData.name;
        //保存数据到数据库
        pData.img = finalFileName;
        brandModel.thenAdd(pData, where, true).then(function(insertId) {
            if (insertId.type === 'add') {
                return self.redirect('/home/index/index');
            } else {
                return self.error(insertId.type);
            }
        });
    } else {
        self.assign({
            'title': '管理-新增品牌'
        });
        return self.display();
    }
},
//图片上传
utilUploadImg: function(upImgName, upImgPath) {
    var extension = '';
    var finalFileName = '';

    //处理后缀和文件名
    upImgPath.indexOf('png') !== -1 ? extension = '.png' : extension = '.jpg';
    finalFileName = new Date().getTime() + extension;

    //读取文件
    fs.readFile(upImgPath, function(err, data) {
        if (err) {
            console.log('There was an error when reading file');
        } else {
            //写入文件到uplaod
            fs.writeFile('upload/' + finalFileName, data, function(err) {
                if (err) {
                    console.log('There was an error when write file');
                } else {
                    console.log('saved');
                }
            });
        }
    });

    return finalFileName;
}

上传的图片会被保存到www/upload下，以品牌的name来命名。

注意这里的fs需要先引用node JS fs模块：

var fs = require('fs');

• 5.3. 删除

Controller：

App/Lib/Controller/Admin/IndexController.js

//删除
delAction: function () {
    var self = this;

    if (self.isGet()) {
        //获取id
        var id = this.get('id');

        D('item').where({id: id}).delete().then(function (affectedRows) {
            if (affectedRows > 0) {
                return self.redirect('index');
            }
        });
    }
}

根据id查找并删除对应项。

• 5.4. 修改

View

App/View/Admin/index_update.html

<form action="/admin/index/update" method="POST" enctype="multipart/form-data">
    <input type="hidden" name="id" value="<%= brand.id %>"/>
    <div class="form-group">
        <input class="form-control" type="text" name="name" value="<%= brand.name %>"/>
    </div>
    <div class="form-group">
        <input type="file" name="img"/>
        <p class="help-block"><%= brand.img %></p>
    </div>
    <div class="form-group">
        <input class="form-control" type="text" name="url" value="<%= brand.url %>"/>
    </div>
    <button class="btn btn-primary" type="submit">Submit</button>
</form>

Controller：

App/Lib/Controller/Admin/IndexController.js

//修改
updateAction: function() {
    var self = this;
    var id = 0;

    //GET数据
    if (self.isGet()) {
        //获取name值
        id = self.get('id');

        D('Brand').where({
            id: id
        }).find().then(function(theBrand) {
            self.assign({
                'title': '管理-修改',
                'brand': theBrand
            });
            self.display();
        });
    } else if (self.isPost()) {
        //POST数据
        var updateData = self.post();
        var vBImg = self.file('img');

        // 如果没有更改图片， 防止上传空文件
        if (vBImg.originalFilename !== '') {
            var finalFileName = this.utilUploadImg(updateData.name, vBImg.path);
            updateData.img = finalFileName;
        }

        id = self.post('id');
        D('Brand').where({
            id: id
        }).update(updateData).then(function(affectedRows) {
            if (affectedRows > 0) {
                return self.redirect('/home/index/index');
            }
        });
    }
}

根据id查找并修改对应项。

未完待续。。。

更多相关文章

水平有限，如果文章有啥错误，还请不吝赐教 :)

完整示例代码