Prac 5

 5Apackage com.example.MongoDB;

import com.mongodb.client.MongoClient;

import com.mongodb.client.MongoClients;

import com.mongodb.client.MongoDatabase;

public class MongoConnection {

public static MongoDatabase connect() {

String uri="mongodb://localhost:27017";

MongoClient mongoClient=MongoClients.create(uri);

return mongoClient.getDatabase("dbs1");

}

}

5B)

package com.example.MongoDB;

import org.bson.Document;

import com.mongodb.client.MongoCollection;

import com.mongodb.client.MongoDatabase;

public class Mongo_Insert {

public static void main(String[] args) {

MongoDatabase database MongoConnection.connect();

MongoCollection<Document> collection=database.getCollection("Employee");

Document doc=new Document("Name", "Jyoti")

.append("Age", 27).append("EmailId", "jyoti07@gmail.com");

collection.insertone(doc);

System.out.println("Document inserted successfully!");

}

5C)

package com.example.MongoDB;

import com.mongodb.client.FindIterable;

import com.mongodb.client.MongoCollection;

import com.mongodb.client.MongoDatabase;

import org.bson.Document;

public class Mongo_Read {

public static void main(String[] args) {

MongoDatabase database-MongoConnection.connect();

MongoCollection<Document> collection=database.getCollection("Employee");

FindIterable<Document> document collection.find();

for (Document doc:document){

System.out.println(doc.toJson());

}

}

}

5D)

package com.example.MongoDB;

import com.mongodb.client.MongoCollection;

import com.mongodb.client.MongoDatabase;

import org.bson.Document;

import static com.mongodb.client.model.Filters.eq;

import static com.mongodb.client.model.Updates.set;

public class Mongo_Update {

public static void main(String[] args) {

MongoDatabase database MongoConnection.connect();

MongoCollection<Document> collection=database.getCollection("Employee");

collection.updateOne (eq("Name", "Kavya"), set("Age", 23));

System.out.println("Employee Document Updated!");

}

}

5E)

package com.example.MongoDB;

import com.mongodb.client.MongoDatabase;

import com.mongodb.client.MongoCollection;

import org.bson.Document;

import static com.mongodb.client.model.Filters.eq;

public class Mongo_Delete {

public static void main(String[] args) {

MongoDatabase database=MongoConnection.connect();

MongoCollection<Document> collection=database.getCollection("Employee");

collection.deleteOne(eq("Name", "Sunita"));

System.out.println("Successfully Deleted!');

}

}