public class TopicRepository extends Object
| 构造器和说明 |
|---|
TopicRepository(BaseRepository baseRepository) |
| 限定符和类型 | 方法和说明 |
|---|---|
TopicDTO |
add(TopicDTO topicDTO) |
int |
decrPartitions(String id,
int value) |
int |
deleteById(String id) |
List<TopicDTO> |
getAll() |
TopicDTO |
getByCodeAndNamespace(String code,
String namespace) |
TopicDTO |
getById(String id) |
int |
getSearchCount(TopicQuery query) |
protected String |
getSearchSql(String prefix,
TopicQuery query,
List<Object> params) |
int |
incrPartitions(String id,
int value) |
List<TopicDTO> |
search(org.joyqueue.model.QPageQuery<TopicQuery> pageQuery) |
TopicDTO |
update(TopicDTO topicDTO) |
public TopicRepository(BaseRepository baseRepository)
public int getSearchCount(TopicQuery query)
public List<TopicDTO> search(org.joyqueue.model.QPageQuery<TopicQuery> pageQuery)
protected String getSearchSql(String prefix, TopicQuery query, List<Object> params)
public int incrPartitions(String id, int value)
public int decrPartitions(String id, int value)
public int deleteById(String id)
Copyright © 2020 Joyqueue Community. All rights reserved.