词库文件更新

nlp/src/main/java/org/diagbot/nlp/util/DictUtil.java

@@ -93,7 +93,7 @@ public class DictUtil {
                     "left join concept c1 on r.start_id = c1.id " +
                     "left join concept c2 on r.end_id = c2.id " +
                     "left join library_info l_1 on l_1.id = c1.lib_id " +
-                    "left join library_info l_2 on l_2.id = c2.lib_id";
+                    "left join library_info l_2 on l_2.id = c2.lib_id where r.relation_id = 3";
             st = conn.createStatement();
             rs = st.executeQuery(sql);
 

public/src/main/java/org/diagbot/pub/jdbc/MysqlJdbc.java

@@ -204,6 +204,40 @@ public class MysqlJdbc {
         this.close(null, null, conn);
     }
 
+    public void update(String sql) {
+        Connection conn = connect();
+        if (conn == null) return;
+        Statement st = null;
+        try {
+            conn.setAutoCommit(false);
+            st = conn.createStatement();
+            st.executeUpdate(sql);
+            conn.commit();
+            st.close();
+        } catch (SQLException sqle) {
+            sqle.printStackTrace();
+        }
+        this.close(null, null, conn);
+    }
+
+    public void update(List<String> sqls) {
+        Connection conn = connect();
+        if (conn == null) return;
+        Statement st = null;
+        try {
+            conn.setAutoCommit(false);
+            st = conn.createStatement();
+            for (String sql : sqls) {
+                st.executeUpdate(sql);
+            }
+            conn.commit();
+            st.close();
+        } catch (SQLException sqle) {
+            sqle.printStackTrace();
+        }
+        this.close(null, null, conn);
+    }
+
     private String joinInsetSql(String table, String[] columns) {
         String sql = "insert into " + table + "(";
         for (int i = 0; i < columns.length; i++) {