OJB中的多表查询和更新

    OJB的文章实在是少的可怜，自己总结了一下一些重点的内容。想到哪里写到哪里吧

比如有课程(event)和类别(catalog)两张表，二者是多对多的关系，关系表叫做catalogEventBridge，字段为[catalogID,eventID]，现在要做的是一旦查询出一个catalog，就要把相关的event也全部搜索出来。

1.repository_user.xml中作如下定义：

1. <class-descriptor class="org.pie.vls.Catalog.Catalog" table="catalog"> 
2. <field-descriptor name="catalogID" column="catalogID" jdbc-type="INTEGER" 
3. primarykey="true" /> <field-descriptor name="catalogName" column="catalogName" 
4. jdbc-type="VARCHAR" /> <collection-descriptor name="catalogEventList" element-
5. class-ref="org.pie.vls.Catalog.CatalogEventBridge" auto-retrieve="true" auto-
6. update="true" auto-delete="true"> <inverse-foreignkey field-ref="catalogID"/> 
7. </collection-descriptor> </class-descriptor> <class-descriptor 
8. class="org.pie.vls.Catalog.CatalogEventBridge" table="catalogEventBridge"> 
9. <field-descriptor name="catalogID" column="catalogID" jdbc-type="INTEGER" 
10. primarykey="true" /> <field-descriptor name="eventTypeID" column="eventTypeID" 
11. jdbc-type="INTEGER" primarykey="true" /> </class-descriptor> <class-descriptor 
12. class="org.pie.vls.EventType.EventType" table="eventType" > <field-descriptor 
13. name="eventTypeID" column="eventTypeID" jdbc-type="INTEGER" primarykey="true" 
14. autoincrement="true" />
16.       <field-descriptor
17.          name="eventTypeTitle"
18.          column="eventTypeTitle"
19.          jdbc-type="VARCHAR"
20.       />
21. ... ...
22. </class-descriptor>

2. bean文件的定义

EventType.java

1. public class EventType implements Cloneable, Comparable {
2.     private String eventTypeTitle;
3.     private String eventTypeCode;
4.     private String eventTypeDesc;
5.     private int eventTypeID;
6.     public int getEventTypeID() {
7.         return this.eventTypeID;
8.     }
10.     public void setEventTypeID(int value) {
11.         this.eventTypeID = value;
12.     }
13.     ... ...
14. }

catalog.java

1. public class Catalog implements Comparable {
3.     private int catalogID;
4.     private String catalogName = "";
5.     private List catalogEventList = new Vector();
6.    /**
7.      * @return Returns the catalogID.
8.      */
9.     public int getCatalogID() {
10.         return catalogID;
11.     }
13.     /**
14.      * @param catalogID The catalogID to set.
15.      */
16.     public void setCatalogID(int catalogID) {
17.         this.catalogID = catalogID;
18.     }
20.     /**
21.      * @return Returns the catalogName.
22.      */
23.     public String getCatalogName() {
24.         return catalogName;
25.     }
27.     /**
28.      * @param catalogName The catalogName to set.
29.      */
30.     public void setCatalogName(String catalogName) {
31.         this.catalogName = catalogName;
32.     }
34.     /**
35.      * @return Returns the catalogEventList.
36.      */
37.     public List getCatalogEventList() {
38.         return catalogEventList;
39.     }
41.     /**
42.      * @param catalogEventList The catalogEventList to set.
43.      */
44.     public void setCatalogEventList(List catalogEventList) {
45.         this.catalogEventList = catalogEventList;
46.     }
47. }

 

 

CatalogEventBridge.java

1. public class CatalogEventBridge {
2.     private int catalogID = 0;
3.     private int eventTypeID = 0;
4.     /**
5.      * @return Returns the catalogID.
6.      */
7.     public int getCatalogID() {
8.         return catalogID;
9.     }
11.     /**
12.      * @param catalogID The catalogID to set.
13.      */
14.     public void setCatalogID(int catalogID) {
15.         this.catalogID = catalogID;
16.     }
18.     /**
19.      * @return Returns the eventTypeID.
20.      */
21.     public int getEventTypeID() {
22.         return eventTypeID;
23.     }
25.     /**
26.      * @param eventTypeID The eventTypeID to set.
27.      */
28.     public void setEventTypeID(int eventTypeID) {
29.         this.eventTypeID = eventTypeID;
30.     }
31. }

3. 定义DAO

1. import java.util.Collection;
2. import java.util.Iterator;
4. import org.apache.log4j.Logger;
5. import org.apache.ojb.broker.PersistenceBroker;
6. import org.apache.ojb.broker.PersistenceBrokerFactory;
7. import org.apache.ojb.broker.query.Criteria;
8. import org.apache.ojb.broker.query.QueryByCriteria;
9. import org.apache.ojb.broker.query.QueryFactory;
10. import org.odmg.Implementation;
11. import org.pie.vls.Application.AbstractVLSBase;
13. public class CatalogDAO extends AbstractVLSBase {
15.     private Collection catalogList;
16.     private PersistenceBroker broker;
17.     private static final Logger logger = Logger.getLogger(Catalog.class);
18.     private int catalogID = 0;
20.     public CatalogDAO(Implementation impl) {
21.         super(impl);
22.         init();
23.     }
25.     public CatalogDAO(Implementation impl, int catalogID) {
26.         super(impl);
27.         this.catalogID = catalogID;
28.         init();
29.     }
31.     /* (non-Javadoc)
32.      * @see org.pie.vls.Application.VLSBase#init()
33.      */
34.     public void init() {
35.         // TODO Auto-generated method stub
36.         try {
37.             broker = PersistenceBrokerFactory.defaultPersistenceBroker();
38.             broker.clearCache();
40.             Criteria crit = new Criteria();
41.             if (this.catalogID > 0) {
42.                 crit.addEqualTo("catalogID", new Integer(this.catalogID));
43.             }
45.             QueryByCriteria tquery = QueryFactory.newQuery(Catalog.class, crit);
46.             this.catalogList = broker.getCollectionByQuery(tquery);
47.             broker.clearCache();
48.             broker.close();
49.         } catch (Throwable t) {
50.             logger.error(t.getMessage(), t);
51.         }
52.     }
53.     
54.     public boolean isEmpty(){
55.         return this.catalogList.isEmpty();
56.     }
58.     public Collection getCatalogList() {
59.         return this.catalogList;
60.     }
62.     public Catalog getCatalog() {
63.         Iterator iter = this.catalogList.iterator();
64.         Catalog catalog = (Catalog) iter.next();
65.         return catalog;
66.     }
68.     public void create(Catalog catalog) {
69.         update(catalog);
70.     }
72.     public void update(Catalog catalog) {
73.         try {
74.             broker = PersistenceBrokerFactory.defaultPersistenceBroker();
75.             broker.clearCache();
76.             broker.beginTransaction();
77.             broker.store(catalog);
78.             broker.commitTransaction();
79.             broker.close();
80.         } catch (Throwable t) {
81.             logger.error(t.getMessage(), t);
82.         }
83.     }
85.     public void delete(Catalog catalog) {
86.         try {
87.             broker = PersistenceBrokerFactory.defaultPersistenceBroker();
88.             broker.clearCache();
89.             broker.beginTransaction();
90.             broker.delete(catalog);
91.             broker.commitTransaction();
92.             broker.close();
93.         } catch (Throwable t) {
94.             logger.error(t.getMessage(), t);
95.         }
96.     }
97. }

catalogEventBridgeDAO.java和eventTypeDAO.java跟上面的这个DAO类似，就不再重复。

    使用方法就很简单了，只要通过CatalogDAO得到了一个catalog的实例，那么就可以通过catalog.getCatalogEventList()来获得bridge表中相关的数据，同样，调用catalogDAO中的create,update和delete方法，不仅对catalog表作操作，同样也对catalogEventBridge表中的数据作操作。