前两篇文章Springboot+Neo4j 初级框架搭建(一)，Springboot+Neo4j 初级增删改查(二)我们介绍了Springboot集成Neo4j，以及Neo4j单节点的操作。
本篇文章我们就来写写节点与节点中关系的操作！！！话不多说直接开干。
在上篇文章中，我们以公司为例子做了演示，本篇文章我们还是以公司和产品为示例演示。
首先我们在model层创建两个类，一个产品类，一个生产关系类，公司类就不创建了，上篇文章已经有了。
@NodeEntity(label = "ProductEntry")
@Data
public class ProductEntryNode {
@Id
private String productEntryId;
/**
* 模板id
*/
private String templateId;
/**
* 词条名称
*/
private String name;
/**
* 词条类型 1:产品种类 2:产品类型 3:产品单元
*/
private String type;
/**
* 别名
*/
private String aliasName;
/**
* 简介
*/
private String introduction;
}
/**
* @Author Created by YangMeng on 2021/3/4 14:09
* 公司->生产 产品关系
* 指定关系名称为Production
*/
@Data
@RelationshipEntity(type = "Production")
public class ProductionRelationship {
@Id
private String uuid;
@StartNode
private CompanyEntryNode startNode;
@EndNode
private ProductEntryNode endNode;
/**
* 收入占比
*/
private String incomeProportion;
/**
* 毛利率
*/
private String productGross;
/**
* 产品单价
*/
private String productPrice;
/**
* 产能
*/
private String capacity;
/**
* 产能利用率
*/
private String capacityRatio;
/**
* 产能占比
*/
private String capacityProportion;
}
分别定义产品和生产关系的dao层结构
@Repositorypublic interface ProductEntryRepository extends Neo4jRepository<ProductEntryNode, String> {}
@Repository
public interface ProductionRelationshipRepository extends Neo4jRepository<ProductionRelationship, String> {
/**
* 根据产品获取供应商
* @param productEntryId
* @return
*/
@Query("match (c:CompanyEntry)-[:Production]->(p:ProductEntry) where p.productEntryId={productEntryId} return c.companyEntryId as companyEntryId,c.name as companyName")
List<DicDto> getCompanyByProductId(String productEntryId);
}
在service层我们定义增删改查操作，单节点产品的我们就不做演示了。我们现在只定义生成关系的操作，在关系里我们实现定义两个接口，第一个addProductionRelationship是把公司和产品创建关系连接起来，第二个getCompanyByProductId是根据产品id查询他的供应商，也就是谁生产了它
/**
* @Author Created by YangMeng on 2021/3/4 15:29
*/
public interface ProductionRelationshipService {
/**
* 添加公司产品 关系
*
* @param startNode
* @param toNode
* @return
*/
ProductionRelationship addProductionRelationship(CompanyEntryNode startNode, ProductEntryNode toNode);
/**
* 添加公司产品 关系
*
* @param startNodeId
* @param toNodeId
* @return
*/
ProductionRelationship addProductionRelationship(String startNodeId, String toNodeId);
/**
* 获取产品的供应商公司
*
* @param productEntryId
* @return
*/
List<DicDto> getCompanyByProductId(String productEntryId);
接着实现接口
@Service
public class ProductionRelationshipServiceImpl implements ProductionRelationshipService {
@Autowired
private ProductionRelationshipRepository productionRelationshipRepository;
@Autowired
private CompanyEntryRepository companyEntryRepository;
@Autowired
private ProductEntryRepository productEntryRepository;
/**
* 添加公司产品 关系
*
* @param startNode
* @param toNode
* @return
*/
@Override
public ProductionRelationship addProductionRelationship(CompanyEntryNode startNode, ProductEntryNode toNode) {
ProductionRelationship productionRelationship = new ProductionRelationship();
productionRelationship.setStartNode(startNode);
productionRelationship.setEndNode(toNode);
//添加属性
productionRelationship.setUuid(UuidUtils.generate());
ProductionRelationship save = productionRelationshipRepository.save(productionRelationship);
return save;
}
/**
* 添加公司产品 关系
*
* @param startNodeId
* @param toNodeId
* @return
*/
@Override
public ProductionRelationship addProductionRelationship(String startNodeId, String toNodeId) {
Optional<CompanyEntryNode> byId = companyEntryRepository.findById(startNodeId);
Optional<ProductEntryNode> byId1 = productEntryRepository.findById(toNodeId);
if (byId.isPresent() && byId1.isPresent()) {
return addProductionRelationship(byId.get(), byId1.get());
}
return new ProductionRelationship();
}
/**
* 获取产品的供应商公司
*
* @param productEntryId
* @return
*/
@Override
public List<DicDto> getCompanyByProductId(String productEntryId) {
return productionRelationshipRepository.getCompanyByProductId(productEntryId);
}
}
创建controller调用
@RestController
@RequestMapping(value = "productionRelationship")
@Slf4j
public class ProductionRelationshipController {
@Autowired
private ProductionRelationshipService productionRelationshipService;
/**
* 关联公司产品 关系
*
* @param startId
* @param endId
* @return
*/
@GetMapping(value = "addRelationship")
public WebResInfo addRelationship(String startId, String endId) {
log.info("addRelationship->startId:{}，endId:{}", startId, endId);
WebResInfo webResInfo = new WebResInfo();
try {
webResInfo.setCode(WebResCode.Successful);
ProductionRelationship productionRelationship = productionRelationshipService.addProductionRelationship(startId, endId);
webResInfo.setData(productionRelationship);
} catch (Exception e) {
log.error("addRelationship error:{}", e);
webResInfo.setCode(WebResCode.Server_Bug_Exception);
webResInfo.setMessage(e.getMessage());
}
return webResInfo;
}
/**
* 根据产品获取供应商信息
*
* @param productEntryId
* @return
*/
@GetMapping(value = "getCompanyByProductId")
public WebResInfo getCompanyByProductId(String productEntryId) {
log.info("getCompanyByProductId->productEntryId:{}", productEntryId);
WebResInfo webResInfo = new WebResInfo();
try {
webResInfo.setCode(WebResCode.Successful);
List<DicDto> companyByProductId = productionRelationshipService.getCompanyByProductId(productEntryId);
webResInfo.setData(companyByProductId);
} catch (Exception e) {
log.error("getCompanyByProductId error:{}", e);
webResInfo.setCode(WebResCode.Server_Bug_Exception);
webResInfo.setMessage(e.getMessage());
}
return webResInfo;
}
我们新增一个公司“阿里巴巴”companyEntryId为2，在新增一个产品“宝马X5”productEntryId为6，然后我们创建他们两个的关系用postman调用
基于以上关系的创建，现在我们查找生产iPhone的公司有哪些
@Query("match (c:CompanyEntry)-[:Production]->(p:ProductEntry) where p.productEntryId={productEntryId} return c.companyEntryId as companyEntryId,c.name as companyName")
List<DicDto> getCompanyByProductId(String productEntryId);
这里就是查询产品id为{productEntryId}的对应的公司，并且指定了关系是Production，然后就可以查出来苹果公司了。具体请求大家试试就好了
本篇主要介绍关系类型，相信大家有了一定的了解，其实neo4j里最主要还是语义化查询，有了关系我们就可以进行这样一系列查询操作，比如我搜索“iPhone12的生产商是谁”可以查询产品节点是iPhone，对应关系是生产，然后就出来了苹果公司了。这只是其中一小部分，后续还有很多。
彩蛋
下篇文章我们来讲讲Springboot同时绑定neo4j和mysql两个数据源。
关注下方公众号，了解最新内容！！！
