Hi,
My java program is a data load program which daily runs and inserts/updates data in DB2 tables using hibernate.
Now while data load , we expect there might be ConstraintViolationException, So I am pasting the code which I am using to insert below.
public boolean insert() {
logger.debug("Attempting to INSERT the session: " + getDObject());
try {
Session hibSession = HibernateUtil.currentSession();
Transaction tx = hibSession.beginTransaction();
logger.debug("successfully began the transaction ");
hibSession.save(getDObject());
hibSession.flush();
logger.debug("successfully flushed the session" );
hibSession.clear();
tx.commit();
} catch(ConstraintViolationException e){
logger.error("ConstraintViolation Exception encountered while inserting database object.", e);
return false;
}
catch (JDBCException e) {
logger.error("JDBC Exception encountered while inserting database object.", e);
HibernateUtil.jdbcExceptionHandler(e);
return false;
} catch (HibernateException e) {
logger.error("Problem inserting object " + dObject, e);
e.printStackTrace();
return false;
}
logger.debug("INSERT successful for the session: " + getDObject());
return true;
}
HibernateUtil Methods
public static Session currentSession() throws HibernateException {
Session s = (Session) threadLocal.get();
logger.debug("The session value is " + s);
// System.err.println("Getting session for "+s+" thread = "+Thread.currentThread());
try {
// Check if the connection is closed
if(s!=null)
{
logger.debug(" The connection is Closed " + s.connection().isClosed());
}
// Open a new Session, if this Thread has none yet
if (s == null) {
logger.debug("The session value is null so opening a new session");
s = sessionFactory.openSession();
logger.debug("successfully opened the session");
threadLocal.set(s);
logger.debug("successfully set the value in localthread");
}
} catch (JDBCException e) {
System.err.println("Am unable to create a session due to JDBC Exception");
jdbcExceptionHandler(e);
}
logger.debug(" Final returned session value is " + s);
return s;
}
public static void jdbcExceptionHandler(JDBCException e) {
logger.error("Problem with JDBC Connection. SQL error code=" + e.getErrorCode(), e);
try {
HibernateUtil.closeSession();
} catch (HibernateException he) {
logger.error("Problem trying to close session", he);
}
// -803 indicates that the entry already exists. No point exiting over existing entry
if (e.getErrorCode() != -803) {
// logger.error("SQL error code=" + e.getErrorCode() + " fatal error has occured ");
// Commented these lines to test the daily load in Production
logger.error("SQL error code=" + e.getErrorCode() + " exiting");
systemExit(2);
}
}
static public synchronized void systemExit(int code) {
logger.fatal("Runtime.getRuntime().halt(2)...");
Runtime.getRuntime().halt(2);
}
So the main program loops over a arrayList and calls this insert one by one, when we encounter ConstraintViolationException we just catch it and return false. so it proceeds to insert the next object in the loop. But this code works fine in UAT environment but in Production as soon as the first constraintViolation occurs the next time the connection is closed.
I even tried closing the connection in the catch(ConstraintViolationException e) block. In such case I get the following exception.
[IBM][CLI Driver] SQL1040N The maximum number of applications is already connected to the database. SQLSTATE=57030
at COM.ibm.db2.jdbc.app.SQLExceptionGenerator.throw_SQLException(Unknown Source)
at COM.ibm.db2.jdbc.app.SQLExceptionGenerator.check_return_code(Unknown Source)
at COM.ibm.db2.jdbc.app.DB2Connection.connect(Unknown Source)
at COM.ibm.db2.jdbc.app.DB2Connection.<init>(Unknown Source)
at COM.ibm.db2.jdbc.app.DB2Driver.connect(Unknown Source)
at com.mchange.v2.c3p0.DriverManagerDataSource.getConnection(DriverManagerDataSource.java:68)
at com.mchange.v2.c3p0.WrapperConnectionPoolDataSource.getPooledConnection(WrapperConnectionPoolDataSource.java:87)
at com.mchange.v2.c3p0.impl.C3P0PooledConnectionPool$1.acquireResource(C3P0PooledConnectionPool.java:83)
at com.mchange.v2.resourcepool.BasicResourcePool.assimilateResource(BasicResourcePool.java:884)
at com.mchange.v2.resourcepool.BasicResourcePool.acquireUntil(BasicResourcePool.java:601)
at com.mchange.v2.resourcepool.BasicResourcePool.access$400(BasicResourcePool.java:31)
at com.mchange.v2.resourcepool.BasicResourcePool$AcquireTask.run(BasicResourcePool.java:1079)
at com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread.run(ThreadPoolAsynchronousRunner.java:354)
COM.ibm.db2.jdbc.DB2Exception: [IBM][CLI Driver] SQL1040N The maximum number of applications is already connected to the database. SQLSTATE=57030My Hibernate config file entries are as follows :<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
<session-factory>
<!-- properties -->
<!-- Connection driver depending on which database java driver you are using -->
<property name="connection.driver_class">COM.ibm.db2.jdbc.app.DB2Driver</property>
<!-- Hibernate dialect class. This differs depending on the type of database being used -->
<property name="dialect">org.hibernate.dialect.DB2Dialect</property>
<!-- If true, displays all generated SQL to System.out -->
<property name="show_sql">true</property>
<property name="cglib.use_reflection_optimizer">false</property>
<!-- All c3po properties required to optimize connection pooling -->
<property name="c3p0.minPoolSize">5</property>
<property name="c3p0.maxPoolSize">40</property>
<property name="c3p0.timeout">30</property>
<property name="c3p0.idle_test_period">3000</property>
<property name="c3p0.maxIdleTime">5000</property>
<property name="c3p0.maxPoolSize">40</property>
<property name="c3p0.maxStatements">27</property>
<property name="c3p0.forceIgnoreUnresolvedTransactions">true</property>
<property name="c3p0.acquire_increment">1</property>
<property name="c3p0.idle_test_period">1000</property> <!-- seconds -->
<property name="c3p0.max_size">100</property>
<property name="c3p0.max_statements">20</property>
<property name="c3p0.min_size">10</property>
<property name="c3p0.timeout">100</property> <!-- seconds -->
<!-- my local test DB -->
<property name="connection.url">jdbc:db2:sample</property>
<property name="connection.connect2">DB2ADMIN</property>
<property name="connection.connectDetails2">db2admin</property>
<!-- The database jdbc url so hibernate knows where to persist -->
<!-- Encoded user_name -->
<!-- Encoded authentication pass_word -->
<!-- starting of code added by jihe -->
<property name="connection.useUnicode">true</property>
<property name="connection.characterEncoding">UTF-8</property>
<!-- stopping of code added by jihe -->
<!-- The names of all the mapping files used to map java classes to tables and establish their relationships -->
<mapping resource="iiw.hbm.xml"/>
</session-factory>
</hibernate-configuration>
It is a very urgent issue. Any Help will be greatly appreciated.
Thanks in advance!
Sudipto
Login
FAQ
Search
