Springboot 撞上 NebulaGraph-NGbatis 初体验

本文首发于 NebulaGraph 公众号 https://mp.weixin.qq.com/s/z56o6AEz1Z4RmS8Zdx6dTA

大家好,我是开源项目 NGbatis 的发起人大叶([CorvusYe@GitHub](https://github.com/CorvusYe))。目前 NGbatis 也已成为 NebulaGraph 开源生态项目之一。在过去的 4 个月里,NGbatis 从提交第一行代码以来,已经发布了 3 个版本,正在一步步变得越来越好。感谢一路同行的人们。

这里给大家贴上仓库地址:https://github.com/nebula-contrib/ngbatis,欢迎大家在仓库下方留言提出建议反馈。

一、目前有哪些参与者?

其中,@Szt-1 做了和 Spring Cloud 和 Nacos 的兼容,@liuxiaocs7 完善了文档,@soul-gin 做了 Java 与数据库之间属性别名的映射,@Nicole00 做了项目自动化与代码规范,@wey-gu 提了很多有利于项目发展的建议并做了国际化。@DawnZzzzz、@hejiahuichengxuyuan、@yarodai 与 @LiuTianyou 则提了不少 issues,issues 让人获得不少灵感。

可以说现阶段的 NGbatis 是使用者与开发者想法碰撞后的共同产物

二、什么是 NGbatis?

NGbatis 是一款针对 NebulaGraph + Spring Boot 的数据库 ORM 框架。借鉴于 MyBatis 的使用习惯进行开发。包含了一些类似于 mybatis-plus 的单表操作,另外还有一些图特有的实体 - 关系基本操作。

如果是 Java 后端服务的开发人员,相信看到这里,大家对 NGbatis 的用途有了比较清晰的理解。接下来会从几个问题出发,跟读者们介绍 NGbatis:

三、关于 NGbatis 有哪些思考?

以上,便是开发之初对 NGbatis 的一些方案选择的思考,做了一些取舍,是好处多一些还是坏处多一些,我自己目前也还在纠结中。比如说放弃 JDBC 的规范后也意味着放弃其背后的生态,比如说优秀的第三方连接池方案。

纠结归纠结,既然做了决定,路还是要往下走。开胃菜上完了,也该上正餐了。

四、NGbatis 能做什么?

一个项目诞生最恰当的理由是:想要用它解决一些问题。以解决问题为中心,可以让项目走得更远。NGbatis 的任务就是尽可能地减少日常开发中或重复或繁琐的工作。

我们生活在一个基础设施相对完善的时代,好处在于问题产生的同时,答案的模型也同时存在,我们需要做的只是在问题与答案之间做适配,这里真诚地对作出贡献的前辈们表示感谢。

以上问题就要求 NGbatis 需要做到以下几点:

方向有了,剩下的就是工程问题了。

五、NGbatis 是怎么实现的?

我们最本质的要求就是:把 GQL 语句执行到 NebulaGraph 当中。我们以带参的 Hello Nebula 为例,即:

根据最朴素的 Java 开发方法,可以想到的是:先通过 XML 给 GQL 定义一个坐标,再定义一个接口,最后编写一个实现类按坐标读取 GQL 语句,使用模板引擎替换参数。即:



    


package com.example.dao;

public interface TestDao {
  String greet(String who);
}
package com.example.dao;

public class TestDaoImpl implements TestDao {

  @Override
  public String greet(String who) {
    Object[] var2 = new Object[]{who};
    String namespace = "com.example.dao.TestDao";
    String methodName = "greet";
    // 有一个函数,可以完成以下事情:
    // 1. 根据坐标读取 GQL
    // 2. 使用模板引擎完成参数拼接(Beetl)
    // 3. 执行到数据库
    // 4. 转换 ResultSet 形成 业务对象
    return foo( namespace, methodName, var2 );
  }
}

做到这里其实就剩下 foo 怎么编写的问题了。到这里,相信读者们都有自己的思路。大家有兴趣的话可以参考 org.nebula.contrib.ngbatis.proxy.MapperProxy

但这里引入了另一个问题:每个 dao 的方法,写法基本是一样的,又带来了重复的工作,有悖于 NGbatis 的初衷。因此,使用动态代理,从 XML 与 DAO 信息中自动生成 TestDao$Proxy,这边使用的代理方案是基于字节码技术 ASM 来生成。上述的例子生成的字节码反编译后的结果如下:

package com.example.dao;

import org.nebula.contrib.ngbatis.proxy.MapperProxy;

public class TestDao$Proxy implements TestDao {

  @Override
  public String greet(String var1) {
    Object[] var2 = new Object[]{var1};
    return (String) MapperProxy.invoke( "com.example.dao.TestDao", "greet", var2 );
  }
}

因此,开发者便不需要再重复编写诸多 TestDaoImpl,定义好 XML 与 DAO,剩下的工作可以放心地交给 NGbatis。

最后剩下一个问题,参数替换问题:这个问题应该是与开发者关系最为密切的问题。所以,这里不得不提的模板引擎框架:Beetl 是国内流行模板引擎,也是 NGbatis 一个重要的组成部分,链接是官网的 API。

                                                  {
String hello = dao.greet(“Nebula”);       -->       “p0”: “Nebula”
                                                  }
RETURN 'Hello ${ p0 }'                  -->        RETURN 'Hello Nebula'

六、全局流程图

七、NGbatis 该如何集成到自己的 Springboot 项目

  1. 添加依赖
    
        org.nebula-contrib
        ngbatis
        1.1.0-rc
    
  1. 配置 NebulaGrpah 数据库
nebula:
  hosts: 127.0.0.1:19669, ip:port, ....
  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
  1. 添加扫描包以引入 NGbatis bean
@SpringBootApplication(
  exclude={ DataSourceAutoConfiguration.class }, 
  scanBasePackages = {  "org.nebula.contrib", "your.domain" }  )
public class YourSpringbootApplication {

}
  1. 声明主键生成器
import org.nebula.contrib.ngbatis.PkGenerator;
@Component
public class CustomPkGenerator implements PkGenerator {

    @Override
    public  T generate(String tagName, Class pkType) {
        Object id = null; // 此处自行对 id 进行设值。
        return (T) id;
    }

}

到此,对于集成工作来说,任务已经完成,剩下就是开发的工作了。

开发人员只需要做三件事:

  1. 定义接口:
package your.domain;

import  org.nebula.contrib.ngbatis.proxy.NebulaDaoBasic;

public interface PersonDao extends NebulaDaoBasic {
    Person selectByName( @Param("name") String param );
}
  1. 在 resources/mapper/PersonDao.xml 中编写 GQL

    

调用

注入:

调用自定义接口

    1. Person tom = dao.selectByName("Tom");

调用基类接口

  // 不管属性是否为空,如果数据库中已有对应 id 的值,则覆盖
  public void insert( Person person ) {
    dao.insert( person );
  }

  // 仅写入非空属性
  public void insertSelective( Person preson ) {
    dao.insertSelective( person );
  }

  // 此处,Person 的主键栏 name 为 String ,则入参为 String
  public Person selectById( String id ) {
    return dao.selectById( id );
  }

  // 按属性查询
  public List selectBySelective( Person person ) {
    return dao.selectBySelective( person );
  }

八、尾声

以上就是本次交流的全部内容。如果 NGbatis 实现方式也是你喜欢的,issue、pr、star 都是 ok 的。如果对项目感兴趣,也可以参与到开发中来,从中获得成就感。仓库地址:https://github.com/nebula-contrib/ngbatis。

最后,希望 NGbatis 能给越来越多的开发者带来开发上的便利。


谢谢你读完本文 (///▽///)

NebulaGraph Desktop,Windows 和 macOS 用户安装图数据库的绿色通道,10s 拉起搞定海量数据的图服务。通道传送门:http://c.nxw.so/blVC6

想看源码的小伙伴可以前往 GitHub 阅读、使用、(^з^)-☆ star 它 ~

展开阅读全文

页面更新:2024-04-21

标签:开发者   属性   接口   模板   参数   代码   数据库   引擎   项目   工作

1 2 3 4 5

上滑加载更多 ↓
推荐阅读:
友情链接:
更多:

本站资料均由网友自行发布提供,仅用于学习交流。如有版权问题,请与我联系,QQ:4156828  

© CopyRight 2020-2024 All Rights Reserved. Powered By 71396.com 闽ICP备11008920号-4
闽公网安备35020302034903号

Top