|
|
@@ -2,13 +2,16 @@ package com.uas.search.controller;
|
|
|
|
|
|
import com.uas.search.annotation.NotEmpty;
|
|
|
import com.uas.search.constant.model.SPage;
|
|
|
+import com.uas.search.dao.KindDao;
|
|
|
import com.uas.search.jms.JmsListener;
|
|
|
import com.uas.search.jms.LuceneMessage;
|
|
|
import com.uas.search.jms.LuceneMessageDao;
|
|
|
import com.uas.search.jms.LuceneMessageService;
|
|
|
+import com.uas.search.model.Kind;
|
|
|
import com.uas.search.service.IndexService;
|
|
|
import com.uas.search.support.DownloadHelper;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.jdbc.core.JdbcTemplate;
|
|
|
import org.springframework.stereotype.Controller;
|
|
|
import com.uas.search.util.StringUtils;
|
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
@@ -42,6 +45,12 @@ public class IndexController {
|
|
|
@Autowired
|
|
|
private JmsListener jmsListener;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private JdbcTemplate jdbcTemplate;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private KindDao kindDao;
|
|
|
+
|
|
|
@RequestMapping("/create")
|
|
|
@ResponseBody
|
|
|
public String initIndexes(String tableNames, HttpServletRequest request) {
|
|
|
@@ -49,6 +58,14 @@ public class IndexController {
|
|
|
indexService.createIndexes(toList(tableNames), true) / 1000.0);
|
|
|
}
|
|
|
|
|
|
+ @RequestMapping("/test")
|
|
|
+ @ResponseBody
|
|
|
+ public String testController(){
|
|
|
+ Integer count = jdbcTemplate.queryForObject("select count(1) from lucene$message", Integer.class);
|
|
|
+ List<Kind> kinds = kindDao.findAll();
|
|
|
+ return String.format("Indexes test success , %s; kind size : %s", count, kinds.size());
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* 根据逗号进行分隔,将字符串转为 List
|
|
|
*
|