import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * Returns an Object array of all FK field values of the specified object.
 * If the specified object is an unmaterialized Proxy, it will be materialized
 * to read the FK values.
 *
 * @throws MetadataException if an error occours while accessing ForeingKey values on obj
 */
public Object[] getForeignKeyValues(Object obj, ClassDescriptor mif)
        throws PersistenceBrokerException
{
    FieldDescriptor[] fks = getForeignKeyFieldDescriptors(mif);
    // materialize object only if FK fields are declared
    if(fks.length > 0) obj = ProxyHelper.getRealObject(obj);
    Object[] result = new Object[fks.length];
    for (int i = 0; i < result.length; i++)
    {
        FieldDescriptor fmd = fks[i];
        PersistentField f = fmd.getPersistentField();

        // BRJ: do NOT convert.
        // conversion is done when binding the sql-statement
        //
        // FieldConversion fc = fmd.getFieldConversion();
        // Object val = fc.javaToSql(f.get(obj));

        result[i] = f.get(obj);
    }
    return result;
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * Determines the number of elements that the query would return. Override this
 * method if the size shall be determined in a specific way.
 * 
 * @return The number of elements
 */
protected synchronized int loadSize() throws PersistenceBrokerException
{
    PersistenceBroker broker = getBroker();
    try
    {
        return broker.getCount(getQuery());
    }
    catch (Exception ex)
    {
        throw new PersistenceBrokerException(ex);
    }
    finally
    {
        releaseBroker(broker);
    }
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
* @see org.apache.ojb.broker.accesslayer.OJBIterator#absolute(int)
*/
  public boolean absolute(int row) throws PersistenceBrokerException
  {
      int newPosition = (m_startAt - 1) + row;
      
      if (newPosition < m_startAt)
      {
          newPosition = Math.max(m_endAt + row, m_startAt - 1);
      }
      
      if (newPosition > m_endAt)
      {
          newPosition = m_endAt;
      }
      
      m_currentCursorPosition = newPosition;
      return m_iterator.absolute(newPosition);
  }
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * returns an Object[] representing the columns of the current ResultSet row.
 * There is no OJB object materialization, Proxy generation etc. involved
 * to maximize performance.
 */
protected Object getObjectFromResultSet() throws PersistenceBrokerException
{
    Object[] result = new Object[columnCount];
    for (int i = 0; i < columnCount; i++)
    {
        try
        {
            int jdbcType = rsMetaData.getColumnType(i + 1);
            Object item = JdbcTypesHelper.getObjectFromColumn(getRsAndStmt().m_rs, new Integer(jdbcType), i + 1);
            result[i] = item;
        }
        catch (SQLException e)
        {
            throw new PersistenceBrokerException(e);
        }
    }
    return result;
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * create either a CollectionPrefetcher or a ReferencePrefetcher
 */ 
public RelationshipPrefetcher createRelationshipPrefetcher(ClassDescriptor anOwnerCld, String aRelationshipName)
{
    ObjectReferenceDescriptor ord;
    
    ord = anOwnerCld.getCollectionDescriptorByName(aRelationshipName);
    if (ord == null)
    {
        ord = anOwnerCld.getObjectReferenceDescriptorByName(aRelationshipName);
        if (ord == null)
        {
            throw new PersistenceBrokerException("Relationship named '" + aRelationshipName
                    + "' not found in owner class " + (anOwnerCld != null ? anOwnerCld.getClassNameOfObject() : null));
        }
    }
    return createRelationshipPrefetcher(ord);
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * returns a proxy or a fully materialized Object from the current row of the
 * underlying resultset.
 */
protected Object getObjectFromResultSet() throws PersistenceBrokerException
{

    try
    {
        // if all primitive attributes of the object are contained in the ResultSet
        // the fast direct mapping can be used
        return super.getObjectFromResultSet();
    }
            // if the full loading failed we assume that at least PK attributes are contained
            // in the ResultSet and perform a slower Identity based loading...
            // This may of course also fail and can throw another PersistenceBrokerException
    catch (PersistenceBrokerException e)
    {
        Identity oid = getIdentityFromResultSet();
        return getBroker().getObjectByIdentity(oid);
    }

}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * returns an Identity object representing the current resultset row
 */
protected Identity getIdentityFromResultSet() throws PersistenceBrokerException
{
    // fill primary key values from Resultset
    FieldDescriptor fld;
    FieldDescriptor[] pkFields = getQueryObject().getClassDescriptor().getPkFields();
    Object[] pkValues = new Object[pkFields.length];

    for (int i = 0; i < pkFields.length; i++)
    {
        fld = pkFields[i];
        pkValues[i] = getRow().get(fld.getColumnName());
    }

    // return identity object build up from primary keys
    return getBroker().serviceIdentity().buildIdentity(
            getQueryObject().getClassDescriptor().getClassOfObject(), getTopLevelClass(), pkValues);
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * @see org.apache.ojb.broker.util.configuration.Configurable#configure(Configuration)
 * looks up the the key getConfigurationKey() in the OjbConfiguration
 * to determine the Class to be served.
 */
public void configure(Configuration pConfig) throws ConfigurationException
{
    if (getConfigurationKey() == null)
    {
        getLogger().error("ConfigurableFactory configuration key is 'null'");
        throw new PersistenceBrokerException("ConfigurableFactory configuration key is 'null'");
    }
    Class clazz = pConfig.getClass(getConfigurationKey(), null);
    if (clazz == null)
    {
        getLogger().error("ConfigurableFactory configuration key class for key'" + getConfigurationKey() + "' does not exist.");
        throw new PersistenceBrokerException(
                "ConfigurableFactory configuration key class for key'" + getConfigurationKey() + "' does not exist.");
    }
    this.setClassToServe(clazz);
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * Implementation of the OJB beforeInsert hook which delegates to {@link #prePersist()}.  This method is final
 * because it is recommended that sub-classes override and implement prePersist if they need to take
 * advantage of this persistence hook.
 *
 * @see org.apache.ojb.broker.PersistenceBrokerAware#beforeInsert(org.apache.ojb.broker.PersistenceBroker)
 */
@Override
@LegacyDataFramework
public final void beforeInsert(PersistenceBroker persistenceBroker) throws PersistenceBrokerException {
    //setObjectId(UUID.randomUUID().toString());
    setObjectId(null);
    prePersist();
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * This method checks whether newly added object code already exists in Object Level table
 *
 * @param chartCode
 * @param objectCode
 * @return false if this object code already exists in the object level table
 */
public boolean objectLevelTableDoesNotHave(String chartCode, String objectCode) {
    try {
        ObjectLevel objLevel = objectLevelService.getByPrimaryId(chartCode, objectCode);
        if (objLevel != null) {
            objLevel.getFinancialObjectLevelCode(); // this might throw an Exception when proxying is in effect
            return false;
        }
    }
    catch (PersistenceBrokerException e) {
        // intentionally ignore the Exception
    }

    return true;
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 *
 * This checks to see if the next year object code already exists in the next fiscal year
 * @param year
 * @param chartCode
 * @param objCode
 * @return false if this object code exists in the next fiscal year
 */
public boolean nextYearObjectCodeDoesNotExistThisYear(Integer year, String chartCode, String objCode) {
    try {
        ObjectCode objectCode = objectCodeService.getByPrimaryId(year, chartCode, objCode);
        if (objectCode != null) {
            return false;
        }
    }
    catch (PersistenceBrokerException e) {
        // intentionally ignore the Exception
    }
    return true;
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
protected void buildReportsTotal(PendingBudgetConstructionAppointmentFunding pendingAppointmentFunding, BudgetConstructionAccountSalaryDetailReport accountMonthlyDetailReport, Collection<BudgetConstructionAccountSalaryDetailReportTotal> accountSalaryDetailTotal) {

        for (BudgetConstructionAccountSalaryDetailReportTotal totalEntry : accountSalaryDetailTotal) {
            if (BudgetConstructionReportHelper.isSameEntry(totalEntry.getPendingBudgetConstructionAppointmentFunding(), pendingAppointmentFunding, fieldsForTotal())) {

                String objectCodeName = StringUtils.EMPTY;
                if (pendingAppointmentFunding.getFinancialObject() != null) {
                    try {
                        objectCodeName = pendingAppointmentFunding.getFinancialObject().getFinancialObjectCodeName();
                    }
                    catch (PersistenceBrokerException e) {
                        objectCodeName = kualiConfigurationService.getPropertyValueAsString(BCKeyConstants.ERROR_REPORT_GETTING_OBJECT_NAME);
                    }
                }
                else {
                    objectCodeName = BCConstants.Report.OBJECT + BCConstants.Report.NOT_DEFINED;
                }
                accountMonthlyDetailReport.setTotalDescription(objectCodeName);

                accountMonthlyDetailReport.setTotalBaseAmount(totalEntry.getTotalBaseAmount());
                accountMonthlyDetailReport.setTotalBaseFte(totalEntry.getTotalBaseFte());
                accountMonthlyDetailReport.setTotalRequestAmount(totalEntry.getTotalRequestAmount());
                accountMonthlyDetailReport.setTotalRequestFte(totalEntry.getTotalRequestFte());

                accountMonthlyDetailReport.setTotalAmountChange(totalEntry.getTotalRequestAmount() - totalEntry.getTotalBaseAmount());
                accountMonthlyDetailReport.setTotalPercentChange(BudgetConstructionReportHelper.calculatePercent(accountMonthlyDetailReport.getTotalAmountChange(), totalEntry.getTotalBaseAmount()));
            }
        }
    }
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
public void testSwizzle3() throws TransactionException, LockingException, PBFactoryException, PersistenceBrokerException
  {
      clearTestData();
      TestClassA a = generateTestData();
      Transaction tx = _kit.getTransaction(_conn);
      tx.begin();
      _conn.makePersistent(a.getB());
      _conn.makePersistent(a);
TestClassB b = a.getB();
      tx.commit();
      /**
      * clear to start test
      */
      _conn.invalidateAll();
      tx = _kit.getTransaction(_conn);
      tx.begin();
      /**
 * load B
 */
Identity oidb = _conn.getIdentity(b);
      TestClassB b1 = (TestClassB) _conn.getObjectByIdentity(oidb);
      assertTrue(b1 != null);
/**
 * load A
	 */
Identity oida = _conn.getIdentity(a);
TestClassA a1 = (TestClassA) _conn.getObjectByIdentity(oida);

/**
 * B, as navigated from A, should be the same as B gotten directly.
 */
assertTrue(a1.getB().equals(b1));
      tx.commit();

/**
 * clear
 */
      clearTestData();
  }
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * Find the index of the specified name in field name array.
 */
private int findIndexForName(String[] fieldNames, String searchName)
{
    for(int i = 0; i < fieldNames.length; i++)
    {
        if(searchName.equals(fieldNames[i]))
        {
            return i;
        }
    }
    throw new PersistenceBrokerException("Can't find field name '" + searchName +
            "' in given array of field names");
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * Deletes collections of objects poiting to <b>obj</b>.
 * All object which have a FK poiting to this object (Via CollectionDescriptors)
 * will be deleted if auto-delete is true <b>AND</b>
 * the member field containing the object reference if NOT null.
 *
 * @param obj Object which we will delete collections for
 * @param listCds list of ObjectReferenceDescriptors
 * @throws PersistenceBrokerException if some goes wrong - please see the error message for details
 */
private void deleteCollections(Object obj, List listCds) throws PersistenceBrokerException
{
    // get all members of obj that are collections and delete all their elements
    Iterator i = listCds.iterator();

    while (i.hasNext())
    {
        CollectionDescriptor cds = (CollectionDescriptor) i.next();
        if(cds.getCascadingDelete() != ObjectReferenceDescriptor.CASCADE_NONE)
        {
            if(cds.isMtoNRelation())
            {
                // if this is a m:n mapped table, remove entries from indirection table
                mtoNBroker.deleteMtoNImplementor(cds, obj);
            }
            /*
            if cascading delete is on, delete all referenced objects.
            NOTE: User has to take care to populate all referenced objects before delete
            the main object to avoid referential constraint violation
             */
            if (cds.getCascadingDelete() == ObjectReferenceDescriptor.CASCADE_OBJECT)
            {
                Object col = cds.getPersistentField().get(obj);
                if (col != null)
                {
                    Iterator colIterator = BrokerHelper.getCollectionIterator(col);
                    while (colIterator.hasNext())
                    {
                        doDelete(colIterator.next(), false);
                    }
                }
            }
        }
    }
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
public void buildReportsBody(BudgetConstructionOrgList2PLGReport orgList2PLGReportEntry, BudgetConstructionTwoPlugListMove twoPlugListMoveEntry) {
        orgList2PLGReportEntry.setAccountNumber(twoPlugListMoveEntry.getAccountNumber());
        orgList2PLGReportEntry.setSubAccountNumber(twoPlugListMoveEntry.getSubAccountNumber());
//        orgList2PLGReportEntry.setAccountSubAccountName(twoPlugListMoveEntry.getAccount().getAccountName());

        if (twoPlugListMoveEntry.getSubAccountNumber().equals(KFSConstants.getDashSubAccountNumber())) {
            if (twoPlugListMoveEntry.getAccount().getAccountName() == null) {
                orgList2PLGReportEntry.setAccountSubAccountName(kualiConfigurationService.getPropertyValueAsString(BCKeyConstants.ERROR_REPORT_GETTING_ACCOUNT_DESCRIPTION));
            }
            else {
                orgList2PLGReportEntry.setAccountSubAccountName(twoPlugListMoveEntry.getAccount().getAccountName());
            }
        }
        else {
            try {
                if (twoPlugListMoveEntry.getSubAccount().getSubAccountName() == null) {
                    orgList2PLGReportEntry.setAccountSubAccountName(kualiConfigurationService.getPropertyValueAsString(BCKeyConstants.ERROR_REPORT_GETTING_SUB_ACCOUNT_DESCRIPTION));
                }
                else {
                    orgList2PLGReportEntry.setAccountSubAccountName(twoPlugListMoveEntry.getSubAccount().getSubAccountName());
                }
            }
            catch (PersistenceBrokerException e) {
                orgList2PLGReportEntry.setAccountSubAccountName(kualiConfigurationService.getPropertyValueAsString(BCKeyConstants.ERROR_REPORT_GETTING_SUB_ACCOUNT_DESCRIPTION));
            }
        }

        orgList2PLGReportEntry.setReqAmount(new Integer(twoPlugListMoveEntry.getAccountLineAnnualBalanceAmount().intValue()));
    }
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * Deletes the concrete representation of the specified object in the underlying
 * persistence system. This method is intended for use in top-level api or
 * by internal calls.
 *
 * @param obj The object to delete.
 * @param ignoreReferences With this flag the automatic deletion/unlinking
 * of references can be suppressed (independent of the used auto-delete setting in metadata),
 * except {@link org.apache.ojb.broker.metadata.SuperReferenceDescriptor}
 * these kind of reference (descriptor) will always be performed. If <em>true</em>
 * all "normal" referenced objects will be ignored, only the specified object is handled.
 * @throws PersistenceBrokerException
 */
public void delete(Object obj, boolean ignoreReferences) throws PersistenceBrokerException
{
    if(isTxCheck() && !isInTransaction())
    {
        if(logger.isEnabledFor(Logger.ERROR))
        {
            String msg = "No running PB-tx found. Please, only delete objects in context of a PB-transaction" +
                " to avoid side-effects - e.g. when rollback of complex objects.";
            try
            {
                throw new Exception("** Delete object without active PersistenceBroker transaction **");
            }
            catch(Exception e)
            {
                logger.error(msg, e);
            }
        }
    }
    try
    {
        doDelete(obj, ignoreReferences);
    }
    finally
    {
        markedForDelete.clear();
    }
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * Lookup all tables associated with given class (search all extent classes)
 * to find the current maximum value for the given field.
 * <br><b>Note:</b> Only works for <code>long</code> autoincrement fields.
 * @param brokerForClass persistence broker instance match the database of the
 * given field/class
 * @param field the target field
 */
public static long getMaxForExtent(PersistenceBroker brokerForClass, FieldDescriptor field) throws PersistenceBrokerException
{
    if (field == null)
    {
        log.error("Given FieldDescriptor was null, could not detect max value across all extents");
        return 0;
        // throw new PersistenceBrokerException("Given FieldDescriptor was null");
    }
    // first lookup top-level class
    Class topLevel = brokerForClass.getTopLevelClass(field.getClassDescriptor().getClassOfObject());
    return getMaxId(brokerForClass, topLevel, field);
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * Constructor declaration
 */
public DescriptorRepository() throws PersistenceBrokerException
{
    descriptorTable = new HashMap();
    extentTable = new HashMap();
    superClassMultipleJoinedTablesMap = new HashMap();
}
 

import org.apache.ojb.broker.PersistenceBrokerException; //导入依赖的package包/类
/**
 * @see org.apache.ojb.broker.core.proxy.CollectionProxyDefaultImpl#loadData()
 */
protected Collection loadData() throws PersistenceBrokerException
{
    Collection result = super.loadData();

    if (result instanceof List)
    {
        return result;
    }
    else
    {
        throw new PersistenceBrokerException("loaded data does not implement java.util.List");
    }

}