-
Notifications
You must be signed in to change notification settings - Fork 0
/
MongoDBJDBC.java
122 lines (98 loc) · 3.36 KB
/
MongoDBJDBC.java
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
import java.io.BufferedWriter;
import java.io.FileWriter;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
public class MongoDBJDBC {
public static void main(String args[]) {
try {
BufferedWriter bw = null;
FileWriter fw = null;
fw = new FileWriter("mongo_node_data.txt");
bw = new BufferedWriter(fw);
MongoClient mongo = new MongoClient("localhost", 27017);
/**** Get database ****/
// if database doesn't exists, MongoDB will create it for you
DB db = mongo.getDB("osm_india");
/**** Get collection / table from 'testdb' ****/
// if collection doesn't exists, MongoDB will create it for you
DBCollection table = db.getCollection("nodes");
/****
* Insert *** // create a document to store key and value
* BasicDBObject document = new BasicDBObject();
* document.put("name", "mkyong"); document.put("age", 30); //
* document.put("createdDate", new Date()); table.insert(document);
*/
/**** Find and display ****/
// BasicDBObject searchQuery = new BasicDBObject();
// db.getCollection("nodes").find({ tags.name: { $exists: true } }
// );
DBObject query = new BasicDBObject("tags.name", new BasicDBObject("$exists", true));
DBCursor result = table.find(query);
System.out.println(result.size());
//int i = 0;
long id = 0;
Double lati = null, longi = null;
String name = null;
while (result.hasNext()) {
//i++;
DBObject obj = result.next();
DBObject tag = (DBObject) (obj.get("tags"));
DBObject loc = (DBObject) (obj.get("loc"));
// double loc[] = (double[]) (obj.get("loc"));
name = (String) (tag.get("name"));
name = name.toLowerCase();
longi = (Double) (loc.get("0"));
lati = (Double) (loc.get("1"));
id = (long) (obj.get("id"));
//bw.write("name=" + name + " id=" + id + " longi= " + longi + " lati=" + lati+"\n");
bw.write(name + "$" + id + "$" + longi + "$" + lati+"$\n");
//System.out.println("name=" + name + " id=" + id + " longi=" + longi + " lati=" + lati);
}
bw.close();
fw.close();
// ({"IMAGE URL":{$ne:null}}) ;
// searchQuery.put("name", "mkyong");
// DBCursor cursor = table.find(searchQuery);
//
// while (cursor.hasNext()) {
// System.out.println(cursor.next());
// }
//
// /**** Update ****/
// // search document where name="mkyong" and update it with new
// values
// BasicDBObject query = new BasicDBObject();
// query.put("name", "mkyong");
//
// BasicDBObject newDocument = new BasicDBObject();
// newDocument.put("name", "mkyong-updated");
//
//
// BasicDBObject updateObj = new BasicDBObject();
// updateObj.put("$set", newDocument);
// updateObj.append("$currentDate", new
// BasicDBObject().append("lastModified", true));
//
// table.update(query, updateObj);
//
// /**** Find and display ****/
// BasicDBObject searchQuery2
// = new BasicDBObject().append("name", "mkyong-updated");
//
// DBCursor cursor2 = table.find(searchQuery2);
//
// while (cursor2.hasNext()) {
// System.out.println(cursor2.next());
// }
//
// /**** Done ****/
// System.out.println("Done");
} catch (Exception e) {
System.err.println(e.getClass().getName() + ": " + e.getMessage());
}
}
}