Mongo DB
public class DBManager {
private static DB database;
public static DB getDatabase() {
if (database == null) {
MongoClient mongo;
try {
mongo = new
MongoClient("localhost", 27017);
database =
mongo.getDB("usermanager"); //db name
} catch (UnknownHostException e) {
// TODO Auto-generated catch
block
e.printStackTrace();
}
}
return database;
}
}
public class User {
private int id;
private String firstName;
private String lastName;
private String email;
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
// GENERATE GETTERS AND SETTERS
}
//Main.java
import
com.mongodb.BasicDBObject;
import
com.mongodb.BasicDBObjectBuilder;
import com.mongodb.DB;
import
com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.WriteResult;
import javax.swing.JOptionPane;
import
javax.swing.table.DefaultTableModel;
public class Main extends javax.swing.JFrame
{
public Main() {
initComponents();
loadTable();
}
private
void btnViewActionPerformed(java.awt.event.ActionEvent evt) {
loadTable();
}
private
void btnAddActionPerformed(java.awt.event.ActionEvent evt) {
User newUser = new User();
newUser.setId(Integer.parseInt(txtID.getText()));
newUser.setFirstName(txtfname.getText());
newUser.setLastName(txtlname.getText());
newUser.setEmail(txtemail.getText());
DBObject doc = createDBObject(newUser);
DB userDB = DBManager.getDatabase();
DBCollection col = userDB.getCollection("Students");
WriteResult result = col.insert(doc);
loadTable();
}
private void
jTable1MouseClicked(java.awt.event.MouseEvent evt) {
int selectrow =
jTable1.getSelectedRow();
selectrow =
jTable1.convertColumnIndexToModel(selectrow);
String id = jTable1.getModel().getValueAt(selectrow,0).toString();
txtID.setText(id);
String fname = jTable1.getModel().getValueAt(selectrow,1).toString();
txtfname.setText(fname);
String lname = jTable1.getModel().getValueAt(selectrow,2).toString();
txtlname.setText(lname);
}
private void
btnUpdateActionPerformed(java.awt.event.ActionEvent evt) {
DB userDB = DBManager.getDatabase();
DBCollection col =
userDB.getCollection("Students");
BasicDBObject query = new
BasicDBObject();
query.put("_id",
Integer.parseInt(txtID.getText()));
BasicDBObject newDocument = new
BasicDBObject();
newDocument.put("firstName",
txtfname.getText());
newDocument.put("lastName",
txtlname.getText());
newDocument.put("email",
txtemail.getText());
BasicDBObject updateObj = new
BasicDBObject();
updateObj.put("$set",
newDocument);
col.update(query,updateObj);
JOptionPane.showMessageDialog(rootPane,
"User Update SucessFully...!");
loadTable();
}
private void
btnDeleteActionPerformed(java.awt.event.ActionEvent evt) {
DB userDB = DBManager.getDatabase();
DBCollection col =
userDB.getCollection("Students");
BasicDBObject
query = new BasicDBObject("_id", new BasicDBObject("$eq",
Integer.parseInt(txtID.getText())));
col.remove(query);
JOptionPane.showMessageDialog(rootPane,
"User Delete SucessFully...!");
//this.setVisible(false);
//this.dispose();
loadTable();
}
private void
btnSearchActionPerformed(java.awt.event.ActionEvent evt) {
DB userDB = DBManager.getDatabase();
DBCollection col = userDB.getCollection("Students");
BasicDBObject query = new
BasicDBObject();
query.put("_id",
Integer.parseInt(txtSearch.getText()));
DBCursor cursor =
col.find(query);
DefaultTableModel model = new DefaultTableModel();
model.addColumn("_id");
model.addColumn("firstName");
model.addColumn("lastName");
model.addColumn("email");
while (cursor.hasNext()) {
DBObject user = (DBObject)
cursor.next();
model.addRow(new
Object[]{user.get("_id"), user.get("firstName"),
user.get("lastName"), user.get("email")});
}
jTable1.setModel(model);
}
private static DBObject
createDBObject(User user) {
BasicDBObjectBuilder
docBuilder = BasicDBObjectBuilder.start();
docBuilder.append("_id",
user.getId());
docBuilder.append("firstName",
user.getFirstName());
docBuilder.append("lastName",
user.getLastName());
docBuilder.append("email",
user.getEmail());
return docBuilder.get();
}
public void loadTable()
{
DefaultTableModel model = new
DefaultTableModel();
model.addColumn("_id");
model.addColumn("firstName");
model.addColumn("lastName");
model.addColumn("email");
DB userDB = DBManager.getDatabase();
DBCollection col =
userDB.getCollection("Students");
DBCursor cursor = col.find();
while (cursor.hasNext()) {
DBObject user = (DBObject)
cursor.next();
model.addRow(new
Object[]{user.get("_id"), user.get("firstName"),
user.get("lastName"), user.get("email")});
}
jTable1.setModel(model);
}
}
No comments:
Post a Comment