资讯专栏INFORMATION COLUMN

上云采购季！| 2核2G4M爆款云服务器低至59元/年，更有多台、长期优惠，快来选购！

立即前往
首页/文章专栏/怎么灵活使用Graph, Document, Key/Value 三种混合模型的数据库？--Java

怎么灵活使用Graph, Document, Key/Value 三种混合模型的数据库？--Java

svtter / 1486人阅读

摘要：请注意本教程是针对版本编写的，有可能不支持旧版本。在本教程的过程中，将使用代码中给出的每个。任何对象都可以作为文档添加到数据库中，并作为对象从数据库中检索。这个例子中，我们使用驱动程序提供的类。

这是一个关于如何用Java Sync Driver 4.1使用ArangoDB的简短教程。在不到10分钟的时间内，您将学会如何用Java 操作ArangoDB (ArangoDB on Github)。有关驱动程序的功能和性能的更多细节，请查看相应的博客文章。
*请注意: 本教程是针对 ArangoDB 3.1版本编写的，有可能不支持旧版本。
如果您使用的是旧版本的ArangoDB，请查看为旧版本设计的Java教程。*

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

</>复制代码 
  1. 1
  2. 2
  3. 3  
  4. 4    com.arangodb
  5. 5    arangodb-java-driver
  6. 6    4.1.0
  7. 7  
  8. 8    ....

使用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.0.0)

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

快速开始

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

</>复制代码 
  1.    1 
  2.    2 package mydb.firstproject;
  3.    3  
  4.    4 import java.util.Map;
  5.    5  
  6.    6 import com.arangodb.ArangoCollection;
  7.    7 import com.arangodb.ArangoCursor;
  8.    8 import com.arangodb.ArangoDB;
  9.    9 import com.arangodb.ArangoDBException;
  10.   10 import com.arangodb.entity.BaseDocument;
  11.   11 import com.arangodb.entity.CollectionEntity;
  12.   12 import com.arangodb.util.MapBuilder;
  13.   13 import com.arangodb.velocypack.VPackSlice;
  14.   14 import com.arangodb.velocypack.exception.VPackException;
  15.   15   
  16.   16 public class FirstProject {
  17.   17   public static void main(final String[] args) {
  18.   18   
  19.   19   }
  20.     }
  21.     
  22.

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

连接

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

</>复制代码 
  1. 1  ArangoDB arangoDB = new ArangoDB.Builder().build();

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

创建数据库

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

</>复制代码 
  1. 1
  2. 2   String dbName = "mydb";
  3. 3    try {
  4. 4     arangoDB.createDatabase(dbName);
  5. 5     System.out.println("Database created: " + dbName);
  6. 6  
  7.   } catch (ArangoDBException e) {
  8. 7      System.err.println("Failed to create database: " + dbName + "; " + e.getMessage());
  9.     }

结果是应该是：

</>复制代码 
  1. Database created: mydb
创建一个集合

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

</>复制代码 
  1. 1
  2. 2 String collectionName = "firstCollection";
  3. 3 try {
  4. 4  CollectionEntity myArangoCollection = arangoDB.db(dbName).createCollection(collectionName);
  5. 5  System.out.println("Collection created: " + myArangoCollection.getName());
  6. 6 } catch (ArangoDBException e) {
  7. 7  System.err.println("Failed to create collection: " + collectionName + "; " + e.getMessage());
  8.   }
  9.

结果是应该是：

</>复制代码 
  1. 1 Collection created: firstCollection

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

createCollection()创建集合

firstCollection 是集合的名字

创建文档

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

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

</>复制代码 
  1. 1
  2. 2 BaseDocument myObject = new BaseDocument();
  3. 3 myObject.setKey("myKey");
  4. 4 myObject.addAttribute("a", "Foo");
  5. 5 myObject.addAttribute("b", 42);
  6. 6 try {
  7. 7   arangoDB.db(dbName).collection(collectionName).insertDocument(myObject);
  8. 8   System.out.println("Document created");
  9. 9 } catch (ArangoDBException e) {
  10. 10  System.err.println("Failed to create document. " + e.getMessage());

结果应该是：

</>复制代码 
  1. 1 Document created

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

setKey() 设置新对象的键值

addAttribute() 将一个新的键/值对放在对象中

每个属性作为单个键／值对存储在文档根目录中

阅读文档

阅读创建的文档：

</>复制代码 
  1.   1
  2.   2 try {
  3.   3  BaseDocument myDocument = arangoDB.db(dbName).collection(collectionName).getDocument("myKey",
  4.   4      BaseDocument.class);
  5.   5  System.out.println("Key: " + myDocument.getKey());
  6.   6  System.out.println("Attribute a: " + myDocument.getAttribute("a"));
  7.   7  System.out.println("Attribute b: " + myDocument.getAttribute("b"));
  8.   8 } catch (ArangoDBException e) {
  9.   9   System.err.println("Failed to get document: myKey; " + e.getMessage());
  10.    }

结果应该是：

</>复制代码 
  1. 1
  2. 2 Key: myKey
  3. 3 Attribute a: Foo
  4.   Attribute b: 42

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

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

阅读VelocyPack 格式文档

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

</>复制代码 
  1. 1
  2. 2 try {
  3. 3   VPackSlice myDocument = arangoDB.db(dbName).collection(collectionName).getDocument("myKey",
  4. 4    VPackSlice.class);
  5. 5  System.out.println("Key: " + myDocument.get("_key").getAsString());
  6. 6  System.out.println("Attribute a: " + myDocument.get("a").getAsString());
  7. 7  System.out.println("Attribute b: " + myDocument.get("b").getAsInt());
  8. 8 } catch (ArangoDBException | VPackException e) {
  9. 9   System.err.println("Failed to get document: myKey; " + e.getMessage());
  10. }

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

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

更新文档 
</>复制代码 
  1. 1
  2. 2 myObject.addAttribute("c", "Bar");
  3. 3 try {
  4. 4  arangoDB.db(dbName).collection(collectionName).updateDocument("myKey", myObject);
  5. 5 } catch (ArangoDBException e) {
  6. 6  System.err.println("Failed to update document. " + e.getMessage());
  7. }

再次阅读文件

我们再次阅读文件：

</>复制代码 
  1. 1
  2. 2 try {
  3. 3   BaseDocument myUpdatedDocument = arangoDB.db(dbName).collection(collectionName).getDocument("myKey",
  4. 4      BaseDocument.class);
  5. 5   System.out.println("Key: " + myUpdatedDocument.getKey());
  6. 6   System.out.println("Attribute a: " + myUpdatedDocument.getAttribute("a"));
  7. 7   System.out.println("Attribute b: " + myUpdatedDocument.getAttribute("b"));
  8. 8   System.out.println("Attribute c: " + myUpdatedDocument.getAttribute("c"));
  9. 9 } catch (ArangoDBException e) {
  10. 10  System.err.println("Failed to get document: myKey; " + e.getMessage());
  11.   }

结果应该是：

</>复制代码 
  1. 1
  2. 2 Key: myKey
  3. 3 Attribute a: Foo
  4. 4 Attribute b: 42
  5.  Attribute c: Bar
删除文档

让我们来删除一个文档：

</>复制代码 
  1. 1 
  2. 2 try {
  3. 3   arangoDB.db(dbName).collection(collectionName).deleteDocument("myKey");
  4. 4 } catch (ArangoDBException e) {
  5. 5   System.err.println("Failed to delete document. " + e.getMessage());
  6. }

执行AQL查询

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

</>复制代码 
  1. 1
  2. 2 ArangoCollection collection = arangoDB.db(dbName).collection(collectionName);
  3. 3 for (int i = 0; i < 10; i++) {
  4. 4   BaseDocument value = new BaseDocument();
  5. 5  value.setKey(String.valueOf(i));
  6. 6  value.addAttribute("name", "Homer");
  7. 7  collection.insertDocument(value);
  8.  }

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

</>复制代码 
  1.  
  2. try {
  3.   String query = "FOR t IN firstCollection FILTER t.name == @name RETURN t";
  4.   Map bindVars = new MapBuilder().put("name", "Homer").get();
  5.   ArangoCursor cursor = arangoDB.db(dbName).query(query, bindVars, null,
  6.       BaseDocument.class);
  7.   cursor.forEachRemaining(aDocument -> {
  8.     System.out.println("Key: " + aDocument.getKey());
  9.   });
  10. } catch (ArangoDBException e) {
  11.   System.err.println("Failed to execute query. " + e.getMessage());
  12. }

结果应该是：

</>复制代码 
  1. Key: 1
  2. Key: 0
  3. Key: 5
  4. Key: 3
  5. Key: 4
  6. Key: 9
  7. Key: 2
  8. Key: 7
  9. Key: 8
  10. Key: 6

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

AQL 查询语法使用占位符@name 其必须被绑定到一个值

query() 执行定义的查询并返回一个具有给定类的ArangoCursor (这里: BaseDocument)

顺序不能保证

使用AQL删除文档

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

</>复制代码 
  1. try {
  2.   String query = "FOR t IN firstCollection FILTER t.name == @name "
  3.           + "REMOVE t IN firstCollection LET removed = OLD RETURN removed";
  4.   Map bindVars = new MapBuilder().put("name", "Homer").get();
  5.   ArangoCursor cursor = arangoDB.db(dbName).query(query, bindVars, null,
  6.       BaseDocument.class);
  7.   cursor.forEachRemaining(aDocument -> {
  8.     System.out.println("Removed document " + aDocument.getKey());
  9.   });
  10. } catch (ArangoDBException e) {
  11.   System.err.println("Failed to execute query. " + e.getMessage());
  12. }

结果应该是：

</>复制代码 
  1. Removed document: 1
  2. Removed document: 0
  3. Removed document: 5
  4. Removed document: 3
  5. Removed document: 4
  6. Removed document: 9
  7. Removed document: 2
  8. Removed document: 7
  9. Removed document: 8
  10. Removed document: 6
学习更多

查看AQL 文档，进一步学习我们的查询语言。

想更多地了解我们的数据库吗点击这里!

阅读关于Collections的更多信息。

在我们的文档中浏览更多关于Documents的信息。

相关更多示例，您可以浏览ArangoDB 菜谱。

云内存存储UMem Redis 云数据库MySQL key value 分布式存储方案 持久化 最灵活的编程语言 公有云,私有云,混合云三种部署方式随心选 java三种排序算法

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/83872.html

相关文章

发表评论

登陆后可评论

0条评论

svtter

男|高级讲师
我要私信

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
UCloud （优刻得科技股份有限公司）

UCloud （优刻得科技股份有限公司）是中立、安全的云计算服务平台，坚持中立，不涉足客户业务领域。公司自主研发IaaS、PaaS、大数据流通平台、AI服务平台等一系列云计算产品，并深入了解互联网、传统企业在不同场景下的业务需求，提供公有云、混合云、私有云、专有云在内的综合性行业解决方案。

Copyright © 2012-2023 UCloud 优刻得科技股份有限公司｜沪公网安备 31011002000058号｜ 沪ICP备12020087号-3｜
<