MongoDB学習日記 - 2019/12/12

#目的

1. MongoDBに接続する
2. CRUD実現

#MongoDBに接続する
１、 GradleでDriverをImportする

build.gradle

dependencies {
    // Mongo db
    compile 'org.mongodb:mongo-java-driver:3.12.0'
}

２、MongoDBに接続して、データ抽出してみる

        // MongoDBサーバに接続
        MongoClient mongoClient = MongoClients.create("mongodb://<user>:<password>@ds253428.mlab.com:53428/heroku_c3swt6jb");
        MongoDatabase database = mongoClient.getDatabase("heroku_c3swt6jb");
        MongoCollection<Document> collection = database.getCollection("parking_lot");
        Document myDoc = collection.find().first();
        System.out.println(myDoc.toJson());
        System.out.println(myDoc.get("id"));

        // サーバから切断
        mongoClient.close();

３、CRUD実現

        // MongoDBサーバに接続
        MongoClient mongoClient = MongoClients.create(
                "mongodb://<user>:<password>@ds253428.mlab.com:53428/heroku_c3swt6jb?retryWrites=false");
        MongoDatabase database = mongoClient.getDatabase("heroku_c3swt6jb");
        MongoCollection<Document> collection = database.getCollection("parking_lot");

        // create
        Document doc = new Document("id", "testid").append("name", "C1-11.haha").append("ParkingEntID","a").append("ParkingLat","b").append("ParkingLon","c");
        collection.insertOne(doc);

        // read
        Document myDoc = collection.find(eq("id","testid")).first();
        System.out.println("this is old one: " + myDoc.toJson());

        // update
        Document docNew = new Document("id", "testid").append("name", "C1-11.haha.New").append("ParkingEntID","a").append("ParkingLat","b").append("ParkingLon","c");;
        collection.updateOne(eq("id","testid"), new Document("$set", docNew));

        // read to check if data updated correctly
        myDoc = collection.find(eq("id","testid")).first();
        System.out.println("this is new one: " + myDoc.toJson());

        // delete
        collection.deleteMany(eq("id","testid"));

        // サーバから切断
        mongoClient.close();

#ハマったところ
１、接続時エラー
driver version: 3.12.0
mongoDB version: 3.6.9
mongoDBのバージョンが古くて、retryWritesという新しい機能をサポートしないためです。
対策は、mongoDBのURIに、query parameterのretryWrites=falseを追加。

com.mongodb.MongoClientException: This MongoDB deployment does not support retryable writes. Please add retryWrites=false to your connection string.

２、Update時エラー

java.lang.IllegalArgumentException: Invalid BSON field name id

原因はこんなCommandだった：

collection.updateOne(eq("id","testid"), docNew);

正しいのは

collection.updateOne(eq("id","testid"), new Document("$set", docNew));

#References

Description	URL
HP of MongoDB driver	URL