init

kbqa-graph/pom.xml

@@ -56,7 +56,6 @@
             <artifactId>spring-boot-starter-undertow</artifactId>
         </dependency>
 
-
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-jdbc</artifactId>
@@ -66,6 +65,11 @@
             <artifactId>mysql-connector-java</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>druid-spring-boot-starter</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>org.nebula-contrib</groupId>
             <artifactId>ngbatis</artifactId>

kbqa-graph/src/main/java/com/supervision/controller/TestController.java

@@ -1,13 +1,17 @@
 package com.supervision.controller;
 
-import com.supervision.ngbatis.dao.ItemBranchDao;
-import com.supervision.ngbatis.domain.ItemBranch;
+import cn.hutool.core.map.MapUtil;
+import com.supervision.ngbatis.dao.tag.ItemBranchDao;
+import com.supervision.ngbatis.domain.tag.ItemBranch;
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 
 
 @RestController
@@ -18,13 +22,19 @@ public class TestController {
     @Resource
     private ItemBranchDao itemBranchDao;
 
-    @GetMapping("hello")
-    public void hello() {
+    @GetMapping("testInsert")
+    public void testInsert() {
         ItemBranch itemBranch = new ItemBranch();
         itemBranch.setItemName("退休");
         itemBranchDao.insert(itemBranch);
     }
 
+    @GetMapping("testQuery")
+    public List<ItemBranch> testQuery(){
+        Map<String, Object> param = MapUtil.builder(new HashMap<String, Object>()).put("item_name", "退休").build();
+        return itemBranchDao.selectByMap(param);
+    }
+
 
 
 

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/edge/AcceptScopeEdgeDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.edge;
+
+import com.supervision.ngbatis.domain.edge.AcceptScopeEdge;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface AcceptScopeEdgeDao extends NebulaDaoBasic<AcceptScopeEdge,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/edge/ChecklistEdgeDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.edge;
+
+import com.supervision.ngbatis.domain.edge.ChecklistEdge;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface ChecklistEdgeDao extends NebulaDaoBasic<ChecklistEdge,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/edge/ConditionEdgeDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.edge;
+
+import com.supervision.ngbatis.domain.edge.ConditionEdge;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface ConditionEdgeDao extends NebulaDaoBasic<ConditionEdge,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/edge/DependenceEdgeDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.edge;
+
+import com.supervision.ngbatis.domain.edge.DependenceEdge;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface DependenceEdgeDao extends NebulaDaoBasic<DependenceEdge,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/edge/HandlerChannelEdgeDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.edge;
+
+import com.supervision.ngbatis.domain.edge.HandlerChannelEdge;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface HandlerChannelEdgeDao extends NebulaDaoBasic<HandlerChannelEdge,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/edge/HandlerPlaceEdgeDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.edge;
+
+import com.supervision.ngbatis.domain.edge.HandlerPlaceEdge;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface HandlerPlaceEdgeDao extends NebulaDaoBasic<HandlerPlaceEdge,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/edge/HandlerProcessEdgeDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.edge;
+
+import com.supervision.ngbatis.domain.edge.HandlerProcessEdge;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface HandlerProcessEdgeDao extends NebulaDaoBasic<HandlerProcessEdge,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/edge/ProcessConditionEdgeDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.edge;
+
+import com.supervision.ngbatis.domain.edge.ProcessConditionEdge;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface ProcessConditionEdgeDao extends NebulaDaoBasic<ProcessConditionEdge,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/tag/AcceptScopeDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.tag;
+
+import com.supervision.ngbatis.domain.tag.AcceptScope;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface AcceptScopeDao extends NebulaDaoBasic<AcceptScope,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/tag/ChecklistDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.tag;
+
+import com.supervision.ngbatis.domain.tag.Checklist;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface ChecklistDao extends NebulaDaoBasic<Checklist,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/tag/ConditionDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.tag;
+
+import com.supervision.ngbatis.domain.tag.Condition;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface ConditionDao extends NebulaDaoBasic<Condition,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/tag/HandlerChannelDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.tag;
+
+import com.supervision.ngbatis.domain.tag.HandlerChannel;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface HandlerChannelDao extends NebulaDaoBasic<HandlerChannel,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/tag/HandlerPlaceDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.tag;
+
+import com.supervision.ngbatis.domain.tag.HandlerPlace;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface HandlerPlaceDao extends NebulaDaoBasic<HandlerPlace,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/tag/HandlerProcessDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.tag;
+
+import com.supervision.ngbatis.domain.tag.HandlerProcess;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface HandlerProcessDao extends NebulaDaoBasic<HandlerProcess,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/tag/ItemBranchDao.java

@@ -1,9 +1,6 @@
-package com.supervision.ngbatis.dao;
+package com.supervision.ngbatis.dao.tag;
 
-import com.supervision.ngbatis.domain.ItemBranch;
+import com.supervision.ngbatis.domain.tag.ItemBranch;
 import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
-
 public interface ItemBranchDao extends NebulaDaoBasic<ItemBranch,String> {
-
-
-}
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/tag/ItemLeafDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.tag;
+
+import com.supervision.ngbatis.domain.tag.ItemLeaf;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface ItemLeafDao extends NebulaDaoBasic<ItemLeaf,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/dao/tag/ProcessConditionDao.java

@@ -0,0 +1,6 @@
+package com.supervision.ngbatis.dao.tag;
+
+import com.supervision.ngbatis.domain.tag.ProcessCondition;
+import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
+public interface ProcessConditionDao extends NebulaDaoBasic<ProcessCondition,String> {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/edge/AcceptScopeEdge.java

@@ -0,0 +1,10 @@
+package com.supervision.ngbatis.domain.edge;
+
+import lombok.Data;
+
+import javax.persistence.Table;
+
+@Data
+@Table(name = "accept_scope_edge")
+public class AcceptScopeEdge {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/edge/ChecklistEdge.java

@@ -0,0 +1,11 @@
+package com.supervision.ngbatis.domain.edge;
+
+
+import lombok.Data;
+
+import javax.persistence.Table;
+
+@Data
+@Table(name = "checklist_edge")
+public class ChecklistEdge {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/edge/ConditionEdge.java

@@ -0,0 +1,12 @@
+package com.supervision.ngbatis.domain.edge;
+
+import lombok.Data;
+
+import javax.persistence.Table;
+
+@Data
+@Table(name = "condition_edge")
+public class ConditionEdge {
+
+    private String operation;
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/edge/DependenceEdge.java

@@ -0,0 +1,10 @@
+package com.supervision.ngbatis.domain.edge;
+
+import lombok.Data;
+
+import javax.persistence.Table;
+
+@Data
+@Table(name = "accept_scope_edge")
+public class DependenceEdge {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/edge/HandlerChannelEdge.java

@@ -0,0 +1,10 @@
+package com.supervision.ngbatis.domain.edge;
+
+import lombok.Data;
+
+import javax.persistence.Table;
+
+@Data
+@Table(name = "accept_scope_edge")
+public class HandlerChannelEdge {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/edge/HandlerPlaceEdge.java

@@ -0,0 +1,10 @@
+package com.supervision.ngbatis.domain.edge;
+
+import lombok.Data;
+
+import javax.persistence.Table;
+
+@Data
+@Table(name = "accept_scope_edge")
+public class HandlerPlaceEdge {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/edge/HandlerProcessEdge.java

@@ -0,0 +1,10 @@
+package com.supervision.ngbatis.domain.edge;
+
+import lombok.Data;
+
+import javax.persistence.Table;
+
+@Data
+@Table(name = "handler_process_edge")
+public class HandlerProcessEdge {
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/edge/ProcessConditionEdge.java

@@ -0,0 +1,11 @@
+package com.supervision.ngbatis.domain.edge;
+
+import lombok.Data;
+
+import javax.persistence.Table;
+
+@Data
+@Table(name = "process_condition_edge")
+public class ProcessConditionEdge {
+
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/tag/AcceptScope.java

@@ -0,0 +1,19 @@
+package com.supervision.ngbatis.domain.tag;
+
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Data
+@Table(name = "accept_scope")
+public class AcceptScope {
+
+    @Id
+    private String id;
+
+    @Column(name = "detail", nullable = false)
+    private String detail;
+
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/tag/Checklist.java

@@ -0,0 +1,18 @@
+package com.supervision.ngbatis.domain.tag;
+
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Data
+@Table(name = "checklist")
+public class Checklist {
+
+    @Id
+    private String id;
+
+    @Column(name = "detail", nullable = false)
+    private String detail;
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/tag/Condition.java

@@ -0,0 +1,19 @@
+package com.supervision.ngbatis.domain.tag;
+
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Table;
+
+@Data
+@Table(name = "condition")
+public class Condition {
+
+    private String id;
+
+    @Column(name = "condition", nullable = false)
+    private String condition;
+
+    @Column(name = "entity_type", nullable = false)
+    private String entityType;
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/tag/HandlerChannel.java

@@ -0,0 +1,18 @@
+package com.supervision.ngbatis.domain.tag;
+
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Data
+@Table(name = "handler_channel")
+public class HandlerChannel {
+
+    @Id
+    private String id;
+
+    @Column(name = "detail", nullable = false)
+    private String detail;
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/tag/HandlerPlace.java

@@ -0,0 +1,18 @@
+package com.supervision.ngbatis.domain.tag;
+
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Data
+@Table(name = "handler_place")
+public class HandlerPlace {
+
+    @Id
+    private String id;
+
+    @Column(name = "detail", nullable = false)
+    private String detail;
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/tag/HandlerProcess.java

@@ -0,0 +1,18 @@
+package com.supervision.ngbatis.domain.tag;
+
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Data
+@Table(name = "handler_process")
+public class HandlerProcess {
+
+    @Id
+    private String id;
+
+    @Column(name = "detail", nullable = false)
+    private String detail;
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/tag/ItemBranch.java

@@ -1,7 +1,8 @@
-package com.supervision.ngbatis.domain;
+package com.supervision.ngbatis.domain.tag;
 
 import lombok.Data;
 
+import javax.persistence.Column;
 import javax.persistence.Id;
 import javax.persistence.Table;
 
@@ -10,8 +11,10 @@ import javax.persistence.Table;
 public class ItemBranch {
 
     @Id
-    private String id;
+    private String vid;
 
+    @Column(name = "item_name")
     private String itemName;
 
+
 }

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/tag/ItemLeaf.java

@@ -0,0 +1,18 @@
+package com.supervision.ngbatis.domain.tag;
+
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Data
+@Table(name = "item_leaf")
+public class ItemLeaf {
+
+    @Id
+    private String vid;
+
+    @Column(name = "item_name")
+    private String itemName;
+}

kbqa-graph/src/main/java/com/supervision/ngbatis/domain/tag/ProcessCondition.java

@@ -0,0 +1,18 @@
+package com.supervision.ngbatis.domain.tag;
+
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Data
+@Table(name = "process_condition")
+public class ProcessCondition {
+
+    @Id
+    private String id;
+
+    @Column(name = "detail", nullable = false)
+    private String detail;
+}

kbqa-graph/src/main/resources/nebulaMapper/ItemBranchDao.xml

@@ -1,3 +0,0 @@
-<mapper namespace="com.supervision.ngbatis.dao.ItemBranchDao">
-
-</mapper>

kbqa-graph/src/main/resources/nebulaMapper/edge/AcceptScopeEdgeDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.edge.AcceptScopeEdgeDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/edge/ChecklistEdgeDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.edge.ChecklistEdgeDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/edge/ConditionEdgeDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.edge.ConditionEdgeDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/edge/DependenceEdgeDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.edge.DependenceEdgeDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/edge/HandlerChannelEdgeDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.edge.HandlerChannelEdgeDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/edge/HandlerPlaceEdgeDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.edge.HandlerPlaceEdgeDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/edge/HandlerProcessEdgeDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.edge.HandlerProcessEdgeDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/edge/ProcessConditionEdgeDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.edge.ProcessConditionEdgeDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/tag/AcceptScopeDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.tag.AcceptScopeDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/tag/ChecklistDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.tag.ChecklistDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/tag/ConditionDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.tag.ConditionDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/tag/HandlerChannelDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.tag.HandlerChannelDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/tag/HandlerPlaceDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.tag.HandlerPlaceDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/tag/HandlerProcessDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.tag.HandlerProcessDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/tag/ItemBranchDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.tag.ItemBranchDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/tag/ItemLeafDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.tag.ItemLeafDao">
+</mapper>

kbqa-graph/src/main/resources/nebulaMapper/tag/ProcessConditionDao.xml

@@ -0,0 +1,2 @@
+<mapper namespace="com.supervision.ngbatis.dao.tag.ProcessConditionDao">
+</mapper>

kbqa-graph/src/test/java/com/supervision/GenerateNebulaEntity.java

@@ -0,0 +1,51 @@
+package com.supervision;
+
+import cn.hutool.core.io.FileUtil;
+
+import java.util.List;
+
+public class GenerateNebulaEntity {
+
+    private static final String basePath = "/Users/flevance/Java/KBQA/kbqa-graph/src/main/java/";
+
+    public static void main(String[] args) {
+        buildDao();
+        buildMapper();
+    }
+
+    /**
+     * 生成mapper
+     */
+    private static void buildMapper(){
+        String filePath = basePath + "com/supervision/ngbatis/dao/edge";
+        String targetPath =  "/Users/flevance/Java/KBQA/kbqa-graph/src/main/resources/nebulaMapper/edge";
+        List<String> strings = FileUtil.listFileNames(filePath);
+        for (String string : strings) {
+            String className = string.substring(0, string.lastIndexOf("."));
+            StringBuilder sb = new StringBuilder();
+            sb.append("<mapper namespace=\"com.supervision.ngbatis.dao.edge.").append(className).append("\">\n");
+            sb.append("</mapper>");
+            FileUtil.writeString(sb.toString(), targetPath + "/" + className + ".xml", "UTF-8");
+        }
+    }
+
+    /**
+     * 生成dao
+     */
+    private static void buildDao() {
+        String filePath = basePath + "com/supervision/ngbatis/domain/tag";
+        String targetPath = basePath + "com/supervision/ngbatis/dao/tag";
+        List<String> strings = FileUtil.listFileNames(filePath);
+        for (String string : strings) {
+            String className = string.substring(0, string.lastIndexOf("."));
+            StringBuilder sb = new StringBuilder();
+            sb.append("package com.supervision.ngbatis.dao.tag;\n");
+            sb.append("\n");
+            sb.append("import com.supervision.ngbatis.domain.tag.").append(className).append(";\n");
+            sb.append("import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;\n");
+            sb.append("public interface ").append(className).append("Dao extends NebulaDaoBasic<").append(className).append(",String> {\n");
+            sb.append("}");
+            FileUtil.writeString(sb.toString(), targetPath + "/" + className + "Dao.java", "UTF-8");
+        }
+    }
+}