1. 查询
knex('table').select()
2. 带条件查询
knex('table').where('id', 1).select()
knex('table').where({'id': 1}).select()
3. 新增
knex('table').insert({'name': '名字'})
4. 更新(更新所有数据)
knex('table').update('name', '名字1')
5. 更新(按条件更新)
knex('table').where({ id: 1 }).update({ name: "名字2" })
6. 删除
knex('table').where('id', 1).del()
7. 事务
knex.transaction((trx) => {
knex('table').transacting(trx).insert({name: '名字'})
.then((res) => {
// 业务代码
})
.then(trx.commit)
.catch(err=>{
trx.rollback()
throw err
});
})
.then((resp) => {
console.log('Transaction complete.');
})
.catch((err) => {
console.error(err);
});
8. 循环update
async.map([{id: 1}], function(item, callback){
knex('table').update(item).then(res => {
callback(res)
})
}, function(err, results){
console.log(results)
})