com.franz.agraph.pool

Class AGConnFactory

java.lang.Object

com.franz.agraph.pool.AGConnFactory

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.commons.pool.PoolableObjectFactory

public class AGConnFactory
extends Object
implements org.apache.commons.pool.PoolableObjectFactory, Closeable

Adapts the AGRepositoryConnection API to the commons-pool factory interface, leaving creation of the connection (and configuration) to a subclass, defined by users of this library.

Since:

v4.3.3

Constructor Summary

Constructors

Constructor and Description
AGConnFactory(AGConnConfig props)
AGConnFactory(AGConnConfig props, AGPoolConfig poolProps)

Method Summary

Modifier and Type	Method and Description
void	activateObject(Object obj) Calls AGRepositoryConnection.rollback() and resets AGRepositoryConnection.setAutoCommit(boolean) if it has changed.
void	close() Release resources.
void	destroyObject(Object obj)
Object	makeObject()
void	passivateObject(Object obj)
boolean	validateObject(Object obj) Calls AGRepositoryConnection.size(org.eclipse.rdf4j.model.Resource...).

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AGConnFactory

public AGConnFactory(AGConnConfig props)

AGConnFactory

public AGConnFactory(AGConnConfig props,
                     AGPoolConfig poolProps)

Method Detail

makeObject

public Object makeObject()
                  throws Exception

Specified by:

makeObject in interface org.apache.commons.pool.PoolableObjectFactory

Throws:

Exception

activateObject

public void activateObject(Object obj)
                    throws Exception

Calls AGRepositoryConnection.rollback() and resets AGRepositoryConnection.setAutoCommit(boolean) if it has changed.

Specified by:

activateObject in interface org.apache.commons.pool.PoolableObjectFactory

Throws:

Exception

destroyObject

public void destroyObject(Object obj)
                   throws Exception

Specified by:

destroyObject in interface org.apache.commons.pool.PoolableObjectFactory

Throws:

Exception

passivateObject

public void passivateObject(Object obj)
                     throws Exception

Specified by:

passivateObject in interface org.apache.commons.pool.PoolableObjectFactory

Throws:

Exception

validateObject

public boolean validateObject(Object obj)

Calls AGRepositoryConnection.size(org.eclipse.rdf4j.model.Resource...).

Specified by:

validateObject in interface org.apache.commons.pool.PoolableObjectFactory

close

public void close()
           throws IOException

Release resources.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException