Integration test on JDBC (No Hibernate !) and Spring AbstractTransactionalJUnit4SpringContextTests

[Stephane Eybert]

Hi,

I'm trying to set up an integration test against a MySql database with a pure JDBC dao, that is, NOT using Hibernate or any ORM tool.

My base abstract test class uses the AbstractTransactionalJUnit4SpringContextTests class so as to have tests that roll back.

public abstract class AbstractDaoTest extends AbstractTransactionalJUnit4SpringContextTests {

}

Spring requires a transactionManager bean which I provide.

	<bean id="transactionManager"
		class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource" />
	</bean>

But I get an exception.

com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: No operations allowed after connection closed.
	at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
	at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39)
	at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)
	at java.lang.reflect.Constructor.newInstance(Constructor.java:513)
	at com.mysql.jdbc.Util.handleNewInstance(Util.java:411)
	at com.mysql.jdbc.Util.getInstance(Util.java:386)
	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1013)
	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:987)
	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:982)
	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:927)
	at com.mysql.jdbc.ConnectionImpl.throwConnectionClosedException(ConnectionImpl.java:1205)
	at com.mysql.jdbc.ConnectionImpl.checkClosed(ConnectionImpl.java:1197)
	at com.mysql.jdbc.ConnectionImpl.setAutoCommit(ConnectionImpl.java:4954)

Do I need to provide some connection pooling ?

Is there any way to do it with a Spring bean ?

Kind Regards,

Stephane

[Rob Spoor]

You're calling setAutoCommit on a Connection that's already closed.

[Stephane Eybert]

How come is the connection closed ?

	public void insert(GInnAdresse gInnAdresse) throws SesamSqlException {
		String sql = "insert into g_inn_adresse values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, null);";
		Connection connection = null;
		try {
			connection = dataSource.getConnection();
			connection.setAutoCommit(false);
			PreparedStatement preparedStatement = connection.prepareStatement(sql);
			preparedStatement.setInt(1, gInnAdresse.getId());
			preparedStatement.setString(2, gInnAdresse.getOpprettet());
			preparedStatement.setInt(3, gInnAdresse.getAdr_id());
			preparedStatement.setString(4, gInnAdresse.getNbr_id());
			preparedStatement.setInt(5, gInnAdresse.getKun_kundenr());
			preparedStatement.setInt(6, gInnAdresse.getAns_id());
			preparedStatement.setString(7, gInnAdresse.getKde_id());
			preparedStatement.setString(8, gInnAdresse.getKua_k_adr_type());
			preparedStatement.setString(9, gInnAdresse.getLnd_kode());
			preparedStatement.setString(10, gInnAdresse.getPos_postnr());
			preparedStatement.setString(11, gInnAdresse.getAdr_adr1());
			preparedStatement.setString(12, gInnAdresse.getAdr_adr2());
			preparedStatement.setString(13, gInnAdresse.getAdr_tlf());
			preparedStatement.setString(14, gInnAdresse.getAdr_fax());
			preparedStatement.setString(15, gInnAdresse.getAdr_utl());
			preparedStatement.setString(16, gInnAdresse.getAdr_endret_dato());
			preparedStatement.executeUpdate();
			connection.commit();
			preparedStatement.close();
		} catch (SQLException e) {
			throwCustomException(connection, e);
		} finally {
			if (connection != null) {
				try {
					connection.close();
				} catch (SQLException e) {
	            	ExceptionUtils.printRootCauseStackTrace(e);
				}
			}
			try {
				connection.setAutoCommit(true);
			} catch (SQLException e) {
				ExceptionUtils.printRootCauseStackTrace(e);
			}
		}
	}

[Rob Spoor]

Because line 32 comes before line 38.

[Stephane Eybert]

Fair enough :-) Thanks !

[Rob Spoor]

You're welcome