谦谦君子
谦谦君子
2018-08-21  ·  1680 次阅读

ArangoDB 教程：Java 10 分钟

原创 arangodb

这是一个关于如何用 Java Sync Driver 使用 ArangoDB 的简短教程。在不到10分钟的时间内，您将学会如何用 Java 操作 ArangoDB。有关驱动程序的功能和性能的更多细节，请查看相应的博客文章。

请注意: 本教程是针对 ArangoDB 3.1 版本编写的，有可能不支持旧版本。

如果您使用的是旧版本的 ArangoDB，请查看为旧版本设计的 Java 教程。

安装 Java 驱动程序

本教程将在 Eclipse 中介绍 Java 驱动程序的用法。首先，通过 maven 将 Java 驱动程序添加到您的项目中：

<dependencies>
  <dependency>
    <groupId>com.arangodb</groupId>
    <artifactId>arangodb-java-driver</artifactId>
    <version>4.2.2</version>
  </dependency>
</dependencies>

使用 eclipse，您需要执行以下步骤：

  • 首先 file, 然后 new 然后点击 other
  • 选择 Maven Project
  • 选择工作区位置
  • 选择默认的原型
  • 最后选择一个Group id (mydb) 和一个Artifact id (firstproject) 然后点击完成
  • 现在打开 pom.xml, 在标签 dependencies 然后点击添加
  • 现在我们填写groupID (com.arangodb), artifactID(arangodb-java-driver) and version(4.2.2)

注意: 确保安装并运行 ArangoDB 3.1 或更高版本。

快速开始

创建一个名为 FirstProject 的文件并写入：

package mydb.firstproject;

import java.util.List;
import java.util.Map;
import java.util.HashMap;

import com.arangodb.ArangoCollection;
import com.arangodb.ArangoCursor;
import com.arangodb.ArangoDB;
import com.arangodb.ArangoDBException;
import com.arangodb.entity.BaseDocument;
import com.arangodb.entity.CollectionEntity;
import com.arangodb.model.AqlQueryOptions;
import com.arangodb.util.MapBuilder;
import com.arangodb.velocypack.VPackSlice;
import com.arangodb.velocypack.exception.VPackException;

public class FirstProject {
  public static void main(final String[] args) {

  }
}

在 eclipse 中，您需要创建一个名为 FirstProject 的新类，并将代码复制到其中。在本教程的过程中，将使用代码中给出的每个 import。

连接

配置和打开连接以启动 ArangoDB。

ArangoDB arangoDB = new ArangoDB.Builder().build();

提示: 原始连接为 http://127.0.0.1:8529。

创建数据库

我们来创建一个新的数据库：

String dbName = "mydb";
try {
  arangoDB.createDatabase(dbName);
  System.out.println("Database created: " + dbName);
} catch (ArangoDBException e) {
  System.err.println("Failed to create database: " + dbName + "; " + e.getMessage());
}

结果是应该是：

Database created: mydb

创建一个集合

现在让我们来创建我们的第一个集合：

String collectionName = "firstCollection";
try {
  CollectionEntity myArangoCollection = arangoDB.db(dbName).createCollection(collectionName);
  System.out.println("Collection created: " + myArangoCollection.getName());
} catch (ArangoDBException e) {
  System.err.println("Failed to create collection: " + collectionName + "; " + e.getMessage());
}

结果是应该是：

Collection created: firstCollection

您应该了解的一些细节代码：

  • createCollection() 创建集合
  • firstCollection 是集合的名字

创建文档

现在我们在集合中创建一个文档。任何对象都可以作为文档添加到数据库中，并作为对象从数据库中检索。

这个例子中，我们使用驱动程序提供的 BaseDocument 类。文档的属性存储在映射中，作为 键<String>/值<Object> 对：

BaseDocument myObject = new BaseDocument();
myObject.setKey("myKey");
myObject.addAttribute("a", "Foo");
myObject.addAttribute("b", 42);
try {
  arangoDB.db(dbName).collection(collectionName).insertDocument(myObject);
  System.out.println("Document created");
} catch (ArangoDBException e) {
  System.err.println("Failed to create document. " + e.getMessage());
}

结果应该是：

Document created

您应该了解的一些细节代码：

  • setKey() 设置新对象的键值
  • addAttribute() 将一个新的键/值对放在对象中
  • 每个属性作为单个键／值对存储在文档根目录中

阅读文档

阅读创建的文档：

try {
  BaseDocument myDocument = arangoDB.db(dbName).collection(collectionName).getDocument("myKey",
      BaseDocument.class);
  System.out.println("Key: " + myDocument.getKey());
  System.out.println("Attribute a: " + myDocument.getAttribute("a"));
  System.out.println("Attribute b: " + myDocument.getAttribute("b"));
} catch (ArangoDBException e) {
  System.err.println("Failed to get document: myKey; " + e.getMessage());
}

结果应该是：

Key: myKey
Attribute a: Foo
Attribute b: 42

您应该了解的一些细节代码：

  • getDocument() 将存储的文档数据返回到给定的JavaBean (BaseDocument)

阅读 VelocyPack 格式文档

您也可以阅读 VelocyPack 格式文档：

try {
  VPackSlice myDocument = arangoDB.db(dbName).collection(collectionName).getDocument("myKey",
    VPackSlice.class);
  System.out.println("Key: " + myDocument.get("_key").getAsString());
  System.out.println("Attribute a: " + myDocument.get("a").getAsString());
  System.out.println("Attribute b: " + myDocument.get("b").getAsInt());
} catch (ArangoDBException | VPackException e) {
  System.err.println("Failed to get document: myKey; " + e.getMessage());
}

结果应该是：

Key: myKey
Attribute a: Foo
Attribute b: 42

您应该了解的一些细节代码：

  • getDocument() 将存储的文档数据返回到 VelocyPack 格式 (VPackSlice)

更新文档

myObject.addAttribute("c", "Bar");
try {
  arangoDB.db(dbName).collection(collectionName).updateDocument("myKey", myObject);
} catch (ArangoDBException e) {
  System.err.println("Failed to update document. " + e.getMessage());
}

再次阅读文件

我们再次阅读文件：

try {
  BaseDocument myUpdatedDocument = arangoDB.db(dbName).collection(collectionName).getDocument("myKey",
      BaseDocument.class);
  System.out.println("Key: " + myUpdatedDocument.getKey());
  System.out.println("Attribute a: " + myUpdatedDocument.getAttribute("a"));
  System.out.println("Attribute b: " + myUpdatedDocument.getAttribute("b"));
  System.out.println("Attribute c: " + myUpdatedDocument.getAttribute("c"));
} catch (ArangoDBException e) {
  System.err.println("Failed to get document: myKey; " + e.getMessage());
}

结果应该是：

Key: myKey
Attribute a: Foo
Attribute b: 42
Attribute c: Bar

删除文档

让我们来删除一个文档：

try {
  arangoDB.db(dbName).collection(collectionName).deleteDocument("myKey");
} catch (ArangoDBException e) {
  System.err.println("Failed to delete document. " + e.getMessage());
}

执行AQL查询

首先我们需要在集合 firstCollection 中创建一些名称为 Homer 的文档：

ArangoCollection collection = arangoDB.db(dbName).collection(collectionName);
for (int i = 0; i < 10; i++) {
  BaseDocument value = new BaseDocument();
  value.setKey(String.valueOf(i));
  value.addAttribute("name", "Homer");
  collection.insertDocument(value);
}

从集合 firstCollection 中获取所有名称为 Homer 的文档，并且遍历存储结果：

try {
  String query = "FOR t IN firstCollection FILTER t.name == @name RETURN t";
  Map<String, Object> bindVars = new MapBuilder().put("name", "Homer").get();
  ArangoCursor<BaseDocument> cursor = arangoDB.db(dbName).query(query, bindVars, null,
      BaseDocument.class);
  cursor.forEachRemaining(aDocument -> {
    System.out.println("Key: " + aDocument.getKey());
  });
} catch (ArangoDBException e) {
  System.err.println("Failed to execute query. " + e.getMessage());
}

结果应该是：

Key: 1
Key: 0
Key: 5
Key: 3
Key: 4
Key: 9
Key: 2
Key: 7
Key: 8
Key: 6

您应该了解的一些细节代码：

  • AQL 查询语法使用占位符 @name 其必须被绑定到一个值
  • query() 执行定义的查询并返回一个具有给定类的 ArangoCursor (这里： BaseDocument)
  • 顺序不能保证

使用AQL删除文档

现在我们将删除之前创建的文档：

try {
  String query = "FOR t IN firstCollection FILTER t.name == @name "
          + "REMOVE t IN firstCollection LET removed = OLD RETURN removed";
  Map<String, Object> bindVars = new MapBuilder().put("name", "Homer").get();
  ArangoCursor<BaseDocument> cursor = arangoDB.db(dbName).query(query, bindVars, null,
      BaseDocument.class);
  cursor.forEachRemaining(aDocument -> {
    System.out.println("Removed document " + aDocument.getKey());
  });
} catch (ArangoDBException e) {
  System.err.println("Failed to execute query. " + e.getMessage());
}

结果应该是：

Removed document: 1
Removed document: 0
Removed document: 5
Removed document: 3
Removed document: 4
Removed document: 9
Removed document: 2
Removed document: 7
Removed document: 8
Removed document: 6

学习更多

 

ArangoDB 官方原文地址：https://www.arangodb.com/tutorials/tutorial-sync-java-driver/

举报
如果觉得这对你有用，请随意赞赏，给与作者支持
本站文章除注明转载外，均为本站原创或编译。转载请征得作者同意，并务必注明出处。
转载请注明：文章转载自 代码饭社区 [https://www.daimafans.com]
评论 0
最新评论