瀏覽代碼

批量插入诊断依据

kongwz 5 年之前
父節點
當前提交
be4e46b441
共有 1 個文件被更改,包括 12 次插入7 次删除
  1. 12 7
      graphdb/src/main/java/org/diagbot/service/impl/KnowledgeServiceImpl.java

+ 12 - 7
graphdb/src/main/java/org/diagbot/service/impl/KnowledgeServiceImpl.java

@@ -28,10 +28,7 @@ import org.springframework.data.domain.Sort;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 
 
 import java.math.RoundingMode;
 import java.math.RoundingMode;
-import java.sql.Connection;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.sql.Statement;
+import java.sql.*;
 import java.text.NumberFormat;
 import java.text.NumberFormat;
 import java.util.*;
 import java.util.*;
 
 
@@ -2124,7 +2121,7 @@ public class    KnowledgeServiceImpl implements KnowledgeService {
             if(disList != null && disList.size()>0){
             if(disList != null && disList.size()>0){
                 for (Long disId:disList) {
                 for (Long disId:disList) {
                    respDTO = this.updateNeo(respDTO, disId, connect, ciKu);
                    respDTO = this.updateNeo(respDTO, disId, connect, ciKu);
-
+                   this.updateDate(connect,disId);
                 }
                 }
             }
             }
             connect.close();
             connect.close();
@@ -2134,8 +2131,16 @@ public class    KnowledgeServiceImpl implements KnowledgeService {
 
 
         return respDTO;
         return respDTO;
     }
     }
-    public void updateDate(Connection connection,Long disId){
-        String sql = "UPDATE `kl_diagnose` set neo_update='1970-01-01 12:00:00' where id="+disId+";";
+    public void updateDate(Connection connection,Long disId) {
+        String sql = "UPDATE `kl_diagnose` set neo_update='1970-01-01 12:00:00' where id=?";
+        try {
+            PreparedStatement preparedStatement = connection.prepareStatement(sql);
+            preparedStatement.setLong(1,disId);
+            int i = preparedStatement.executeUpdate();
+            preparedStatement.close();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
     }
     }
     public List<Long> getDisList(Connection connection){
     public List<Long> getDisList(Connection connection){
         List<Long> disIds = new ArrayList<>();
         List<Long> disIds = new ArrayList<>();