MongoDB基礎：JAVAでCRUDから入門

#はじめに
MongoDBは、NoSQLの世界ではドキュメント型の代表者であり、CRUDの実装は簡単です。
JAVAでCRUDのAPIを利用して簡単にまとめます。

#ドライバライブラリ導入

build.gradle

// https://mvnrepository.com/artifact/org.mongodb/mongo-java-driver
compileInclude group: 'org.mongodb', name: 'mongo-java-driver', version: '3.11.0'

#Create
##インサートイメージ

##JAVAインサートサンプル

MongoDBTest.java

package mongodb;

import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;

import org.bson.Document;

public class MongoDBTest {

	public static void main(String[] args) {
		// MongoDBクライントを生成する
		MongoClient client = MongoClients.create("mongodb://localhost:27017");
		// DBオブジェクトを取得する
		MongoDatabase db = client.getDatabase("mydb");
		// ユーザーコレクションを取得する
		MongoCollection<Document> users = db.getCollection("users");

		// ユーザーの属性をセット
		Document user = new Document();
		user.append("lastName", "tanaka");
		user.append("firstName", "ichiro");
		user.append("gender", "男性");

		// DBにインサート
		users.insertOne(user);

		// クライントを閉じる
		client.close();
	}
}

##コレクションイメージ

複数インサート

List<Document> userList = new ArrayList<Document>();
		
Document user1 = new Document();
user1.append("lastName", "tanaka");
		
Document user2 = new Document();
user2.append("lastName", "yamada");
		
userList.add(user1);
userList.add(user2);
		
// リストをDBにインサート
users.insertMany(userList);

#Read
##検索イメージ

##Find One
db.collection.find(filter).first()の感じで一件目を取得する。_idで検索したい場合はfirstメソッドが便利です。

MongoDBTest.java

package mongodb;

import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;

import org.bson.Document;
import org.bson.types.ObjectId;

public class MongoDBTest {

	public static void main(String[] args) {
		// MongoDBクライントを生成する
		MongoClient client = MongoClients.create("mongodb://localhost:27017");
		// DBオブジェクトを取得する
		MongoDatabase db = client.getDatabase("mydb");
		// ユーザーコレクションを取得する
		MongoCollection<Document> users = db.getCollection("users");

		// _idで検索する
		Document user = users.find(Filters.eq("_id", new ObjectId("5d858b36c491de05900c4e32"))).first();
		if (user != null) {
			System.out.println("lastName:" + user.getString("lastName"));
		}

		// クライントを閉じる
		client.close();
	}
}

出力：

lastName:tanaka

##Find List
findメソッドのパラメータに検索条件を渡すと絞り込むことは可能です。
Filtersクラスではいろんなメソッドを用意されています。

###検索サンプル

// 姓で複数人を検索する
MongoCursor<Document> cursor = users.find(Filters.or(Filters.in("lastName", "tanaka", "yamada"))).cursor();
while (cursor.hasNext()) {
    Document user = (Document) cursor.next();
    // do something
}

// Cursorではなく、リストに変換しても便利です。
// List<Document> documents = users.find(Filters.or(Filters.in("lastName", "tanaka", "yamada"))).into(new ArrayList<Document>());

###　ソート、skip,limitなど

Document sort = new Document();
sort.append("updateDate", -1);
MongoCursor<Document> cursor = users.find(Filters.in("lastName", "tanaka", "yamada")).sort(sort).skip(20).limit(10).cursor();

#Update

更新イメージ

##Update One

updateOneメソッドで１件のデータを更新

MongoDBTest.java

package mongodb;

import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;

import java.util.Date;

import org.bson.Document;
import org.bson.types.ObjectId;

public class MongoDBTest {

	public static void main(String[] args) {
		// MongoDBクライントを生成する
		MongoClient client = MongoClients.create("mongodb://localhost:27017");
		// DBオブジェクトを取得する
		MongoDatabase db = client.getDatabase("mydb");
		// ユーザーコレクションを取得する
		MongoCollection<Document> users = db.getCollection("users");
		
		// 更新条件
		Document filter = new Document();
		filter.append("_id", new ObjectId("5d858b36c491de05900c4e32"));
		
		// 更新データ
		Document updateSet = new Document();
		updateSet.append("lastName", "鈴木");
		updateSet.append("updateDate", new Date());
		
		// updateオブジェクト
		Document update = new Document();
		update.append("$set", updateSet);
		
		// 更新
		users.updateOne(filter , update);
		
		// クライントを閉じる
		client.close();
	}
}

###更新後のコレクションのデータ

##Update Many
条件と一致するデータを更新したい場合はupdateManyメソッドを使います。

更新のマニュアル：https://docs.mongodb.com/manual/tutorial/update-documents/

##Replace One
ドキュメントを一部データ更新ではなく、完全差し替えの場合は、replaceOneメソッドを使います。

// 更新条件
Document filter = new Document();
filter.append("_id", new ObjectId("5d858b36c491de05900c4e32"));
		
// 更新データ
Document update = new Document();
update.append("lastName", "鈴木");
update.append("updateDate", new Date());
		
// 差し替え
users.replaceOne(filter, update);

一点注意したいのは、DBで検索したドキュメントを差し替えデータとして処理すると、エラーになります。
悪い例：

// DBからデータ取得
Document user = users.find(Filters.eq("_id", new ObjectId("5d858b36c491de05900c4e32"))).first();
user.append("memo", "new user");
		
// 差し替え(違う_idなので、エラーになる。同じ_idなら問題ありません。)
users.replaceOne(Filters.eq("_id", new ObjectId("5d859c77b64c3286a4d29d90")), user);

違う_idの場合は、userの_idフィールドを削除すればエラー解消できます。
Versionデータが有る場合は、replaceOneメソッドを使ってよいかもしれません。

// DBからデータ取得
Document user = users.find(Filters.eq("_id", new ObjectId("5d858b36c491de05900c4e32"))).first();
user.append("memo", "new user");
user.remove("_id");

#Delete

削除イメージ

##deleteOne
users.deleteOne(Filters.eq("_id", new ObjectId("5d859c77b64c3286a4d29d90")));

##deleteMany
users.deleteMany(Filters.eq("lastName", "鈴木"));

##削除関連メソッド

マニュアル：　https://docs.mongodb.com/manual/
CRUD（本文のイメージ）：　https://docs.mongodb.com/manual/crud/

以上