package com.example.demo.dao;

import java.util.ArrayList;
import java.util.List;

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

import com.example.demo.model.Curso2;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.mongodb.BasicDBObject;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;

public class CursoMongoDAO {

    public CursoMongoDAO() {
        MongoClient mongo = new MongoClient();
        MongoDatabase database = mongo.getDatabase("projeto");
        MongoCollection<Document> collection = database.getCollection("cursos");

        // INSERT ONE
        Curso2 curso = new Curso2(null, "anderson", "123");
        ObjectMapper mapper = new ObjectMapper();
        Document document;
        try {
            document = Document.parse(mapper.writeValueAsString(curso));
            collection.insertOne(document);
        } catch (JsonProcessingException e) {
            e.printStackTrace();
        }

        MongoCursor<Document> find = collection.find().iterator();
        List<Curso2> list = new ArrayList<>();

        // GET ALL
        while (find.hasNext()) {
            Document obj = find.next();
            Curso2 aux = new Curso2(
                    ""+obj.get("_id"),
                    ""+ obj.get("nome"),
                    ""+ obj.get("duracao"));
            System.out.println("GET ALL: " + aux);
        }

        // GET ID
        Bson filter1 = Filters.eq("nome", "alex");
        Bson filter2 = Filters.eq("_id", new ObjectId("5cffdfab1eabc52ba8c7cb89"));
        Bson filter3 = Filters.eq("duracao", "1234");
        Bson filterResult = Filters.and(filter1, filter2);
        Bson filterResult2 = Filters.and(filterResult, filter3);

        find = collection.find(filterResult2).iterator();
        list = new ArrayList<>();
        while (find.hasNext()) {
            Document obj = find.next();
            Curso2 aux = new Curso2(
                    ""+obj.get("_id"),
                    ""+ obj.get("nome"),
                    ""+ obj.get("duracao"));
            System.out.println("GET ID: " + aux);
        }

        // UPDATE
        BasicDBObject update = new BasicDBObject("$set",
                new BasicDBObject("nome", "alex").append("duracao", "1234"));
        collection.updateOne(filterResult2, update);

        // DELETE
        collection.deleteOne(filterResult2);
    }
}