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 <[EMAIL PROTECTED]> " - + "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 <[EMAIL PROTECTED]> " + + "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: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]
