Skip to content

Commit 9a68cee

Browse files
hungcdevhungcdev
committed
query document
1 parent ba7a3c7 commit 9a68cee

File tree

5 files changed

+282
-4
lines changed

5 files changed

+282
-4
lines changed

‎mongodb-java/src/main/java/com/hungcdev/mongodb/connection/MongoDBConnection.java

-1
Original file line numberDiff line numberDiff line change
@@ -45,5 +45,4 @@ private static void connectionExample() {
4545
MongoDatabase mongoDatabase = mongoClient.getDatabase("HungcDev");
4646
mongoDatabase.createCollection("User");
4747
}
48-
4948
}

‎mongodb-java/src/main/java/com/hungcdev/mongodb/data/Post.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -4,16 +4,19 @@
44

55
import java.util.List;
66

7-
@Data
87
@Builder
98
@Getter
109
@Setter
10+
@NoArgsConstructor
11+
@AllArgsConstructor
12+
@ToString
1113
public class Post {
1214
private String id;
1315
private String title;
1416
private String user;
1517
private String content;
1618
private List<String> tags;
19+
private int view;
1720
private boolean enable;
1821

1922
}

‎mongodb-java/src/main/java/com/hungcdev/mongodb/insertion/InsertDocument.java

+7-2
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,16 @@ public InsertDocument(String ip, int port, String databaseName) {
1818
this.mongoDatabase = mongoClient.getDatabase(databaseName);
1919
}
2020

21-
public <T> void insert(String collectionName, T document , Class<T> classType) {
21+
public <T> void insert(String collectionName, Class<T> classType, T document){
2222
MongoCollection<T> collection = mongoDatabase.getCollection(collectionName, classType);
2323
collection.insertOne(document);
2424
}
2525

26+
public <T> void insertMany(String collectionName, Class<T> classType, T... documents) {
27+
MongoCollection<T> collection = mongoDatabase.getCollection(collectionName, classType);
28+
collection.insertMany(List.of(documents));
29+
}
30+
2631
public static void main(String[] args) {
2732
insertDocumentExample();
2833
}
@@ -37,7 +42,7 @@ private static void insertDocumentExample() {
3742
.tags(List.of("Mongodb", "Mongodb Java"))
3843
.enable(true)
3944
.build();
40-
insertDocument.insert("Post", post, Post.class);
45+
insertDocument.insert("Post", Post.class, post);
4146
System.out.println("Insert Post Successful!");
4247
}
4348

‎mongodb-java/src/main/java/com/hungcdev/mongodb/query/QueryDocument.java

+65
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,65 @@
1+
package com.hungcdev.mongodb.query;
2+
3+
import com.hungcdev.mongodb.connection.MongoDBConnection;
4+
import com.hungcdev.mongodb.data.Post;
5+
import com.hungcdev.mongodb.insertion.InsertDocument;
6+
import com.mongodb.client.*;
7+
import com.mongodb.client.model.Filters;
8+
import org.bson.conversions.Bson;
9+
10+
import java.util.ArrayList;
11+
import java.util.List;
12+
import java.util.UUID;
13+
14+
public class QueryDocument {
15+
16+
private MongoDatabase mongoDatabase;
17+
18+
public QueryDocument(String ip, int port, String databaseName) {
19+
MongoClient mongoClient = MongoDBConnection.connectMongoDBWithPOJOs(ip, port);
20+
this.mongoDatabase = mongoClient.getDatabase(databaseName);
21+
}
22+
23+
/**
24+
* The method to find all document in Collection
25+
* @param collectionName
26+
* @param classType
27+
* @param <T>
28+
* @return
29+
*/
30+
public <T> List<T> findAll(String collectionName, Class<T> classType) {
31+
MongoCollection<T> collection = mongoDatabase.getCollection(collectionName, classType);
32+
FindIterable<T> findResult = collection.find();
33+
return convert(findResult);
34+
}
35+
36+
/**
37+
* The method to find document in Collection with condition
38+
* @param collectionName
39+
* @param classType
40+
* @param query
41+
* @param <T>
42+
* @return
43+
*/
44+
public <T> List<T> find(String collectionName, Class<T> classType, Bson query) {
45+
MongoCollection<T> collection = mongoDatabase.getCollection(collectionName, classType);
46+
FindIterable<T> findResult = collection.find(query);
47+
return convert(findResult);
48+
}
49+
50+
/**
51+
* The method to convert from FindIterable to List
52+
* @param findIterable
53+
* @param <T>
54+
* @return
55+
*/
56+
private <T> List<T> convert(FindIterable<T> findIterable) {
57+
List<T> documents = new ArrayList<>();
58+
MongoCursor<T> cursor = findIterable.cursor();
59+
while (cursor.hasNext())
60+
documents.add(cursor.next());
61+
62+
return documents;
63+
}
64+
65+
}

‎mongodb-java/src/main/java/com/hungcdev/mongodb/query/QueryDocumentExample.java

+206
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,206 @@
1+
package com.hungcdev.mongodb.query;
2+
3+
import com.hungcdev.mongodb.data.Post;
4+
import com.hungcdev.mongodb.insertion.InsertDocument;
5+
import com.mongodb.client.model.Filters;
6+
import org.bson.conversions.Bson;
7+
8+
import java.util.List;
9+
import java.util.UUID;
10+
11+
public class QueryDocumentExample {
12+
13+
public static void main(String[] args) {
14+
// Thong tin cau hinh de ket noi MongoDB
15+
String IP = "localhost";
16+
int port = 27017;
17+
String databaseName = "HungcDev";
18+
String collection = "Post";
19+
20+
/* Khoi tao du lieu */
21+
initDataExample(IP, port, databaseName, collection);
22+
23+
/* Tim kiem tat ca document Post trong Collection */
24+
findAllExample(IP, port, databaseName, collection);
25+
26+
/* Tim kiem document Post trong Collection voi dieu kien so sanh Equals */
27+
findEqualsExample(IP, port, databaseName, collection);
28+
29+
/* Tim kiem document Post trong Collection voi dieu kien so sanh Not Equals */
30+
findNotEqualsExample(IP, port, databaseName, collection);
31+
32+
/* Tim kiem document Post trong Collection voi dieu kien so sanh In */
33+
findInExample(IP, port, databaseName, collection);
34+
35+
/* Tim kiem document Post trong Collection voi dieu kien so sanh Not In */
36+
findNotInExample(IP, port, databaseName, collection);
37+
38+
/* Tim kiem document Post trong Collection voi dieu kien so sanh Greater Than */
39+
findGreaterThanExample(IP, port, databaseName, collection);
40+
41+
/* Tim kiem document Post trong Collection voi dieu kien so sanh Greater Than Or Equals */
42+
findGreaterThanOrEqualsExample(IP, port, databaseName, collection);
43+
44+
/* Tim kiem document Post trong Collection voi dieu kien so sanh Less than */
45+
findLessThanExample(IP, port, databaseName, collection);
46+
47+
/* Tim kiem document Post trong Collection voi dieu kien so sanh Less than or Equals */
48+
findLessThanOrEqualsExample(IP, port, databaseName, collection);
49+
50+
/* Tim kiem document Post trong Collection thoa man tat ca cac dieu kien */
51+
findANDLogicExample(IP, port, databaseName, collection);
52+
53+
/* Tim kiem document Post trong Collection bat ky mot trong cac dieu kien */
54+
findORLogicExample(IP, port, databaseName, collection);
55+
}
56+
57+
private static void findORLogicExample(String ip, int port, String databaseName, String collection) {
58+
QueryDocument queryDocument = new QueryDocument(ip, port,databaseName);
59+
60+
/* tim kiem document voi view >= 100 && view < 300 */
61+
Bson query = Filters.or(Filters.eq("user", "Hungcdev"), Filters.in("title", List.of("Spring", "Java")));
62+
63+
List<Post> postList = queryDocument.find(collection, Post.class, query);
64+
System.out.println("--- Document trong Collection Post voi "+ query.toString() + "---");
65+
postList.forEach(post -> System.out.println(post.toString()));
66+
System.out.println("--- End ---");
67+
}
68+
69+
private static void findANDLogicExample(String ip, int port, String databaseName, String collection) {
70+
QueryDocument queryDocument = new QueryDocument(ip, port,databaseName);
71+
72+
/* tim kiem document voi view >= 100 && view < 300 */
73+
Bson query = Filters.and(Filters.gte("view", 100), Filters.lt("view", 300));
74+
75+
List<Post> postList = queryDocument.find(collection, Post.class, query);
76+
System.out.println("--- Document trong Collection Post voi "+ query.toString() + "---");
77+
postList.forEach(post -> System.out.println(post.toString()));
78+
System.out.println("--- End ---");
79+
}
80+
81+
private static void findLessThanOrEqualsExample(String ip, int port, String databaseName, String collection) {
82+
QueryDocument queryDocument = new QueryDocument(ip, port,databaseName);
83+
84+
/* tim kiem document voi view <= 300 */
85+
Bson query = Filters.lte("view", 300);
86+
87+
List<Post> postList = queryDocument.find(collection, Post.class, query);
88+
System.out.println("--- Document trong Collection Post voi "+ query.toString() + "---");
89+
postList.forEach(post -> System.out.println(post.toString()));
90+
System.out.println("--- End ---");
91+
}
92+
93+
private static void findLessThanExample(String ip, int port, String databaseName, String collection) {
94+
QueryDocument queryDocument = new QueryDocument(ip, port,databaseName);
95+
96+
/* tim kiem document voi view < 300 */
97+
Bson query = Filters.lt("view", 300);
98+
99+
List<Post> postList = queryDocument.find(collection, Post.class, query);
100+
System.out.println("--- Document trong Collection Post voi "+ query.toString() + "---");
101+
postList.forEach(post -> System.out.println(post.toString()));
102+
System.out.println("--- End ---");
103+
}
104+
105+
private static void findGreaterThanOrEqualsExample(String ip, int port, String databaseName, String collection) {
106+
QueryDocument queryDocument = new QueryDocument(ip, port,databaseName);
107+
108+
/* tim kiem document voi view >= 300 */
109+
Bson query = Filters.gte("view", 300);
110+
111+
List<Post> postList = queryDocument.find(collection, Post.class, query);
112+
System.out.println("--- Document trong Collection Post voi "+ query.toString() + "---");
113+
postList.forEach(post -> System.out.println(post.toString()));
114+
System.out.println("--- End ---");
115+
}
116+
117+
private static void findGreaterThanExample(String ip, int port, String databaseName, String collection) {
118+
QueryDocument queryDocument = new QueryDocument(ip, port,databaseName);
119+
120+
/* tim kiem document voi view > 300 */
121+
Bson query = Filters.gt("view", 300);
122+
123+
List<Post> postList = queryDocument.find(collection, Post.class, query);
124+
System.out.println("--- Document trong Collection Post voi "+ query.toString() + "---");
125+
postList.forEach(post -> System.out.println(post.toString()));
126+
System.out.println("--- End ---");
127+
}
128+
129+
private static void findNotInExample(String ip, int port, String databaseName, String collection) {
130+
QueryDocument queryDocument = new QueryDocument(ip, port,databaseName);
131+
132+
/* tim kiem document voi title khong nam trong danh sach {Mongodb, Spring, Java}*/
133+
Bson query = Filters.nin("title",List.of("Mongodb", "Spring", "Java"));
134+
135+
List<Post> postList = queryDocument.find(collection, Post.class, query);
136+
System.out.println("--- Document trong Collection Post voi "+ query.toString() + "---");
137+
postList.forEach(post -> System.out.println(post.toString()));
138+
System.out.println("--- End ---");
139+
}
140+
141+
private static void findInExample(String ip, int port, String databaseName, String collection) {
142+
QueryDocument queryDocument = new QueryDocument(ip, port,databaseName);
143+
144+
/* tim kiem document voi title nam trong danh sach {Mongodb, Spring, Java}*/
145+
Bson query = Filters.in("title",List.of("Mongodb", "Spring", "Java"));
146+
147+
List<Post> postList = queryDocument.find(collection, Post.class, query);
148+
System.out.println("--- Document trong Collection Post voi "+ query.toString() + "---");
149+
postList.forEach(post -> System.out.println(post.toString()));
150+
System.out.println("--- End ---");
151+
}
152+
153+
private static void findNotEqualsExample(String ip, int port, String databaseName, String collection) {
154+
QueryDocument queryDocument = new QueryDocument(ip, port,databaseName);
155+
156+
/* tim kiem document voi user khac gia tri Hungcdev */
157+
Bson query = Filters.ne("user","Hungcdev");
158+
159+
/* tim kiem document voi enable khac gia tri true */
160+
// Bson query = Filters.ne("enable",true);
161+
162+
List<Post> postList = queryDocument.find(collection, Post.class, query);
163+
System.out.println("--- Document trong Collection Post voi "+ query.toString() + "---");
164+
postList.forEach(post -> System.out.println(post.toString()));
165+
System.out.println("--- End ---");
166+
}
167+
168+
private static void findEqualsExample(String ip, int port, String databaseName, String collection) {
169+
QueryDocument queryDocument = new QueryDocument(ip, port,databaseName);
170+
171+
/* tim kiem document voi id = 8cf90a70-d7cd-4b7b-995b-167daab3c059 */
172+
// Bson query = Filters.eq("_id","8cf90a70-d7cd-4b7b-995b-167daab3c059");
173+
174+
/* tim kiem document voi user la Hungcdev */
175+
// Bson query = Filters.eq("user","Hungcdev");
176+
177+
/* tim kiem document voi enable la true */
178+
Bson query = Filters.eq("enable",true);
179+
180+
List<Post> postList = queryDocument.find(collection, Post.class, query);
181+
System.out.println("--- Document trong Collection Post voi "+ query.toString() + "---");
182+
postList.forEach(post -> System.out.println(post.toString()));
183+
System.out.println("--- End ---");
184+
}
185+
186+
private static void initDataExample(String ip, int port , String databaseName, String collection) {
187+
InsertDocument insertDocument = new InsertDocument(ip, port, databaseName);
188+
189+
insertDocument.insertMany(collection, Post.class,
190+
Post.builder().id(UUID.randomUUID().toString()).title("Mongodb").user("Hungcdev").content("MongoDB Tutorial").view(100).enable(true).build(),
191+
Post.builder().id(UUID.randomUUID().toString()).title("Spring").user("Hungcdev").content("Spring Tutorial").view(200).enable(false).build(),
192+
Post.builder().id(UUID.randomUUID().toString()).title("Java").user("AtomPtit").content("Java Tutorial").view(300).enable(true).build(),
193+
Post.builder().id(UUID.randomUUID().toString()).title("Spring Boot").user("AtomPtit").content("Spring Boot Tutorial").view(400).enable(true).build(),
194+
Post.builder().id(UUID.randomUUID().toString()).title("PHP").user("HungHoi").content("PHP Tutorial").view(500).enable(true).build()
195+
);
196+
}
197+
198+
private static void findAllExample(String ip, int port, String databaseName, String collection) {
199+
QueryDocument queryDocument = new QueryDocument(ip, port,databaseName);
200+
List<Post> postList = queryDocument.findAll(collection, Post.class);
201+
System.out.println("--- Document trong Collection Post ---");
202+
postList.forEach(post -> System.out.println(post.toString()));
203+
System.out.println("--- End ---");
204+
}
205+
206+
}

0 commit comments

Comments
 (0)