Oracle Streams AQ.session.getQueue, выбрасывающий AQOracleSQLException: исчерпанный результат - PullRequest
Новая
       22

Oracle Streams AQ.session.getQueue, выбрасывающий AQOracleSQLException: исчерпанный результат

0 голосов
/ 06 апреля 2011

Используя Oracle Streams AQ в многопоточной среде / среде с несколькими приложениями, я получил AQOracleSQLException: исчерпанный Resultset после примерно 10 минут работы только в одном потоке. 

oracle.AQ.AQOracleSQLException: Exhausted Resultset
        at oracle.AQ.AQOracleSession.getQueue(AQOracleSession.java:751)
        at au.com.xxx.queue.OracleQueue$$anonfun$2.apply(OracleQueue.scala:53)

AQOracleSession объединяется в пулчерез Spring следующим образом: 

<bean id="dataSource" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName" value="jdbc/MessageManagerDB"/>
</bean>

<bean id="aqSessionFactory" class="au.com.xxx.queue.AQSessionFactory">
    <constructor-arg ref="dataSource"/>
</bean>

<bean id="aqSessionTarget" factory-bean="aqSessionFactory" 
    factory-method="createAQSession" scope="prototype"/>

<bean id="aqSessionPoolTargetSource" 
    class="org.springframework.aop.target.CommonsPoolTargetSource">
    <property name="targetBeanName" value="aqSessionTarget"/>
    <property name="maxSize" value="25"/>
</bean>

<bean id="aqSession" class="org.springframework.aop.framework.ProxyFactoryBean">
    <property name="targetSource" ref="aqSessionPoolTargetSource"/>
</bean>

При заводском методе createAQSession (в Scala): 

def createAQSession = {
  val wasConnection = dataSource.getConnection.asInstanceOf[WSJdbcConnection]
  val connection = WSCallHelper.getNativeConnection(wasConnection).asInstanceOf[Connection]
  SessionWithConnection(AQDriverManager.createAQSession(connection), connection)
  // SessionWithConnection is just a case class akin to 
  // Tuple2[AQOracleSession, Connection]
}

Исключение было сгенерировано из последней строки этого блока: 

def sessionAndConnection = {
  applicationContext.getBean("aqSession").asInstanceOf[SessionWithConnectionI]
}

def write(category: String, relatedId: Option[String], payload: String): Array[Byte] = {
  val (session, conn) = {
    val sc = sessionAndConnection
    (sc.session, sc.connection)
  }
  val queueDef = dao.queueForWriting(category, relatedId).map{_.name}
  val queue = queueDef.map{name => session.getQueue("QUSR", name)}

Очевидно, я не обращаюсь непосредственно к ResultSet, используемому в AQOracleSession.

I am , используя Connection, связанный с Session, но это не до тех пор, пока в том же методе, и поэтому не может быть виноват здесь: 

val clob = CLOB.createTemporary(conn, true, CLOB.DURATION_SESSION)

Возможно ли, что конфигурация пула не является правильной, и было несколько параллельных операций на том жесессия?В других журналах не было ничего необычного.

1 Ответ

0 голосов
/ 14 апреля 2011

Это дефект драйвера v10, который я использовал по ошибке.В драйвере СУБД v11 такой проблемы нет.

...