|
|
@@ -1384,7 +1384,7 @@ public class HanaOrderComponent {
|
|
|
stmt.execute("CREATE TABLE IF NOT EXISTS meta_hana_sales_order_temp LIKE meta_hana_sales_order");
|
|
|
|
|
|
// 2. 加载数据到临时表
|
|
|
- String testSql = "LOAD DATA LOCAL INFILE ? into table meta_hana_sales_order_temp fields terminated by '$$' lines terminated by '\\n'";
|
|
|
+ String testSql = "LOAD DATA LOCAL INFILE 'testIO.txt' into table meta_hana_sales_order_temp fields terminated by '$$' lines terminated by '\\n'";
|
|
|
long beginTime = System.currentTimeMillis();
|
|
|
String filePath = Global.getTemdataPath() + "salesOrder/";
|
|
|
try (InputStream inputStream = mergeGetStream(new File(filePath))) {
|
|
|
@@ -1430,10 +1430,7 @@ public class HanaOrderComponent {
|
|
|
} catch (SQLException ex) {
|
|
|
log.error("事务回滚失败", ex);
|
|
|
}
|
|
|
- String name = "meta_hana_sales_order订单表同步异常";
|
|
|
- userOrderAuthorService.sendMailHanaWarning(name);
|
|
|
- log.error(name + ", 文件路径: " + Global.getTemdataPath() + "salesOrder/", e);
|
|
|
- throw new RuntimeException(e);
|
|
|
+
|
|
|
} finally {
|
|
|
try {
|
|
|
conn.setAutoCommit(true);
|
|
|
@@ -1552,7 +1549,7 @@ public class HanaOrderComponent {
|
|
|
stmt.execute("CREATE TABLE IF NOT EXISTS meta_hana_deliver_order_temp LIKE meta_hana_deliver_order");
|
|
|
|
|
|
// 2. 加载数据到临时表
|
|
|
- String testSql = "LOAD DATA LOCAL INFILE ? into table meta_hana_deliver_order_temp fields terminated by '$$' lines terminated by '\\n'";
|
|
|
+ String testSql = "LOAD DATA LOCAL INFILE 'testIO.txt' into table meta_hana_deliver_order_temp fields terminated by '$$' lines terminated by '\\n'";
|
|
|
long beginTime = System.currentTimeMillis();
|
|
|
String filePath = Global.getTemdataPath() + "deliverOrder/";
|
|
|
try (InputStream inputStream = mergeGetStream(new File(filePath))) {
|