Modified: james/protocols/imap/trunk/torque/src/main/java/org/apache/james/mailboxmanager/torque/om/BaseMessageFlagsPeer.java URL: http://svn.apache.org/viewvc/james/protocols/imap/trunk/torque/src/main/java/org/apache/james/mailboxmanager/torque/om/BaseMessageFlagsPeer.java?rev=696828&r1=696827&r2=696828&view=diff ============================================================================== --- james/protocols/imap/trunk/torque/src/main/java/org/apache/james/mailboxmanager/torque/om/BaseMessageFlagsPeer.java (original) +++ james/protocols/imap/trunk/torque/src/main/java/org/apache/james/mailboxmanager/torque/om/BaseMessageFlagsPeer.java Thu Sep 18 14:44:56 2008 @@ -23,122 +23,113 @@ 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 BaseMessageFlagsPeer - extends BasePeer -{ +public abstract class BaseMessageFlagsPeer 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(MessageFlagsMapBuilder.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(MessageFlagsMapBuilder.CLASS_NAME) + * instead + */ + public static MapBuilder getMapBuilder() throws TorqueException { return Torque.getMapBuilder(MessageFlagsMapBuilder.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 answered field */ + + /** the column name for the answered field */ public static final String ANSWERED; - /** the column name for the deleted field */ + + /** the column name for the deleted field */ public static final String DELETED; - /** the column name for the draft field */ + + /** the column name for the draft field */ public static final String DRAFT; - /** the column name for the flagged field */ + + /** the column name for the flagged field */ public static final String FLAGGED; - /** the column name for the recent field */ + + /** the column name for the recent field */ public static final String RECENT; - /** the column name for the seen field */ + + /** the column name for the seen field */ public static final String SEEN; - - static - { + + static { DATABASE_NAME = "mailboxmanager"; TABLE_NAME = "message_flags"; - MAILBOX_ID = "message_flags.mailbox_id"; - UID = "message_flags.uid"; - ANSWERED = "message_flags.answered"; - DELETED = "message_flags.deleted"; - DRAFT = "message_flags.draft"; - FLAGGED = "message_flags.flagged"; - RECENT = "message_flags.recent"; - SEEN = "message_flags.seen"; - if (Torque.isInit()) - { - try - { + MAILBOX_ID = "message_flags.mailbox_id"; + UID = "message_flags.uid"; + ANSWERED = "message_flags.answered"; + DELETED = "message_flags.deleted"; + DRAFT = "message_flags.draft"; + FLAGGED = "message_flags.flagged"; + RECENT = "message_flags.recent"; + SEEN = "message_flags.seen"; + if (Torque.isInit()) { + try { Torque.getMapBuilder(MessageFlagsMapBuilder.CLASS_NAME); - } - catch (TorqueException e) - { + } catch (TorqueException e) { log.error("Could not initialize Peer", e); throw new RuntimeException(e); } - } - else - { + } else { Torque.registerMapBuilder(MessageFlagsMapBuilder.CLASS_NAME); } } - + /** number of columns for this peer */ - public static final int numColumns = 8; + public static final int numColumns = 8; /** A class that can be returned by this peer. */ - protected static final String CLASSNAME_DEFAULT = - "org.apache.james.mailboxmanager.torque.om.MessageFlags"; + protected static final String CLASSNAME_DEFAULT = "org.apache.james.mailboxmanager.torque.om.MessageFlags"; /** 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(); } } @@ -146,584 +137,558 @@ } /** - * 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 BaseMessageFlagsPeer - .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 BaseMessageFlagsPeer.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(ANSWERED); - criteria.addSelectColumn(DELETED); - criteria.addSelectColumn(DRAFT); - criteria.addSelectColumn(FLAGGED); - criteria.addSelectColumn(RECENT); - criteria.addSelectColumn(SEEN); - } + throws TorqueException { + criteria.addSelectColumn(MAILBOX_ID); + criteria.addSelectColumn(UID); + criteria.addSelectColumn(ANSWERED); + criteria.addSelectColumn(DELETED); + criteria.addSelectColumn(DRAFT); + criteria.addSelectColumn(FLAGGED); + criteria.addSelectColumn(RECENT); + criteria.addSelectColumn(SEEN); + } /** * 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 MessageFlags 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 MessageFlags row2Object(Record row, int offset, Class cls) + throws TorqueException { + try { MessageFlags obj = (MessageFlags) cls.newInstance(); MessageFlagsPeer.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, - MessageFlags obj) - throws TorqueException - { - try - { - obj.setMailboxId(row.getValue(offset + 0).asLong()); - obj.setUid(row.getValue(offset + 1).asLong()); - obj.setAnswered(row.getValue(offset + 2).asBoolean()); - obj.setDeleted(row.getValue(offset + 3).asBoolean()); - obj.setDraft(row.getValue(offset + 4).asBoolean()); - obj.setFlagged(row.getValue(offset + 5).asBoolean()); - obj.setRecent(row.getValue(offset + 6).asBoolean()); - obj.setSeen(row.getValue(offset + 7).asBoolean()); - } - 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, MessageFlags obj) + throws TorqueException { + try { + obj.setMailboxId(row.getValue(offset + 0).asLong()); + obj.setUid(row.getValue(offset + 1).asLong()); + obj.setAnswered(row.getValue(offset + 2).asBoolean()); + obj.setDeleted(row.getValue(offset + 3).asBoolean()); + obj.setDraft(row.getValue(offset + 4).asBoolean()); + obj.setFlagged(row.getValue(offset + 5).asBoolean()); + obj.setRecent(row.getValue(offset + 6).asBoolean()); + obj.setSeen(row.getValue(offset + 7).asBoolean()); + } 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 BaseMessageFlagsPeer - .doSelectVillageRecords(criteria, (Connection) null); + throws TorqueException { + return BaseMessageFlagsPeer.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(MessageFlagsPeer.row2Object(row, 1, - MessageFlagsPeer.getOMClass())); - } + results.add(MessageFlagsPeer.row2Object(row, 1, MessageFlagsPeer + .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 - { - BaseMessageFlagsPeer - .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 { + BaseMessageFlagsPeer.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(MAILBOX_ID, criteria.remove(MAILBOX_ID)); + + selectCriteria.put(UID, criteria.remove(UID)); + 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 - { - MessageFlagsPeer - .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 - { + * + * @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 { + MessageFlagsPeer.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 { 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(MessageFlags obj) throws TorqueException - { + public static List doSelect(MessageFlags 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(MessageFlags 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(MessageFlags 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(MessageFlags obj) throws TorqueException - { + public static void doUpdate(MessageFlags 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(MessageFlags obj) throws TorqueException - { + public static void doDelete(MessageFlags obj) throws TorqueException { doDelete(buildSelectCriteria(obj)); } /** - * Method to do inserts. This method is to be used during a transaction, - * otherwise use the doInsert(MessageFlags) 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(MessageFlags) 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(MessageFlags 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(MessageFlags) 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(MessageFlags) 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(MessageFlags 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(MessageFlags) 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(MessageFlags) 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(MessageFlags 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 - { - BaseMessageFlagsPeer - .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 { + BaseMessageFlagsPeer.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]); - return criteria; - } + SimpleKey[] keys = (SimpleKey[]) pk.getValue(); + criteria.add(MAILBOX_ID, keys[0]); + criteria.add(UID, keys[1]); + return criteria; + } /** Build a Criteria object from the data object for this peer */ - public static Criteria buildCriteria( MessageFlags obj ) - { + public static Criteria buildCriteria(MessageFlags obj) { Criteria criteria = new Criteria(DATABASE_NAME); - criteria.add(MAILBOX_ID, obj.getMailboxId()); - criteria.add(UID, obj.getUid()); - criteria.add(ANSWERED, obj.getAnswered()); - criteria.add(DELETED, obj.getDeleted()); - criteria.add(DRAFT, obj.getDraft()); - criteria.add(FLAGGED, obj.getFlagged()); - criteria.add(RECENT, obj.getRecent()); - criteria.add(SEEN, obj.getSeen()); - return criteria; + criteria.add(MAILBOX_ID, obj.getMailboxId()); + criteria.add(UID, obj.getUid()); + criteria.add(ANSWERED, obj.getAnswered()); + criteria.add(DELETED, obj.getDeleted()); + criteria.add(DRAFT, obj.getDraft()); + criteria.add(FLAGGED, obj.getFlagged()); + criteria.add(RECENT, obj.getRecent()); + criteria.add(SEEN, obj.getSeen()); + return criteria; } - /** Build a Criteria object from the data object for this peer, skipping all binary columns */ - public static Criteria buildSelectCriteria( MessageFlags obj ) - { + /** + * Build a Criteria object from the data object for this peer, skipping all + * binary columns + */ + public static Criteria buildSelectCriteria(MessageFlags obj) { Criteria criteria = new Criteria(DATABASE_NAME); - criteria.add(MAILBOX_ID, obj.getMailboxId()); - criteria.add(UID, obj.getUid()); - criteria.add(ANSWERED, obj.getAnswered()); - criteria.add(DELETED, obj.getDeleted()); - criteria.add(DRAFT, obj.getDraft()); - criteria.add(FLAGGED, obj.getFlagged()); - criteria.add(RECENT, obj.getRecent()); - criteria.add(SEEN, obj.getSeen()); - return criteria; - } - - - + criteria.add(MAILBOX_ID, obj.getMailboxId()); + criteria.add(UID, obj.getUid()); + criteria.add(ANSWERED, obj.getAnswered()); + criteria.add(DELETED, obj.getDeleted()); + criteria.add(DRAFT, obj.getDraft()); + criteria.add(FLAGGED, obj.getFlagged()); + criteria.add(RECENT, obj.getRecent()); + criteria.add(SEEN, obj.getSeen()); + 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 MessageFlags retrieveByPK(ObjectKey pk) - throws TorqueException, NoRowsException, TooManyRowsException - { + throws TorqueException, NoRowsException, TooManyRowsException { Connection db = null; MessageFlags retVal = null; - try - { + try { db = Torque.getConnection(DATABASE_NAME); retVal = retrieveByPK(pk, db); - } - finally - { + } finally { Torque.closeConnection(db); } return retVal; @@ -731,52 +696,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 MessageFlags 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 (MessageFlags)v.get(0); + } else { + return (MessageFlags) 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; @@ -784,217 +745,182 @@ /** * 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.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.or(c0); } - objs = doSelect(criteria, dbcon); + objs = doSelect(criteria, dbcon); } return objs; } - /** * retrieve object using using pk values. - * - * @param mailboxId long - * @param uid long - */ - public static MessageFlags retrieveByPK( - long mailboxId - , long uid - ) throws TorqueException - { + * + * @param mailboxId + * long + * @param uid + * long + */ + public static MessageFlags retrieveByPK(long mailboxId, long uid) + throws TorqueException { Connection db = null; MessageFlags retVal = null; - try - { - db = Torque.getConnection(DATABASE_NAME); - retVal = retrieveByPK( - mailboxId - , uid - , db); - } - finally - { + try { + db = Torque.getConnection(DATABASE_NAME); + retVal = retrieveByPK(mailboxId, uid, db); + } finally { Torque.closeConnection(db); } return retVal; } - /** + /** * retrieve object using using pk values. - * - * @param mailboxId long - * @param uid long - * @param con Connection - */ - public static MessageFlags retrieveByPK( - long mailboxId - , long uid - ,Connection con) throws TorqueException - { + * + * @param mailboxId + * long + * @param uid + * long + * @param con + * Connection + */ + public static MessageFlags retrieveByPK(long mailboxId, long uid, + Connection con) throws TorqueException { Criteria criteria = new Criteria(5); - criteria.add(MAILBOX_ID, mailboxId); - criteria.add(UID, uid); - List v = doSelect(criteria, con); - if (v.size() == 1) - { + criteria.add(MAILBOX_ID, mailboxId); + criteria.add(UID, uid); + List v = doSelect(criteria, con); + if (v.size() == 1) { return (MessageFlags) v.get(0); - } - else - { + } else { throw new TorqueException("Failed to select one and only one row."); } } - - - - - - - /** * selects a collection of MessageFlags 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 MessageFlagsPeer. - * - * @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 + * MessageFlagsPeer. + * + * @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 MessageFlags 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 MessageFlagsPeer. - * - * @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 + * MessageFlagsPeer. + * + * @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); MessageFlagsPeer.addSelectColumns(criteria); int offset = numColumns + 1; MessageRowPeer.addSelectColumns(criteria); - criteria.addJoin(MessageFlagsPeer.MAILBOX_ID, - MessageRowPeer.MAILBOX_ID); - criteria.addJoin(MessageFlagsPeer.UID, - MessageRowPeer.UID); - + criteria + .addJoin(MessageFlagsPeer.MAILBOX_ID, MessageRowPeer.MAILBOX_ID); + criteria.addJoin(MessageFlagsPeer.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 = MessageFlagsPeer.getOMClass(); - MessageFlags obj1 = (MessageFlags) MessageFlagsPeer - .row2Object(row, 1, omClass); - omClass = MessageRowPeer.getOMClass(); - MessageRow obj2 = (MessageRow) MessageRowPeer - .row2Object(row, offset, omClass); + Class omClass = MessageFlagsPeer.getOMClass(); + MessageFlags obj1 = (MessageFlags) MessageFlagsPeer.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++) { MessageFlags temp_obj1 = (MessageFlags) 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.addMessageFlags(obj1); - break; + temp_obj2.addMessageFlags(obj1); + break; } } - if (newObject) - { + if (newObject) { obj2.initMessageFlagss(); obj2.addMessageFlags(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]
