Subversion Repositories SmartDukaan

package in.shop2020.server;

import java.util.ArrayList;

import java.util.Collection;

import java.util.List;

import javax.jdo.Extent;

import javax.jdo.JDOHelper;

import javax.jdo.PersistenceManager;

import javax.jdo.PersistenceManagerFactory;

import in.shop2020.model.Message;

public class MessageRepository {

	PersistenceManagerFactory pmfInstance = JDOHelper.getPersistenceManagerFactory("transactions-optional");

	public Collection<Message> getAll() {

		PersistenceManager pm = pmfInstance.getPersistenceManager();

		try {

			List<Message> messages = new ArrayList<Message>();

		    Extent<Message> extent = pm.getExtent(Message.class, false);

		    for (Message message : extent) {

		        messages.add(message);

		    }

		    extent.closeAll();

		    return messages;

		} finally {

			pm.close();

		}

	}

	public void create(Message message) {

		PersistenceManager pm = pmfInstance.getPersistenceManager();

		try {

		    pm.makePersistent(message);

		} finally {

			pm.close();

		}

	}

	public void deleteById(Long id) {

		PersistenceManager pm = pmfInstance.getPersistenceManager();

		try {

			pm.deletePersistent(pm.getObjectById(Message.class, id));

		} finally {

			pm.close();

		}

	}

}