设置要查询的字段。
field
string | array 要查询的字段,可以是字符串,也可以是数组reverse
boolean 是否反选字段return
this// 生成的 sql 语句为,以下同:
// SELECT * FROM `meinv_group`
D('Group').field().select();
// SELECT `id`,`title` FROM `meinv_group`
D('Group').field('id, title').select();
// SELECT `id`,`title` FROM `meinv_group`
D('Group').field(['id', 'title']).select();
// SELECT `cate_id`,`md5`,`width`,`height`,`pic_nums`,`view_nums`,`date` FROM `meinv_group`
D('Group').field(['id', 'title'], true).select();
设置表名
table
String 表名hasPrefix
Boolean 表名里是否已经含有了表前缀// 设置表名为 xxx
D('Group').table('xxx').select();
// 也可以将一条 sql 语句设置为表名
D('Group').group('name').buildSql().then(function(sql){
return D('Article').table(sql, true).select();
}).then(function(data){
})
设置查询的数量。
offset
起始位置length
查询的数目return
this// SELECT * FROM `meinv_group` LIMIT 10
D('Group').limit(10).select();
// SELECT * FROM `meinv_group` LIMIT 10,20
D('Group').limit(10, 20).select();
设置当前查询的页数,页数从 1 开始
page
当前的页数listRows
一页多少条记录,默认值为 C('db_nums_per_page')
return
this// SELECT * FROM `meinv_group`
D('Group').page().select();
// SELECT * FROM `meinv_group` LIMIT 0,20
D('Group').page(1).select();
// SELECT * FROM `meinv_group` LIMIT 10,10
D('Group').page(2, 10).select();
联合查询
union
联合查询的字符串all
是否为 UNION ALL 模式return
this// SELECT * FROM `meinv_pic1` UNION (SELECT * FROM meinv_pic2)
D('Pic1').union('SELECT * FROM meinv_pic2').select();
// SELECT * FROM `meinv_pic1` UNION ALL (SELECT * FROM meinv_pic2)
D('Pic1').union('SELECT * FROM meinv_pic2', true).select();
// SELECT * FROM `meinv_pic1` UNION ALL (SELECT * FROM `meinv_pic2`)
D('Pic1').union({table: 'meinv_pic2'}, true).select();
// SELECT * FROM `meinv_pic1` UNION ALL (SELECT * FROM `meinv_pic2`) UNION (SELECT * FROM meinv_pic3)
D('Pic1').union({table: 'meinv_pic2'}, true).union({table: 'meinv_pic3'}).select();
组合查询
join
可以是字符串、数组、对象return
this// SELECT * FROM `meinv_group` LEFT JOIN meinv_cate ON meinv_group.cate_id=meinv_cate.id
D('Group').join('meinv_cate ON meinv_group.cate_id=meinv_cate.id').select();
// SELECT * FROM `meinv_group` LEFT JOIN meinv_cate ON meinv_group.cate_id=meinv_cate.id RIGHT JION meinv_tag ON meinv_group.tag_id=meinv_tag.id
D('Group').join([
'meinv_cate ON meinv_group.cate_id=meinv_cate.id',
'RIGHT JOIN meinv_tag ON meinv_group.tag_id=meinv_tag.id'
]).select();
// SELECT * FROM meinv_group INNER JOIN `meinv_cate` AS c ON meinv_group.`cate_id`=c.`id`
D('Group').join({
table: 'cate',
join: 'inner', //join 方式,有 left, right, inner 3 种方式
as: 'c', // 表别名
on: ['cate_id', 'id'] //ON 条件
}).select();
// SELECT * FROM meinv_group AS a LEFT JOIN `meinv_cate` AS c ON a.`cate_id`=c.`id` LEFT JOIN `meinv_group_tag` AS d ON a.`id`=d.`group_id`
D('Group').alias('a').join({
table: 'cate',
join: 'left',
as: 'c',
on: ['cate_id', 'id']
}).join({
table: 'group_tag',
join: 'left',
as: 'd',
on: ['id', 'group_id']
}).select()
// SELECT * FROM meinv_group AS a LEFT JOIN `meinv_cate` AS c ON a.`id`=c.`id` LEFT JOIN `meinv_group_tag` AS d ON a.`id`=d.`group_id`
D('Group').alias('a').join({
cate: {
join: 'left', // 有 left,right,inner 3 个值
as: 'c',
on: ['id', 'id']
},
group_tag: {
join: 'left',
as: 'd',
on: ['id', 'group_id']
}
}).select()
//SELECT * FROM `meinv_group` LEFT JOIN `meinv_cate` ON meinv_group.`id`=meinv_cate.`id` LEFT JOIN `meinv_group_tag` ON meinv_group.`id`=meinv_group_tag.`group_id`
D('Group').join({
cate: {
on: ['id', 'id']
},
group_tag: {
on: ['id', 'group_id']
}
}).select()
//SELECT * FROM `meinv_group` LEFT JOIN `meinv_cate` ON meinv_group.`id`=meinv_cate.`id` LEFT JOIN `meinv_group_tag` ON meinv_group.`id`=meinv_group_tag.`group_id` LEFT JOIN `meinv_tag` ON (meinv_group.`id`=meinv_tag.`id` AND meinv_group.`title`=meinv_tag.`name`)
D('Group').join({
cate: {
on: 'id, id'
},
group_tag: {
on: ['id', 'group_id']
},
tag: {
on: { // 多个字段的 ON
id: 'id',
title: 'name'
}
}
}).select()
// join 的 table 为 sql 语句
// 这个方式推荐和 buildSql 结合使用,也可以单独使用
// SELECT id as team_id,ta.team_name,ifnull(sum,0) as sum FROM ThinkJS_team AS ta LEFT JOIN (SELECT tt.id as team_id,`team_name`,`team_partin_year`,sum(IFNULL(invest_value,0)) as sum FROM ThinkJS_team AS tt LEFT JOIN `ThinkJS_invest` AS ti ON tt.`id`=ti.`invest_team_id` WHERE (invest_is_cancel = 0 or invest_is_cancel is null) GROUP BY tt.`id` HAVING team_partin_year=2014 ORDER BY `sum` desc ) AS temp ON ta.`id`=temp.`team_id` ORDER BY sum desc
return D('team').alias('tt')
.field('tt.id as team_id, team_name, team_partin_year, sum(IFNULL(invest_value, 0)) as sum')
.join({
table: 'invest',
join: 'left',
as: 'ti',
on: ['tt.id', 'invest_team_id']
})
.where('invest_is_cancel = 0 or invest_is_cancel is null')
.group('tt.id')
.order({sum: 'desc'})
.having('team_partin_year='+year).buildSql();}).then(function(sql){
return D('team')
.field('id as team_id, ta.team_name, ifnull(sum, 0) as sum')
.alias('ta').join({
table: sql,
join: 'left',
as: 'temp',
on: ['id', 'temp.team_id']
})
.order('sum desc').select();});
设置排序方式
order
排序方式,字符串return
this// SELECT * FROM `meinv_group` ORDER BY id
D('Group').order('id').select();
// SELECT * FROM `meinv_group` ORDER BY id DESC
D('Group').order('id DESC').select();
// SELECT * FROM `meinv_group` ORDER BY id DESC,title ASC
D('Group').order('id DESC,title ASC').select();
// SELECT * FROM `meinv_group` ORDER BY id ASC
D('Group').order(['id ASC']).select();
// SELECT * FROM `meinv_group` ORDER BY id ASC,title DESC
D('Group').order(['id ASC', 'title DESC']).select()
// SELECT * FROM `meinv_group` ORDER BY `id` ASC,`title` DESC
D('Group').order({id: 'ASC', title: 'DESC'}).select()
设置表别名
alaias
表别名,字符串return
this//SELECT * FROM meinv_group AS a
D('Group').alias('a').select();
having 查询
str
having 查询的字符串return
this// SELECT * FROM `meinv_group` HAVING view_nums > 1000 AND view_nums < 2000
D('Group').having('view_nums> 1000 AND view_nums <2000').select();
分组查询
field
设定分组查询的字段return
this// SELECT * FROM `meinv_group` GROUP BY `view_nums`
D('Group').group('view_nums').select();
去重查询
field
去重的字段return
this// SELECT Distinct `view_nums` FROM `meinv_group`
D('Group').distinct('view_nums').select();
设置 where 条件
where
查询条件,可以是字符串、对象return
this** 普通条件 **
// SELECT * FROM `meinv_group`
D('Group').where().select();
// SELECT * FROM `meinv_group` WHERE (`id` = 10)
D('Group').where({id: 10}).select();
// 查询字符串
// SELECT * FROM `meinv_group` WHERE id = 10 OR id < 2
D('GROUP').where('id = 10 OR id < 2').select();
// 操作符
// SELECT * FROM `meinv_group` WHERE (`id` != 10)
D('Group').where({id: ['!=', 10]}).select(); // 这里的操作符有> >= < <= !=
*EXP 条件 *
ThinkJS 默认会对字段和值进行转义,防止安全漏洞。有时候一些特殊的情况不希望被转义,可以使用 EXP 的方式
//SELECT * FROM `meinv_group` WHERE name='name'
D('GROUP').where({name: ['EXP', "='name'"]});
// 将 view_nums 字段值加 1
D('GROUP').update({view_nums: ['EXP', 'view_nums+1']});
*LIKE 条件 *
// LIKE 和 NOT LIKE
// SELECT * FROM `meinv_group` WHERE (`title` NOT LIKE 'welefen')
D('Group').where({title: ['NOTLIKE', 'welefen']}).select();
// SELECT * FROM `meinv_group` WHERE (`title` LIKE '%welefen%')
D('Group').where({title: ['like', '%welefen%']}).select();
//LIKE 多个值
// SELECT * FROM `meinv_group` WHERE ((`title` LIKE 'welefen' OR `title` LIKE 'suredy') )
D('Group').where({title: ['like', ['welefen', 'suredy']]}).select()
// 多个字段 LIKE 同一个值,或的关系
//SELECT * FROM `meinv_group` WHERE ((`title` LIKE '%welefen%') OR (`content` LIKE '%welefen%') )
D('Group').where({'title|content': ['like', '%welefen%']}).select();
// 多个字段 LIKE 同一个只,与的关系
//SELECT * FROM `meinv_group` WHERE ((`title` LIKE '%welefen%') AND (`content` LIKE '%welefen%') )
D('Group').where({'title&content': ['like', '%welefen%']}).select();
*IN 条件 *
//SELECT * FROM `meinv_group` WHERE (`id` IN ('10','20') )
D('Group').where({id: ['IN', '10,20']}).select();
//SELECT * FROM `meinv_group` WHERE (`id` IN (10,20) )
D('Group').where({id: ['IN', [10, 20]]}).select();
//SELECT * FROM `meinv_group` WHERE (`id` NOT IN (10,20) )
D('Group').where({id: ['NOTIN', [10, 20]]}).select()
** 多字段查询 **
//SELECT * FROM `meinv_group` WHERE (`id` = 10) AND (`title` = 'www')
D('Group').where({id: 10, title: "www"}).select();
// 修改为或的关系
//SELECT * FROM `meinv_group` WHERE (`id` = 10) OR (`title` = 'www')
D('Group').where({id: 10, title: "www", _logic: 'OR'}).select();
// 修改为异或的关系
//SELECT * FROM `meinv_group` WHERE (`id` = 10) XOR (`title` = 'www')
D('Group').where({id: 10, title: "www", _logic: 'XOR'})
*BETWEEN 查询 *
//SELECT * FROM `meinv_group` WHERE ((`id` BETWEEN 1 AND 2) )
D('Group').where({id: ['BETWEEN', 1, 2]}).select();
//SELECT * FROM `meinv_group` WHERE ((`id` BETWEEN '1' AND '2') )
D('Group').where({id: ['between', '1,2']}).select()
** 复合查询 **
// SELECT * FROM `meinv_group` WHERE (`id`> 10 AND `id` <20)
D('Group').where({
id: {
'>': 10,
'<': 20
}
}).select()
// SELECT * FROM `meinv_group` WHERE (`id` < 10 OR `id`> 20 )
D('Group').where({
id: {
'<': 10,
'>': 20,
_logic: 'OR'
}
}).select()
//SELECT * FROM `meinv_group` WHERE (`id`>= 10 AND `id` <= 20) OR (`title` LIKE '%welefen%') OR (`date`> '2014-08-12' )
D('Group').where({
id: {
'>=': 10,
'<=': 20
},
'title': ['like', '%welefen%'],
date: ['>', '2014-08-12'],
_logic: 'OR'
}).select();
//SELECT * FROM `think_group` WHERE (`title` = 'test') AND ((`id` IN (1,2,3) ) OR (`content` = 'www') )
D('Group').where({
title: 'test',
_complex: {id: ['IN', [1, 2, 3]],
content: 'www',
_logic: 'or'
}
}).select()
查询符合条件的数目,可以有 where 条件
field
count 的字段,默认会从数据表里查找主键的字段return
promise//SELECT COUNT(id) AS ThinkJS_count FROM `meinv_group` LIMIT 1
D('Group').count('id').then(function(count){
//count 为符合条件的数目
});
对符合条件的字段值求和,可以有 where 条件
field
求和的字段return
promise//SELECT SUM(view_nums) AS ThinkJS_sum FROM `meinv_group` LIMIT 1
D('Group').sum('view_nums').then(function(sum){
//sum 为求和的值
})
求字段的最小值
field
要求最小值的字段return
promise//SELECT MIN(view_nums) AS ThinkJS_min FROM `meinv_group` LIMIT 1
D('Group').min('view_nums').then(function(min){
//min 为最小的 view_nums 值
})
求字段的最大值
field
要求最大值的字段return
promise//SELECT MAX(view_nums) AS ThinkJS_max FROM `meinv_group` LIMIT 1
D('Group').max('view_nums').then(function(max){
//max 为最小的 view_nums 值
})
求字段的平均值
field
要求平均值的字段return
promise//SELECT AVG(view_nums) AS ThinkJS_avg FROM `meinv_group` LIMIT 1
D('Group').avg('view_nums').then(function(avg){
})
插入数据
data
要插入的数据,对象return
promisevar data = {
title: 'xxx',
content: 'yyy'
};
D('Group').add(data).then(function(insertId){
// 如果插入成功,insertId 为插入的 id
}).catch(function(err){
// 插入失败,err 为具体的错误信息
})
如果数据表中有字段设置为 unique
,插入一个已经存在的值时就会报错。这种情况一般需要先按这个字段去查询下看有没有对应的记录,如果没有在进行插入。
为了简化开发者的使用,ThinkJS 提供了 thenAdd 方法。
当数据表中不存在 where 条件对应的数据时,才进行插入。
data
要插入的数据where
检测的条件returnDetail
是否返回详细的信息// 假设数据表中字段 title 类型为 UNIQUE
var data = {
title: 'xxx',
content: 'yyy'
};
var where = {title: 'xxx'}
D('Group').thenAdd(data, where).then(function(id){
//id 为已经存在的 id 或者刚插入的 id
})
// 返回详细的信息
D('Group').thenAdd(data, where, true).then(function(data){
//data 数据结构为
data = {
type: 'exist' || 'add', //exist 表示之前已经存在,add 表示新添加
id: 111
}
})
使用场景:用户注册时就可以通过该方法来检查用户名或者邮箱已经存在。
一次添加多条数据
data
要添加的数据,数组return
promisevar data = [{title: 'xxx'}, {title: 'yyy'}];
D('Group').addAll(data).then(function(insertId){
// 插入成功
}).catch(function(err){
// 插入失败
})
return
promise删除符合条件的数据
// 删除所有数据
D('Group').delete().then(function(affectedRows){
//affectedRows 为影响的行数
})
// 删除 id 小于 100 的数据
D('Group').where({id: ['<', 100]}).delete().then(function(affectedRows){
//affectedRows 为影响的行数
})
更新符合条件的数据
data
要更新的数据return
promise// 将 id<10 的 title 设置为空
D('Group').where({id: ['<', 10]}).update({title: ''})
查询符合条件的数据
return
promiseD('Group').where({id: ['IN', [1, 2, 3]]}).select().then(function(data){
//data 为数组
// 如果查询数据为空,那么 data 为 []
data = [{
id: 1,
title: '',
...
},{
id: 2,
title: ''
...
}
]
})
查找某一条符合条件的数据。
return
promise// 查询 id=1000 的一条数据
D('Group').where({id: 1000}).find().then(function(data){
//data 为一个数据对象
// 如果数据为空,那么 data 为 {}
data = {
id: 1000,
title: 'xxx',
...
}
})
将字段值增加
field
要增加的字段step
增加的数值,默认为 1return
promise// 将 id=10 的浏览数加 1
D('Group').where({id: 10}).updateInc('view_nums').then(function(){
})
// 将 id=100 的浏览数加 10
D('Group').where({id: 100}).updateInc('view_nums', 10).then(function(){
})
将字段值减少
field
要减少的字段step
减少的值,默认为 1return
promise// 将 id=10 的浏览数减 1
D('Group').where({id: 10}).updateDec('view_nums').then(function(){
})
// 将 id=100 的浏览数减 10
D('Group').where({id: 100}).updateDec('view_nums', 10).then(function(){
})
获取某个字段的值。
field
要获取的字段,可以是一个字段,也可以是多个字段,多个字段用, 隔开onlyOne
是否只需要一个值, true 或者数字return
promise// 取 id>5000 的集合,只需要 id 值,不需要其他字段值
D('Group').where({id: ['>',5000]}).getField('id').then(function(data){
//data 为一个数组
data = [7565,7564,7563,7562,7561,7560,7559,7558,7557]
})
// 只需要 id>5000 的一个值
D('Group').where({id: ['>', 5000]}).getField('id', true).then(function(data){
//data 为数字
data = 7557;
})
// 只需要 id>5000 的 3 值
D('Group').where({id: ['>', 5000]}).getField('id', 3).then(function(data){
//data 为数字
data = [7559, 7558, 7557];
})
// 获取 id 和 view_nums 2 个字段的值
D('Group').getField('id,view_nums').then(function(data){data = {"id":[7565,7564,7563,7562,7561,7560,7559,7558,7557],
"view_nums":[1965,1558,2335,2013,1425,1433,1994,2035,1118]
}
})
options
查询参数flag
当分页值不合法的时候,处理情况。true 为修正到第一页,false 为修正到最后一页,默认不进行修正。return
promise// 按每页 20 条数据来展现文件
D('Article').page(this.get("page"), 20).countSelect().then(function(data){
//data 的数据格式为
{
count: 123, // 总条数
total: 10, // 总页数
page: 1, // 当前页
num: 20, // 每页显示多少条
data: [{}, {}] // 详细的数据
}
});
//countSelect 里使用 group
D('Article').page(10).group('name').countSelect().then(function(data){})
//countSelect 里有子查询
D('Group').group('name').buildSql().then(function(sql){
return D('Artigle').table(sql, true).countSelect();
}).then(function(data){})
将当前查询条件生成一个 SELECT 语句,可以用作子查询的 sql 语句。
options
操作选项return
promiseD('Cate').where({id: ['>', 10]}).buildSql().then(function(sql){//sql = SELECT `id` FROM `meinv_cate` WHERE id> 10
return D('GROUP').where({cate_id: ['IN', sql, 'exp']});
})
自定义 sql 语句进行查询,用于非常复杂的 sql 语句时使用。
sql
要执行的 sql 语句parse
格式参数的数据return
promisevar data = [
value.field || '*',
mapOptions.mapfKey,
value.rTable || self.getRelationTableName(mapOptions.model),
mapOptions.model.getTableName(),
whereStr || 'WHERE',
value.rfKey || (mapOptions.model.getModelName().toLowerCase() + '_id'),
mapOptions.model.getPk(),
value.where ? ('AND' + value.where) : ''
]
D('Group').query('SELECT b.%s, a.%s FROM %s as a, %s as b %s AND a.%s=b.%s %s', data).then(function(data){
// 查询的数据
})
sql 语句中支持如下字符串的自动替换:
__TABLE__
替换为当前模型里的表名__USER__
替换为 C('db_prefix') + 'user'
表,其他表类似// 解析后的 sql 为 SELECT * FROM meinv_group as a LEFT JOIN meinv_user as u ON a.id=u.id WHERE u.id > 10
D('Group').query('SELECT * FROM __TABLE__ as a LEFT JOIN __USER__ as u ON a.id=u.id WHERE u.id> %d', 10);
自定义 sql 语句执行,用户复杂 sql 语句的情况。
使用方式与 query
相同,只是 then 里拿到的结果不同。exectue 为影响的行数。
关闭当前数据库连接,非特殊条件下不要使用该方法。
开启事务
return
Promise提交事务
return
Promise回滚事务
return
Promise事务操作 DEMO:
var model = D('Group');
// 开启事务
model.startTrans().then(function(){
return model.add(data);
}).then(function(){
return model.commit(); // 提交事务
}).catch(function(){
return model.rollback(); // 回滚事务
})
注意:只有支持事务的存储引擎使用这 3 个方法才有效
关闭所有数据库连接。
thinkRequire('Model').close();
数据库默认使用长连接的方式,不建议关闭数据库连接。该接口非特殊条件下,不要使用。