package jp.ac.u_ryukyu.ie.cr.tatsuki.mongo;

import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import org.bson.Document;


class ReadMongoThread extends Thread {

    MongoCollection<Document> mongoDB;
    int findCount;
    int successCount;
    int faildCount;
    boolean loop = true;

    public ReadMongoThread(MongoCollection<Document> mongoDB) {
        this.mongoDB = mongoDB;
        this.findCount = 0;
        this.successCount = 0;
        this.faildCount = 0;
    }

    public int getFindCount() {
        System.out.println("thread count = " + findCount);
        return findCount;
    }

    public void set(boolean loop) {
        this.loop = loop;
    }

    @Override
    public void run() {
        Document query = new Document("Personid", "p:3");
        while (loop) {
            MongoCursor<Document> result = mongoDB.find(query).iterator();
            if (result.hasNext())
                findCount++;
            }
    }
}