From 45be2f5e61430a3453b3e72f509f5966928375e1 Mon Sep 17 00:00:00 2001
From: 赵文轩 <1652863494@qq.com>
Date: 星期四, 06 六月 2024 19:38:52 +0800
Subject: [PATCH] 每次执行前清空日志
---
src/main/java/com/example/utils/DictionaryUtil.java | 91 +++++++++++++++++++++++++++++++--------------
1 files changed, 63 insertions(+), 28 deletions(-)
diff --git a/src/main/java/com/example/utils/DictionaryUtil.java b/src/main/java/com/example/utils/DictionaryUtil.java
index 08b022d..c3f4269 100644
--- a/src/main/java/com/example/utils/DictionaryUtil.java
+++ b/src/main/java/com/example/utils/DictionaryUtil.java
@@ -25,8 +25,9 @@
@Slf4j
@Component
public class DictionaryUtil {
-// 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 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 final String CONFIG_PATH = "D:\\ltkjprojectconf\\config.properties";
private static String BASE_API_URL = "";
// 璇锋眰浠ｇ爜鎬婚泦鍚�
private static List<String> methods = new ArrayList<>();
@@ -42,6 +43,9 @@
// 鍒嗛〉姣忔1000鏉�
static {
+ try {
+ Class.forName("com.mysql.cj.jdbc.Driver");
+ } catch (ClassNotFoundException e) {}
methods.add("JGDM");
methods.add("ZDZYZ");
methods.add("YQZD");
@@ -135,13 +139,13 @@
}
public static void main(String[] args) {
- DictionaryUtil util = new DictionaryUtil();
- try {
- util.exec1();
- } catch (IOException e) {
- e.printStackTrace();
- log.error("寮傚父");
- }
+// DictionaryUtil util = new DictionaryUtil();
+// try {
+// util.exec1();
+// } catch (IOException e) {
+// e.printStackTrace();
+// log.error("寮傚父");
+// }
}
/**
@@ -158,7 +162,16 @@
return jsonObject;
}
+ public void execSync(){
+
+ }
+
+ /**
+ * 鍗曠嚎绋嬫墽琛�
+ * @throws IOException
+ */
public void exec1() throws IOException {
+ log.info("寮�濮嬫墽琛屽悓姝�");
int size = 1000;
FileInputStream inputStream = new FileInputStream(CONFIG_PATH);
Properties props = new Properties();
@@ -193,6 +206,11 @@
assert entries != null;
JSONObject response = entries.getJSONObject("Response");
if ("0".equals(response.getStr("ResultCode"))) {
+ try {
+ dropTable(tabName,connection);
+ } catch (SQLException e) {
+ log.error("鍒犻櫎琛ㄥ紓甯� ->{}",e.getMessage());
+ }
if (isLimit) {
maxPage = LimitInsertData(connection, tabName, response,name,page);
log.info("璁＄畻椤电爜涓� ->{}", maxPage);
@@ -226,6 +244,7 @@
log.error("{}璇锋眰澶辫触 - 璇锋眰鐘舵�佺爜涓嶄负0,璇锋眰鍙傛暟 ->{},璇锋眰杩斿洖 ->{}", method,object.toString(),response.toString());
}
});
+ log.info("鎵ц鍚屾瀹屾瘯");
}
/**
@@ -290,11 +309,11 @@
connection.setRequestMethod("POST");
connection.setRequestProperty("Accept", "application/json");
// connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
- connection.setRequestProperty("Content-Type", "application/json;utf-8");
+ connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
connection.setDoOutput(true);
OutputStream stream = connection.getOutputStream();
stream.write(params.getBytes(StandardCharsets.UTF_8));
- BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
+ BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(),StandardCharsets.UTF_8));
StringBuilder builder = new StringBuilder();
String str;
while ((str = reader.readLine()) != null) {
@@ -361,7 +380,7 @@
if (!responseColums.isEmpty()) {
// 闇�瑕佸鍔犲瓧娈� 骞舵彃鍏ユ暟鎹�
for (String colum : responseColums) {
- String sql = "alter table " + tabName + " add column " + colum + " text null";
+ String sql = "alter table " + tabName + " add column " + colum + " VARCHAR(200) null";
// log.info("淇敼瀛楁 ->{}",sql.toString());
Statement statement = connection.createStatement();
statement.executeUpdate(sql);
@@ -383,36 +402,39 @@
*/
private void insertData(String tabName, Connection connection, JSONObject jsonObject) throws SQLException {
// 鎻掑叆鏁版嵁鍓� 鍏堟煡璇㈡暟鎹槸鍚﹀瓨鍦�
- StringBuilder selectSqlBuilder = new StringBuilder();
+// StringBuilder selectSqlBuilder = new StringBuilder();
StringBuilder insertSqlBuilder = new StringBuilder();
StringBuilder valueBuilder = new StringBuilder();
insertSqlBuilder.append("insert into ").append(tabName).append(" (");
- selectSqlBuilder.append("select count(1) as count from ").append(tabName).append(" where ");
+// selectSqlBuilder.append("select count(1) as count from ").append(tabName).append(" where ");
for (Map.Entry<String, Object> entry : jsonObject.entrySet()) {
+ String str = entry.getValue().toString().replaceAll("\\\\", "");
+ if (str.equals("null"))
+ continue;
insertSqlBuilder.append(entry.getKey()).append(", ");
- valueBuilder.append("'").append(entry.getValue().toString().replaceAll("'","鈥�")).append("', ");
- selectSqlBuilder.append(entry.getKey()).append(" = '").append(entry.getValue().toString().replaceAll("'","鈥�")).append("' and ");
+ valueBuilder.append("'").append(str.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());
valueBuilder.append("'").append(time).append("'").append(", ");
insertSqlBuilder.delete(insertSqlBuilder.length() - 2, insertSqlBuilder.length());
valueBuilder.delete(valueBuilder.length() - 2, valueBuilder.length());
- selectSqlBuilder.delete(selectSqlBuilder.length() - 5, selectSqlBuilder.length());
+// selectSqlBuilder.delete(selectSqlBuilder.length() - 5, selectSqlBuilder.length());
insertSqlBuilder.append(") values (").append(valueBuilder).append(")");
// log.info("鎻掑叆鍓嶆煡璇� sql ->{}", selectSqlBuilder.toString());
- Statement statement = connection.prepareStatement(selectSqlBuilder.toString());
- ResultSet resultSet = statement.executeQuery(selectSqlBuilder.toString());
- resultSet.next();
- String string = resultSet.getString("count");
- statement.close();
+// Statement statement = connection.prepareStatement(selectSqlBuilder.toString());
+// ResultSet resultSet = statement.executeQuery(selectSqlBuilder.toString());
+// resultSet.next();
+// String string = resultSet.getString("count");
+// statement.close();
// 濡傛灉涓嶄负0 鍒欒繖鏉℃暟鎹瓨鍦� 涓嶈繘琛屾彃鍏�
- if (!"0".equals(string)) {
+// if (!"0".equals(string)) {
// log.info("鏁版嵁瀛樺湪涓嶉渶瑕佹彃鍏� {}", jsonObject);
- return;
- }
+// return;
+// }
// 鎻掑叆鏁版嵁
- statement = connection.createStatement();
+ Statement statement = connection.createStatement();
// log.info("鎻掑叆鏁版嵁 sql-> {}", insertSqlBuilder.toString());
statement.execute(insertSqlBuilder.toString());
statement.close();
@@ -448,13 +470,26 @@
private void creatTable(JSONObject resultDataIndex1, String tabName, Connection connection) throws SQLException {
StringBuilder sql = new StringBuilder("CREATE TABLE " + tabName + " (");
for (Map.Entry<String, Object> entry : resultDataIndex1.entrySet()) {
- sql.append(entry.getKey()).append(" text null,");
+ sql.append(entry.getKey()).append(" VARCHAR(200) null,");
}
- sql.append("insert_time").append(" text null,");
+ sql.append("insert_time").append(" VARCHAR(100) null,");
sql = new StringBuilder(sql.substring(0, sql.length() - 1));
sql.append(");");
// log.info("鍒涘缓琛ㄦ牸 -> {}",sql.toString());
Statement statement = connection.createStatement();
statement.execute(sql.toString());
}
+
+ /**
+ * 鍒犻櫎琛�
+ * @param tabName
+ * @param connection
+ * @throws SQLException
+ */
+ private void dropTable(String tabName,Connection connection) throws SQLException {
+ String sql = "DROP TABLE IF EXISTS " + tabName;
+ Statement statement = connection.createStatement();
+ statement.executeUpdate(sql);
+ statement.close();
+ }
}
--
Gitblit v1.8.0