Jakarta NoSQL 介绍

Jakarta NoSQL 是 Jakarta EE 中的一个规范， 最近被批准为EE4J 项目，它可以帮助开发人员使用Java 和NoSQL 技术来创建企业级的应用程序。JNoSQL 是Jakarta NoSQL 的参考实现，它为一系列NoSQL 数据库（如 Cassandra 、 MongoDB 、 Neo4J 、 CouchDB 和 OrientDB 等）提供了一组 API 和一个标准实现。

Jakarta NoSQL 是由通信层（Diana）组成的，它提供了一组用于定义与 NoSQL 数据库通信的 API。根据 NoSQL 数据库的不同类型，它包含了四个模块：键值（Key-Value）、列族（Column Family）、文档（Document）和图（Graph）；映射层（Artemis）提供了一系列 API 来帮助开发人员将 Java 应用程序与 NoSQL 数据库集成。映射层是注解驱动的，它使用了 CDI 和 Bean Validation 等技术，这使得开发人员使用起来更加简单。也可以将映射层与传统 RDBMS 世界中的 JPA/Hibernate 进行比较。

让我们更深入地探讨一下如何与键值、列族、文档和图等 NoSQL 数据库进行通信。

实体的定义与 JPA 非常相似。基本上也是使用 @Entity、@Id、@Column 等注解：

@Entity
public class Person {
 
  @Id
  private long id;
 
  @Column
  private String name;
 
  @Column
  private List phones;
}

存储库和 Spring 的数据存储库看起来很像，可以通过 Repository<T, ID> 进行扩展：

public interface PersonRepository extends Repository {
 
  List<Person> findByName(String name);
 
  Stream<Person> findByPhones(String phone);
}

现在，我们必须稍微调整一下它，因为 maven 构件会根据 NoSQL 数据库的类型、设置配置以及如何在服务中注入存储库而改变。

我们比较一下列和文档 NoSQL 数据库之间的差异：

列（Column）

Maven 依赖的构件如下：

<dependency>
   <groupId>org.jnosql.artemis</groupId>
   <artifactId>artemis-column</artifactId>
   <version>0.0.9</version>
</dependency>
<dependency>
   <groupId>org.jnosql.diana</groupId>
   <artifactId>cassandra-driver</artifactId>
   <version>0.0.9</version>
</dependency>

用于设置 ColumnFamilyManager 生产者的示例如下：

@ApplicationScoped
public class ColumnFamilyManagerProducer {
 
  private static final String KEY_SPACE = "developers";
  private ColumnConfiguration<> cassandraConfiguration;
  private ColumnFamilyManagerFactory managerFactory;
 
  @PostConstruct
  public void init() {
    cassandraConfiguration = new CassandraConfiguration();
    managerFactory = cassandraConfiguration.get();
  }
 
  @Produces
  public ColumnFamilyManager getManagerCassandra() {
    return managerFactory.get(KEY_SPACE);
  }
}

最后，是一个如何执行一些插入 / 查询的示例：

Person person = Person.builder()
  .withPhones(Arrays.asList("234", "432"))
  .withName("Name")
  .withId(id)
  .build();
 
// 使用 ColumnTemplate
ColumnTemplate columnTemplate =  container.select(CassandraTemplate.class).get();
Person saved = columnTemplate.insert(PERSON);
System.out.println("Person saved" + saved);
 
ColumnQuery query = select().from("Person").where(eq(Column.of("id", 1L))).build();
 
Optional<Person> person = columnTemplate.singleResult(query);
System.out.println("Entity found: " + person);
 
// 使用 PersonRepository
PersonRepository repository = container.select(PersonRepository.class).select(ofColumn()).get();
Person saved = repository.save(PERSON);
System.out.println("Person saved" + saved);
 
Optional<Person> person = repository.findById(1L);
System.out.println("Entity found: " + person);

文档（Document）

Maven 依赖的构件如下：

<dependency>
   <groupId>org.jnosql.artemis</groupId>
   <artifactId>artemis-document</artifactId>
   <version>0.0.9</version>
</dependency>
<dependency>
   <groupId>org.jnosql.diana</groupId>
   <artifactId>mongodb-driver</artifactId>
   <version>0.0.9</version>
</dependency>

用于设置 DocumentCollectionManager 的生产者示例如下：

@ApplicationScoped
public class DocumentCollectionManagerProducer {
 
  private static final String COLLECTION = "developers";
  private DocumentConfiguration configuration;
  private DocumentCollectionManagerFactory managerFactory;
 
  @PostConstruct
  public void init() {
    configuration = new MongoDBDocumentConfiguration();
    Map<String, Object> settings = Collections.singletonMap("mongodb-server-host-1", "localhost:27017");
    managerFactory = configuration.get(Settings.of(settings));
  }
 
  @Produces
  public DocumentCollectionManager getManager() {
    return managerFactory.get(COLLECTION);
  }
}

最后，是一个如何执行一些插入 / 查询的示例：

Person person = Person.builder()
  .withPhones(Arrays.asList("234", "432"))
  .withName("Name")
  .withId(id)
  .build();
 
// 使用 DocumentTemplate
DocumentTemplate documentTemplate = container.select(DocumentTemplate.class).get();
Person saved = documentTemplate.insert(person);
System.out.println("Person saved" + saved);
 
DocumentQuery query = select().from("Person")
  .where(eq(Document.of("_id", id))).build();
 
Optional<Person> personOptional = documentTemplate.singleResult(query);
System.out.println("Entity found: " + personOptional);
 
// 使用 PersonRepository
PersonRepository repository = container.select(PersonRepository.class)
  .select(ofDocument()).get();
repository.save(person);
 
List<Person> people = repository.findByName("Name");
System.out.println("Entity found: " + people);
repository.findByPhones("234").forEach(System.out::println);

有关 Jakarta NoSQL 参考实现的更多细节可以在 JNoSQL 上找到。

在 Jakarta One  上还有一个 Jakarta NoSQL 的演示视频。

想要投稿的用户可以订阅邮件列表，或者通过 Twitter 和我们联系。

原文链接：

Introducing Jakarta NoSQL