You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by rd...@apache.org on 2008/09/18 23:45:03 UTC
svn commit: r696828 [28/32] - in /james/protocols/imap/trunk:
api/src/main/java/org/apache/james/api/imap/
api/src/main/java/org/apache/james/api/imap/display/
api/src/main/java/org/apache/james/api/imap/imap4rev1/
api/src/main/java/org/apache/james/ap...
Modified: james/protocols/imap/trunk/torque/src/main/java/org/apache/james/mailboxmanager/torque/om/BaseMessageHeaderPeer.java
URL: http://svn.apache.org/viewvc/james/protocols/imap/trunk/torque/src/main/java/org/apache/james/mailboxmanager/torque/om/BaseMessageHeaderPeer.java?rev=696828&r1=696827&r2=696828&view=diff
==============================================================================
--- james/protocols/imap/trunk/torque/src/main/java/org/apache/james/mailboxmanager/torque/om/BaseMessageHeaderPeer.java (original)
+++ james/protocols/imap/trunk/torque/src/main/java/org/apache/james/mailboxmanager/torque/om/BaseMessageHeaderPeer.java Thu Sep 18 14:44:56 2008
@@ -23,113 +23,101 @@
import java.util.LinkedList;
import java.util.List;
-
-
-
/**
* This class was autogenerated by Torque on:
- *
+ *
* [Sun Dec 09 17:45:09 GMT 2007]
- *
+ *
*/
-public abstract class BaseMessageHeaderPeer
- extends BasePeer
-{
+public abstract class BaseMessageHeaderPeer extends BasePeer {
/** Serial version */
private static final long serialVersionUID = 1197222309712L;
-
/** the default database name for this class */
public static final String DATABASE_NAME;
- /** the table name for this class */
+ /** the table name for this class */
public static final String TABLE_NAME;
/**
* @return the map builder for this peer
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- * @deprecated Torque.getMapBuilder(MessageHeaderMapBuilder.CLASS_NAME) instead
- */
- public static MapBuilder getMapBuilder()
- throws TorqueException
- {
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ * @deprecated Torque.getMapBuilder(MessageHeaderMapBuilder.CLASS_NAME)
+ * instead
+ */
+ public static MapBuilder getMapBuilder() throws TorqueException {
return Torque.getMapBuilder(MessageHeaderMapBuilder.CLASS_NAME);
}
- /** the column name for the mailbox_id field */
+ /** the column name for the mailbox_id field */
public static final String MAILBOX_ID;
- /** the column name for the uid field */
+
+ /** the column name for the uid field */
public static final String UID;
- /** the column name for the line_number field */
+
+ /** the column name for the line_number field */
public static final String LINE_NUMBER;
- /** the column name for the field field */
+
+ /** the column name for the field field */
public static final String FIELD;
- /** the column name for the value field */
+
+ /** the column name for the value field */
public static final String VALUE;
-
- static
- {
+
+ static {
DATABASE_NAME = "mailboxmanager";
TABLE_NAME = "message_header";
- MAILBOX_ID = "message_header.mailbox_id";
- UID = "message_header.uid";
- LINE_NUMBER = "message_header.line_number";
- FIELD = "message_header.field";
- VALUE = "message_header.value";
- if (Torque.isInit())
- {
- try
- {
+ MAILBOX_ID = "message_header.mailbox_id";
+ UID = "message_header.uid";
+ LINE_NUMBER = "message_header.line_number";
+ FIELD = "message_header.field";
+ VALUE = "message_header.value";
+ if (Torque.isInit()) {
+ try {
Torque.getMapBuilder(MessageHeaderMapBuilder.CLASS_NAME);
- }
- catch (TorqueException e)
- {
+ } catch (TorqueException e) {
log.error("Could not initialize Peer", e);
throw new RuntimeException(e);
}
- }
- else
- {
+ } else {
Torque.registerMapBuilder(MessageHeaderMapBuilder.CLASS_NAME);
}
}
-
+
/** number of columns for this peer */
- public static final int numColumns = 5;
+ public static final int numColumns = 5;
/** A class that can be returned by this peer. */
- protected static final String CLASSNAME_DEFAULT =
- "org.apache.james.mailboxmanager.torque.om.MessageHeader";
+ protected static final String CLASSNAME_DEFAULT = "org.apache.james.mailboxmanager.torque.om.MessageHeader";
/** A class that can be returned by this peer. */
protected static final Class CLASS_DEFAULT = initClass(CLASSNAME_DEFAULT);
/**
* Class object initialization method.
- *
- * @param className name of the class to initialize
+ *
+ * @param className
+ * name of the class to initialize
* @return the initialized class
*/
- private static Class initClass(String className)
- {
+ private static Class initClass(String className) {
Class c = null;
- try
- {
+ try {
c = Class.forName(className);
- }
- catch (Throwable t)
- {
- log.error("A FATAL ERROR has occurred which should not "
- + "have happened under any circumstance. Please notify "
- + "the Torque developers <to...@db.apache.org> "
- + "and give as many details as possible (including the error "
- + "stack trace).", t);
+ } catch (Throwable t) {
+ log
+ .error(
+ "A FATAL ERROR has occurred which should not "
+ + "have happened under any circumstance. Please notify "
+ + "the Torque developers <to...@db.apache.org> "
+ + "and give as many details as possible (including the error "
+ + "stack trace).", t);
// Error objects should always be propogated.
- if (t instanceof Error)
- {
+ if (t instanceof Error) {
throw (Error) t.fillInStackTrace();
}
}
@@ -137,571 +125,549 @@
}
/**
- * Get the list of objects for a ResultSet. Please not that your
- * resultset MUST return columns in the right order. You can use
- * getFieldNames() in BaseObject to get the correct sequence.
- *
- * @param results the ResultSet
+ * Get the list of objects for a ResultSet. Please not that your resultset
+ * MUST return columns in the right order. You can use getFieldNames() in
+ * BaseObject to get the correct sequence.
+ *
+ * @param results
+ * the ResultSet
* @return the list of objects
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
public static List resultSet2Objects(java.sql.ResultSet results)
- throws TorqueException
- {
- try
- {
+ throws TorqueException {
+ try {
QueryDataSet qds = null;
List rows = null;
- try
- {
+ try {
qds = new QueryDataSet(results);
rows = getSelectResults(qds);
- }
- finally
- {
- if (qds != null)
- {
+ } finally {
+ if (qds != null) {
qds.close();
}
}
return populateObjects(rows);
- }
- catch (SQLException e)
- {
+ } catch (SQLException e) {
throw new TorqueException(e);
- }
- catch (DataSetException e)
- {
+ } catch (DataSetException e) {
throw new TorqueException(e);
}
}
-
-
/**
* Method to do inserts.
- *
- * @param criteria object used to create the INSERT statement.
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static ObjectKey doInsert(Criteria criteria)
- throws TorqueException
- {
- return BaseMessageHeaderPeer
- .doInsert(criteria, (Connection) null);
+ *
+ * @param criteria
+ * object used to create the INSERT statement.
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static ObjectKey doInsert(Criteria criteria) throws TorqueException {
+ return BaseMessageHeaderPeer.doInsert(criteria, (Connection) null);
}
/**
- * Method to do inserts. This method is to be used during a transaction,
- * otherwise use the doInsert(Criteria) method. It will take care of
- * the connection details internally.
- *
- * @param criteria object used to create the INSERT statement.
- * @param con the connection to use
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * Method to do inserts. This method is to be used during a transaction,
+ * otherwise use the doInsert(Criteria) method. It will take care of the
+ * connection details internally.
+ *
+ * @param criteria
+ * object used to create the INSERT statement.
+ * @param con
+ * the connection to use
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
public static ObjectKey doInsert(Criteria criteria, Connection con)
- throws TorqueException
- {
+ throws TorqueException {
correctBooleans(criteria);
setDbName(criteria);
- if (con == null)
- {
+ if (con == null) {
return BasePeer.doInsert(criteria);
- }
- else
- {
+ } else {
return BasePeer.doInsert(criteria, con);
}
}
/**
* Add all the columns needed to create a new object.
- *
- * @param criteria object containing the columns to add.
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ *
+ * @param criteria
+ * object containing the columns to add.
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
public static void addSelectColumns(Criteria criteria)
- throws TorqueException
- {
- criteria.addSelectColumn(MAILBOX_ID);
- criteria.addSelectColumn(UID);
- criteria.addSelectColumn(LINE_NUMBER);
- criteria.addSelectColumn(FIELD);
- criteria.addSelectColumn(VALUE);
- }
+ throws TorqueException {
+ criteria.addSelectColumn(MAILBOX_ID);
+ criteria.addSelectColumn(UID);
+ criteria.addSelectColumn(LINE_NUMBER);
+ criteria.addSelectColumn(FIELD);
+ criteria.addSelectColumn(VALUE);
+ }
/**
* changes the boolean values in the criteria to the appropriate type,
- * whenever a booleanchar or booleanint column is involved.
- * This enables the user to create criteria using Boolean values
- * for booleanchar or booleanint columns
- * @param criteria the criteria in which the boolean values should be corrected
- * @throws TorqueException if the database map for the criteria cannot be
- obtained.
+ * whenever a booleanchar or booleanint column is involved. This enables the
+ * user to create criteria using Boolean values for booleanchar or
+ * booleanint columns
+ *
+ * @param criteria
+ * the criteria in which the boolean values should be corrected
+ * @throws TorqueException
+ * if the database map for the criteria cannot be obtained.
*/
- public static void correctBooleans(Criteria criteria) throws TorqueException
- {
+ public static void correctBooleans(Criteria criteria)
+ throws TorqueException {
correctBooleans(criteria, getTableMap());
}
/**
- * Create a new object of type cls from a resultset row starting
- * from a specified offset. This is done so that you can select
- * other rows than just those needed for this object. You may
- * for example want to create two objects from the same row.
- *
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static MessageHeader row2Object(Record row,
- int offset,
- Class cls)
- throws TorqueException
- {
- try
- {
+ * Create a new object of type cls from a resultset row starting from a
+ * specified offset. This is done so that you can select other rows than
+ * just those needed for this object. You may for example want to create two
+ * objects from the same row.
+ *
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static MessageHeader row2Object(Record row, int offset, Class cls)
+ throws TorqueException {
+ try {
MessageHeader obj = (MessageHeader) cls.newInstance();
MessageHeaderPeer.populateObject(row, offset, obj);
- obj.setModified(false);
- obj.setNew(false);
+ obj.setModified(false);
+ obj.setNew(false);
return obj;
- }
- catch (InstantiationException e)
- {
+ } catch (InstantiationException e) {
throw new TorqueException(e);
- }
- catch (IllegalAccessException e)
- {
+ } catch (IllegalAccessException e) {
throw new TorqueException(e);
}
}
/**
- * Populates an object from a resultset row starting
- * from a specified offset. This is done so that you can select
- * other rows than just those needed for this object. You may
- * for example want to create two objects from the same row.
- *
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static void populateObject(Record row,
- int offset,
- MessageHeader obj)
- throws TorqueException
- {
- try
- {
- obj.setMailboxId(row.getValue(offset + 0).asLong());
- obj.setUid(row.getValue(offset + 1).asLong());
- obj.setLineNumber(row.getValue(offset + 2).asInt());
- obj.setField(row.getValue(offset + 3).asString());
- obj.setValue(row.getValue(offset + 4).asString());
- }
- catch (DataSetException e)
- {
+ * Populates an object from a resultset row starting from a specified
+ * offset. This is done so that you can select other rows than just those
+ * needed for this object. You may for example want to create two objects
+ * from the same row.
+ *
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static void populateObject(Record row, int offset, MessageHeader obj)
+ throws TorqueException {
+ try {
+ obj.setMailboxId(row.getValue(offset + 0).asLong());
+ obj.setUid(row.getValue(offset + 1).asLong());
+ obj.setLineNumber(row.getValue(offset + 2).asInt());
+ obj.setField(row.getValue(offset + 3).asString());
+ obj.setValue(row.getValue(offset + 4).asString());
+ } catch (DataSetException e) {
throw new TorqueException(e);
}
}
/**
* Method to do selects.
- *
- * @param criteria object used to create the SELECT statement.
+ *
+ * @param criteria
+ * object used to create the SELECT statement.
* @return List of selected Objects
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
- public static List doSelect(Criteria criteria) throws TorqueException
- {
+ public static List doSelect(Criteria criteria) throws TorqueException {
return populateObjects(doSelectVillageRecords(criteria));
}
/**
* Method to do selects within a transaction.
- *
- * @param criteria object used to create the SELECT statement.
- * @param con the connection to use
+ *
+ * @param criteria
+ * object used to create the SELECT statement.
+ * @param con
+ * the connection to use
* @return List of selected Objects
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
public static List doSelect(Criteria criteria, Connection con)
- throws TorqueException
- {
+ throws TorqueException {
return populateObjects(doSelectVillageRecords(criteria, con));
}
/**
- * Grabs the raw Village records to be formed into objects.
- * This method handles connections internally. The Record objects
- * returned by this method should be considered readonly. Do not
- * alter the data and call save(), your results may vary, but are
- * certainly likely to result in hard to track MT bugs.
- *
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * Grabs the raw Village records to be formed into objects. This method
+ * handles connections internally. The Record objects returned by this
+ * method should be considered readonly. Do not alter the data and call
+ * save(), your results may vary, but are certainly likely to result in hard
+ * to track MT bugs.
+ *
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
public static List doSelectVillageRecords(Criteria criteria)
- throws TorqueException
- {
- return BaseMessageHeaderPeer
- .doSelectVillageRecords(criteria, (Connection) null);
+ throws TorqueException {
+ return BaseMessageHeaderPeer.doSelectVillageRecords(criteria,
+ (Connection) null);
}
/**
- * Grabs the raw Village records to be formed into objects.
- * This method should be used for transactions
- *
- * @param criteria object used to create the SELECT statement.
- * @param con the connection to use
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * Grabs the raw Village records to be formed into objects. This method
+ * should be used for transactions
+ *
+ * @param criteria
+ * object used to create the SELECT statement.
+ * @param con
+ * the connection to use
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
public static List doSelectVillageRecords(Criteria criteria, Connection con)
- throws TorqueException
- {
- if (criteria.getSelectColumns().size() == 0)
- {
+ throws TorqueException {
+ if (criteria.getSelectColumns().size() == 0) {
addSelectColumns(criteria);
}
correctBooleans(criteria);
setDbName(criteria);
- // BasePeer returns a List of Value (Village) arrays. The array
+ // BasePeer returns a List of Value (Village) arrays. The array
// order follows the order columns were placed in the Select clause.
- if (con == null)
- {
+ if (con == null) {
return BasePeer.doSelect(criteria);
- }
- else
- {
+ } else {
return BasePeer.doSelect(criteria, con);
}
}
/**
- * The returned List will contain objects of the default type or
- * objects that inherit from the default.
- *
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static List populateObjects(List records)
- throws TorqueException
- {
+ * The returned List will contain objects of the default type or objects
+ * that inherit from the default.
+ *
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static List populateObjects(List records) throws TorqueException {
List results = new ArrayList(records.size());
// populate the object(s)
- for (int i = 0; i < records.size(); i++)
- {
+ for (int i = 0; i < records.size(); i++) {
Record row = (Record) records.get(i);
- results.add(MessageHeaderPeer.row2Object(row, 1,
- MessageHeaderPeer.getOMClass()));
- }
+ results.add(MessageHeaderPeer.row2Object(row, 1, MessageHeaderPeer
+ .getOMClass()));
+ }
return results;
}
-
/**
- * The class that the Peer will make instances of.
- * If the BO is abstract then you must implement this method
- * in the BO.
- *
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static Class getOMClass()
- throws TorqueException
- {
+ * The class that the Peer will make instances of. If the BO is abstract
+ * then you must implement this method in the BO.
+ *
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static Class getOMClass() throws TorqueException {
return CLASS_DEFAULT;
}
/**
* Method to do updates.
- *
- * @param criteria object containing data that is used to create the UPDATE
- * statement.
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static void doUpdate(Criteria criteria) throws TorqueException
- {
- BaseMessageHeaderPeer
- .doUpdate(criteria, (Connection) null);
+ *
+ * @param criteria
+ * object containing data that is used to create the UPDATE
+ * statement.
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static void doUpdate(Criteria criteria) throws TorqueException {
+ BaseMessageHeaderPeer.doUpdate(criteria, (Connection) null);
}
/**
- * Method to do updates. This method is to be used during a transaction,
- * otherwise use the doUpdate(Criteria) method. It will take care of
- * the connection details internally.
- *
- * @param criteria object containing data that is used to create the UPDATE
- * statement.
- * @param con the connection to use
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * Method to do updates. This method is to be used during a transaction,
+ * otherwise use the doUpdate(Criteria) method. It will take care of the
+ * connection details internally.
+ *
+ * @param criteria
+ * object containing data that is used to create the UPDATE
+ * statement.
+ * @param con
+ * the connection to use
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
public static void doUpdate(Criteria criteria, Connection con)
- throws TorqueException
- {
+ throws TorqueException {
Criteria selectCriteria = new Criteria(DATABASE_NAME, 2);
correctBooleans(criteria);
-
- selectCriteria.put(MAILBOX_ID, criteria.remove(MAILBOX_ID));
-
- selectCriteria.put(UID, criteria.remove(UID));
-
- selectCriteria.put(LINE_NUMBER, criteria.remove(LINE_NUMBER));
-
-
-
+ selectCriteria.put(MAILBOX_ID, criteria.remove(MAILBOX_ID));
+
+ selectCriteria.put(UID, criteria.remove(UID));
+
+ selectCriteria.put(LINE_NUMBER, criteria.remove(LINE_NUMBER));
+
setDbName(criteria);
- if (con == null)
- {
+ if (con == null) {
BasePeer.doUpdate(selectCriteria, criteria);
- }
- else
- {
+ } else {
BasePeer.doUpdate(selectCriteria, criteria, con);
}
}
/**
* Method to do deletes.
- *
- * @param criteria object containing data that is used DELETE from database.
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static void doDelete(Criteria criteria) throws TorqueException
- {
- MessageHeaderPeer
- .doDelete(criteria, (Connection) null);
- }
+ *
+ * @param criteria
+ * object containing data that is used DELETE from database.
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static void doDelete(Criteria criteria) throws TorqueException {
+ MessageHeaderPeer.doDelete(criteria, (Connection) null);
+ }
/**
- * Method to do deletes. This method is to be used during a transaction,
- * otherwise use the doDelete(Criteria) method. It will take care of
- * the connection details internally.
- *
- * @param criteria object containing data that is used DELETE from database.
- * @param con the connection to use
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static void doDelete(Criteria criteria, Connection con)
- throws TorqueException
- {
+ * Method to do deletes. This method is to be used during a transaction,
+ * otherwise use the doDelete(Criteria) method. It will take care of the
+ * connection details internally.
+ *
+ * @param criteria
+ * object containing data that is used DELETE from database.
+ * @param con
+ * the connection to use
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static void doDelete(Criteria criteria, Connection con)
+ throws TorqueException {
correctBooleans(criteria);
setDbName(criteria);
- if (con == null)
- {
+ if (con == null) {
BasePeer.doDelete(criteria);
- }
- else
- {
+ } else {
BasePeer.doDelete(criteria, con);
}
- }
+ }
/**
* Method to do selects
- *
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ *
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
- public static List doSelect(MessageHeader obj) throws TorqueException
- {
+ public static List doSelect(MessageHeader obj) throws TorqueException {
return doSelect(buildSelectCriteria(obj));
}
/**
* Method to do inserts
- *
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static void doInsert(MessageHeader obj) throws TorqueException
- {
- doInsert(buildCriteria(obj));
- obj.setNew(false);
+ *
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static void doInsert(MessageHeader obj) throws TorqueException {
+ doInsert(buildCriteria(obj));
+ obj.setNew(false);
obj.setModified(false);
}
/**
- * @param obj the data object to update in the database.
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * @param obj
+ * the data object to update in the database.
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
- public static void doUpdate(MessageHeader obj) throws TorqueException
- {
+ public static void doUpdate(MessageHeader obj) throws TorqueException {
doUpdate(buildCriteria(obj));
obj.setModified(false);
}
/**
- * @param obj the data object to delete in the database.
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * @param obj
+ * the data object to delete in the database.
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
- public static void doDelete(MessageHeader obj) throws TorqueException
- {
+ public static void doDelete(MessageHeader obj) throws TorqueException {
doDelete(buildSelectCriteria(obj));
}
/**
- * Method to do inserts. This method is to be used during a transaction,
- * otherwise use the doInsert(MessageHeader) method. It will take
- * care of the connection details internally.
- *
- * @param obj the data object to insert into the database.
- * @param con the connection to use
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * Method to do inserts. This method is to be used during a transaction,
+ * otherwise use the doInsert(MessageHeader) method. It will take care of
+ * the connection details internally.
+ *
+ * @param obj
+ * the data object to insert into the database.
+ * @param con
+ * the connection to use
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
public static void doInsert(MessageHeader obj, Connection con)
- throws TorqueException
- {
- doInsert(buildCriteria(obj), con);
- obj.setNew(false);
+ throws TorqueException {
+ doInsert(buildCriteria(obj), con);
+ obj.setNew(false);
obj.setModified(false);
}
/**
- * Method to do update. This method is to be used during a transaction,
- * otherwise use the doUpdate(MessageHeader) method. It will take
- * care of the connection details internally.
- *
- * @param obj the data object to update in the database.
- * @param con the connection to use
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * Method to do update. This method is to be used during a transaction,
+ * otherwise use the doUpdate(MessageHeader) method. It will take care of
+ * the connection details internally.
+ *
+ * @param obj
+ * the data object to update in the database.
+ * @param con
+ * the connection to use
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
public static void doUpdate(MessageHeader obj, Connection con)
- throws TorqueException
- {
+ throws TorqueException {
doUpdate(buildCriteria(obj), con);
obj.setModified(false);
}
/**
- * Method to delete. This method is to be used during a transaction,
- * otherwise use the doDelete(MessageHeader) method. It will take
- * care of the connection details internally.
- *
- * @param obj the data object to delete in the database.
- * @param con the connection to use
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * Method to delete. This method is to be used during a transaction,
+ * otherwise use the doDelete(MessageHeader) method. It will take care of
+ * the connection details internally.
+ *
+ * @param obj
+ * the data object to delete in the database.
+ * @param con
+ * the connection to use
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
public static void doDelete(MessageHeader obj, Connection con)
- throws TorqueException
- {
+ throws TorqueException {
doDelete(buildSelectCriteria(obj), con);
}
/**
* Method to do deletes.
- *
- * @param pk ObjectKey that is used DELETE from database.
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static void doDelete(ObjectKey pk) throws TorqueException
- {
- BaseMessageHeaderPeer
- .doDelete(pk, (Connection) null);
+ *
+ * @param pk
+ * ObjectKey that is used DELETE from database.
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static void doDelete(ObjectKey pk) throws TorqueException {
+ BaseMessageHeaderPeer.doDelete(pk, (Connection) null);
}
/**
- * Method to delete. This method is to be used during a transaction,
- * otherwise use the doDelete(ObjectKey) method. It will take
- * care of the connection details internally.
- *
- * @param pk the primary key for the object to delete in the database.
- * @param con the connection to use
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ * Method to delete. This method is to be used during a transaction,
+ * otherwise use the doDelete(ObjectKey) method. It will take care of the
+ * connection details internally.
+ *
+ * @param pk
+ * the primary key for the object to delete in the database.
+ * @param con
+ * the connection to use
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
public static void doDelete(ObjectKey pk, Connection con)
- throws TorqueException
- {
+ throws TorqueException {
doDelete(buildCriteria(pk), con);
}
/** Build a Criteria object from an ObjectKey */
- public static Criteria buildCriteria( ObjectKey pk )
- {
+ public static Criteria buildCriteria(ObjectKey pk) {
Criteria criteria = new Criteria();
- SimpleKey[] keys = (SimpleKey[])pk.getValue();
- criteria.add(MAILBOX_ID, keys[0]);
- criteria.add(UID, keys[1]);
- criteria.add(LINE_NUMBER, keys[2]);
- return criteria;
- }
+ SimpleKey[] keys = (SimpleKey[]) pk.getValue();
+ criteria.add(MAILBOX_ID, keys[0]);
+ criteria.add(UID, keys[1]);
+ criteria.add(LINE_NUMBER, keys[2]);
+ return criteria;
+ }
/** Build a Criteria object from the data object for this peer */
- public static Criteria buildCriteria( MessageHeader obj )
- {
+ public static Criteria buildCriteria(MessageHeader obj) {
Criteria criteria = new Criteria(DATABASE_NAME);
- criteria.add(MAILBOX_ID, obj.getMailboxId());
- criteria.add(UID, obj.getUid());
- criteria.add(LINE_NUMBER, obj.getLineNumber());
- criteria.add(FIELD, obj.getField());
- criteria.add(VALUE, obj.getValue());
- return criteria;
+ criteria.add(MAILBOX_ID, obj.getMailboxId());
+ criteria.add(UID, obj.getUid());
+ criteria.add(LINE_NUMBER, obj.getLineNumber());
+ criteria.add(FIELD, obj.getField());
+ criteria.add(VALUE, obj.getValue());
+ return criteria;
}
- /** Build a Criteria object from the data object for this peer, skipping all binary columns */
- public static Criteria buildSelectCriteria( MessageHeader obj )
- {
+ /**
+ * Build a Criteria object from the data object for this peer, skipping all
+ * binary columns
+ */
+ public static Criteria buildSelectCriteria(MessageHeader obj) {
Criteria criteria = new Criteria(DATABASE_NAME);
- criteria.add(MAILBOX_ID, obj.getMailboxId());
- criteria.add(UID, obj.getUid());
- criteria.add(LINE_NUMBER, obj.getLineNumber());
- criteria.add(FIELD, obj.getField());
- criteria.add(VALUE, obj.getValue());
- return criteria;
- }
-
-
-
+ criteria.add(MAILBOX_ID, obj.getMailboxId());
+ criteria.add(UID, obj.getUid());
+ criteria.add(LINE_NUMBER, obj.getLineNumber());
+ criteria.add(FIELD, obj.getField());
+ criteria.add(VALUE, obj.getValue());
+ return criteria;
+ }
+
/**
* Retrieve a single object by pk
- *
- * @param pk the primary key
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- * @throws NoRowsException Primary key was not found in database.
- * @throws TooManyRowsException Primary key was not found in database.
+ *
+ * @param pk
+ * the primary key
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ * @throws NoRowsException
+ * Primary key was not found in database.
+ * @throws TooManyRowsException
+ * Primary key was not found in database.
*/
public static MessageHeader retrieveByPK(ObjectKey pk)
- throws TorqueException, NoRowsException, TooManyRowsException
- {
+ throws TorqueException, NoRowsException, TooManyRowsException {
Connection db = null;
MessageHeader retVal = null;
- try
- {
+ try {
db = Torque.getConnection(DATABASE_NAME);
retVal = retrieveByPK(pk, db);
- }
- finally
- {
+ } finally {
Torque.closeConnection(db);
}
return retVal;
@@ -709,52 +675,48 @@
/**
* Retrieve a single object by pk
- *
- * @param pk the primary key
- * @param con the connection to use
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- * @throws NoRowsException Primary key was not found in database.
- * @throws TooManyRowsException Primary key was not found in database.
+ *
+ * @param pk
+ * the primary key
+ * @param con
+ * the connection to use
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ * @throws NoRowsException
+ * Primary key was not found in database.
+ * @throws TooManyRowsException
+ * Primary key was not found in database.
*/
public static MessageHeader retrieveByPK(ObjectKey pk, Connection con)
- throws TorqueException, NoRowsException, TooManyRowsException
- {
+ throws TorqueException, NoRowsException, TooManyRowsException {
Criteria criteria = buildCriteria(pk);
List v = doSelect(criteria, con);
- if (v.size() == 0)
- {
+ if (v.size() == 0) {
throw new NoRowsException("Failed to select a row.");
- }
- else if (v.size() > 1)
- {
+ } else if (v.size() > 1) {
throw new TooManyRowsException("Failed to select only one row.");
- }
- else
- {
- return (MessageHeader)v.get(0);
+ } else {
+ return (MessageHeader) v.get(0);
}
}
/**
* Retrieve a multiple objects by pk
- *
- * @param pks List of primary keys
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static List retrieveByPKs(List pks)
- throws TorqueException
- {
+ *
+ * @param pks
+ * List of primary keys
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static List retrieveByPKs(List pks) throws TorqueException {
Connection db = null;
List retVal = null;
- try
- {
- db = Torque.getConnection(DATABASE_NAME);
- retVal = retrieveByPKs(pks, db);
- }
- finally
- {
+ try {
+ db = Torque.getConnection(DATABASE_NAME);
+ retVal = retrieveByPKs(pks, db);
+ } finally {
Torque.closeConnection(db);
}
return retVal;
@@ -762,226 +724,190 @@
/**
* Retrieve a multiple objects by pk
- *
- * @param pks List of primary keys
- * @param dbcon the connection to use
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static List retrieveByPKs( List pks, Connection dbcon )
- throws TorqueException
- {
+ *
+ * @param pks
+ * List of primary keys
+ * @param dbcon
+ * the connection to use
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static List retrieveByPKs(List pks, Connection dbcon)
+ throws TorqueException {
List objs = null;
- if (pks == null || pks.size() == 0)
- {
+ if (pks == null || pks.size() == 0) {
objs = new LinkedList();
- }
- else
- {
+ } else {
Criteria criteria = new Criteria();
- Iterator iter = pks.iterator();
- while (iter.hasNext())
- {
+ Iterator iter = pks.iterator();
+ while (iter.hasNext()) {
ObjectKey pk = (ObjectKey) iter.next();
- SimpleKey[] keys = (SimpleKey[])pk.getValue();
- Criteria.Criterion c0 = criteria.getNewCriterion(
- MAILBOX_ID, keys[0], Criteria.EQUAL);
- Criteria.Criterion c1 = criteria.getNewCriterion(
- UID, keys[1], Criteria.EQUAL);
- c0.and(c1);
- Criteria.Criterion c2 = criteria.getNewCriterion(
- LINE_NUMBER, keys[2], Criteria.EQUAL);
- c1.and(c2);
- criteria.or(c0);
+ SimpleKey[] keys = (SimpleKey[]) pk.getValue();
+ Criteria.Criterion c0 = criteria.getNewCriterion(MAILBOX_ID,
+ keys[0], Criteria.EQUAL);
+ Criteria.Criterion c1 = criteria.getNewCriterion(UID, keys[1],
+ Criteria.EQUAL);
+ c0.and(c1);
+ Criteria.Criterion c2 = criteria.getNewCriterion(LINE_NUMBER,
+ keys[2], Criteria.EQUAL);
+ c1.and(c2);
+ criteria.or(c0);
}
- objs = doSelect(criteria, dbcon);
+ objs = doSelect(criteria, dbcon);
}
return objs;
}
-
/**
* retrieve object using using pk values.
- *
- * @param mailboxId long
- * @param uid long
- * @param lineNumber int
- */
- public static MessageHeader retrieveByPK(
- long mailboxId
- , long uid
- , int lineNumber
- ) throws TorqueException
- {
+ *
+ * @param mailboxId
+ * long
+ * @param uid
+ * long
+ * @param lineNumber
+ * int
+ */
+ public static MessageHeader retrieveByPK(long mailboxId, long uid,
+ int lineNumber) throws TorqueException {
Connection db = null;
MessageHeader retVal = null;
- try
- {
- db = Torque.getConnection(DATABASE_NAME);
- retVal = retrieveByPK(
- mailboxId
- , uid
- , lineNumber
- , db);
- }
- finally
- {
+ try {
+ db = Torque.getConnection(DATABASE_NAME);
+ retVal = retrieveByPK(mailboxId, uid, lineNumber, db);
+ } finally {
Torque.closeConnection(db);
}
return retVal;
}
- /**
+ /**
* retrieve object using using pk values.
- *
- * @param mailboxId long
- * @param uid long
- * @param lineNumber int
- * @param con Connection
- */
- public static MessageHeader retrieveByPK(
- long mailboxId
- , long uid
- , int lineNumber
- ,Connection con) throws TorqueException
- {
+ *
+ * @param mailboxId
+ * long
+ * @param uid
+ * long
+ * @param lineNumber
+ * int
+ * @param con
+ * Connection
+ */
+ public static MessageHeader retrieveByPK(long mailboxId, long uid,
+ int lineNumber, Connection con) throws TorqueException {
Criteria criteria = new Criteria(5);
- criteria.add(MAILBOX_ID, mailboxId);
- criteria.add(UID, uid);
- criteria.add(LINE_NUMBER, lineNumber);
- List v = doSelect(criteria, con);
- if (v.size() == 1)
- {
+ criteria.add(MAILBOX_ID, mailboxId);
+ criteria.add(UID, uid);
+ criteria.add(LINE_NUMBER, lineNumber);
+ List v = doSelect(criteria, con);
+ if (v.size() == 1) {
return (MessageHeader) v.get(0);
- }
- else
- {
+ } else {
throw new TorqueException("Failed to select one and only one row.");
}
}
-
-
-
-
-
-
-
/**
* selects a collection of MessageHeader objects pre-filled with their
* MessageRow objects.
- *
- * This method is protected by default in order to keep the public
- * api reasonable. You can provide public methods for those you
- * actually need in MessageHeaderPeer.
- *
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
+ *
+ * This method is protected by default in order to keep the public api
+ * reasonable. You can provide public methods for those you actually need in
+ * MessageHeaderPeer.
+ *
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
*/
protected static List doSelectJoinMessageRow(Criteria criteria)
- throws TorqueException
- {
+ throws TorqueException {
return doSelectJoinMessageRow(criteria, null);
}
/**
* selects a collection of MessageHeader objects pre-filled with their
* MessageRow objects.
- *
- * This method is protected by default in order to keep the public
- * api reasonable. You can provide public methods for those you
- * actually need in MessageHeaderPeer.
- *
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- protected static List doSelectJoinMessageRow(Criteria criteria, Connection conn)
- throws TorqueException
- {
+ *
+ * This method is protected by default in order to keep the public api
+ * reasonable. You can provide public methods for those you actually need in
+ * MessageHeaderPeer.
+ *
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ protected static List doSelectJoinMessageRow(Criteria criteria,
+ Connection conn) throws TorqueException {
setDbName(criteria);
MessageHeaderPeer.addSelectColumns(criteria);
int offset = numColumns + 1;
MessageRowPeer.addSelectColumns(criteria);
- criteria.addJoin(MessageHeaderPeer.MAILBOX_ID,
- MessageRowPeer.MAILBOX_ID);
- criteria.addJoin(MessageHeaderPeer.UID,
- MessageRowPeer.UID);
-
+ criteria.addJoin(MessageHeaderPeer.MAILBOX_ID,
+ MessageRowPeer.MAILBOX_ID);
+ criteria.addJoin(MessageHeaderPeer.UID, MessageRowPeer.UID);
+
correctBooleans(criteria);
List rows;
- if (conn == null)
- {
+ if (conn == null) {
rows = BasePeer.doSelect(criteria);
- }
- else
- {
- rows = BasePeer.doSelect(criteria,conn);
+ } else {
+ rows = BasePeer.doSelect(criteria, conn);
}
List results = new ArrayList();
- for (int i = 0; i < rows.size(); i++)
- {
+ for (int i = 0; i < rows.size(); i++) {
Record row = (Record) rows.get(i);
- Class omClass = MessageHeaderPeer.getOMClass();
- MessageHeader obj1 = (MessageHeader) MessageHeaderPeer
- .row2Object(row, 1, omClass);
- omClass = MessageRowPeer.getOMClass();
- MessageRow obj2 = (MessageRow) MessageRowPeer
- .row2Object(row, offset, omClass);
+ Class omClass = MessageHeaderPeer.getOMClass();
+ MessageHeader obj1 = (MessageHeader) MessageHeaderPeer.row2Object(
+ row, 1, omClass);
+ omClass = MessageRowPeer.getOMClass();
+ MessageRow obj2 = (MessageRow) MessageRowPeer.row2Object(row,
+ offset, omClass);
boolean newObject = true;
- for (int j = 0; j < results.size(); j++)
- {
+ for (int j = 0; j < results.size(); j++) {
MessageHeader temp_obj1 = (MessageHeader) results.get(j);
MessageRow temp_obj2 = (MessageRow) temp_obj1.getMessageRow();
- if (temp_obj2.getPrimaryKey().equals(obj2.getPrimaryKey()))
- {
+ if (temp_obj2.getPrimaryKey().equals(obj2.getPrimaryKey())) {
newObject = false;
- temp_obj2.addMessageHeader(obj1);
- break;
+ temp_obj2.addMessageHeader(obj1);
+ break;
}
}
- if (newObject)
- {
+ if (newObject) {
obj2.initMessageHeaders();
obj2.addMessageHeader(obj1);
}
- results.add(obj1);
+ results.add(obj1);
}
return results;
}
-
-
-
-
- /**
+
+ /**
* Returns the TableMap related to this peer.
- *
- * @throws TorqueException Any exceptions caught during processing will be
- * rethrown wrapped into a TorqueException.
- */
- public static TableMap getTableMap()
- throws TorqueException
- {
+ *
+ * @throws TorqueException
+ * Any exceptions caught during processing will be rethrown
+ * wrapped into a TorqueException.
+ */
+ public static TableMap getTableMap() throws TorqueException {
return Torque.getDatabaseMap(DATABASE_NAME).getTable(TABLE_NAME);
}
-
- private static void setDbName(Criteria crit)
- {
+
+ private static void setDbName(Criteria crit) {
// Set the correct dbName if it has not been overridden
// crit.getDbName will return the same object if not set to
// another value so == check is okay and faster
- if (crit.getDbName() == Torque.getDefaultDB())
- {
+ if (crit.getDbName() == Torque.getDefaultDB()) {
crit.setDbName(DATABASE_NAME);
}
}
-
}
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org