java 中 mongodb 使用指南-亚博电竞手机版

mongodb是当今非常流行的一款nosql数据库,本文介绍如何使用mongodb的java驱动来操作mongodb。

一、引入mongodb java driver包

如果需要操作mongodb的java项目是一个maven项目,可以在依赖中加上以下的配置。

              org.mongodb         mongo-java-driver         2.13.2      

或者通过直接下载jar包的方式使用,下载地址:mongo-java-driver-2.13.2.jar。

详细的如何引入mongodb jar包的方法可以参考官方文档。

二、连接mongodb

可以使用mongoclient来连接mongodb,mongoclient的使用方式如下:

mongoclient mongoclient = new mongoclient("localhost", 27017); db db = mongoclient.getdb("mydb");

上面的代码连接了localhost:27017上mongodb服务,并指定使用mydb数据库。连接后便可以对这个数据库作进一步的操作。

需要指出的是,mongoclient是线程安全的,可以在多程程环境中共享同一个mongoclient。通常来说,一个应用程序中,只需要生成一个全局的mongoclient实例,然后在程序的其他地方使用这个实例即可。

三、认证

可以使用多种方式对连接进行认证,下面介绍两种方式。

1. 方式一:mongocredential

mongocredential类的createcredential方法可以指定认证的用户名,密码,以及使用的数据库,并返回一个mongocredential对象。其方法的声明如下:

static mongocredential createcredential(string username, string database, char[] password)

例如

mongocredential credential = mongocredential.createcredential("user", "mydb", "password".tochararray();

上面创建了一个用户名为user,密码为password,数据库为mydb的mongocredential对象。

将生成mongocredential的对象作为mongoclient构造函数的参数。由于mongoclient构造函数的为list类型,所以需要先构造成一个list再传递。完整的认证的例子如下:

mongocredential credential = mongocredential.createcredential("user", "mydb", "password".tochararray());  serveraddress serveraddress = new serveraddress("localhost", 27017);  mongoclient mongoclient = new mongoclient(serveraddress, arrays.aslist(credential));  db db = mongoclient.getdb("mydb");

2. 方式二:mongoclienturi

亦可以使用mongoclienturi完成mongodb的认证,它代表了一个uri对象。mongoclienturi的构造函数接受一个string类型的字符串,这个字符串的格式如下:

mongodb://[username:password@]host1[:port1][,host2[:port2],…[,hostn[:portn]]][/[database][?options]]

生成的mongoclienturi对象作为mongoclient构造函数的参数,完整的认证例子如下:

string suri = string.format("mongodb://%s:%s@%s:%d/%s", "user", "password", "localhost", 27017, "mydb");  mongoclienturi uri = new mongoclienturi(suri);  mongoclient mongoclient = new mongoclient(uri);  db db = mongoclient.getdb("mydb");

四、获取一个集合

dbcollection coll = db.getcollection("mycol");

然后可以对指定的集合进行操作,例如,插入,删除,查找,更新文档等。

五、插入文档

例如,一个文档以json来表示如下,

{ “name”: “mongo”, “info”: { “ver”: “3.0” } }

现在需要插入到集合mycol中。为了插入到集合中,可以使用basicdbobject构造一个文档。

basicdbobject doc = new basicdbobject("name", "mongo").append("info", new basicdbobject("ver", "3.0")); coll.insert(doc);

六、查找文档

1. 通过findone查找一个符合条件文档

通过findone可以查找一个符合条件的文档。例如,对于上面的mycol集合,执行以下命令:

dbobject mydoc = coll.findone(); system.out.println(mydoc);

将输出mycol集合中的第一个文档。也可以通过指定findone的查找参数,来查找符合查找条件的一个文档。

2. 通过find查找所有符合条件的文档

find用来查找符合条件的文档,它返回一个dbcursor对象,通过遍历dbcursor对象,可以获得所有符合查找条件的文档。

为了说明和测试,我们先插入一批以下格式的文档

{ “i”: value }
for (int i=0; i < 100; i  ) {     coll.insert(new basicdbobject("i", i)); }

find的使用示例如下:

dbcursor cursor = coll.find(); try {    while(cursor.hasnext()) {        system.out.println(cursor.next());    } } finally {    cursor.close(); }

会输出mycol集合中所有的文档。

也可以指定查找的条件,例如:

basicdbobject query = new basicdbobject("i", 71);  dbcursor cursor = coll.find(query);  try {    while(cursor.hasnext()) {        system.out.println(cursor.next());    } } finally {    cursor.close(); }

对于查找条件中包括$操作符的情形,例如以下一条mongo shell命令:

db.coll.find({i: {$gte: 50}});

可以使用dbobject生成查找条件,

// find all where i >= 50 basicdbobject query = new basicdbobject("i", new basicdbobject("$gte", 50));  dbcursor cursor = coll.find(query); try {     while (cursor.hasnext()) {         system.out.println(cursor.next());     } } finally {     cursor.close(); }

七、更新文档

basicdbobject query = new basicdbobject("i", 70); basicdbobject up = new basicdbobject("$set", new basicdbobject("i", 100)); coll.update(query, up);

上面的语句将i为70的文档更新i的值等于100。

与我们常用的更新文档的mongo语句一样,dbcollection还包含了savefindandmodify等更新文档的方法,其使用方法在此不再赘述,可以参考api说明文档即可。

八、删除文档

可以通过生成一个dbobject对象来删除指定的文档,例如:

basicdbobject query = new basicdbobject("i", 71); coll.remove(query);

上面的语句删除i为71的文档。

展开全文
内容来源于互联网和用户投稿,文章中一旦含有亚博电竞手机版的联系方式务必识别真假,本站仅做信息展示不承担任何相关责任,如有侵权或涉及法律问题请联系亚博电竞手机版删除

最新文章

网站地图