UserDAO and User Model for MongoDB

| Saturday, May 29, 2010
/*
 * file : UserDAO.java
 *
 */

import com.mongodb.BasicDBObject;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.ObjectId;
import com.sigawe.accounts.db.DBConnection;
import com.sigawe.accounts.models.User;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

public class UserDAO {

    private DBCollection coll;

    public UserDAO() {
        coll = DBConnection.getDBCollection("user");
    }

    public void save(User user) {
        BasicDBObject bdbo = new BasicDBObject();
        bdbo.put("username", user.getUsername());
        bdbo.put("password", user.getPassword());
        bdbo.put("email", user.getEmail());
        bdbo.put("name", user.getName());
        bdbo.put("address", user.getAddress());
        bdbo.put("sex", user.getSex());
        bdbo.put("birthDate", user.getBirthDate());
        bdbo.put("city", user.getCity());
        bdbo.put("state", user.getState());
        bdbo.put("status", user.getStatus());
        coll.save(bdbo);
    }

    public void remove(String username) {
        BasicDBObject query = new BasicDBObject();
        query.put("username", username);
        coll.remove(query);
    }

    public void update(String username, User user) {
        BasicDBObject query = new BasicDBObject();
        query.put("username", username);
        BasicDBObject bdbo = new BasicDBObject();
        bdbo.put("username", user.getUsername());
        bdbo.put("password", user.getPassword());
        bdbo.put("email", user.getEmail());
        bdbo.put("name", user.getName());
        bdbo.put("address", user.getAddress());
        bdbo.put("sex", user.getSex());
        bdbo.put("birthDate", user.getBirthDate());
        bdbo.put("city", user.getCity());
        bdbo.put("state", user.getState());
        bdbo.put("status", user.getStatus());
        coll.update(query, bdbo);
    }

    public User find(String username) {
        BasicDBObject query = new BasicDBObject();
        query.put("username", username);
        User user = new User();
        DBCursor cur = coll.find(query);
        while (cur.hasNext()) {
            DBObject dbo = cur.next();
            user.setId((ObjectId) dbo.get("_id"));
            user.setUsername((String) dbo.get("username"));
            user.setPassword((String) dbo.get("password"));
            user.setEmail((String) dbo.get("email"));
            user.setAddress((String) dbo.get("address"));
            user.setSex((String) dbo.get("sex"));
            user.setBirthDate((Date) dbo.get("birthDate"));
            user.setCity((String) dbo.get("city"));
            user.setState((String) dbo.get("state"));
            user.setStatus((String) dbo.get("status"));
        }
        return user;
    }

    public List find() {
        List users = new ArrayList();
        DBCursor cur = coll.find();
        while (cur.hasNext()) {
            DBObject dbo = cur.next();
            User user = new User();
            user.setId((ObjectId) dbo.get("_id"));
            user.setUsername((String) dbo.get("username"));
            user.setPassword((String) dbo.get("password"));
            user.setEmail((String) dbo.get("email"));
            user.setName((String) dbo.get("name"));
            user.setAddress((String) dbo.get("address"));
            user.setSex((String) dbo.get("sex"));
            user.setBirthDate((Date) dbo.get("birthDate"));
            user.setCity((String) dbo.get("city"));
            user.setState((String) dbo.get("state"));
            user.setStatus((String) dbo.get("status"));
            users.add(user);
        }
        return users;
    }

    public List find(DBObject query) {
        List users = new ArrayList();
        DBCursor cur = coll.find(query);
        while (cur.hasNext()) {
            DBObject dbo = cur.next();
            User user = new User();
            user.setId((ObjectId) dbo.get("_id"));
            user.setUsername((String) dbo.get("username"));
            user.setPassword((String) dbo.get("password"));
            user.setEmail((String) dbo.get("email"));
            user.setName((String) dbo.get("name"));
            user.setAddress((String) dbo.get("address"));
            user.setSex((String) dbo.get("sex"));
            user.setBirthDate((Date) dbo.get("birthDate"));
            user.setCity((String) dbo.get("city"));
            user.setState((String) dbo.get("state"));
            user.setStatus((String) dbo.get("status"));
            users.add(user);
        }
        return users;
    }

    public User findOne() {
        DBObject dbo = coll.findOne();
        User user = new User();
        user.setId((ObjectId) dbo.get("_id"));
        user.setUsername((String) dbo.get("username"));
        user.setPassword((String) dbo.get("password"));
        user.setEmail((String) dbo.get("email"));
        user.setName((String) dbo.get("name"));
        user.setAddress((String) dbo.get("address"));
        user.setSex((String) dbo.get("sex"));
        user.setBirthDate((Date) dbo.get("birthDate"));
        user.setCity((String) dbo.get("city"));
        user.setState((String) dbo.get("state"));
        user.setStatus((String) dbo.get("status"));
        return user;
    }
}

/*
 * file : User.java
 *
 */

import com.mongodb.ObjectId;
import java.util.Date;

public class User {

    private ObjectId id;
    private String username;
    private String password;
    private String email;
    private String name;
    private String address;
    private String sex;
    private Date birthDate;
    private String city;
    private String state;
    private String status;

    public User() {
    }

    public ObjectId getId() {
        return id;
    }

    public void setId(ObjectId id) {
        this.id = id;
    }

    public String getAddress() {
        return address;
    }

    public void setAddress(String address) {
        this.address = address;
    }

    public Date getBirthDate() {
        return birthDate;
    }

    public void setBirthDate(Date birthDate) {
        this.birthDate = birthDate;
    }

    public String getCity() {
        return city;
    }

    public void setCity(String city) {
        this.city = city;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public String getSex() {
        return sex;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }

    public String getState() {
        return state;
    }

    public void setState(String state) {
        this.state = state;
    }

    public String getStatus() {
        return status;
    }

    public void setStatus(String status) {
        this.status = status;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }
}



0 comments:

Post a Comment