Java での MongoDB 使用ガイドのコード共有

黄舟
リリース: 2017-04-01 10:39:15
オリジナル
1554 人が閲覧しました

MongoDB は現在非常に人気のある NoSQL データベースです。この記事では、MongoDB の Java ドライバー を使用して MongoDB を操作する方法を紹介します。

1. MongoDB Java Driver パッケージを導入します

MongoDB を操作する必要がある Java プロジェクトが Maven プロジェクトの場合は、次の構成を依存関係に追加できます。

<dependencies>
    <dependency>
        <groupId>org.mongodb</groupId>
        <artifactId>mongo-java-driver</artifactId>
        <version>2.13.2</version>
    </dependency>
</dependencies>
ログイン後にコピー

または、jar パッケージを直接ダウンロードして使用します (ダウンロード アドレス: mongo-java-driver-2.13.2.jar)。

MongoDB jar パッケージの導入方法の詳細については、公式ドキュメントを参照してください。

2. MongoDB に接続します

MongoClient を使用して MongoDB に接続できます。MongoClient の使用法は次のとおりです: 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构造函数的为<a href="http://www.php.cn/wiki/1059.html" target="_blank">List</a><MongoCredential>类型,所以需要先构造成一个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中。为了插入到集合中,可以使用BasicDB<a href="http://www.php.cn/wiki/60.html" target="_blank">Object</a>构造一个文档。

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();
}
ログイン後にコピー

上記のコードは MongoDB に接続します。 localhost:27017 のサービスを実行し、mydb データベースを使用するように指定します。接続後、このデータベースに対してさらに操作を実行できます。

MongoClient はスレッド安全

であることを指摘しておく必要があります。同じ MongoClient を複数のプロセスで共有します。一般に、アプリケーションでは、グローバル MongoClient インスタンスを生成するだけで済み、その後、このインスタンスをプログラム内の他の場所で使用できます。

🎜3. 認証🎜🎜 接続の認証には複数の方法を使用できます。以下に 2 つの方法を紹介します。 🎜

1. メソッド 1: MongoCredential

🎜 MongoCredential クラスの createCredential メソッドでは、使用する認証ユーザー名、パスワード、データベースを指定できます。 MongoCredential
オブジェクト 🎜 を返します。そのメソッドの宣言は次のとおりです。 🎜
BasicDBObject query = new BasicDBObject("i", 70);
BasicDBObject up = new BasicDBObject("$set", new BasicDBObject("i", 100));
coll.update(query, up);
ログイン後にコピー
🎜たとえば、🎜
BasicDBObject query = new BasicDBObject("i", 71);
coll.remove(query);
ログイン後にコピー
ログイン後にコピー
🎜 上記は、ユーザー名 user、パスワード passwd、データベース mydb を使用して MongoCredential オブジェクトを作成します。 🎜🎜 MongoCredentialMongoClient
関数🎜のパラメータ。 MongoClientコンストラクター 🎜 は <a href="http であるため、次のようになります。 //www.php.cn/wiki/1059.html" target="_blank">List🎜<MongoCredential> タイプなので、渡す前に List に構築する必要があります。完全な認証例は次のとおりです: 🎜rrreee

2. 方法 2: MongoClientURI

🎜 URI オブジェクトを表す MongoClientURI を使用して MongoDB 認証を完了することもできます。 MongoClientURI のコンストラクターは、文字列型
文字列 🎜 を受け入れます。この文字列の形式は次のとおりです。次のように: 🎜rrreee🎜 生成された MongoClientURI オブジェクトは、MongoClient コンストラクターのパラメーターとして使用されます。 完全な認証の例は次のとおりです: 🎜rrreee🎜4. 🎜rrreee🎜その後、指定したコレクションに対して操作を実行できます。たとえば、挿入、delete 、検索、🎜ドキュメントの更新など。 🎜🎜5. ドキュメントの挿入 🎜🎜たとえば、ドキュメントは次のように Json🎜 で表されます。 🎜ここで、mycol コレクションに挿入する必要があります。コレクションに挿入するには、BasicDB<a href="http://www.php.cn/wiki/60.html" target="_blank">Object🎜 を使用してドキュメントを構築します。 。 🎜rrreee🎜 6. ドキュメントを検索します🎜

1. findOne を通じて適格なドキュメントを検索します

🎜 findOne を通じて適格なドキュメントを見つけることができます。たとえば、上記の mycol コレクションの場合、次のコマンドを実行すると: 🎜rrreee🎜 は、mycol コレクションの最初のドキュメントを出力します。 findOne の検索パラメータを指定して、検索条件を満たすドキュメントを検索することもできます。 🎜

2. find

で条件を満たすすべてのドキュメントを検索します。🎜find は、条件を満たすドキュメントを検索するために使用されます。DBCursor オブジェクトを返します。を走査する DBCursor オブジェクトは、検索条件を満たすすべてのドキュメントを取得できます。
説明とテストのために、まず次の形式でドキュメントのバッチを挿入します🎜rrreeerrreee🎜find
使用例 🎜 は以下のとおりです。 🎜rrreee🎜 は、mycol コレクション内のすべてのドキュメントを出力します。 🎜🎜例: 🎜rrreee🎜 $演算子を含む検索条件の場合🎜 たとえば、次の mongo シェル コマンド: 🎜rrreee🎜 DBObject を使用して検索条件を生成できます 🎜rrreee🎜7。ドキュメントを更新します 🎜rrreee🎜 上記のステートメントは、i の値を更新します。 i が 70 であるドキュメントは 100 と等しくなります。 🎜

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

八、删除文档

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

BasicDBObject query = new BasicDBObject("i", 71);
coll.remove(query);
ログイン後にコピー
ログイン後にコピー

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

以上がJava での MongoDB 使用ガイドのコード共有の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

関連ラベル:
ソース:php.cn
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
最新の問題
人気のチュートリアル
詳細>
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート
私たちについて 免責事項 Sitemap
PHP中国語ウェブサイト:福祉オンライン PHP トレーニング,PHP 学習者の迅速な成長を支援します!