DBManager.java
user.setId(Integer.parseInt(jTextField1.getText().toString()));
user.setFirstName(jTextField2.getText().toString());
user.setLastName(jTextField3.getText().toString());
user.setEmail(jTextField4.getText().toString());
DBObject doc = createDBObject(user);
DB useDb = DBManager.getDatabase();
DBCollection col = useDb.getCollection("user");
WriteResult result = col.insert(doc);
create a this method in ur main class
private static DBObject createDBObject(User user) {
BasicDBObjectBuilder b = BasicDBObjectBuilder.start();
b.append("_id", user.getId());
b.append("firstName", user.getFirstName());
b.append("lastName", user.getLastName());
b.append("email", user.getEmail());
return b.get();
}
Update Object
User user = new User();
user.setId(Integer.parseInt(jTextField1.getText().toString()));
user.setFirstName(jTextField2.getText().toString());
user.setLastName(jTextField3.getText().toString());
user.setEmail(jTextField4.getText().toString());
updatePerson(user);
private static void updatePerson(User user) {
DB db = DBManager.getDatabase();
DBCollection collection = db.getCollection("user");
BasicDBObject newUser = new BasicDBObject();
newUser.append("firstName", user.getFirstName());
newUser.append("lastName", user.getLastName());
newUser.append("email", user.getEmail());
BasicDBObject updateOb = new BasicDBObject("$set", newUser);
BasicDBObject searchQuery = new BasicDBObject().append("_id",
user.getId());
collection.update(searchQuery, updateOb);
}
Delete Object
int id = Integer.parseInt(jTextField1.getText().toString());
deleteUser(id);
public void deleteUser(int userID) {
DB db = DBManager.getDatabase();
DBCollection collection = db.getCollection("user");
BasicDBObject remOb = new BasicDBObject();
remOb.put("_id", userID);
collection.remove(remOb);
}
Search Object
int id = Integer.parseInt(jTextField5.getText().toString());
Vector v = selectOneExample(id);
for(int i=0;i<v.size();i++)
{
Vector v1 = (Vector) v.get(i);
jTextField1.setText(v1.get(0).toString());
jTextField2.setText(v1.get(1).toString());
jTextField3.setText(v1.get(2).toString());
jTextField4.setText(v1.get(3).toString());
}
private static Vector<Vector<String>> selectOneExample(int id) {
DB db = DBManager.getDatabase();
DBCollection collection = db.getCollection("user");
BasicDBObject query = new BasicDBObject("_id", id);
DBCursor cursor = collection.find(query);
Vector<Vector<String>> detailsVector = new Vector<Vector<String>>();
try {
List<DBObject> li = cursor.toArray();
for (int i = 0; i < li.size(); i++) {
Vector<String> v = new Vector<String>();
v.add(li.get(i).get("_id").toString());
v.add(li.get(i).get("firstName").toString());
v.add(li.get(i).get("lastName").toString());
v.add(li.get(i).get("email").toString());
detailsVector.add(v);
}
} catch (Exception e) {
System.out.println(e);
}
return detailsVector;
}
private static DB database;
public static DB getDatabase() {
if (database == null) {
try {
MongoClient mongo;
mongo = new MongoClient("localhost", 27017);
database = mongo.getDB("usermanager");
} catch (UnknownHostException ex) {
Logger.getLogger(DBManager.class.getName()).log(Level.SEVERE, null, ex);
}
}
return database;
}
Insert Object
Code inside the button cliked
User user = new User();user.setId(Integer.parseInt(jTextField1.getText().toString()));
user.setFirstName(jTextField2.getText().toString());
user.setLastName(jTextField3.getText().toString());
user.setEmail(jTextField4.getText().toString());
DBObject doc = createDBObject(user);
DB useDb = DBManager.getDatabase();
DBCollection col = useDb.getCollection("user");
WriteResult result = col.insert(doc);
create a this method in ur main class
private static DBObject createDBObject(User user) {
BasicDBObjectBuilder b = BasicDBObjectBuilder.start();
b.append("_id", user.getId());
b.append("firstName", user.getFirstName());
b.append("lastName", user.getLastName());
b.append("email", user.getEmail());
return b.get();
}
Update Object
User user = new User();
user.setId(Integer.parseInt(jTextField1.getText().toString()));
user.setFirstName(jTextField2.getText().toString());
user.setLastName(jTextField3.getText().toString());
user.setEmail(jTextField4.getText().toString());
updatePerson(user);
private static void updatePerson(User user) {
DB db = DBManager.getDatabase();
DBCollection collection = db.getCollection("user");
BasicDBObject newUser = new BasicDBObject();
newUser.append("firstName", user.getFirstName());
newUser.append("lastName", user.getLastName());
newUser.append("email", user.getEmail());
BasicDBObject updateOb = new BasicDBObject("$set", newUser);
BasicDBObject searchQuery = new BasicDBObject().append("_id",
user.getId());
collection.update(searchQuery, updateOb);
}
Delete Object
int id = Integer.parseInt(jTextField1.getText().toString());
deleteUser(id);
public void deleteUser(int userID) {
DB db = DBManager.getDatabase();
DBCollection collection = db.getCollection("user");
BasicDBObject remOb = new BasicDBObject();
remOb.put("_id", userID);
collection.remove(remOb);
}
Search Object
int id = Integer.parseInt(jTextField5.getText().toString());
Vector v = selectOneExample(id);
for(int i=0;i<v.size();i++)
{
Vector v1 = (Vector) v.get(i);
jTextField1.setText(v1.get(0).toString());
jTextField2.setText(v1.get(1).toString());
jTextField3.setText(v1.get(2).toString());
jTextField4.setText(v1.get(3).toString());
}
private static Vector<Vector<String>> selectOneExample(int id) {
DB db = DBManager.getDatabase();
DBCollection collection = db.getCollection("user");
BasicDBObject query = new BasicDBObject("_id", id);
DBCursor cursor = collection.find(query);
Vector<Vector<String>> detailsVector = new Vector<Vector<String>>();
try {
List<DBObject> li = cursor.toArray();
for (int i = 0; i < li.size(); i++) {
Vector<String> v = new Vector<String>();
v.add(li.get(i).get("_id").toString());
v.add(li.get(i).get("firstName").toString());
v.add(li.get(i).get("lastName").toString());
v.add(li.get(i).get("email").toString());
detailsVector.add(v);
}
} catch (Exception e) {
System.out.println(e);
}
return detailsVector;
}
No comments:
Post a Comment