import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
private Long nextAvailableSequenceNumber(String sequenceName, Class clazz) {
       ModuleService moduleService = getKualiModuleService().getResponsibleModuleService(clazz);
       if ( moduleService == null )
       	throw new ConfigurationException("moduleService is null");
       	        	
       ModuleConfiguration moduleConfig = moduleService.getModuleConfiguration();
       if ( moduleConfig == null )
       	throw new ConfigurationException("moduleConfiguration is null");

       String dataSourceName = moduleConfig.getDataSourceName();

       if (StringUtils.isEmpty(dataSourceName)) {
           return nextAvailableSequenceNumber(sequenceName);
       } else {
           PBKey key = new PBKey(dataSourceName);
           PersistenceBroker broker = OjbFactoryUtils.getPersistenceBroker(key, false);

           if (broker != null) {
               return getDbPlatform().getNextValSQL(sequenceName, broker);
           } else {
               throw new ConfigurationException("PersistenceBroker is null");
           }
       }
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
/**
 * Return all objects for the given class.
 */
public Collection getAllObjects(Class target)
{
    PersistenceBroker broker = getBroker();
    Collection result;
    try
    {
        Query q = new QueryByCriteria(target);
        result = broker.getCollectionByQuery(q);
    }
    finally
    {
        if (broker != null) broker.close();
    }
    return result;
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
/**
 * If users want to implement clone on all their objects, we can use this
 * to make copies. This is hazardous as user may mess it up, but it is also
 * potentially the fastest way of making a copy.
 *
 * Usually the OjbCloneable interface should just be delegating to the clone()
 * operation that the user has implemented.
 *
 * @see org.apache.ojb.otm.copy.ObjectCopyStrategy#copy(Object)
 *
 */
public Object copy(Object obj, PersistenceBroker broker)
		throws ObjectCopyException
{
	if (obj instanceof OjbCloneable)
	{
		try
		{
			return ((OjbCloneable) obj).ojbClone();
		}
		catch (Exception e)
		{
			throw new ObjectCopyException(e);
		}
	}
	else
	{
		throw new ObjectCopyException("Object must implement OjbCloneable in order to use the"
									  + " CloneableObjectCopyStrategy");
	}
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
/**
 * @ejb:interface-method
 */
public Collection getPersons(String firstname, String lastname)
{
    PersistenceBroker broker = getBroker();
    Criteria criteria = new Criteria();
    if (firstname != null) criteria.addEqualTo("firstname", firstname);
    if (lastname != null) criteria.addEqualTo("firstname", lastname);
    Query q = new QueryByCriteria(PersonVO.class);
    Collection result = broker.getCollectionByQuery(q);
    broker.close();
    return result;
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
/**
 * test to check PB create with PBKey
 */
public void testLookupPB1()
{
    PBKey key1 = new PBKey(TestHelper.DEF_JCD_ALIAS);
    PBKey key2 = new PBKey(TestHelper.DEF_JCD_ALIAS, TestHelper.DEF_USER, TestHelper.DEF_PASSWORD);
    PBKey key3 = new PBKey(TestHelper.FAR_AWAY_JCD_ALIAS);
    Query query = QueryFactory.newQuery(TEST_CLASS, new Criteria());

    PersistenceBroker broker = PersistenceBrokerFactory.createPersistenceBroker(key1);
    broker.getCount(query);
    broker.close();

    broker = PersistenceBrokerFactory.createPersistenceBroker(key2);
    broker.getCount(query);
    broker.close();

    broker = PersistenceBrokerFactory.createPersistenceBroker(key3);
    broker.getCount(query);
    broker.close();
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
/**
 * In managed environment do internal close the used connection
 */
private void internalCleanup()
{
    if(hasBroker())
    {
        PersistenceBroker broker = getBroker();
        if(log.isDebugEnabled())
        {
            log.debug("Do internal cleanup and close the internal used connection without" +
                    " closing the used broker");
        }
        ConnectionManagerIF cm = broker.serviceConnectionManager();
        if(cm.isInLocalTransaction())
        {
            /*
            arminw:
            in managed environment this call will be ignored because, the JTA transaction
            manager control the connection status. But to make connectionManager happy we
            have to complete the "local tx" of the connectionManager before release the
            connection
            */
            cm.localCommit();
        }
        cm.releaseConnection();
    }
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
public SequenceManagerHandle(PersistenceBroker broker, Class targetClass, int loops)
{
    this.broker = broker;
    this.targetClass = targetClass;
    this.field = broker.getClassDescriptor(targetClass).getAutoIncrementFields()[0];
    if(field == null)
    {
        String error = "No autoincrement field found for class "+targetClass+
        " using class descriptor from given broker: "+broker.getClassDescriptor(targetClass);
        throw new PersistenceBrokerException(error);
    }
    this.loops = loops;
    resultList = new ArrayList();
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
public void execute(PersistenceBroker broker)
{
    if(isUnlink)
    {
        broker.serviceBrokerHelper().unlink(source, (CollectionDescriptor) ord, referenceToLink);
    }
    else
    {
        broker.serviceBrokerHelper().link(source, (CollectionDescriptor) ord, referenceToLink);
    }
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
public void execute(PersistenceBroker broker)
{
    if(isUnlink)
    {
        broker.serviceBrokerHelper().unlink(referenceToLink, ord, false);
    }
    else
    {
        broker.serviceBrokerHelper().link(referenceToLink, ord, false);
    }
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
/**
 * buildObjectImage() will return the image of the Object.
 */
private Map buildObjectImage(PersistenceBroker broker) throws PersistenceBrokerException
{
    Map imageMap = new HashMap();
    ClassDescriptor cld = broker.getClassDescriptor(getObject().getClass());
    //System.out.println("++++ build image: " + getObject());
    // register 1:1 references in image
    buildImageForSingleReferences(imageMap, cld);
    // put object values to image map
    buildImageForFields(imageMap, cld);
    // register 1:n and m:n references in image
    buildImageForCollectionReferences(imageMap, cld);
    return imageMap;
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
/**
* @see com.sun.jdori.StoreManager#insert(BitSet, BitSet, StateManagerInternal)
*/
public synchronized int insert(
    BitSet loadedFields,
    BitSet dirtyFields,
    StateManagerInternal sm)
{

    try
    {
        logger.debug("OjbStoreManager.insert");
        PersistenceBroker broker = connector.getBroker();
        Object instance = sm.getObject();
        broker.store(instance, ObjectModificationDefaultImpl.INSERT);
    }
    catch (Exception ex)
    {
        throw new OjbStoreFatalInternalException(getClass(), "insert", ex); 
    }
    dirtyFields.xor(dirtyFields);
    return StateManagerInternal.FLUSHED_COMPLETE;
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
protected int getDBObjectCountWithNewPB(PBKey pbKey, Class target) throws Exception
{
    PersistenceBroker broker = PersistenceBrokerFactory.createPersistenceBroker(pbKey);
    Criteria c = new Criteria();
    Query q = new QueryByCriteria(target, c);
    int count = broker.getCount(q);
    broker.close();
    return count;
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
public void changeReferenceSetting(PersistenceBroker broker, Class clazz,
                                           String referenceField, boolean autoRetrieve,
                                           int autoUpdate, int autoDelete, boolean useProxy)
        {
            ClassDescriptor cld = broker.getClassDescriptor(clazz);
            ObjectReferenceDescriptor ref = cld.getCollectionDescriptorByName(referenceField);
            ref = cld.getCollectionDescriptorByName(referenceField);
            if(ref == null) ref = cld.getObjectReferenceDescriptorByName(referenceField);
            if(ref == null)
            {
                throw new OJBRuntimeException("Given field " + referenceField + " does not match a reference in " + clazz);
            }

            prepareSetting(ref, cld, clazz, referenceField);

            ref.setLazy(useProxy);
            ref.setCascadeRetrieve(autoRetrieve);
            ref.setCascadingStore(autoUpdate);
            ref.setCascadingDelete(autoDelete);

//            System.out.println("old settings: " + oldRef.toXML());
//            System.out.println("new settings: " + ref.toXML());
        }
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
public PerfArticle getArticleByIdentity(Long articleId) throws Exception
        {
//            m_tx.setImplicitLocking(false);
//            m_tx.begin();
//            OQLQuery query = odmg.newOQLQuery();
//            String sql = "select allArticles from " + PerfArticleImpl.class.getName() +
//                    " where articleId=$";
//            query.create(sql);
//            query.bind(articleId);
//            List result = (List) query.execute();
//            m_tx.commit();
//            return (PerfArticle) result.get(0);
// use OJB's extension for faster Identity lookup
            PerfArticle result;
            m_tx.setImplicitLocking(false);
            m_tx.begin();
            PersistenceBroker pb = m_tx.getBroker();
            result = (PerfArticle) pb.getObjectByIdentity(pb.serviceIdentity().buildIdentity(PerfArticleImpl.class, articleId));
            m_tx.commit();
            return result;
        }
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
private Class getElementsExtentClass(PersistenceBroker broker) throws PersistenceBrokerException
{
    // we ll have to compute the most general extent class here !!!
    DListEntry entry = (DListEntry) elements.get(0);
    Class elementsClass = entry.getRealSubject().getClass();
    Class extentClass = broker.getTopLevelClass(elementsClass);
    return extentClass;
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
public SequenceManagerHighLowImpl(PersistenceBroker broker)
{
    super(broker);
    Long start = SequenceManagerHelper.getSeqStart(getConfigurationProperties());
    sequenceStart = start != null ? start.longValue() : 1;
    grabSize = Integer.parseInt(getConfigurationProperty(PROPERTY_GRAB_SIZE, "20"));
    useGlobalSequenceIdentities = Boolean.getBoolean(getConfigurationProperty(PROPERTY_GLOBAL_SEQUENCE_ID, "false"));
    // support for deprecated properties
    long globalSequenceStart = Long.parseLong(getConfigurationProperty(PROPERTY_GLOBAL_SEQUENCE_START, "1"));
    if(useGlobalSequenceIdentities && globalSequenceStart > sequenceStart)
    {
        sequenceStart = globalSequenceStart;
    }
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
/**
 * This test only works, when using
 * {@link org.apache.ojb.broker.util.sequence.SequenceManagerNextValImpl}
 * for sequence generation.
 */
public void testDatabaseSequenceGeneration() throws Exception
{
    PersistenceBroker broker = PersistenceBrokerFactory.defaultPersistenceBroker();
    SequenceManager sm = SequenceManagerFactory.getSequenceManager(broker);
    if (!(sm instanceof SequenceManagerNextValImpl))
    {
        System.out.println("This test only works for SeqMan implementations using "
                + SequenceManagerNextValImpl.class + " Skip test case.");
        broker.close();
        return;
    }
    int count = 0;
    FieldDescriptor idFld = broker.getClassDescriptor(
            Repository.SMDatabaseSequence.class).getAutoIncrementFields()[0];
    for (int i = 0; i < 10; i++)
    {
        Integer val = (Integer) sm.getUniqueValue(idFld);
        count += val.intValue();
        System.err.println("count " + count);
    }
    assertFalse("No keys generated", count == 0);
    broker.close();
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
/**
 * @see org.apache.ojb.broker.ManageableCollection#afterStore(PersistenceBroker broker)
 */
public void afterStore(PersistenceBroker broker) throws PersistenceBrokerException
{
    // make sure allObjectsToBeRemoved does not contain
    // any instances that got re-added to the list
    allObjectsToBeRemoved.removeAll(this);

    Iterator iter = allObjectsToBeRemoved.iterator();
    while (iter.hasNext())
    {
        Object obj = iter.next();
        ClassDescriptor cld = broker.getClassDescriptor(obj.getClass());
        if (broker.serviceBrokerHelper().assertValidPkForDelete(cld, obj))
        {    
            broker.delete(obj);
        }    
    }
    allObjectsToBeRemoved.clear();
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
/**
 * Calls the stored procedure stored procedure throws an
 * error if it doesn't exist.
 * @param broker
 * @param cld
 * @param sequenceName
 * @return
 * @throws LookupException
 * @throws SQLException
 */
protected long buildNextSequence(PersistenceBroker broker, ClassDescriptor cld, String sequenceName)
        throws LookupException, SQLException, PlatformException
{
    CallableStatement cs = null;
    try
    {
        Connection con = broker.serviceConnectionManager().getConnection();
        cs = getPlatform().prepareNextValProcedureStatement(con, PROCEDURE_NAME, sequenceName);
        cs.executeUpdate();
        return cs.getLong(1);
    }
    finally
    {
        try
        {
            if (cs != null)
                cs.close();
        }
        catch (SQLException ignore)
        {
            // ignore it
        }
    }
}
 

import org.apache.ojb.broker.PersistenceBroker; //导入依赖的package包/类
public Collection readArticlesByCursor(String articleName) throws Exception
{
    Criteria c = new Criteria();
    c.addLike("articleName", articleName);
    Query q = new QueryByCriteria(PerfArticleImpl.class, c);

    Collection col = null;
    PersistenceBroker broker = null;
    try
    {
        broker = PersistenceBrokerFactory.defaultPersistenceBroker();
        col = broker.getCollectionByQuery(q);
    }
    finally
    {
        if (broker != null) broker.close();
    }
    return col;
}