commit 08aaba61b77b96e81cd26de7add4093823066c15
author Thomas Dudziak <tomdz@apache.org> Tue Sep 04 04:53:58 2007 +0000
committer Thomas Dudziak <tomdz@apache.org> Tue Sep 04 04:53:58 2007 +0000
tree 292709eb22b4c3d484f34d3a3b31d170b011f882
parent b055db20fefeb856b8dd5de6041835c3f3f7b0aa

Check for existence of connection before trying to close it

git-svn-id: https://svn.apache.org/repos/asf/db/ddlutils/trunk@572520 13f79535-47bb-0310-9956-ffa450edef68

src/java/org/apache/ddlutils/io/DataToDatabaseSink.java

diff --git a/src/java/org/apache/ddlutils/io/DataToDatabaseSink.java b/src/java/org/apache/ddlutils/io/DataToDatabaseSink.java
index 1f8ef96..bde5a1e 100644
--- a/src/java/org/apache/ddlutils/io/DataToDatabaseSink.java
+++ b/src/java/org/apache/ddlutils/io/DataToDatabaseSink.java
@@ -210,13 +210,16 @@
     public void end() throws DataSinkException

     {

         purgeBatchQueue();

-        try

+        if (_connection != null)

         {

-            _connection.close();

-        }

-        catch (SQLException ex)

-        {

-            throw new DataSinkException(ex);

+            try

+            {

+                _connection.close();

+            }

+            catch (SQLException ex)

+            {

+                throw new DataSinkException(ex);

+            }

         }

         if (!_waitingObjects.isEmpty())

         {