Tuesday, October 14, 2014

Mongo DB



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