Re: CachedRowSet Concurrency
On Nov 14, 11:18 am, Lew <l...@lewscanon.com> wrote:
cksanjose wrote:
I have an application that starts a new process every 15 minutes. I
create a new thread for each process so it is possible that they will
run concurrently. I have a data access layer that returns a
CachedRowSet object. When I only have 1 process running, the program
is fine. As soon as another process starts, I start getting errors in
the data access layer. I get an exception in
"com.sun.rowset.CachedRowSetImpl.populate".
What is the exact message from the exception?
What are the first few exact lines of the stack trace?
My data access layer method looks like this:
We might need an SSCCE to answer this. We certainly need to know what the
error is.
<http://www.physci.org/codes/sscce.html>
Creating an SSCCE often helps one discover an answer as they're documenting
the question.
public RowSet retrieve(String sql)
{
Connection connection = null;
Oh, please do not use TAB characters in Usenet listings!
ResultSet resultset = null;
CachedRowSet rowset = null;
Statement statement = null;
try
{
connection = Current.getConnection();
Hmm - a mysterious undocumented class with a black-box method. There's no way
this could in any way be involved with the problem.
statement =
connection.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY);
resultset = statement.executeQuery(sql);
You may wish to read up on "SQL Injection attacks".
rowset = new CachedRowSetImpl();
rowset.populate(resultset);
resultset.close();
statement.close();
Note that exceptions could leave the ResultSet or the Statement not close()d.
What would that induce?
}
catch (SQLException sqle)
{
sqle.printStackTrace();
You should also emit the message and the SQL error code.
}
finally
{
connection = null;
What do you imagine that this accomplishes?
The variable goes out of scope anyway. The assignment accomplishes nothing,
and indeed might be optimized away.
}
return rowset;
}
--
Lew
Lew,
Thanks for the quick response.
The stack trace is listed but the inner exception error is
ConversionBufferFullException.
The error is:
com.ibm.db2.jcc.b.SqlException
at com.ibm.db2.jcc.b.s.a(s.java:1517)
at com.ibm.db2.jcc.b.s.n(s.java:532)
at com.ibm.db2.jcc.b.s.W(s.java:1436)
at com.ibm.db2.jcc.b.kf.a(kf.java:1135)
at com.ibm.db2.jcc.b.kf.getObject(kf.java:1122)
at com.sun.rowset.CachedRowSetImpl.populate(CachedRowSetImpl.java:
646)
at com.gaic.crop.ewa.eWADataAccess.retrieve(eWADataAccess.java:97)
at com.gaic.crop.ewa.eWADataAccess.retrieve(eWADataAccess.java:64)
at
com.gaic.crop.ewa.eWARecordTypeFactory08.buildAcreageRecords(eWARecordTypeFactory08.java:
650)
at
com.gaic.crop.ewa.eWARecordTypeFactory08.build(eWARecordTypeFactory08.java:
160)
at com.gaic.crop.ewa.eWAJob.run(eWAJob.java:128)
at java.util.concurrent.ThreadPoolExecutor
$Worker.runTask(ThreadPoolExecutor.java:650)
at java.util.concurrent.ThreadPoolExecutor
$Worker.run(ThreadPoolExecutor.java:675)
at java.lang.Thread.run(Thread.java:595)