-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathconnectToMongoDB.java
More file actions
65 lines (57 loc) · 2.34 KB
/
connectToMongoDB.java
File metadata and controls
65 lines (57 loc) · 2.34 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
package connectMongoDB;
import com.mongodb.BasicDBObject;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.connection.*;
import org.bson.Document;
import java.util.ArrayList;
import java.util.List;
public class connectToMongoDB {
public static MongoDatabase mongoDatabase = null;
public static MongoDatabase connectToMongoDB() {
MongoClient mongoClient = new MongoClient();
mongoDatabase = mongoClient.getDatabase("STUDENTS");
System.out.println("Database Connected");
return mongoDatabase;
}
public static String insertToMongoDB(User user) {
String profile = user.getStName();
MongoDatabase mongoDatabase1 = connectToMongoDB();
MongoCollection<Document> collection = mongoDatabase1.getCollection("profile");
Document document = new Document().append("stName", user.getStName()).append("stID", user.getStID()).
append("stDOB", user.getStDOB());
collection.insertOne(document);
return profile + " has been registered";
}
public static List<User> readFromMongoDB() {
List<User> list = new ArrayList<User>();
User user = new User();
MongoDatabase mongoDatabase = connectToMongoDB();
MongoCollection<Document> collection = mongoDatabase.getCollection("profile");
BasicDBObject basicDBObject = new BasicDBObject();
FindIterable<Document> iterable = collection.find(basicDBObject);
for (Document doc : iterable) {
String id = "";
int idInt = 0;
String stName = (String) doc.get("stName");
user.setStName(stName);
String stID = (String) doc.get("stID");
user.setStID(stID);
String stDOB = (String) doc.get("stDOB");
user.setStID(stDOB);
user = new User(stName, stID, stDOB);
list.add(user);
}
return list;
}
public static void main(String[] args) {
insertToMongoDB(new User("Fahim Ahmed2", "3713", "02-1988"));
List<User> user = readFromMongoDB();
for (User person : user) {
System.out.println(person.getStName() + " " + person.getStID()+" "+person.getStDOB());
}
}
}