代码拉取完成，页面将自动刷新
English | 中文
NGBATIS 是一款针对 Nebula Graph + Springboot 的数据库 ORM 框架。借鉴于 MyBatis 的使用习惯进行开发。包含了一些类似于mybatis-plus的单表操作，另外还有一些图特有的实体-关系基本操作。
如果使用上更习惯于JPA的方式，graph-ocean 是个不错的选择。
请看设计文档 EXECUTION-PROCESS.md
| NgBatis | nebula-java | JDK | Springboot | Beetl |
|---|---|---|---|---|
| 1.2.1-jdk17 | 3.6.0 | 17 | 3.0.7 | 3.15.10.RELEASE |
| 1.2.1 | 3.6.0 | 8 | 2.7.0 | 3.15.10.RELEASE |
| 1.2.0-jdk17 | 3.6.0 | 17 | 3.0.7 | 3.15.10.RELEASE |
| 1.2.0 | 3.6.0 | 8 | 2.7.0 | 3.15.10.RELEASE |
| 1.1.5 | 3.5.0 | 8 | 2.7.0 | 3.1.8.RELEASE |
| 1.1.4 | 3.5.0 | 8 | 2.7.0 | 3.1.8.RELEASE |
| 1.1.3 | 3.5.0 | 8 | 2.7.0 | 3.1.8.RELEASE |
| 1.1.2 | 3.4.0 | 8 | 2.7.0 | 3.1.8.RELEASE |
| NgBatis | nebula-java | JDK | Springboot | Beetl |
|---|---|---|---|---|
| 1.2.2-jdk17-SNAPSHOT | 3.6.0 | 17 | 3.0.7 | 3.15.10.RELEASE |
| 1.2.2-SNAPSHOT | 3.6.0 | 8 | 2.7.0 | 3.15.10.RELEASE |
在同版本号快照版中，依赖的第三方可能会随时升级
Maven
<dependency>
<groupId>org.nebula-contrib</groupId>
<artifactId>ngbatis</artifactId>
<version>1.2.1</version>
</dependency>
Gradle
implementation 'org.nebula-contrib:ngbatis:1.2.1'
在 application.yml 中添加配置 将数据源修改成可访问到的NebulaGraph
nebula:
ngbatis:
session-life-length: 300000 # since v1.1.2
check-fixed-rate: 300000 # since v1.1.2
# `use-session-pool` 默认是 false，如开启，则 space 是必须指定的
# space除了使用当前文件的声明意外，还可以使用：(@Space) or xml(space="test")
use-session-pool: false # since v1.1.2
hosts: 127.0.0.1:19669, 127.0.0.1:9669
username: root
password: nebula
space: test
pool-config:
min-conns-size: 0
max-conns-size: 10
timeout: 0
idle-time: 0
interval-idle: -1
wait-time: 0
min-cluster-health-rate: 1.0
enable-ssl: false
@SpringBootApplication(scanBasePackages = { "org.nebula", "your.domain"})
public class YourApplication {
public static void main(String[] args) {
new SpringApplication(YourApplication.class).run(args);
}
}
如果项目中使用的是 SpringCloud， 请使用
@ComponentScan( basePackages = {"org.nebula.contrib", "your.domain"} )
package ye.weicheng.ngbatis.demo.repository;
import ye.weicheng.ngbatis.demo.pojo.Person;
import java.util.List;
import java.util.Map;
import java.util.Set;
public interface TestRepository {
// new features from v1.2.0
Integer returnAge(@Param("person")Person person);
Person selectPerson();
Person selectByPerson(Person person);
List<Person> selectAgeGt(Integer age);
List<String> selectListString();
List<Map> selectPersonsMap();
Map<String, Object> selectTriple();
}
resource/mapper/TestRepository.xml
<mapper
namespace=
"ye.weicheng.ngbatis.demo.repository.TestRepository"
>
<!-- v1.2.0 新特性 start -->
<nGQL id="include-test-value">
${myInt}
</nGQL>
<nGQL id="ngql-return-age">
RETURN @ng.include('include-test-value',{'myInt':age});
</nGQL>
<!--
等同于:
RETURN ${person.age};
你可以试着提取更多有意义的公共脚本.
-->
<select id="returnAge" resultType="java.lang.Integer">
@ng.include('ngql-return-age',person);
</select>
<!-- v1.2.0 新特性 v1.2.0 end -->
<select id="selectPerson" resultType="ye.weicheng.ngbatis.demo.pojo.Person">
match (v:person) return v.person.name as name, v.person.age as age limit 1
</select>
<select id="selectAgeGt" resultType="ye.weicheng.ngbatis.demo.pojo.Person">
MATCH (n: person)
WHERE n.person.age > $p0
RETURN n
LIMIT 100
</select>
<select id="selectByPerson" resultType="ye.weicheng.ngbatis.demo.pojo.Person">
MATCH (n: person)
WHERE n.person.name == $p0.name
RETURN n
LIMIT 100
</select>
<select id="selectListString" resultType="java.lang.String">
match (v:person) return v.person.name as name limit 100
</select>
<select id="selectPersonsMap" resultType="java.util.Map">
match (v:person) return v.person.name as name, v.person.age as age limit 100
</select>
<select id="selectTriple" resultType="java.util.Map">
MATCH (n: person)-[r: like]->(n2: person)
RETURN n, r, n2
LIMIT 100
</select>
<!--
更多复杂的 nGQL 可能还需要充分的测试，
目前我自己在用的项目两层对象的数据结构也是可以满足的。
Path 因为开发中基本都可以用 n, r, n2 的结构处理，便还没来得及支持。
-->
</mapper>
package com.example.model.vertex.Person;
import lombok.Data;
import javax.persistence.Id;
import javax.persistence.Table;
@Data
@Table(name = "person")
public class Person {
@Id
private String name;
private Integer age;
}
package com.example.model.edge.Like;
import lombok.AllArgsConstructor;
import lombok.NoArgsConstructor;
import lombok.Data;
import javax.persistence.Table;
@Data
@Table(name = "like")
@NoArgsConstructor
@AllArgsConstructor
public class Like {
private Double likeness;
}
package com.example.dao;
import org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;
import com.example.model.vertex.Person;
public interface PersonDao extends NebulaDaoBasic<Person, String>{}
<mapper
namespace=
"com.example.dao.PersonDao"
>
</mapper>
package com.example.service;
import org.nebula.contrib.ngbatis.utils.Page;
import com.example.dao.PersonDao;
import com.example.model.vertex.Person;
import com.example.model.edge.Like;
@Service
public class PersonServiceImpl {
@Autowired private PersonDao dao;
public void demos() {
// 实现 两个节点插入
Person tom = new Person();
tom.setName("Tom");
dao.insert( tom );
Person jerry = new Person();
jerry.setName( "Jerry" );
dao.insert( jerry );
// 建立两个节点的关系
Like like = new Like( 0.99999 );
dao.insertEdge( tom, like, jerry );
// 查找喜欢 jerry 的人
String jerryId = jerry.getName();
List<Person> whoLikeJerry = dao.listStartNodes( Like.class, jerryId );
// 查找唯一喜欢 jerry 的人。非唯一时报错。（限定在特定关系仅有一个上游的场景）
Person tom = dao.startNode( Like.class, jerryId );
// 查看 Tom 跟 Jerry 之间的 Like关系
String tomId = tom.getName();
Boolean tomLikeJerry = dao.existsEdge( tomId, Like.class, jerryId ); // true
Boolean jerryLikeTom = dao.existsEdge( jerryId, Like.class, tomId ); // false
// 可怜的 Tom
// 根据 Tom 的名字查找全部信息
Person tomDb = dao.selectById( "Tom" );
// 查找分页
Page<Person> page = new Page<>();
List<Person> personPage = dao.selectPage( page );
page.getTotal(); // 2 rows， Tom and Jerry
Boolean theyAreFamily = page.getRows() == personPage; // true
// 故事总想要有个好的结局
dao.insertEdge( jerry, like, tom );
// 更多 基类的操作还在开发中。期待
}
}
项目遵循 Apache License, Version 2.0, January 2004 开源协议。
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
1. 开源生态
2. 协作、人、软件
3. 评估模型