MondoDB

MongoDB

    private void jButton1ActionPerformed(java.awt.event.ActionEvent evt) {                                        

        AddUser add=new AddUser();

        add.setVisible(true);      

    }

•      DBManager

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("NewDB");

                                                          //boolean auth = database.authenticate(myUserName, myPassword);

                                                } catch (UnknownHostException e) {

                                                                e.printStackTrace();

                                                }

                                }

                                return database;

                }  

}

•      User Class

public class User {

        private int id;

                private String firstName;

                private String lastName;

                private String email;

//getter  and setter

}

•      Insert

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

   }

private void jButton1ActionPerformed(java.awt.event.ActionEvent evt) {  

                                     

        User newUser = new User();

        newUser.setId(Integer.parseInt(txtId.getText()));

        newUser.setFirstName(txtFirstName.getText());

        newUser.setLastName(txtLastName.getText());

        newUser.setEmail(txtEmail.getText());

        DBObject doc = createDBObject(newUser);

        DB userDB = DBManager.getDatabase();

        DBCollection col = userDB.getCollection("user");

        WriteResult result = col.insert(doc);

       

        JOptionPane.showMessageDialog(rootPane, "User Insert SucessFully...!");

        txtId.setText("");       

        txtFirstName.setText("");

        txtLastName.setText(""); 

        txtEmail.setText("");                      

    }

•   List User

public viewUser() {

        initComponents();

        printmongData();

    }

    public void printmongData()

    {

         DefaultTableModel model = new DefaultTableModel();

        model.addColumn("ID");

        model.addColumn("First Name");

        model.addColumn("Last Name");

        model.addColumn("Email");        

        DB userDB = DBManager.getDatabase();

        DBCollection col = userDB.getCollection("user");       

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

         }

         jTable3.setModel(model);

    }

•  Manage User

·         Combo Box Load When page load

public ManageUser() {

        initComponents();

        fillID();

    }

    public void fillID() {

        DB userDB = DBManager.getDatabase();

        DBCollection col = userDB.getCollection("user");

        DBCursor cursor = col.find();

        while (cursor.hasNext()) {

            DBObject user = (DBObject) cursor.next();

            jComboBox1.addItem(user.get("_id"));

        }

    }

·         Combobox Change event

private void jComboBox1ItemStateChanged(java.awt.event.ItemEvent evt) {                                           

        DB userDB = DBManager.getDatabase();

        DBCollection col = userDB.getCollection("user");

        DBCursor cursor = col.find();

        while (cursor.hasNext()) {

            DBObject user = (DBObject) cursor.next();

            int seletedID = Integer.parseInt(jComboBox1.getSelectedItem().toString());

            if (user.get("_id") == seletedID) {

                jTextField1.setText(user.get("_id").toString());

                jTextField2.setText(user.get("firstName").toString());

                jTextField3.setText(user.get("lastName").toString());

                jTextField4.setText(user.get("email").toString());

            }

        }

    } 

·         Update button

private void jButton1ActionPerformed(java.awt.event.ActionEvent evt) {                                        

        try {

            DB userDB = DBManager.getDatabase();

            DBCollection col = userDB.getCollection("user");

            BasicDBObject query = new BasicDBObject("_id", new BasicDBObject("$eq", Integer.parseInt(jTextField1.getText())));

            BasicDBObject newDocument = new BasicDBObject();

            newDocument.put("firstName", jTextField2.getText());

            newDocument.put("lastName", jTextField3.getText());

            newDocument.put("email", jTextField4.getText());

            BasicDBObject updateObj = new BasicDBObject();

            updateObj.put("$set", newDocument);

            col.update(query, updateObj, false, true);

            JOptionPane.showMessageDialog(rootPane, "User Update SucessFully...!");

        } catch (Exception e) {

            JOptionPane.showMessageDialog(rootPane, "Please Select User");

        }

    }

·         Delete Button

private void jButton2ActionPerformed(java.awt.event.ActionEvent evt) {                                        

        try {

            DB userDB = DBManager.getDatabase();

            DBCollection col = userDB.getCollection("user");

            BasicDBObject query = new BasicDBObject("_id", new BasicDBObject("$eq", Integer.parseInt(jTextField1.getText())));

            col.remove(query);

            JOptionPane.showMessageDialog(rootPane, "User Delete SucessFully...!");

             this.setVisible(false);

              this.dispose();

               ManageUser mange= new ManageUser();

               mange.setVisible(true);

          

           

        } catch (Exception e) {

            JOptionPane.showMessageDialog(rootPane, "Please Select User");

        }

    }