614 lines
25 KiB
Java
614 lines
25 KiB
Java
package com.nis.web.service;
|
||
|
||
import java.lang.reflect.Field;
|
||
import java.lang.reflect.Method;
|
||
import java.sql.ResultSet;
|
||
import java.text.ParseException;
|
||
import java.text.SimpleDateFormat;
|
||
import java.util.ArrayList;
|
||
import java.util.Date;
|
||
import java.util.HashMap;
|
||
import java.util.List;
|
||
import java.util.Map;
|
||
|
||
import org.apache.ibatis.mapping.ResultMap;
|
||
import org.apache.ibatis.mapping.ResultMapping;
|
||
import org.apache.ibatis.session.SqlSessionFactory;
|
||
import org.slf4j.Logger;
|
||
import org.slf4j.LoggerFactory;
|
||
|
||
import com.nis.domain.Page;
|
||
import com.nis.util.Configurations;
|
||
import com.nis.util.Constants;
|
||
import com.nis.util.HiveDataSource;
|
||
import com.nis.util.StringUtil;
|
||
import com.nis.util.redis.SaveRedisThread;
|
||
|
||
public class HiveSqlService {
|
||
private final static Logger logger = LoggerFactory.getLogger(HiveSqlService.class);
|
||
private static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
||
|
||
public static ResultSet getResultSet(Page page, Object bean, String tableName,
|
||
Map<String, Map<String, String>> col2col, String orderBy, String searchActiveSys) throws Exception {
|
||
tableName = tableName.toLowerCase();
|
||
String showColmun = getFiledsSql(bean.getClass().getSimpleName(), page.getFields());
|
||
StringBuffer sql = new StringBuffer();
|
||
Map<String, String> filedAndColumnMap = getFiledAndColumnMap(bean.getClass());
|
||
if (null == showColmun || showColmun.equals("")) {
|
||
for (String key : filedAndColumnMap.keySet()) {
|
||
if (!filedAndColumnMap.get(key).toLowerCase().equals("id")) {
|
||
sql.append(filedAndColumnMap.get(key) + ",");
|
||
}
|
||
}
|
||
} else {
|
||
sql.append(showColmun);
|
||
}
|
||
String sqlTrim = sql.toString().trim();
|
||
if (sqlTrim.endsWith(",")) {
|
||
sqlTrim = sqlTrim.substring(0, sqlTrim.length() - 1);
|
||
}
|
||
sql.setLength(0);
|
||
sql.append(" select " + sqlTrim + " from " + tableName + " t where 1=1 ");
|
||
if (bean != null) {
|
||
Class<?> clazz = bean.getClass();
|
||
for (; clazz != Object.class; clazz = clazz.getSuperclass()) {
|
||
// 获å<C2B7>–所有的å—段包括public,private,protected,private
|
||
// Field[] fields = bean.getClass().getDeclaredFields();
|
||
Field[] fields = clazz.getDeclaredFields();
|
||
Long foundTimePartStart = null;
|
||
Long foundTimePartEnd = null;
|
||
for (int i = 0; i < fields.length; i++) {
|
||
// 现在gwall日志表结构ä¸å<C2AD>ªæœ‰æ•°å€¼å’Œå—符串两ç§<C3A7>类型,数值都是int类型没有bigint所以ä¸<C3A4>需è¦<C3A8>åŠ L,
|
||
Field f = fields[i];
|
||
String key = f.getName();// 获å<C2B7>–å—段å<C2B5><C3A5>
|
||
String typeName = f.getType().getName();
|
||
if (f.getType().getName().equals("java.lang.String") && key.startsWith("search")) {
|
||
Object value = getFieldValue(bean, key);
|
||
if (value != null) {
|
||
setFieldValue(bean, key, value.toString().trim());
|
||
if (key.endsWith("Time")) {// 日期开始或结æ<E2809C>Ÿçš„å—段
|
||
if (col2col.containsKey(key)) {
|
||
value = sdf.parse(value.toString().trim()).getTime() / 1000;
|
||
if (key.toLowerCase().equals("searchfoundstarttime")) {
|
||
foundTimePartStart = Long.parseLong(value.toString()) / 3600L/ 24L;
|
||
}
|
||
if (key.toLowerCase().equals("searchfoundendtime")) {
|
||
foundTimePartEnd = Long.parseLong(value.toString()) / 3600L/ 24L;
|
||
}
|
||
if (col2col.get(key).get("start") != null) {
|
||
// sql.append(" and " +
|
||
// filedAndColumnMap.get(col2col.get(key).get("start"))
|
||
// + ">=to_date('" +
|
||
// value.toString().trim()
|
||
// + "','yyyy-mm-dd HH24:mi:ss')");
|
||
sql.append(" and " + filedAndColumnMap.get(col2col.get(key).get("start")) + ">="
|
||
+ value);
|
||
} else {
|
||
// sql.append(" and " +
|
||
// filedAndColumnMap.get(col2col.get(key).get("end"))
|
||
// + "<=to_date('" +
|
||
// value.toString().trim()
|
||
// + "','yyyy-mm-dd HH24:mi:ss')");
|
||
sql.append(" and " + filedAndColumnMap.get(col2col.get(key).get("end")) + "<"
|
||
+ value);
|
||
}
|
||
}
|
||
} else {
|
||
if (key.toLowerCase().startsWith("search")) {
|
||
key = key.replace("search", "");
|
||
key = key.substring(0, 1).toLowerCase() + key.substring(1);
|
||
}
|
||
|
||
if (typeName.equals("java.lang.String")) {
|
||
sql.append(" and " + filedAndColumnMap.get(key) + "='" + value.toString().trim()
|
||
+ "'");
|
||
} else if (typeName.equals("java.lang.Integer") || typeName.equals("int")) {
|
||
sql.append(" and " + filedAndColumnMap.get(key) + "=" + value.toString().trim());
|
||
|
||
} else if (typeName.equals("java.lang.Long") || typeName.equals("long")) {
|
||
sql.append(
|
||
" and " + filedAndColumnMap.get(key) + "=" + value.toString().trim() + "L");
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
if (null != foundTimePartStart) {
|
||
// sql.append(" and found_time_partition>=" + foundTimePartStart + "L");
|
||
sql.append(" and found_time_partition>=" + foundTimePartStart);
|
||
}
|
||
if (null != foundTimePartEnd) {
|
||
// sql.append(" and found_time_partition<" + foundTimePartEnd + "L");
|
||
sql.append(" and found_time_partition<" + foundTimePartEnd);
|
||
}
|
||
|
||
}
|
||
}
|
||
Integer startNum = (page.getPageNo() - 1) * page.getPageSize() + 1;
|
||
Integer endNum = startNum - 1 + page.getPageSize();
|
||
// sql.append(" order by " + orderBy + " limit 10000) t1) t2 where
|
||
// row_Num between " + startNum + " and " + endNum);
|
||
sql.append(" limit " + Constants.EVERY_GETHIVEDATANUM);
|
||
logger.info("获å<EFBFBD>–æ•°æ<EFBFBD>®ä¸å¿ƒæ—¥å¿—sql==================={}", sql);
|
||
// ResultSet query = HiveJDBC.query(sql.toString());
|
||
ResultSet query = HiveDataSource.query(sql.toString());
|
||
logger.info("获å<EFBFBD>–æ•°æ<EFBFBD>®ä¸å¿ƒæ—¥å¿—æˆ<EFBFBD>功");
|
||
return query;
|
||
}
|
||
|
||
public static Long getHivePageCount(Object bean, String countKey, String tableName,
|
||
Map<String, Map<String, String>> col2col, String searchActiveSys) throws Exception {
|
||
tableName = tableName.toLowerCase();
|
||
StringBuffer sql = new StringBuffer();
|
||
Map<String, String> filedAndColumnMap = getFiledAndColumnMap(bean.getClass());
|
||
sql.append("select count(1) from " + tableName + " where 1=1 ");
|
||
if (bean != null) {
|
||
Class<?> clazz = bean.getClass();
|
||
for (; clazz != Object.class; clazz = clazz.getSuperclass()) {
|
||
// 获å<C2B7>–所有的å—段包括public,private,protected,private
|
||
// Field[] fields = bean.getClass().getDeclaredFields();
|
||
Field[] fields = clazz.getDeclaredFields();
|
||
Long foundTimePartStart = null;
|
||
Long foundTimePartEnd = null;
|
||
for (int i = 0; i < fields.length; i++) {
|
||
// 现在gwall日志表结构ä¸å<C2AD>ªæœ‰æ•°å€¼å’Œå—符串两ç§<C3A7>类型,数值都是int类型没有bigint所以ä¸<C3A4>需è¦<C3A8>åŠ L,
|
||
Field f = fields[i];
|
||
String key = f.getName();// 获å<C2B7>–å—段å<C2B5><C3A5>
|
||
String typeName = f.getType().getName();
|
||
if (f.getType().getName().equals("java.lang.String") && key.startsWith("search")) {
|
||
Object value = getFieldValue(bean, key);
|
||
if (value != null) {
|
||
setFieldValue(bean, key, value.toString().trim());
|
||
if (key.endsWith("Time")) {// 日期开始或结æ<E2809C>Ÿçš„å—段
|
||
if (col2col.containsKey(key)) {
|
||
value = sdf.parse(value.toString().trim()).getTime() / 1000;
|
||
if (key.toLowerCase().equals("searchfoundstarttime")) {
|
||
foundTimePartStart = Long.parseLong(value.toString()) / 3600L/ 24L;
|
||
}
|
||
if (key.toLowerCase().equals("searchfoundendtime")) {
|
||
foundTimePartEnd = Long.parseLong(value.toString()) / 3600L/ 24L;
|
||
}
|
||
if (col2col.get(key).get("start") != null) {
|
||
// sql.append(" and " +
|
||
// filedAndColumnMap.get(col2col.get(key).get("start"))
|
||
// + ">=to_date('" +
|
||
// value.toString().trim()
|
||
// + "','yyyy-mm-dd HH24:mi:ss')");
|
||
sql.append(" and " + filedAndColumnMap.get(col2col.get(key).get("start")) + ">="
|
||
+ value);
|
||
} else {
|
||
// sql.append(" and " +
|
||
// filedAndColumnMap.get(col2col.get(key).get("end"))
|
||
// + "<=to_date('" +
|
||
// value.toString().trim()
|
||
// + "','yyyy-mm-dd HH24:mi:ss')");
|
||
sql.append(" and " + filedAndColumnMap.get(col2col.get(key).get("end")) + "<"
|
||
+ value);
|
||
}
|
||
}
|
||
} else {
|
||
if (key.toLowerCase().startsWith("search")) {
|
||
key = key.replace("search", "");
|
||
key = key.substring(0, 1).toLowerCase() + key.substring(1);
|
||
}
|
||
|
||
if (typeName.equals("java.lang.String")) {
|
||
sql.append(" and " + filedAndColumnMap.get(key) + "='" + value.toString().trim()
|
||
+ "'");
|
||
} else if (typeName.equals("java.lang.Integer") || typeName.equals("int")) {
|
||
sql.append(" and " + filedAndColumnMap.get(key) + "=" + value.toString().trim());
|
||
|
||
} else if (typeName.equals("java.lang.Long") || typeName.equals("long")) {
|
||
sql.append(
|
||
" and " + filedAndColumnMap.get(key) + "=" + value.toString().trim() + "L");
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
if (null != foundTimePartStart) {
|
||
// sql.append(" and found_time_partition>=" + foundTimePartStart + "L");
|
||
sql.append(" and found_time_partition>=" + foundTimePartStart);
|
||
}
|
||
if (null != foundTimePartEnd) {
|
||
// sql.append(" and found_time_partition<" + foundTimePartEnd + "L");
|
||
sql.append(" and found_time_partition<" + foundTimePartEnd);
|
||
}
|
||
|
||
}
|
||
}
|
||
logger.info("获å<EFBFBD>–æ•°æ<EFBFBD>®ä¸å¿ƒæ—¥å¿—总æ<EFBFBD>¡æ•°sql==================" + sql.toString());
|
||
// ResultSet countRs = HiveJDBC.query(countSql.toString());
|
||
ResultSet countRs = HiveDataSource.query(sql.toString());
|
||
String countStr = null;
|
||
while (countRs.next()) {
|
||
countStr = countRs.getObject(1).toString();
|
||
break;
|
||
}
|
||
if (countStr == null || countStr.equals("")) {
|
||
logger.info("获å<EFBFBD>–æ•°æ<EFBFBD>®ä¸å¿ƒæ—¥å¿—总æ<EFBFBD>¡æ•°æˆ<EFBFBD>功总共===================0æ<30>¡é…<C3A9>ç½®");
|
||
return 0l;
|
||
}
|
||
Long count = Long.valueOf(countStr);
|
||
logger.info("获å<EFBFBD>–æ•°æ<EFBFBD>®ä¸å¿ƒæ—¥å¿—总æ<EFBFBD>¡æ•°æˆ<EFBFBD>功总共===================" + count + "æ<EFBFBD>¡é…<EFBFBD>ç½®");
|
||
// HiveJDBC.closeConn();
|
||
if (Constants.IS_OPEN_REDIS && Constants.DATACENTER_OPEN_REDIS) {
|
||
new SaveRedisThread(countKey, count, Constants.HIVE_EXPIRE).start();
|
||
}
|
||
return count;
|
||
}
|
||
|
||
public static ResultSet getResultSet2(Page page, Object bean, String tableName,
|
||
Map<String, Map<String, String>> col2col, String orderBy, String searchActiveSys) throws Exception {
|
||
tableName = tableName.toLowerCase();
|
||
String showColmun = getFiledsSql(bean.getClass().getSimpleName(), page.getFields());
|
||
StringBuffer sql = new StringBuffer();
|
||
Map<String, String> filedAndColumnMap = getFiledAndColumnMap(bean.getClass());
|
||
if (null == showColmun || showColmun.equals("")) {
|
||
for (String key : filedAndColumnMap.keySet()) {
|
||
if (!filedAndColumnMap.get(key).toLowerCase().equals("id")) {
|
||
sql.append(filedAndColumnMap.get(key) + ",");
|
||
}
|
||
}
|
||
} else {
|
||
sql.append(showColmun);
|
||
}
|
||
String sqlTrim = sql.toString().trim();
|
||
if (sqlTrim.endsWith(",")) {
|
||
sqlTrim = sqlTrim.substring(0, sqlTrim.length() - 1);
|
||
}
|
||
sql.setLength(0);
|
||
sql.append("select " + sqlTrim + " from(select " + sqlTrim + ",row_Num from(select " + sqlTrim
|
||
+ ",row_number() over() as row_Num from " + tableName + " t where 1=1 ");
|
||
if (bean != null) {
|
||
Class<?> clazz = bean.getClass();
|
||
for (; clazz != Object.class; clazz = clazz.getSuperclass()) {
|
||
// 获å<C2B7>–所有的å—段包括public,private,protected,private
|
||
// Field[] fields = bean.getClass().getDeclaredFields();
|
||
Field[] fields = clazz.getDeclaredFields();
|
||
Long foundTimePartStart = null;
|
||
Long foundTimePartEnd = null;
|
||
for (int i = 0; i < fields.length; i++) {
|
||
// 现在gwall日志表结构ä¸å<C2AD>ªæœ‰æ•°å€¼å’Œå—符串两ç§<C3A7>类型,数值都是int类型没有bigint所以ä¸<C3A4>需è¦<C3A8>åŠ L,
|
||
Field f = fields[i];
|
||
String key = f.getName();// 获å<C2B7>–å—段å<C2B5><C3A5>
|
||
String typeName = f.getType().getName();
|
||
if (f.getType().getName().equals("java.lang.String") && key.startsWith("search")) {
|
||
Object value = getFieldValue(bean, key);
|
||
if (value != null) {
|
||
setFieldValue(bean, key, value.toString().trim());
|
||
if (key.endsWith("Time")) {// 日期开始或结æ<E2809C>Ÿçš„å—段
|
||
if (col2col.containsKey(key)) {
|
||
value = sdf.parse(value.toString().trim()).getTime() / 1000;
|
||
if (key.toLowerCase().equals("searchfoundstarttime")) {
|
||
foundTimePartStart = Long.parseLong(value.toString()) / 3600L/ 24L;
|
||
}
|
||
if (key.toLowerCase().equals("searchfoundendtime")) {
|
||
foundTimePartEnd = Long.parseLong(value.toString()) / 3600L/ 24L;
|
||
}
|
||
if (col2col.get(key).get("start") != null) {
|
||
// sql.append(" and " +
|
||
// filedAndColumnMap.get(col2col.get(key).get("start"))
|
||
// + ">=to_date('" +
|
||
// value.toString().trim()
|
||
// + "','yyyy-mm-dd HH24:mi:ss')");
|
||
sql.append(" and " + filedAndColumnMap.get(col2col.get(key).get("start")) + ">="
|
||
+ value);
|
||
} else {
|
||
// sql.append(" and " +
|
||
// filedAndColumnMap.get(col2col.get(key).get("end"))
|
||
// + "<=to_date('" +
|
||
// value.toString().trim()
|
||
// + "','yyyy-mm-dd HH24:mi:ss')");
|
||
sql.append(" and " + filedAndColumnMap.get(col2col.get(key).get("end")) + "<"
|
||
+ value);
|
||
}
|
||
}
|
||
} else {
|
||
if (key.toLowerCase().startsWith("search")) {
|
||
key = key.replace("search", "");
|
||
key = key.substring(0, 1).toLowerCase() + key.substring(1);
|
||
}
|
||
|
||
if (typeName.equals("java.lang.String")) {
|
||
sql.append(" and " + filedAndColumnMap.get(key) + "='" + value.toString().trim()
|
||
+ "'");
|
||
} else if (typeName.equals("java.lang.Integer") || typeName.equals("int")) {
|
||
sql.append(" and " + filedAndColumnMap.get(key) + "=" + value.toString().trim());
|
||
|
||
} else if (typeName.equals("java.lang.Long") || typeName.equals("long")) {
|
||
sql.append(
|
||
" and " + filedAndColumnMap.get(key) + "=" + value.toString().trim() + "L");
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
if (null != foundTimePartStart) {
|
||
// sql.append(" and found_time_partition>=" + foundTimePartStart + "L");
|
||
sql.append(" and found_time_partition>=" + foundTimePartStart);
|
||
}
|
||
if (null != foundTimePartEnd) {
|
||
// sql.append(" and found_time_partition<" + foundTimePartEnd + "L");
|
||
sql.append(" and found_time_partition<" + foundTimePartEnd);
|
||
}
|
||
|
||
}
|
||
}
|
||
Integer startNum = (page.getPageNo() - 1) * page.getPageSize() + 1;
|
||
Integer endNum = startNum - 1 + page.getPageSize();
|
||
//sql.append(" order by " + orderBy + " limit 10000) t1) t2 where row_Num between " + startNum + " and " + endNum);
|
||
sql.append(" order by " + orderBy + " ) t1) t2 where row_Num between " + startNum + " and " + endNum);
|
||
logger.info("获å<EFBFBD>–æ•°æ<EFBFBD>®ä¸å¿ƒæ—¥å¿—sql===================" + sql);
|
||
ResultSet query = HiveDataSource.query(sql.toString());
|
||
logger.info("获å<EFBFBD>–æ•°æ<EFBFBD>®ä¸å¿ƒæ—¥å¿—æˆ<EFBFBD>功");
|
||
return query;
|
||
}
|
||
|
||
public static Long getHivePageCount2(Object bean, String tableName, Map<String, Map<String, String>> col2col,
|
||
String searchActiveSys) throws Exception {
|
||
tableName = tableName.toLowerCase();
|
||
tableName = Configurations.getStringProperty(tableName, "t_" + tableName).trim();
|
||
StringBuffer countSql = new StringBuffer();
|
||
Map<String, String> filedAndColumnMap = getFiledAndColumnMap(bean.getClass());
|
||
countSql.append("select count(1) from " + tableName + " where 1=1 ");
|
||
if (bean != null) {
|
||
Class<?> clazz = bean.getClass();
|
||
for (; clazz != Object.class; clazz = clazz.getSuperclass()) {
|
||
// 获å<C2B7>–所有的å—段包括public,private,protected,private
|
||
// Field[] fields = bean.getClass().getDeclaredFields();
|
||
Field[] fields = clazz.getDeclaredFields();
|
||
Long foundTimePartStart = null;
|
||
Long foundTimePartEnd = null;
|
||
for (int i = 0; i < fields.length; i++) {
|
||
Field f = fields[i];
|
||
String key = f.getName();// 获å<C2B7>–å—段å<C2B5><C3A5>
|
||
if (f.getType().getName().equals("java.lang.String") && key.startsWith("search")) {
|
||
Object value = getFieldValue(bean, key);
|
||
if (value != null) {
|
||
setFieldValue(bean, key, value.toString().trim());
|
||
if (key.endsWith("Time")) {// 日期开始或结æ<E2809C>Ÿçš„å—段
|
||
if (col2col.containsKey(key)) {
|
||
value = sdf.parse(value.toString().trim()).getTime() / 1000;
|
||
if (key.toLowerCase().equals("searchfoundstarttime")) {
|
||
foundTimePartStart = Long.parseLong(value.toString()) / 3600;
|
||
}
|
||
if (key.toLowerCase().equals("searchfoundendtime")) {
|
||
foundTimePartEnd = Long.parseLong(value.toString()) / 3600;
|
||
}
|
||
if (col2col.get(key).get("start") != null) {
|
||
countSql.append(" and " + filedAndColumnMap.get(col2col.get(key).get("start"))
|
||
+ ">=" + value + "L");
|
||
} else {
|
||
countSql.append(" and " + filedAndColumnMap.get(col2col.get(key).get("end"))
|
||
+ "<" + value + "L");
|
||
}
|
||
}
|
||
} else {
|
||
if (key.toLowerCase().startsWith("search")) {
|
||
key = key.replace("search", "");
|
||
key = key.substring(0, 1).toLowerCase() + key.substring(1);
|
||
}
|
||
|
||
if (!value.toString().trim().equals("") && filedAndColumnMap.containsKey(key)
|
||
&& (key.toLowerCase().equals("cfgid")
|
||
|| key.toLowerCase().equals("entranceid"))) {
|
||
countSql.append(
|
||
" and " + filedAndColumnMap.get(key) + "=" + value.toString().trim() + "L");
|
||
} else if (!value.toString().trim().equals("") && filedAndColumnMap.containsKey(key)
|
||
&& (key.toLowerCase().equals("protocol") || key.toLowerCase().equals("serverip")
|
||
|| key.toLowerCase().equals("clientip")
|
||
|| key.toLowerCase().equals("cljip"))) {
|
||
countSql.append(" and " + filedAndColumnMap.get(key) + "='"
|
||
+ value.toString().trim() + "'");
|
||
} else if (!value.toString().trim().equals("") && filedAndColumnMap.containsKey(key)
|
||
&& key.toLowerCase().equals("servicetype")) {
|
||
countSql.append(
|
||
" and " + filedAndColumnMap.get(key) + "=" + value.toString().trim());
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
if (null != searchActiveSys && !searchActiveSys.equals(Constants.ACTIVESYS_A)) {// B版数æ<C2B0>®åº“æ‰<C3A6>有found_time_partitionå—段,A版毛衣found_time_partition分区å—段
|
||
if (null != foundTimePartStart) {
|
||
countSql.append(" and found_time_partition>=" + foundTimePartStart + "L");
|
||
}
|
||
if (null != foundTimePartEnd) {
|
||
countSql.append(" and found_time_partition<" + foundTimePartEnd + "L");
|
||
}
|
||
}
|
||
}
|
||
}
|
||
logger.info("获å<EFBFBD>–æ•°æ<EFBFBD>®ä¸å¿ƒæ—¥å¿—总æ<EFBFBD>¡æ•°sql==================" + countSql.toString());
|
||
ResultSet countRs = HiveDataSource.query(countSql.toString());
|
||
String countStr = null;
|
||
while (countRs.next()) {
|
||
countStr = countRs.getObject(1).toString();
|
||
break;
|
||
}
|
||
if (countStr == null || countStr.equals("")) {
|
||
logger.info("获å<EFBFBD>–æ•°æ<EFBFBD>®ä¸å¿ƒæ—¥å¿—总æ<EFBFBD>¡æ•°æˆ<EFBFBD>功总共===================0æ<30>¡é…<C3A9>ç½®");
|
||
return 0l;
|
||
}
|
||
Long count = Long.valueOf(countStr);
|
||
logger.info("获å<EFBFBD>–æ•°æ<EFBFBD>®ä¸å¿ƒæ—¥å¿—总æ<EFBFBD>¡æ•°æˆ<EFBFBD>功总共===================" + count + "æ<EFBFBD>¡é…<EFBFBD>ç½®");
|
||
HiveDataSource.closeConn();
|
||
return count;
|
||
}
|
||
|
||
public static String getFiledsSql(String mapName, String fileds) throws Exception {
|
||
String[] fieldsColoumn = null;
|
||
String orderByStr = "";
|
||
// 所有å—段å<C2B5><C3A5>
|
||
List<String> columnList = new ArrayList<String>();
|
||
// 所有属性å<C2A7><C3A5>
|
||
List<String> propertyList = new ArrayList<String>();
|
||
// 属性å<C2A7><C3A5>称为key，å—段å<C2B5><C3A5>称为value
|
||
Map<String, String> columnMap = new HashMap<String, String>();
|
||
|
||
if (!StringUtil.isBlank(fileds)) {
|
||
// 解æž<C3A6>Filedsçš„å—段/属性å<C2A7><C3A5>称
|
||
fieldsColoumn = fileds.split(",");
|
||
|
||
// 从resultMapä¸èŽ·å<C2B7>–å—段å<C2B5><C3A5>称和属性å<C2A7><C3A5>称
|
||
if (fieldsColoumn != null) {
|
||
SqlSessionFactory sqlSessionFactory = SpringContextHolder.getBean(SqlSessionFactory.class);
|
||
ResultMap map = sqlSessionFactory.getConfiguration().getResultMap(mapName + "Map");
|
||
List<ResultMapping> mapping = map.getResultMappings();
|
||
for (ResultMapping mapp : mapping) {
|
||
columnList.add(mapp.getColumn().toLowerCase());
|
||
propertyList.add(mapp.getProperty());
|
||
columnMap.put(mapp.getProperty(), mapp.getColumn());
|
||
}
|
||
}
|
||
if (fieldsColoumn != null) {
|
||
fileds = "";
|
||
for (String column : fieldsColoumn) {
|
||
if (!StringUtil.isBlank(column)) {
|
||
column = column.trim();
|
||
if (columnList.contains(column)) {
|
||
fileds += "," + column;
|
||
} else if (propertyList.contains(column)) {
|
||
fileds += "," + columnMap.get(column).toString();
|
||
}
|
||
}
|
||
}
|
||
if (!StringUtil.isBlank(fileds)) {
|
||
fileds = fileds.substring(1);
|
||
}
|
||
|
||
}
|
||
|
||
}
|
||
return fileds;
|
||
}
|
||
|
||
public static Map<String, String> getFiledAndColumnMap(Class clazz) {
|
||
Map<String, String> map = new HashMap<String, String>();
|
||
SqlSessionFactory sqlSessionFactory = SpringContextHolder.getBean(SqlSessionFactory.class);
|
||
ResultMap resultMap = sqlSessionFactory.getConfiguration().getResultMap(clazz.getSimpleName() + "Map");
|
||
List<ResultMapping> mapping = resultMap.getResultMappings();
|
||
for (ResultMapping mapp : mapping) {
|
||
map.put(mapp.getProperty(), mapp.getColumn().toLowerCase());
|
||
}
|
||
return map;
|
||
|
||
}
|
||
|
||
/**
|
||
* 利用å<C2A8><C3A5>射通过get方法获å<C2B7>–beanä¸å—段fieldName的值
|
||
*
|
||
* @param bean
|
||
* @param fieldName
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
private static Object getFieldValue(Object bean, String fieldName) throws Exception {
|
||
StringBuffer result = new StringBuffer();
|
||
String methodName = result.append("get").append(fieldName.substring(0, 1).toUpperCase())
|
||
.append(fieldName.substring(1)).toString();
|
||
|
||
Object rObject = null;
|
||
Method method = null;
|
||
|
||
@SuppressWarnings("rawtypes")
|
||
Class[] classArr = new Class[0];
|
||
method = bean.getClass().getMethod(methodName, classArr);
|
||
rObject = method.invoke(bean, new Object[0]);
|
||
|
||
return rObject;
|
||
}
|
||
|
||
/**
|
||
* 利用å<C2A8>‘射调用bean.set方法将value设置到å—段
|
||
*
|
||
* @param bean
|
||
* @param fieldName
|
||
* @param value
|
||
* @throws Exception
|
||
*/
|
||
private static void setFieldValue(Object bean, String fieldName, Object value) throws Exception {
|
||
StringBuffer result = new StringBuffer();
|
||
String methodName = result.append("set").append(fieldName.substring(0, 1).toUpperCase())
|
||
.append(fieldName.substring(1)).toString();
|
||
/**
|
||
* 利用å<C2A8>‘射调用bean.set方法将value设置到å—段
|
||
*/
|
||
Class[] classArr = new Class[1];
|
||
classArr[0] = "java.lang.String".getClass();
|
||
Method method = bean.getClass().getMethod(methodName, classArr);
|
||
method.invoke(bean, value);
|
||
}
|
||
|
||
/**
|
||
* 比较开始时间或者结æ<E2809C>Ÿæ—¶é—´æ˜¯å<C2AF>¦æ¯”当å‰<C3A5>系统时间早48å°<C3A5>æ—¶
|
||
*
|
||
* @param startTime
|
||
* 开始时间
|
||
* @param endTime
|
||
* 结æ<E2809C>Ÿæ—¶é—´
|
||
* @return
|
||
* @throws ParseException
|
||
*/
|
||
public static boolean ifTimeGreaterThan48(String startTime, String endTime) throws Exception {
|
||
logger.info("ifTimeGreaterThan48方法开始" + System.currentTimeMillis());
|
||
if (null != startTime && !startTime.equals("") && null != endTime && !endTime.equals("")) {// 开始和结æ<E2809C>Ÿæ—¶é—´éƒ½ä¸<C3A4>为空
|
||
Date startDate = sdf.parse(startTime);
|
||
Date endDate = sdf.parse(endTime);
|
||
if (startDate.getTime() < endDate.getTime()) {// 开始时间比结æ<E2809C>Ÿæ—¶é—´æ—©
|
||
logger.info("ifTimeGreaterThan48方法结æ<EFBFBD>Ÿ" + System.currentTimeMillis());
|
||
return gt48(endTime);
|
||
} else {// 开始时间比结æ<E2809C>Ÿæ—¶é—´æ™š,ä¸<C3A4>符å<C2A6>ˆä¸€èˆ¬æƒ…况
|
||
logger.info("ifTimeGreaterThan48方法结æ<EFBFBD>Ÿ" + System.currentTimeMillis());
|
||
return false;
|
||
}
|
||
} else if (null != endTime && !endTime.equals("")) {// 开始时间为空,结æ<E2809C>Ÿæ—¶é—´ä¸<C3A4>为空
|
||
logger.info("ifTimeGreaterThan48方法结æ<EFBFBD>Ÿ" + System.currentTimeMillis());
|
||
return gt48(endTime);
|
||
} else if (null != startTime && !startTime.equals("")) {// 结æ<E2809C>Ÿæ—¶é—´ä¸ºç©º,开始时间ä¸<C3A4>为空
|
||
logger.info("ifTimeGreaterThan48方法结æ<EFBFBD>Ÿ" + System.currentTimeMillis());
|
||
return gt48(startTime);
|
||
} else {// 开始和结æ<E2809C>Ÿæ—¶é—´éƒ½ä¸ºç©º
|
||
logger.info("ifTimeGreaterThan48方法结æ<EFBFBD>Ÿ" + System.currentTimeMillis());
|
||
return false;
|
||
}
|
||
|
||
}
|
||
|
||
public static boolean gt48(String eqTime) throws ParseException {
|
||
logger.info("gt48方法开始" + System.currentTimeMillis());
|
||
Date eqDate = sdf.parse(eqTime);
|
||
Long dateNum = eqDate.getTime();
|
||
Long currentDate = new Date().getTime();
|
||
Long time = 0l;
|
||
if (dateNum < currentDate) {
|
||
time = currentDate - dateNum;// 获å<C2B7>–结æ<E2809C>Ÿæ—¶é—´ä¸Žå½“å‰<C3A5>系统时间的时间差毫秒数
|
||
} else {
|
||
logger.info("gt48方法结æ<EFBFBD>Ÿ" + System.currentTimeMillis());
|
||
return false;// 结æ<E2809C>Ÿæ—¶é—´æ¯”当å‰<C3A5>系统时间晚,ä¸<C3A4>符å<C2A6>ˆä»Žæ•°æ<C2B0>®ä¸å¿ƒæŸ¥è¯¢æ•°æ<C2B0>®è¦<C3A8>求(当å‰<C3A5>日期48å°<C3A5>æ—¶å‰<C3A5>æ•°æ<C2B0>®ä»Žæ•°æ<C2B0>®ä¸å¿ƒæŸ¥è¯¢)
|
||
}
|
||
double hours = time.doubleValue() / (1000 * 60 * 60);
|
||
Long datacenterTime = Constants.DATACENTER_TIME;
|
||
double doubleValue = datacenterTime.doubleValue();
|
||
if (hours > doubleValue) {
|
||
logger.info("gt48方法结æ<EFBFBD>Ÿ" + System.currentTimeMillis());
|
||
return true;// 符å<C2A6>ˆè¦<C3A8>求
|
||
} else {
|
||
logger.info("gt48方法结æ<EFBFBD>Ÿ" + System.currentTimeMillis());
|
||
return false;
|
||
}
|
||
|
||
}
|
||
|
||
public static void main(String[] args) {
|
||
Long datacenterTime = Constants.DATACENTER_TIME;
|
||
double doubleValue = datacenterTime.doubleValue();
|
||
System.out.println(doubleValue);
|
||
}
|
||
}
|