Now using JPA with a container managed entity manager.
[utils] / mythtv / monitor / src / main / java / org / wamblee / mythtv / RecordingDatabase.java
1 /*
2  * Copyright 2006 the original author or authors.
3  * 
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  * 
8  *      http://www.apache.org/licenses/LICENSE-2.0
9  * 
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */ 
16
17 package org.wamblee.mythtv;
18
19 import java.sql.SQLException;
20 import java.util.HashMap;
21 import java.util.List;
22 import java.util.Map;
23
24 import javax.persistence.EntityManager;
25 import javax.persistence.Query;
26
27 import org.apache.commons.logging.Log;
28 import org.apache.commons.logging.LogFactory;
29 import org.hibernate.HibernateException;
30 import org.hibernate.Session;
31 import org.hibernate.criterion.Expression;
32 import org.springframework.orm.hibernate3.HibernateCallback;
33 import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
34 import org.springframework.orm.jpa.JpaTemplate;
35 import org.springframework.orm.jpa.support.JpaDaoSupport;
36
37 /**
38  * 
39  */
40 public class RecordingDatabase extends JpaDaoSupport {
41     
42     private static final Log LOG = LogFactory.getLog(RecordingDatabase.class);
43
44     public RecordingDatabase() { 
45         // Empty
46     }
47     
48     public void init() {  
49         /* 
50         for (Recording recording: (List<Recording>)getHibernateTemplate().loadAll(Recording.class) ) { 
51             LOG.info("Found recording " + recording);
52         }
53         LOG.info("After listing recordings");
54         */
55     }
56     
57     public Recording findRecording(final String aName) {
58         JpaTemplate jpaTemplate = getJpaTemplate();
59         EntityManager entityManager = jpaTemplate.getEntityManager();
60         Query query = entityManager.createQuery(
61                 "from org.wamblee.mythtv.Recording where basename = ?1");
62         query.setParameter(1, aName);
63         List<Recording> result = query.getResultList();
64         if ( result.size() > 1 ) { 
65             throw new RuntimeException("More than two recordings returned");
66         }
67         if ( result.size() == 0 ) { 
68             return null; 
69         }
70         return result.get(0);
71     }
72     
73     public void update(Recording aRecording) { 
74         // Update is not required since the whole task of updating the 
75         // directory structure occurs within a single transaction. 
76         // Therefore, modifications to recordings are automatically persisted. 
77     }
78 }