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);

    }

                                

}