Skip to content

A
aroad_aqsc
提交 3d701905 authored 作者: 董吉利's avatar 董吉利
浏览文件
操作

所有查询的index表名写死

上级 d45c8225
显示空白字符变更
内嵌 并排
正在显示 包含 22 行增加 和 561 行删除
src/main/java/com/elephant/framework/galaxy/aroad/bigdata/EsUtil_fanshe.java
浏览文件 @ 3d701905
...@@ -102,9 +102,9 @@ public class EsUtil_fanshe { ...@@ -102,9 +102,9 @@ public class EsUtil_fanshe {
* @Author: dongjili * @Author: dongjili
* @Date: 2019/5/13 0013 * @Date: 2019/5/13 0013
*/ */
public static List<Basebridgealldata> queryBridgeAll(String index, String type, int start, int row) throws Exception { public static List<Basebridgealldata> queryBridgeAll(String type, int start, int row) throws Exception {
// 搜索数据 // 搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row); SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch("basebridgealldata").setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度） //isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
//searchRequestBuilder.setQuery(QueryBuilders.matchAllQuery()); //searchRequestBuilder.setQuery(QueryBuilders.matchAllQuery());
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery() BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery()
...@@ -263,9 +263,9 @@ public class EsUtil_fanshe { ...@@ -263,9 +263,9 @@ public class EsUtil_fanshe {
* @Author: dongjili * @Author: dongjili
* @Date: * @Date:
*/ */
public static Map<String, Object> queryBridge(String keyword, String index, String type, int start, int row) throws Exception { public static Map<String, Object> queryBridge(String keyword,String type, int start, int row) throws Exception {
// 搜索数据 // 搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row); SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch("basebridgealldata").setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度） //isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) { if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值 //multiMatchQuery多个字段匹配某一个值
...@@ -426,198 +426,6 @@ public class EsUtil_fanshe { ...@@ -426,198 +426,6 @@ public class EsUtil_fanshe {
}}; }};
} }
/**
* @Description: termquery()桥梁代码词条查询
* @Param:
* @return:
* @Author: dongjili
* @Date: 2019/5/10 0010
*/
public static ArrayList<Basebridgealldata> queryBridgeQLDM(String keyword, String index, String type, int start, int row) throws Exception {
// 搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.termQuery("qiaoliangdaima", keyword));
}
String[] bridgeNames = {
"id",
"quhuadaima",
"quhuamingcheng",
"qiaoliangmingcheng",
"qiaoliangdaima",
"zhongxinzhuanghao",
"luxianbianma",
"luxianmingcheng",
"jishudengji",
"quanchang",
"kuajingzongchang",
"dankongzuidakuajing",
"qiaoliangquankuan",
"qiaomianjingkuan",
"kuajingfenleidaima",
"kuajingfenleileixing",
"nianxianfenleidaima",
"nianxianfenleileixing",
"yuanshangbujiegou1daima",
"yuanshangbujiegou1xingshi",
"yuanshangbujiegou2daima",
"yuanshangbujiegou2xingshi",
"shangbujiegoudaima",
"shangbujiegouxingshi",
"shangbujiegoucailiaodaima",
"shangbujiegoucailiaomingcheng",
"qiaodunleixingdaima",
"qiaodunleixingmingcheng",
"shejihezaidaima",
"shejihezaidengji",
"kangzhendengjidaima",
"kangzhendengji",
"kuayuediwudaima",
"kuayuediwuleixing",
"kuayuemingcheng",
"tonghangdengji",
"fangzhuangleixing",
"lijiaoleibie",
"jianshedanwei",
"shejidanwei",
"shigongdanwei",
"jianlidanwei",
"xiujianniandu",
"tongcheriqi",
"guanyangdaima",
"guanyangmingcheng",
"jianguandanweimingcheng",
"shoufeixingzhidaima",
"shoufeixingzhi",
"pingdingdengjidaima",
"pingdingdengji",
"pingdingdanwei",
"pingdingriqi",
"gaizaoniandu",
"wangongriqi",
"gaizaobuwei",
"gaizaoshigongdanwei",
"gongchengxingzhi",
"bubuxiangmu",
"binghaidaima",
"binghaibuwei",
"binghaimiaoshu",
"guanzhicuoshidaima",
"guanzhicuoshi",
"beizhu",
"zhuqiaokongshu",
"zhuqiaozhukua",
"zhuqiaobiankua",
"qianyinqiaochang",
"houyinqiaochang",
"qiaoxiajingkong",
"xiabujiegoudaima",
"xiabujiegoumingcheng",
"qiaotaidaima",
"qiaotaimingcheng",
"zhizuodaima",
"zhizuomingcheng",
"qiaomianpuzhuangdaima",
"qiaomianpuzhuangmingcheng",
"shensuofengdaima",
"shensuofengmingcheng",
"wanpoxiedaima",
"wanpoxiemingcheng",
"yuyingliqiao",
"zaixiuzaijian",
"zhadaomianji",
"shejihongshuipinlv",
"zongzaojia",
"maishezhuanghao",
"shifouzhadaoqiao",
"shifoushangkuaqiao",
"guanlidanweimingcheng",
"guanlidanweidaima",
"biangengyuanyindaima",
"biangengyuanyin",
"biangengshijian",
"xiangmuxingzhi",
"xiangmumingcheng",
"jihuaxiangmubianma",
"xiangmuleibie",
"xiangmudaima",
"xiangmuluxianbianma",
"xiangmuluxianmingcheng",
"xiangmuqiaoliangzhuanghao",
"xiangmubiangengyuanyin",
"xiangmubiangengshijian",
"touzilaiyuan",
"qiaoliangsuozaiweizhi",
"shifoukuanluzhaiqiao",
"shifouzaizhangdaqiaolaingmuluzhong",
"tianbaodanweimingcheng",
"shape",
"qiaokuazuhe"
};
SearchResponse response = searchRequestBuilder.get();
//获取命中次数，查询结果有多少对象
SearchHits hits = response.getHits();
ArrayList<Basebridgealldata> basebridgealldataList = new ArrayList<>();
for (SearchHit hit : hits) {
//System.out.println(hit.getSourceAsString());
Map<String, Object> sourceAsMap = hit.getSourceAsMap();
//LuKeBridge luKeBridge = new LuKeBridge();
//获取该类在堆区的Class对象
Class<?> clazz = Class.forName("com.elephant.framework.galaxy.aroad.bigdata.Basebridgealldata");
//获取私有的构造方法
Constructor<?> constructor = clazz.getDeclaredConstructor();
//暴力破解
constructor.setAccessible(true);
//实例化对象
Basebridgealldata basebridgealldata = (Basebridgealldata) constructor.newInstance();
//获得私有的属性对象
Field[] beanFiled = clazz.getDeclaredFields();
basebridgealldata.setId(hit.getId());
for (int a = 1; a < bridgeNames.length; a++) {
//暴力破解
beanFiled[a].setAccessible(true);
//把查询到的每一个字段的值赋给luKeBridge的每一个属性
beanFiled[a].set(basebridgealldata, sourceAsMap.get(bridgeNames[a]) == null ? "" : sourceAsMap.get(bridgeNames[a]).toString());
}
basebridgealldataList.add(basebridgealldata);
}
return basebridgealldataList;
}
/**
* @Description: 桥梁字段查询查询出一条结果就返回
* @Param:
* @return:
* @Author: dongjili
* @Date:
*/
public static boolean queryBridgeOne(String keyword, String index, String type, int start, int row) throws Exception {
// 搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.multiMatchQuery(keyword,
"id",
"qiaoliangmingcheng",
"qiaoliangdaima"
));
}
SearchResponse response = searchRequestBuilder.get();
//获取命中次数，查询结果有多少对象
SearchHits hits = response.getHits();
if (hits.getHits().length > 0) {
return true;
} else {
return false;
}
}
/** /**
* @Description: 路段查询所有数据 * @Description: 路段查询所有数据
* @Param: * @Param:
...@@ -625,9 +433,9 @@ public class EsUtil_fanshe { ...@@ -625,9 +433,9 @@ public class EsUtil_fanshe {
* @Author: dongjili * @Author: dongjili
* @Date: 2019/5/13 0013 * @Date: 2019/5/13 0013
*/ */
public static List<Basehighwayalldata> queryHighWayAll(String index, String type, int start, int row) throws Exception { public static List<Basehighwayalldata> queryHighWayAll(String type, int start, int row) throws Exception {
//搜索数据 //搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row); SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch("basehighwayalldata").setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度） //isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
//multiMatchQuery多个字段匹配某一个值 //multiMatchQuery多个字段匹配某一个值
...@@ -799,9 +607,9 @@ public class EsUtil_fanshe { ...@@ -799,9 +607,9 @@ public class EsUtil_fanshe {
* @Author: dongjili * @Author: dongjili
* @Date: * @Date:
*/ */
public static Map<String, Object> queryHighWay(String keyword, String index, String type, int start, int row) throws Exception { public static Map<String, Object> queryHighWay(String keyword,String type, int start, int row) throws Exception {
//搜索数据 //搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row); SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch("basehighwayalldata").setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度） //isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) { if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值 //multiMatchQuery多个字段匹配某一个值
...@@ -984,9 +792,9 @@ public class EsUtil_fanshe { ...@@ -984,9 +792,9 @@ public class EsUtil_fanshe {
* @Author: dongjili * @Author: dongjili
* @Date: 2019/5/14 0014 * @Date: 2019/5/14 0014
*/ */
public static List<Basehighwayalldata> queryHighWayFiler(String lxbh,double zh, String index, String type) throws Exception { public static List<Basehighwayalldata> queryHighWayFiler(String lxbh,double zh,String type) throws Exception {
//搜索数据 //搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(0).setSize(1); SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch("basehighwayalldata").setTypes(type).setFrom(0).setSize(1);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度） //isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(lxbh)) { if (org.apache.commons.lang.StringUtils.isNotBlank(lxbh)) {
//multiMatchQuery多个字段匹配某一个值 //multiMatchQuery多个字段匹配某一个值
...@@ -1155,176 +963,6 @@ public class EsUtil_fanshe { ...@@ -1155,176 +963,6 @@ public class EsUtil_fanshe {
} }
return basehighwayalldataList; return basehighwayalldataList;
} }
/**
* @Description: termquery()路线编号词条查询
* @Param:
* @return:
* @Author: dongjili
* @Date: 2019/5/10 0010
*/
public static ArrayList<Basehighwayalldata> queryHighWayLXBH(String keyword, String index, String type, int start, int row) throws Exception {
//搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.termQuery("luxianbianhao", keyword));
/*searchRequestBuilder.setQuery(QueryBuilders.matchQuery("luxianbianhao",keyword));*/
}
String[] highwayNames = {
"id",
"luxianbianhao",
"quhuadaima",
"luxianmingcheng",
"qidianmingcheng",
"zhidianmingcheng",
"qidianzhuanghaoa",
"zhidianzhuanghao",
"licheng",
"lichengjisuan",
"sandlicheng",
"dengjidaima",
"dengjimingcheng",
"chedaodaima",
"chedaofenlei",
"mianchengdaima",
"mianchengfenlei",
"lujikuandu",
"lumiankuandu",
"shejishisu",
"xiujianniandu",
"gaijianniandu",
"chengguanlu",
"duantoulu",
"chongfubianma",
"chongfuxuhao",
"qidianzhuanghaob",
"zhongdianzhuanghao",
"yanghulicheng",
"qingyulicheng",
"kelvhaolicheng",
"yilvhualicheng",
"dimaodaima",
"dimaohanzi",
"handongshuliang",
"maisheqidianzhuanghao",
"maishezhidianzhuanghao",
"quhuamingchengshi",
"quhuamingchengxian",
"quhuamingchengxiang",
"luduanxuhao",
"guanyangdanweileibie",
"beizhu",
"kaigongriqi",
"jungongriqi",
"qidianfenjiedianleixing",
"zhidianfenjiedianleixing",
"shengjichurukou",
"gbmlicheng",
"yangbanlicheng",
"tongcheriqi",
"luxiandifangmingcheng",
"jianshexingzhidaima",
"jianshexingzhihanzi",
"duanlianleixing",
"luduanleixingdaima",
"luduanleixing",
"guanyangdanweimingcheng",
"mqi",
"pingdingdengji",
"shoufeixingzhi",
"biangengyuanyindaima",
"biangengyuanyin",
"biangengshijian",
"xiangmuxingzhi",
"xiangmumingcheng",
"xiangmudaima",
"xiangmuqidianmingcheng",
"xiangmuzhidianmingcheng",
"xiangmuleibie",
"jihuaxiangmubianma",
"xiangmuluxianbianma",
"xiangmuluxianmingcheng",
"xiangmubiangengyuanyin",
"xiangmubiangengshijian",
"touzilaiyuan",
"miancenghoudu",
"zuijinyicidaxiuniandu",
"zuijinyicizhongxiuniandu",
"guodaotiaozhengqianluxianbianma",
"guodaozhuanghaochuandiyuliulicheng",
"nianpingjunrijiaotongliang",
"shifouanganxiangongluguanlijieyang",
"luxiantiaozhengleixing",
"shangnianluxianbianma",
"shangnianluxianmingcheng",
"shangnianluxianqidianzhuanghao",
"shangnianluxianzhidianzhuanghao",
"tianbaodanweimingcheng",
"shape"
};
SearchResponse response = searchRequestBuilder.get();
//获取命中次数，查询结果有多少对象
SearchHits hits = response.getHits();
ArrayList<Basehighwayalldata> basehighwayalldataList = new ArrayList<>();
for (SearchHit hit : hits) {
Map<String, Object> sourceAsMap = hit.getSourceAsMap();
//LuKeHighWay luKeHighWay = new LuKeHighWay();
//获取该类在堆区的Class对象
Class<?> clazz = Class.forName("com.elephant.framework.galaxy.aroad.bigdata.Basehighwayalldata");
//获取私有的构造方法
Constructor<?> constructor = clazz.getDeclaredConstructor();
//暴力破解
constructor.setAccessible(true);
//实例化对象
Basehighwayalldata basehighwayalldata = (Basehighwayalldata) constructor.newInstance();
//获取私有的属性字段
Field[] beanFiled = clazz.getDeclaredFields();
basehighwayalldata.setId(hit.getId());
for (int a = 1; a < highwayNames.length; a++) {
//暴力破解
beanFiled[a].setAccessible(true);
//给路段属性复制
beanFiled[a].set(basehighwayalldata, sourceAsMap.get(highwayNames[a]) == null ? "" : sourceAsMap.get(highwayNames[a]).toString());
}
basehighwayalldataList.add(basehighwayalldata);
}
return basehighwayalldataList;
}
/**
* @Description: 路段全字段查询, 查询出一条结果就返回
* @Param:
* @return: ArrayList<LuKeHighWay> lukehighways
* @Author: dongjili
* @Date:
*/
public static boolean queryHighWayOne(String keyword, String index, String type, int start, int row) throws Exception {
//搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.multiMatchQuery(keyword,
"id",
"luxianbianhao",
"luxianmingcheng",
"qidianmingcheng",
"zhidianmingcheng"
));
}
SearchResponse response = searchRequestBuilder.get();
//获取命中次数，查询结果有多少对象
SearchHits hits = response.getHits();
if (hits.getHits().length > 0) {
return true;
} else {
return false;
}
}
/** /**
* @Description: 隧道查询所有数据 * @Description: 隧道查询所有数据
...@@ -1333,9 +971,9 @@ public class EsUtil_fanshe { ...@@ -1333,9 +971,9 @@ public class EsUtil_fanshe {
* @Author: dongjili * @Author: dongjili
* @Date: 2019/5/13 0013 * @Date: 2019/5/13 0013
*/ */
public static List<Basetunnelalldata> queryTunnelAll(String index, String type, int start, int row) throws Exception { public static List<Basetunnelalldata> queryTunnelAll(String type, int start, int row) throws Exception {
//搜索数据 //搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row); SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch("basetunnelalldata").setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度） //isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
//multiMatchQuery多个字段匹配某一个值 //multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔 //multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
...@@ -1427,9 +1065,9 @@ public class EsUtil_fanshe { ...@@ -1427,9 +1065,9 @@ public class EsUtil_fanshe {
* @Author: dongjili * @Author: dongjili
* @Date: 2019/4/28 0028 * @Date: 2019/4/28 0028
*/ */
public static HashMap<String, Object> queryTunnel(String keyword, String index, String type, int start, int row) throws Exception { public static HashMap<String, Object> queryTunnel(String keyword,String type, int start, int row) throws Exception {
//搜索数据 //搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row); SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch("basetunnelalldata").setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度） //isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) { if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值 //multiMatchQuery多个字段匹配某一个值
...@@ -1521,127 +1159,6 @@ public class EsUtil_fanshe { ...@@ -1521,127 +1159,6 @@ public class EsUtil_fanshe {
}}; }};
} }
/**
* @Description: termquery()隧道代码词条匹配查询
* @Param:
* @return:
* @Author: dongjili
* @Date: 2019/5/10 0010
*/
public static List<Basetunnelalldata> queryTunnelSDDM(String keyword, String index, String type, int start, int row) throws Exception {
//搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.termQuery("suidaodaima", keyword));
}
String[] basicTunnelNames = {
"id",
"suidaomingcheng",
"suidaodaima",
"zhongxinzhuanghao",
"luxianbianma",
"luxianmingcheng",
"jishudengji",
"changdu",
"jingkuan",
"jinggao",
"changdufenleidaima",
"fenleimingcheng",
"shuixiasuidao",
"xiujianniandu",
"jianshedanwei",
"shejidanwei",
"shigongdanwei",
"jianlidanwei",
"tongcheshijian",
"shuidaoyanghudengji",
"guanyangdanweixingzhi",
"guanyangdanweimingcheng",
"jianguandanwei",
"pingdingdengji",
"pingdingriqi",
"pingdingdanwei",
"pingdingdengjitujian",
"pingdingriqitujian",
"pingdingdanweitujian",
"pingdingdengjijidian",
"pingdingriqijidian",
"pingdingdanweijidian",
"pingdingdengjiqita",
"pingdingriqiqita",
"pingdingdanweiqita",
"gaijianniandu",
"wangongriqi",
"gaizaibuwei",
"gongchengxingzhi",
"binghaibuwei",
"binghaimiaoshu",
"xianjizhengqudaima",
"shifouzaizhangdasuidaomuluzhong",
"beizhu",
"shape"
};
SearchResponse response = searchRequestBuilder.get();
//获取命中次数，查询结果有多少对象
SearchHits hits = response.getHits();
List<Basetunnelalldata> basetunnelalldataList = new ArrayList<>();
for (SearchHit hit : hits) {
Map<String, Object> sourceAsMap = hit.getSourceAsMap();
//LuKeHighWay luKeHighWay = new LuKeHighWay();
//获取该类在堆区的Class对象
Class<?> clazz = Class.forName("com.elephant.framework.galaxy.aroad.bigdata.Basetunnelalldata");
//获取私有的构造方法
Constructor<?> constructor = clazz.getDeclaredConstructor();
//暴力破解
constructor.setAccessible(true);
//实例化对象
Basetunnelalldata basetunnelalldata = (Basetunnelalldata) constructor.newInstance();
//获取私有的属性字段
Field[] beanFiled = clazz.getDeclaredFields();
basetunnelalldata.setId(hit.getId());
for (int a = 1; a < basicTunnelNames.length; a++) {
//暴力破解
beanFiled[a].setAccessible(true);
//给路段属性复制
beanFiled[a].set(basetunnelalldata, sourceAsMap.get(basicTunnelNames[a]) == null ? "" : sourceAsMap.get(basicTunnelNames[a]).toString());
}
basetunnelalldataList.add(basetunnelalldata);
}
return basetunnelalldataList;
}
/**
* @Description: 隧道全字段查询，查询出一条就返回
* @Param:
* @return:
* @Author: dongjili
* @Date: 2019/4/28 0028
*/
public static boolean queryTunnelOne(String keyword, String index, String type, int start, int row) throws Exception {
//搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.multiMatchQuery(keyword,
"suidaomingcheng"
));
}
SearchResponse response = searchRequestBuilder.get();
//获取命中次数，查询结果有多少对象
SearchHits hits = response.getHits();
if (hits.getHits().length > 0) {
return true;
} else {
return false;
}
}
/** /**
* @Description: 收费站查询所有数据 * @Description: 收费站查询所有数据
* @Param: * @Param:
...@@ -1649,9 +1166,9 @@ public class EsUtil_fanshe { ...@@ -1649,9 +1166,9 @@ public class EsUtil_fanshe {
* @Author: dongjili * @Author: dongjili
* @Date: 2019/5/13 0013 * @Date: 2019/5/13 0013
*/ */
public static List<BaseRoadToll_String> queryBaseRoadTollStringAll(String index, String type, int start, int row) throws Exception { public static List<BaseRoadToll_String> queryBaseRoadTollStringAll(String type, int start, int row) throws Exception {
//搜索数据 //搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row); SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch("baseroadtolldata").setTypes(type).setFrom(start).setSize(row);
searchRequestBuilder.setQuery(QueryBuilders.matchAllQuery()); searchRequestBuilder.setQuery(QueryBuilders.matchAllQuery());
String[] baseRoadTollNames = {"id", String[] baseRoadTollNames = {"id",
"roadCode", "roadCode",
...@@ -1712,9 +1229,9 @@ public class EsUtil_fanshe { ...@@ -1712,9 +1229,9 @@ public class EsUtil_fanshe {
* @Author: dongjili * @Author: dongjili
* @Date: 2019/4/28 0028 * @Date: 2019/4/28 0028
*/ */
public static HashMap<String, Object> queryBaseRoadTollString(String keyword, String index, String type, int start, int row) throws Exception { public static HashMap<String, Object> queryBaseRoadTollString(String keyword,String type, int start, int row) throws Exception {
//搜索数据 //搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row); SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch("baseroadtolldata").setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度） //isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) { if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值 //multiMatchQuery多个字段匹配某一个值
...@@ -1779,34 +1296,6 @@ public class EsUtil_fanshe { ...@@ -1779,34 +1296,6 @@ public class EsUtil_fanshe {
}}; }};
} }
/**
* @Description: 收费站全字段查询，查询出一条数据就返回
* @Param:
* @return:
* @Author: dongjili
* @Date: 2019/4/28 0028
*/
public static boolean queryBaseRoadTollOne(String keyword, String index, String type, int start, int row) throws Exception {
//搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.multiMatchQuery(keyword,
"name"
));
}
SearchResponse response = searchRequestBuilder.get();
//获取命中次数，查询结果有多少对象
SearchHits hits = response.getHits();
if (hits.getHits().length > 0) {
return true;
} else {
return false;
}
}
/** /**
* @Description: 查询服务区所有数据 * @Description: 查询服务区所有数据
...@@ -1815,9 +1304,9 @@ public class EsUtil_fanshe { ...@@ -1815,9 +1304,9 @@ public class EsUtil_fanshe {
* @Author: dongjili * @Author: dongjili
* @Date: 2019/5/13 0013 * @Date: 2019/5/13 0013
*/ */
public static List<BaseHighWayService> queryBaseHighWayServiceAll(String index, String type, int start, int row) throws Exception { public static List<BaseHighWayService> queryBaseHighWayServiceAll(String type, int start, int row) throws Exception {
//搜索数据 //搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row); SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch("basehighwayservice").setTypes(type).setFrom(start).setSize(row);
searchRequestBuilder.setQuery(QueryBuilders.matchAllQuery()); searchRequestBuilder.setQuery(QueryBuilders.matchAllQuery());
String[] baseRoadTollNames = { String[] baseRoadTollNames = {
"id", "id",
...@@ -1883,9 +1372,9 @@ public class EsUtil_fanshe { ...@@ -1883,9 +1372,9 @@ public class EsUtil_fanshe {
* @Author: dongjili * @Author: dongjili
* @Date: 2019/5/8 0008 * @Date: 2019/5/8 0008
*/ */
public static HashMap<String, Object> queryBaseHighWayService(String keyword, String index, String type, int start, int row) throws Exception { public static HashMap<String, Object> queryBaseHighWayService(String keyword,String type, int start, int row) throws Exception {
//搜索数据 //搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row); SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch("basehighwayservice").setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度） //isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) { if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值 //multiMatchQuery多个字段匹配某一个值
...@@ -1953,33 +1442,5 @@ public class EsUtil_fanshe { ...@@ -1953,33 +1442,5 @@ public class EsUtil_fanshe {
put("list", baseHighWayServices); put("list", baseHighWayServices);
}}; }};
} }
/**
* @Description: 服务区全字段查询，查询出一条数据就返回
* @Param:
* @return:
* @Author: dongjili
* @Date: 2019/5/8 0008
*/
public static boolean queryBaseHighWayServiceOne(String keyword, String index, String type, int start, int row) throws Exception {
//搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.multiMatchQuery(keyword,
"fwssmc"
));
}
SearchResponse response = searchRequestBuilder.get();
//获取命中次数，查询结果有多少对象
SearchHits hits = response.getHits();
if (hits.getHits().length > 0) {
return true;
} else {
return false;
}
}
} }
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论