p78659104
/
ossean
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

gather_program add git conditions

This commit is contained in:
waterbeach 2017-03-20 10:33:08 +08:00
parent ed6683fecf
commit 649a6363a7
2 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
gather_program/src/main/java/org/ossean/gather/process/GatherThreadNew.java
View File

@ -145,7 +145,12 @@ public class GatherThreadNew implements Runnable {
} else
//这是对项目进行汇总的操作
if (conf.getTargetTableName().equals("gather_projects")) {
List<GatherProject> dataGet = gatherDao.getPrjGatherData(sourceTableName, selectItems, beginId, endId,
List<GatherProject> dataGet = null;
if(sourceTableName.equals("github"))
dataGet = gatherDao.getPrjGatherDataForGit(sourceTableName, selectItems, beginId, endId,
conf.getAndWhere());
else
dataGet = gatherDao.getPrjGatherData(sourceTableName, selectItems, beginId, endId,
conf.getAndWhere());
gatherProjects(dataGet);

9
gather_program/src/main/java/org/ossean/gather/sourceDao/GatherDao.java
View File

@ -59,6 +59,15 @@ public interface GatherDao {
@Param("idBegin") int idBegin, @Param("idEnd") int idEnd,
@Param("andWhere") String andWhere);
// 获取项目分表中相应数据 两边都有等于号
@Select("Select ${selectItems} from ${sourceTable} "
+ "where id >=${idBegin} and id <= ${idEnd} and fork=0 ${andWhere}")
public List<GatherProject> getPrjGatherDataForGit(
@Param("sourceTable") String sourceTableName,
@Param("selectItems") String selectItems,
@Param("idBegin") int idBegin, @Param("idEnd") int idEnd,
@Param("andWhere") String andWhere);
// 获取job_requirement中相应数据 两边都有等于号
@Select("Select ${selectItems} from ${sourceTable} "
+ "where id >=${idBegin} and id <= ${idEnd} ${andWhere}")