Subversion Repositories SmartDukaan

Rev

Rev 2620 | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 2620 Rev 3099
Line 1... Line 1...
1 
 
 1 
 
2 
package in.shop2020.server;
 2 
package in.shop2020.server;
3 
 
 3 
 
- 
 
 4 
import in.shop2020.model.Message;
- 
 
 5 
 
4 
import java.util.ArrayList;
 6 
import java.util.ArrayList;
5 
import java.util.Collection;
 7 
import java.util.Collection;
6 
import java.util.List;
 8 
import java.util.List;
7 
 
 9 
 
8 
import javax.jdo.Extent;
 10 
import javax.jdo.Extent;
9 
import javax.jdo.JDOHelper;
 - 
 
10 
import javax.jdo.PersistenceManager;
 11 
import javax.jdo.PersistenceManager;
11 
import javax.jdo.PersistenceManagerFactory;
 - 
 
12 
 
 - 
 
13 
import in.shop2020.model.Message;
 - 
 
14 
 
 12 
 
15 
public class MessageRepository {
 13 
public class MessageRepository {
16 
 
 14 
 
17 
	PersistenceManagerFactory pmfInstance = JDOHelper.getPersistenceManagerFactory("transactions-optional");
 - 
 
18 
 
 - 
 
19 
	public Collection<Message> getAll() {
 15 
	public Collection<Message> getAll() {
20 
		PersistenceManager pm = pmfInstance.getPersistenceManager();
 16 
		PersistenceManager pm = PMF.get().getPersistenceManager();
21 
		try {
 17 
		try {
22 
			List<Message> messages = new ArrayList<Message>();
 18 
			List<Message> messages = new ArrayList<Message>();
23 
		    Extent<Message> extent = pm.getExtent(Message.class, false);
 19 
		    Extent<Message> extent = pm.getExtent(Message.class, false);
24 
		    for (Message message : extent) {
 20 
		    for (Message message : extent) {
25 
		        messages.add(message);
 21 
		        messages.add(message);
Line 31... Line 27...
31 
			pm.close();
 27 
			pm.close();
32 
		}
 28 
		}
33 
	}
 29 
	}
34 
 
 30 
 
35 
	public void create(Message message) {
 31 
	public void create(Message message) {
36 
		PersistenceManager pm = pmfInstance.getPersistenceManager();
 32 
		PersistenceManager pm = PMF.get().getPersistenceManager();
37 
		try {
 33 
		try {
38 
		    pm.makePersistent(message);
 34 
		    pm.makePersistent(message);
39 
		} finally {
 35 
		} finally {
40 
			pm.close();
 36 
			pm.close();
41 
		}
 37 
		}
42 
	}
 38 
	}
43 
 
 39 
 
44 
	public void deleteById(Long id) {
 40 
	public void deleteById(Long id) {
45 
		PersistenceManager pm = pmfInstance.getPersistenceManager();
 41 
		PersistenceManager pm = PMF.get().getPersistenceManager();
46 
		try {
 42 
		try {
47 
			pm.deletePersistent(pm.getObjectById(Message.class, id));
 43 
			pm.deletePersistent(pm.getObjectById(Message.class, id));
48 
		} finally {
 44 
		} finally {
49 
			pm.close();
 45 
			pm.close();
50 
		}
 46 
		}