From 5737d7e7ed0cb02df1f4be1dc8b9035f9f7cdae2 Mon Sep 17 00:00:00 2001
From: 赵文轩 <1652863494@qq.com>
Date: 星期二, 04 六月 2024 16:06:34 +0800
Subject: [PATCH] 同步字典数据工具类
---
src/main/java/com/example/utils/DictionaryUtil.java | 290 +++++++++++++++++++++++-----------------------------------
1 files changed, 115 insertions(+), 175 deletions(-)
diff --git a/src/main/java/com/example/utils/DictionaryUtil.java b/src/main/java/com/example/utils/DictionaryUtil.java
index 08cd5c7..08b022d 100644
--- a/src/main/java/com/example/utils/DictionaryUtil.java
+++ b/src/main/java/com/example/utils/DictionaryUtil.java
@@ -3,8 +3,10 @@
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
+import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
import java.io.*;
import java.net.HttpURLConnection;
@@ -20,15 +22,14 @@
* @Author: zhaowenxuan
* @Date: 2024/5/21 16:41
*/
+@Slf4j
+@Component
public class DictionaryUtil {
- private static final String CONFIG_PATH = "D:\\ltkjprojectconf\\config.properties";
- private static final Logger log = LoggerFactory.getLogger(DictionaryUtil.class);
+// private static final String CONFIG_PATH = "/Users/chacca/寮�鍙戠浉鍏�/浠ｇ爜/ltkj_peis_sjpt/src/main/resources/config.properties";
+ private static final String CONFIG_PATH = "/Users/chacca/寮�鍙戠浉鍏�/浠ｇ爜/ltkj_peis_sjpt/src/main/resources/ltkj.properties";
private static String BASE_API_URL = "";
// 璇锋眰浠ｇ爜鎬婚泦鍚�
private static List<String> methods = new ArrayList<>();
-// private static final String url = "jdbc:mysql://localhost:3306/test_urlreq";
-// private static final String user = "root";
-// private static final String password = "Root_ltkj123";
// 闇�瑕佸垎椤电殑浠ｇ爜闆嗗悎
private static List<String> limits = new ArrayList<>();
@@ -43,68 +44,68 @@
static {
methods.add("JGDM");
methods.add("ZDZYZ");
-// methods.add("YQZD");
-// methods.add("KSFLZD");
-// methods.add("BQZD");
-// methods.add("ZKKSZD");
-// methods.add("KSZD");
-// methods.add("YWCKZD");
-// methods.add("GHZLZD");
-// methods.add("YHZD");
-// methods.add("XYZDZD");
-// methods.add("ZYZDZD");
-// methods.add("SSZD");
+ methods.add("YQZD");
+ methods.add("KSFLZD");
+ methods.add("BQZD");
+ methods.add("ZKKSZD");
+ methods.add("KSZD");
+ methods.add("YWCKZD");
+ methods.add("GHZLZD");
+ methods.add("YHZD");
+ methods.add("XYZDZD");
+ methods.add("ZYZDZD");
+ methods.add("SSZD");
methods.add("ZLXTXZD");
-// methods.add("ZYZZZFZD");
-// methods.add("YJJFXMZD");
-// methods.add("EJJFXMZD");
-// methods.add("ZHFLXMZD");
-// methods.add("JFZHXMZD");
-// methods.add("JFZHGLMXJFXMZD");
-// methods.add("CFLXZD");
-// methods.add("YPZLZD");
-// methods.add("YPJXZD");
-// methods.add("YPGXZD");
-// methods.add("YPLXZD");
-// methods.add("JLDWZD");
-// methods.add("YFZD");
-// methods.add("YPZD");
-// methods.add("JYKSZD");
-// methods.add("JYYSZD");
-// methods.add("JYFZZD");
-// methods.add("JYFLZD");
-// methods.add("JYFFZD");
-// methods.add("JYBBZD");
-// methods.add("JYXMZD");
-// methods.add("JYZBZD");
-// methods.add("JYXMZBZD");
-// methods.add("JFXMGLJYXMZD");
-// methods.add("JFZHGLJYXMZD");
-// methods.add("JCSBZD");
-// methods.add("JCBWFLZD");
-// methods.add("JCBWZD");
-// methods.add("JCBWMSZD");
+ methods.add("ZYZZZFZD");
+ methods.add("YJJFXMZD");
+ methods.add("EJJFXMZD");
+ methods.add("ZHFLXMZD");
+ methods.add("JFZHXMZD");
+ methods.add("JFZHGLMXJFXMZD");
+ methods.add("CFLXZD");
+ methods.add("YPZLZD");
+ methods.add("YPJXZD");
+ methods.add("YPGXZD");
+ methods.add("YPLXZD");
+ methods.add("JLDWZD");
+ methods.add("YFZD");
+ methods.add("YPZD");
+ methods.add("JYKSZD");
+ methods.add("JYYSZD");
+ methods.add("JYFZZD");
+ methods.add("JYFLZD");
+ methods.add("JYFFZD");
+ methods.add("JYBBZD");
+ methods.add("JYXMZD");
+ methods.add("JYZBZD");
+ methods.add("JYXMZBZD");
+ methods.add("JFXMGLJYXMZD");
+ methods.add("JFZHGLJYXMZD");
+ methods.add("JCSBZD");
+ methods.add("JCBWFLZD");
+ methods.add("JCBWZD");
+ methods.add("JCBWMSZD");
methods.add("JFXMGLJCBWZD");
-// methods.add("JFZHXMGLJCBWZD");
-//
-// methods.add("TJDWXZZD");
-// methods.add("TJRYLBZD");
-// methods.add("TJLBZD");
-// methods.add("TJFQZD");
-// methods.add("TJKSZD");
-// methods.add("TJYSZD");
-// methods.add("TJXMZD");
-// methods.add("TJZHXMZD");
-// methods.add("TJZHGLMXZD");
-// methods.add("TJTCZD");
-// methods.add("TJTCGLTJZHZD");
-//
-// methods.add("HTDWZD");
-// methods.add("ZFLXZD");
-// methods.add("MZJCJYSQD");
-// methods.add("MZJCJYSQXMFL");
-// methods.add("MZJCJYSQDDYXM");
-// methods.add("BRFB");
+ methods.add("JFZHXMGLJCBWZD");
+
+ methods.add("TJDWXZZD");
+ methods.add("TJRYLBZD");
+ methods.add("TJLBZD");
+ methods.add("TJFQZD");
+ methods.add("TJKSZD");
+ methods.add("TJYSZD");
+ methods.add("TJXMZD");
+ methods.add("TJZHXMZD");
+ methods.add("TJZHGLMXZD");
+ methods.add("TJTCZD");
+ methods.add("TJTCGLTJZHZD");
+
+ methods.add("HTDWZD");
+ methods.add("ZFLXZD");
+ methods.add("MZJCJYSQD");
+ methods.add("MZJCJYSQXMFL");
+ methods.add("MZJCJYSQDDYXM");
+ methods.add("BRFB");
limits.add("ZDZYZ");
limits.add("KSZD");
@@ -135,14 +136,19 @@
public static void main(String[] args) {
DictionaryUtil util = new DictionaryUtil();
-// String json = "{\"Response\":{\"ResultCode\":\"0\",\"ResultContent\":\"鏌ヨ鎴愬姛\",\"ResultData\":[{\"RowNumber\":1,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"娉惧窛鍘夸汉姘戝尰闄",\"KSDM\":\"0000000002\",\"KSMC\":\"璐ㄦ帶鑲",\"KSPY\":\"ZKG\",\"FLKSDM\":\"0000000001\",\"FLKSMC\":\"鍔炲叕\",\"KSLXDM\":\"0\",\"KSLXMC\":\"鍏敤\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":\"\",\"KSMS\":null,\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":2,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"娉惧窛鍘夸汉姘戝尰闄",\"KSDM\":\"0001\",\"KSMC\":\"鎬诲姟搴撴埧\",\"KSPY\":\"ZWKF\",\"FLKSDM\":\"01\",\"FLKSMC\":\"鍖荤枟\",\"KSLXDM\":\"0\",\"KSLXMC\":\"鍏敤\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":\"\",\"KSMS\":\"\",\"KSDZ\":null,\"LXDH\":\"\",\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":3,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"娉惧窛鍘夸汉姘戝尰闄",\"KSDM\":\"0002\",\"KSMC\":\"瑗胯嵂搴撴埧\",\"KSPY\":\"XYKF\",\"FLKSDM\":\"01\",\"FLKSMC\":\"鍖荤枟\",\"KSLXDM\":\"0\",\"KSLXMC\":\"鍏敤\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":null,\"KSMS\":null,\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":4,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"娉惧窛鍘夸汉姘戝尰闄",\"KSDM\":\"0003\",\"KSMC\":\"闂ㄨ瘖瑗胯嵂鎴縗",\"KSPY\":\"MZXYF\",\"FLKSDM\":\"01\",\"FLKSMC\":\"鍖荤枟\",\"KSLXDM\":\"0\",\"KSLXMC\":\"鍏敤\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":\"\",\"KSMS\":\"闂ㄨ瘖涓�妤艰タ鑽埧鍙栬嵂\",\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":5,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"娉惧窛鍘夸汉姘戝尰闄",\"KSDM\":\"0004\",\"KSMC\":\"闂ㄨ瘖涓嵂鎴縗",\"KSPY\":\"MZZYF\",\"FLKSDM\":\"01\",\"FLKSMC\":\"鍖荤枟\",\"KSLXDM\":\"0\",\"KSLXMC\":\"鍏敤\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":\"\",\"KSMS\":\"闂ㄨ瘖涓�妤间腑鑽埧鍙栬嵂\",\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":6,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"娉惧窛鍘夸汉姘戝尰闄",\"KSDM\":\"0005\",\"KSMC\":\"浣忛櫌鑽埧\",\"KSPY\":\"ZYYF\",\"FLKSDM\":\"01\",\"FLKSMC\":\"鍖荤枟\",\"KSLXDM\":\"0\",\"KSLXMC\":\"鍏敤\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":\"\",\"KSMS\":\"浣忛櫌閮ㄤ簩妤艰嵂鎴垮彇鑽痋",\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":7,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"娉惧窛鍘夸汉姘戝尰闄",\"KSDM\":\"0006\",\"KSMC\":\"鍔炲叕瀹",\"KSPY\":\"BGS\",\"FLKSDM\":\"01\",\"FLKSMC\":\"鍖荤枟\",\"KSLXDM\":\"0\",\"KSLXMC\":\"鍏敤\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":null,\"KSMS\":null,\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":8,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"娉惧窛鍘夸汉姘戝尰闄",\"KSDM\":\"0007\",\"KSMC\":\"鎬诲姟鑲",\"KSPY\":\"ZWG\",\"FLKSDM\":\"01\",\"FLKSMC\":\"鍖荤枟\",\"KSLXDM\":\"0\",\"KSLXMC\":\"鍏敤\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":null,\"KSMS\":null,\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":9,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"娉惧窛鍘夸汉姘戝尰闄",\"KSDM\":\"0008\",\"KSMC\":\"鍖诲姟鑲",\"KSPY\":\"YWG\",\"FLKSDM\":\"01\",\"FLKSMC\":\"鍖荤枟\",\"KSLXDM\":\"0\",\"KSLXMC\":\"鍏敤\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":null,\"KSMS\":null,\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":10,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"娉惧窛鍘夸汉姘戝尰闄",\"KSDM\":\"0009\",\"KSMC\":\"闂ㄨ瘖鏀惰垂瀹",\"KSPY\":\"MZSFS\",\"FLKSDM\":\"01\",\"FLKSMC\":\"鍖荤枟\",\"KSLXDM\":\"0\",\"KSLXMC\":\"鍏敤\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":\"\",\"KSMS\":\"闂ㄨ瘖妤间竴妤笺�侀棬璇婃ゼ浜屾ゼ缂磋垂\",\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"}]}}";
- util.exec1();
-// Connection connection = util.getConnection();
-// String tabName = "ltkj_kszd";
-// JSONObject entries = JSONUtil.parseObj(json);
-// util.LimitInsertData(connection,tabName,entries.getJSONObject("Response"));
+ try {
+ util.exec1();
+ } catch (IOException e) {
+ e.printStackTrace();
+ log.error("寮傚父");
+ }
}
+ /**
+ * 澧炲姞榛樿鍙傛暟
+ * @param jsonObject
+ * @return
+ */
public JSONObject addInputVal(JSONObject jsonObject){
JSONObject obj = JSONUtil.createObj();
obj.putOpt("jgbm","");
@@ -152,9 +158,20 @@
return jsonObject;
}
- public void exec1() {
+ public void exec1() throws IOException {
int size = 1000;
- Connection connection = getConnection();
+ FileInputStream inputStream = new FileInputStream(CONFIG_PATH);
+ Properties props = new Properties();
+ props.load(inputStream);
+ String name = props.getProperty("name");
+ String url = "jdbc:mysql://" + props.getProperty("ip") + ":" + props.getProperty("prot") + "/" + name + "" +
+ "?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8";
+ String user = props.getProperty("username");
+ String password = props.getProperty("password");
+ String apiUrl = props.getProperty("his_api_url");
+ String apiPort = props.getProperty("his_api_port");
+ BASE_API_URL = apiUrl+":"+apiPort+"/api/His/HisRequest";
+ Connection connection = getConnection(user,password,url);
methods.forEach(method -> {
log.info("寮�濮嬭姹備唬鐮� ->{}",method);
String tabName = "ltkj_" + method.toLowerCase();
@@ -163,35 +180,37 @@
int maxPage = 1;
JSONObject object = JSONUtil.createObj();
object.putOpt("method", method);
+ object = addInputVal(object);
if (limits.contains(method)) {
isLimit = true;
- object.putOpt("pagecount", size);
- object.putOpt("page", page);
+ JSONObject input = object.getJSONObject("input");
+ input.putOpt("pagecount", size);
+ input.putOpt("page", page);
}
- object = addInputVal(object);
log.info("璇锋眰鎺ュ彛 ->{},璇锋眰鍙傛暟 ->{}",BASE_API_URL,object.toString());
JSONObject entries = execRequest(object.toString());
- log.info("璇锋眰杩斿洖 ->{}",entries.toString());
+// log.info("璇锋眰杩斿洖 ->{}",entries.toString());
assert entries != null;
JSONObject response = entries.getJSONObject("Response");
if ("0".equals(response.getStr("ResultCode"))) {
if (isLimit) {
- maxPage = LimitInsertData(connection, tabName, response);
+ maxPage = LimitInsertData(connection, tabName, response,name,page);
log.info("璁＄畻椤电爜涓� ->{}", maxPage);
if (maxPage > 1) {
page += 1;
for (int i = page; i <= maxPage; i++) {
object.clear();
object.putOpt("method", method);
- object.putOpt("pagecount", size);
- object.putOpt("page", page);
object = addInputVal(object);
+ JSONObject input = object.getJSONObject("input");
+ input.putOpt("pagecount", size);
+ input.putOpt("page", page);
log.info("璇锋眰鎺ュ彛 ->{},璇锋眰鍙傛暟 ->{}",BASE_API_URL,object.toString());
entries = execRequest(object.toString());
- log.info("璇锋眰杩斿洖 ->{}",entries.toString());
+// log.info("璇锋眰杩斿洖 ->{}",entries.toString());
response = entries.getJSONObject("Response");
if ("0".equals(response.getStr("ResultCode"))) {
- LimitInsertData(connection, tabName, response);
+ LimitInsertData(connection, tabName, response,name,page);
} else {
log.error("{} 璇锋眰澶辫触锛歿}",method,object.toString());
}
@@ -201,10 +220,10 @@
} else {
JSONArray resultData = response.getJSONArray("ResultData");
JSONObject jsonObject = JSONUtil.toList(resultData, JSONObject.class).get(0);
- editDataBase(connection, tabName, resultData, jsonObject);
+ editDataBase(connection, tabName, jsonObject,name);
}
} else {
- log.error("{}璇锋眰澶辫触 - 璇锋眰鐘舵�佺爜涓嶄负0锛歿}", method,object.toString());
+ log.error("{}璇锋眰澶辫触 - 璇锋眰鐘舵�佺爜涓嶄负0,璇锋眰鍙傛暟 ->{},璇锋眰杩斿洖 ->{}", method,object.toString(),response.toString());
}
});
}
@@ -217,7 +236,7 @@
* @param response
* @return
*/
- private int LimitInsertData(Connection connection, String tabName, JSONObject response) {
+ private int LimitInsertData(Connection connection, String tabName, JSONObject response,String name,Integer page) {
JSONArray jsonArray = response.getJSONArray("ResultData");
JSONObject entries = (JSONObject) jsonArray.get(0);
int maxPage;
@@ -226,9 +245,9 @@
// 鎬绘潯鏁�
Integer totalCount = entries.getInt("totalCount");
maxPage = (totalCount + 1000 - 1) / 1000;
- log.info("璇锋眰杩斿洖闆嗗悎澶у皬 ->{},鎬婚〉鏁� ->{}",jsonArray.size(),maxPage);
+ log.info("璇锋眰杩斿洖鎬绘潯鏁� ->{},褰撳墠椤� ->{},鎬婚〉鏁� ->{}",totalCount,page,maxPage);
jsonArray.forEach(obj -> {
- editDataBase(connection, tabName, jsonArray, (JSONObject) obj);
+ editDataBase(connection, tabName, (JSONObject) obj,name);
});
return maxPage;
}
@@ -238,12 +257,11 @@
*
* @param connection
* @param tabName
- * @param jsonArray
* @param obj
*/
- private void editDataBase(Connection connection, String tabName, JSONArray jsonArray, JSONObject obj) {
+ private void editDataBase(Connection connection, String tabName, JSONObject obj,String name) {
try {
- if (!tabIsExists(connection, tabName)) {
+ if (!tabIsExists(connection, tabName,name)) {
// 鍒涘缓琛�
creatTable(obj, tabName, connection);
}
@@ -255,31 +273,6 @@
log.error(throwables.getMessage());
}
}
-
-// private void exec() {
-// JSONObject entries = execRequest();
-// if (entries != null) {
-// JSONObject response = entries.getJSONObject("Response");
-// // 0 鎴愬姛 -1澶辫触
-// if ("0".equals(response.getStr("ResultCode"))) {
-// JSONArray jsonArray = response.getJSONArray("ResultData");
-// JSONObject resultDataIndex1 = jsonArray.getJSONObject(0);
-// String method = entries.getStr("method");
-// String tabName = "ltkj_" + method;
-// Connection connection = getConnection();
-// try {
-// if (!tabIsExists(connection, tabName)) {
-// // 鍒涘缓琛�
-// creatTable(resultDataIndex1, tabName, connection);
-// }
-// // 瀵规瘮瀛楁 骞舵彃鍏ユ暟鎹�
-// operationTable((JSONObject) jsonArray.get(0), tabName, connection);
-// } catch (SQLException throwables) {
-// throwables.printStackTrace();
-// }
-// }
-// }
-// }
/**
* 鎵цpost璇锋眰
@@ -318,62 +311,9 @@
return null;
}
- /**
- * 鎵цhttp璇锋眰
- *
- * @return
- */
-// private JSONObject execRequest() {
-// URL url = null;
-// HttpURLConnection connection = null;
-// try {
-// url = new URL(BASE_API_URL);
-// connection = (HttpURLConnection) url.openConnection();
-// connection.setRequestMethod("POST");
-// connection.setDoOutput(true);
-// connection.setRequestProperty("Accept", "application/json");
-// connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
-// OutputStream stream = connection.getOutputStream();
-// int index = 0;
-// if (methods.size() > 1) {
-// index = RandomUtil.randomInt(0, methods.size() - 1);
-// }
-// String method = methods.get(index);
-// String param = "method=" + method;
-// stream.write(param.getBytes(StandardCharsets.UTF_8));
-// BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
-// StringBuilder builder = new StringBuilder();
-// String str;
-// while ((str = reader.readLine()) != null) {
-// builder.append(str);
-// }
-// log.info("鎵ц璇锋眰鍝嶅簲锛歿}", builder.toString());
-// JSONObject entries = JSONUtil.parseObj(builder.toString());
-// entries.set("method", method);
-// return entries;
-// } catch (IOException e) {
-// e.printStackTrace();
-// } finally {
-// if (connection != null) {
-// connection.disconnect();
-// }
-// }
-// return null;
-// }
-
- private Connection getConnection() {
+ private Connection getConnection(String user,String password,String url) {
try {
- FileInputStream inputStream = new FileInputStream(CONFIG_PATH);
- Properties props = new Properties();
- props.load(inputStream);
- String name = props.getProperty("name");
- String url = "jdbc:mysql://" + props.getProperty("ip") + ":" + props.getProperty("prot") + "/" + name + "" +
- "?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8";
- String user = props.getProperty("username");
- String password = props.getProperty("password");
- String apiUrl = props.getProperty("his_api_url");
- String apiPort = props.getProperty("his_api_port");
- BASE_API_URL = apiUrl+":"+apiPort+"/api/His/HisRequest";
+ log.info("鏁版嵁搴撲俊鎭� ->{},{},{}",user,password,url);
return DriverManager.getConnection(url, user, password);
} catch (Exception throwables) {
log.error("鑾峰彇sql杩炴帴澶辫触");
@@ -390,10 +330,10 @@
* @return
* @throws SQLException
*/
- private Boolean tabIsExists(Connection connection, String tableName) throws SQLException {
+ private Boolean tabIsExists(Connection connection, String tableName,String name) throws SQLException {
String tabSql = "SELECT table_name FROM information_schema.tables WHERE table_schema = ? AND table_name = ?";
PreparedStatement statement = connection.prepareStatement(tabSql);
- statement.setString(1, "test_urlreq");
+ statement.setString(1, name);
statement.setString(2, tableName);
// log.info("鍒ゆ柇琛ㄦ槸鍚﹀瓨鍦� sql-> {}", statement.toString());
ResultSet resultSet = statement.executeQuery();
@@ -422,7 +362,7 @@
// 闇�瑕佸鍔犲瓧娈� 骞舵彃鍏ユ暟鎹�
for (String colum : responseColums) {
String sql = "alter table " + tabName + " add column " + colum + " text null";
-// log.info("淇敼瀛楁 ->{}",sql.toString());
+// log.info("淇敼瀛楁 ->{}",sql.toString());
Statement statement = connection.createStatement();
statement.executeUpdate(sql);
statement.close();
@@ -450,8 +390,8 @@
selectSqlBuilder.append("select count(1) as count from ").append(tabName).append(" where ");
for (Map.Entry<String, Object> entry : jsonObject.entrySet()) {
insertSqlBuilder.append(entry.getKey()).append(", ");
- valueBuilder.append("'").append(entry.getValue()).append("', ");
- selectSqlBuilder.append(entry.getKey()).append(" = '").append(entry.getValue()).append("' and ");
+ valueBuilder.append("'").append(entry.getValue().toString().replaceAll("'","鈥�")).append("', ");
+ selectSqlBuilder.append(entry.getKey()).append(" = '").append(entry.getValue().toString().replaceAll("'","鈥�")).append("' and ");
}
insertSqlBuilder.append("insert_time, ");
String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
--
Gitblit v1.8.0