Changeset 9858 for branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/metadata

Timestamp:

2005-05-12T14:52:45+12:00 (19 years ago)

Author:

kjdon

Message:

OK, changed my mind about making SQLConnection kill off the previous statement.
To make it more transparent what is happening, you now have to create a Statement (connection.createStatement()), then use the Statement to execute the query. This means that the thing doing the query owns the Statement, and can kill it off when finished with it, and nothing else can kill it off unexpectedly. The previous way this was all implemented meant that there was a large memory leak, and some functionality actually relied on this. A newer version of the mysql connector/J has fixed the bug where the statement wasn't closed on garbage collection, but it still seems better to close it explicitly.
Hopefully I have got it all back to working as well as it was bfore, and haven't introduced any bugs :-)

Location:

branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/metadata

Files:

• METSDescriptive.java (modified) (7 diffs)
• METSDescriptiveSet.java (modified) (2 diffs)
• METSDivision.java (modified) (8 diffs)
• METSFile.java (modified) (6 diffs)
• METSFileGroup.java (modified) (10 diffs)
• METSFileSet.java (modified) (5 diffs)
• METSNamespace.java (modified) (5 diffs)
• METSStructure.java (modified) (7 diffs)
• METSStructureSet.java (modified) (2 diffs)
• SimpleNamespace.java (modified) (4 diffs)

branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/metadata/METSDescriptive.java

@@ -8 +8 @@
 
 import java.sql.SQLException;
+import java.sql.Statement;
 import java.sql.ResultSet;
 
@@ -275 +276 @@
         } else {
         // TODO: raise an error!
-        System.out.println("Error: METSDescriiptive: unrecognised tag "+childName);
+        System.out.println("Error: METSDescriptive: unrecognised tag "+childName);
         }
     }
@@ -375 +376 @@
     select.setWhere(where);
     
-    connection.execute(select.toString());
-    
     try {
+        Statement statement = connection.createStatement();
+        ResultSet resultSet = statement.executeQuery(select.toString());
         GS3SQLAction action;
         
-        ResultSet resultSet = connection.getResultSet();
-        
-        if (resultSet != null &&
-        resultSet.first()) {
+        if (resultSet.first()) {
         // the node already exists - no need to do anything as such
         GS3SQLUpdate update = new GS3SQLUpdate("metadata");
@@ -390 +388 @@
         }
         else { // Set result set to null, just in case first() didn't work above...
-        resultSet = null;
-        
         // It is a new node and needs writing
         action = new GS3SQLInsert("metadata");
@@ -403 +399 @@
         
         // execute the action as required
-        connection.execute(action.toString());
+        statement.execute(action.toString());
         
         // get the resultSet again
@@ -409 +405 @@
         // 'MetadataRef'
         // System.out.println(select.toString());
-        connection.execute(select.toString());
-        
-        resultSet = connection.getResultSet();
-        resultSet.first();
-        
-        
-        // get the reference for this item...
-        sqlId = resultSet.getInt("MetadataRef");
-        connection.closeStatement();
+        resultSet = statement.executeQuery(select.toString());
+        
+        if (resultSet.first()) {
+        // get the reference for this item...
+        sqlId = resultSet.getInt("MetadataRef");
+        }
+        statement.close();
     }
     catch (SQLException sql){
-        System.out.println(sql);
+        System.err.println("METSDescriptive.writeSQL(): "+sql);
+    }
+    if (sqlId == -1) {
+        return false;
     }
     
@@ -470 +467 @@
         select.setWhere(where);
         
-        connection.execute(select.toString());
-        
-        // parse through the namespaces, calling the namespace class to create instances
-        // as it will
-        ResultSet namespaceSet = connection.getResultSet();
-
-        // clone the connection cos we are still usign the old result set
-        GS3SQLConnection cloned_connection = connection.cloneConnection();
-
-        if (namespaceSet != null && namespaceSet.first()) {
+        Statement statement = connection.createStatement();
+        ResultSet namespaceSet = statement.executeQuery(select.toString());
+        
+        // parse through the namespaces, calling the namespace class to create instances as it will
+        if (namespaceSet.first()) {
         do {
-            METSNamespace namespace = METSNamespace.readSQL(cloned_connection, namespaceSet);
+            METSNamespace namespace = METSNamespace.readSQL(connection, namespaceSet);
             if (namespace != null) {
             descriptive.addNamespace(namespace);
             }
             else {
-            System.out.println("Null namespace output");
+            System.err.println("Null namespace output");
             }
         }
         while (namespaceSet.next());
         }
-        cloned_connection.close();
-        cloned_connection = null;
+        statement.close();
         return descriptive;
     }
     catch (SQLException sqlEx){
-        System.out.println(sqlEx);
-        sqlEx.printStackTrace();
+        System.err.println("METSDescriptive.readSQL(): "+sqlEx);
         System.exit(1);
     }

branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/metadata/METSDescriptiveSet.java

@@ -9 +9 @@
 
 import java.sql.SQLException;
+import java.sql.Statement;
 import java.sql.ResultSet;
 
@@ -236 +237 @@
     GS3SQLWhereItem whereItem = new GS3SQLWhereItem("DocID", "=", document.getID().toString());
     select.setWhere(new GS3SQLWhere(whereItem));
-    connection.execute(select.toString());
-    
-    // clone the connection cos we are still using the old result set
-    GS3SQLConnection cloned_connection = connection.cloneConnection();
 
     // start going through the matching metadata blocks
     try {
-        ResultSet resultSet = connection.getResultSet();
-        resultSet.first();
-        do {
-        METSDescriptive descriptive = METSDescriptive.readSQL(document, cloned_connection, resultSet);
-        if (descriptive != null) {
-            set.addDescriptive(descriptive);
-        }
-        else {
-            System.out.println("Null descriptive");
-        }
-        } while (resultSet.next());
-        
-        connection.closeStatement();
+        Statement statement = connection.createStatement();
+        ResultSet resultSet = statement.executeQuery(select.toString());
+        if (resultSet.first()) {
+        do {
+            METSDescriptive descriptive = METSDescriptive.readSQL(document, connection, resultSet);
+            if (descriptive != null) {
+            set.addDescriptive(descriptive);
+            }
+            else {
+            System.out.println("Null descriptive");
+            }
+        } while (resultSet.next());
+        }
+        statement.close();
     }
     catch (SQLException sqlEx) {
-        System.out.println(sqlEx);
-        sqlEx.printStackTrace();
+        System.err.println("METSDescriptiveSet.readSQL(): "+sqlEx);
         System.exit(1);
     }

branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/metadata/METSDivision.java

@@ -10 +10 @@
 
 import java.sql.SQLException;
+import java.sql.Statement;
 import java.sql.ResultSet;
 
@@ -475 +476 @@
     select.setWhere(where);
     
-    connection.execute(select.toString());
+    Statement statement = null;
+    ResultSet resultSet = null;
     
     // Do the actual writing
     GS3SQLAction action;
     
-    ResultSet resultSet = connection.getResultSet();
     try {
-        if (resultSet == null ||
-        !resultSet.first()) {
-        if (resultSet != null) {
-            resultSet.close();
-            resultSet = null;
-        }
+        statement = connection.createStatement();
+        resultSet = statement.executeQuery(select.toString());
+        if (!resultSet.first()) {
         
         GS3SQLInsert insert = new GS3SQLInsert("divisions");
@@ -517 +515 @@
     action.addValue("UserLabel", this.userLabel);
     
-    if (!connection.execute(action.toString())){
+    try {
+        statement.execute(action.toString());
+    } catch (SQLException e) {
+        System.err.println("METSDivision.writeSQL(): "+e);
         return false;
     }
     
     // if doing a fresh item, get the new structure reference...
-    if (resultSet == null){
+    if (sqlRef == -1){
         // get the new structure reference
-        connection.execute(select.toString());
-        
-        // get the sql reference for the division
         try {
         // read in the structure reference
-        resultSet = connection.getResultSet();
-        if (resultSet == null) {
-            return false;
+        resultSet = statement.executeQuery(select.toString());
+        if (resultSet.first()) {
+            sqlRef = resultSet.getInt("DivisionRef");
         }
-        resultSet.first();
-        sqlRef = resultSet.getInt("DivisionRef");
-        resultSet.close();
-        resultSet = null;
         }
         catch (SQLException sqlex) {
-        System.err.println("Unable to retrieve reference for Division " + sqlex);
+        System.err.println("METSDIVISION.writeSQL(): Unable to retrieve reference for Division " + sqlex);
         return false;
         }
     }
-    // close the open resultSet, as we don't need it any longer...
-    else {
-        try {
-        resultSet.close();
-        }
-        catch (SQLException sql) {
-        System.err.println(sql + " " + select.toString());
-        }
-    }
     
     // delete the old file/metadata references
-    GS3SQLWhere referenceWhere = 
-        new GS3SQLWhere(new GS3SQLWhereItem("DivisionRef", "=", Integer.toString(sqlRef), 
-                        GS3SQLField.INTEGER_TYPE));
-    
-    GS3SQLDelete delete = new GS3SQLDelete("divisionfilerefs");
-    delete.setWhere(referenceWhere);
-    connection.execute(delete.toString());
-    
-    delete = new GS3SQLDelete("divisionmetarefs");
-    delete.setWhere(referenceWhere);
-    connection.execute(delete.toString());
-    
-    // write the new file references
-    if (this.fileRefs.size() > 0){
-        Iterator iterator = this.fileRefs.iterator();
-        
-        while (iterator.hasNext()) {
-        GS3SQLInsert fileinsert = new GS3SQLInsert("divisionfilerefs");
-        fileinsert.addValue("DocID", docId.toString());
-        fileinsert.addValue("DivisionRef", Integer.toString(sqlRef), GS3SQLField.INTEGER_TYPE);
-        fileinsert.addValue("DivisionType", "Group");
-        fileinsert.addValue("FileID", iterator.next().toString());
-        connection.execute(fileinsert.toString());
-        }
-    }
-    
-    // write the metadata references
-    if (this.metadataRefs.size() > 0){
-        Iterator iterator = this.metadataRefs.iterator();
-        
-        while (iterator.hasNext()) {
-        GS3SQLInsert metainsert = new GS3SQLInsert("divisionmetarefs");
-        metainsert.addValue("DocID", docId.toString());
-        metainsert.addValue("DivisionRef", Integer.toString(sqlRef), GS3SQLField.INTEGER_TYPE);
-        metainsert.addValue("DivisionType", "Group");
-        metainsert.addValue("MetaID", iterator.next().toString());
-        connection.execute(metainsert.toString());
-        }
-    }
-    
+    try {
+        GS3SQLWhere referenceWhere = 
+        new GS3SQLWhere(new GS3SQLWhereItem("DivisionRef", "=", Integer.toString(sqlRef), 
+                            GS3SQLField.INTEGER_TYPE));
+        
+        GS3SQLDelete delete = new GS3SQLDelete("divisionfilerefs");
+        delete.setWhere(referenceWhere);
+        
+        statement.execute(delete.toString());
+        
+        delete = new GS3SQLDelete("divisionmetarefs");
+        delete.setWhere(referenceWhere);
+        statement.execute(delete.toString());
+    
+        // write the new file references
+        if (this.fileRefs.size() > 0){
+        Iterator iterator = this.fileRefs.iterator();
+        
+        while (iterator.hasNext()) {
+            GS3SQLInsert fileinsert = new GS3SQLInsert("divisionfilerefs");
+            fileinsert.addValue("DocID", docId.toString());
+            fileinsert.addValue("DivisionRef", Integer.toString(sqlRef), GS3SQLField.INTEGER_TYPE);
+            fileinsert.addValue("DivisionType", "Group");
+            fileinsert.addValue("FileID", iterator.next().toString());
+            statement.execute(fileinsert.toString());
+        }
+        }
+        
+        // write the metadata references
+        if (this.metadataRefs.size() > 0){
+        Iterator iterator = this.metadataRefs.iterator();
+        
+        while (iterator.hasNext()) {
+            GS3SQLInsert metainsert = new GS3SQLInsert("divisionmetarefs");
+            metainsert.addValue("DocID", docId.toString());
+            metainsert.addValue("DivisionRef", Integer.toString(sqlRef), GS3SQLField.INTEGER_TYPE);
+            metainsert.addValue("DivisionType", "Group");
+            metainsert.addValue("MetaID", iterator.next().toString());
+            statement.execute(metainsert.toString());
+        }
+        }
+        statement.close();
+    } catch (SQLException e) {
+        System.err.println("METSDIVISION.writeSQL(): "+e);
+        return false;
+    }
     // write out any children in turn
     Iterator groups = this.children.values().iterator();
@@ -635 +626 @@
         select.setWhere(where);
 
-        connection.execute(select.toString());
+        Statement statement = connection.createStatement();
+        ResultSet childSet = statement.executeQuery(select.toString());
       
         // circulate through to obtain further children
-        ResultSet childSet = connection.getResultSet();
-        // clone the connection cos we are still usign the old result set
-        GS3SQLConnection cloned_connection = connection.cloneConnection();
-
         if (childSet.first())
         {
             do {
-            METSDivision childDivision = METSDivision.readSQL(cloned_connection, childSet);
+            METSDivision childDivision = METSDivision.readSQL(connection, childSet);
             division.addDivision(childDivision);
             }
             while (childSet.next());
         }
-
-        cloned_connection.close();
-        cloned_connection = null;
         select = new GS3SQLSelect("divisionfilerefs");
         select.addField("*");
@@ -659 +644 @@
         select.setWhere(where);
 
-        connection.execute(select.toString());
-
-        ResultSet fileSet = connection.getResultSet();
-        if (fileSet != null && fileSet.first()){
+        ResultSet fileSet = statement.executeQuery(select.toString());
+
+        if (fileSet.first()){
         do {
             String reference = fileSet.getString("FileID");
@@ -669 +653 @@
         while (fileSet.next());  
         }
-
+        
         select = new GS3SQLSelect("divisionmetarefs");
         select.addField("*");
@@ -676 +660 @@
         select.setWhere(where);
 
-        connection.execute(select.toString());
-
-        ResultSet metaSet = connection.getResultSet();
-        if (metaSet != null && metaSet.first()){
+        ResultSet metaSet = statement.executeQuery(select.toString());
+
+        if (metaSet.first()){
         do {
             String reference = metaSet.getString("MetaID");
@@ -687 +670 @@
         }
         
-        connection.closeStatement();
+        statement.close();
         return division;
     }

branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/metadata/METSFile.java

@@ -11 +11 @@
 import java.sql.ResultSet;
 import java.sql.SQLException;
+import java.sql.Statement;
 
 import org.w3c.dom.Document;
@@ -201 +202 @@
     where.add(whereItem);
     select.setWhere(where);
-    connection.execute(select.toString());
+
+    Statement statement = null;
     
     // if not, then make an insert action
     try {
-        ResultSet results = connection.getResultSet();
-        if (results == null ||
-        !results.first()){
+        statement = connection.createStatement();
+        ResultSet results = statement.executeQuery(select.toString());
+        if (!results.first()){
         GS3SQLInsert insert = new GS3SQLInsert("files");
         
@@ -223 +225 @@
     }
     catch (SQLException ex){
-        System.err.println(ex);
+        System.err.println("METSFile.writeSQL(): "+ex);
         return false;
     }
@@ -230 +232 @@
     action.addValue("MIMEType", this.MIMEType);
     
-    boolean return_val = connection.execute(action.toString());
-    connection.closeStatement();
-    return return_val;
+    try {
+        statement.execute(action.toString());
+        statement.close();
+        
+    } catch (SQLException e) {
+        System.err.println("METSFile.writeSQL():"+e);
+        return false;
+    }
+    return true;
     }
     
@@ -250 +258 @@
     }
     catch (SQLException ex){
-        System.out.println(ex);
+        System.out.println("METSFile.readSQL(): "+ex);
     }
     catch (java.net.MalformedURLException urlEx){
-        System.out.println(urlEx);
+        System.out.println("METSFile.readSQL(): "+urlEx);
     }
     return null;
@@ -311 +319 @@
     } catch (java.net.MalformedURLException ex) {
         // TODO: raise error
-        System.err.println(ex);
+        System.err.println("METSFile.parse_flocateXML(): "+ex);
     }
     return thisFilePos;

branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/metadata/METSFileGroup.java

@@ -8 +8 @@
 
 import java.sql.SQLException;
+import java.sql.Statement;
 import java.sql.ResultSet;
 
@@ -271 +272 @@
     { 
     int sqlId = -1;
-    
     // check if this node is in the database already
     GS3SQLSelect select = new GS3SQLSelect("filegroups");
@@ -281 +281 @@
     select.setWhere(where);
     
-    connection.execute(select.toString());
-    
-    ResultSet selectResult = connection.getResultSet();
+    ResultSet results = null;
+    Statement statement = null;
     
     try {
-        if (selectResult == null ||
-        !selectResult.first()) {
+        statement = connection.createStatement();
+        results = statement.executeQuery(select.toString());
+        if (!results.first()) {
         GS3SQLInsert insert = new GS3SQLInsert("filegroups");
         
@@ -295 +295 @@
         insert.addValue("ParentType", parentIsSection ? SECTION_PARENT : GROUP_PARENT);
         
-        if (!connection.execute(insert.toString())) {
-            return false;
-        }
+        statement.execute(insert.toString());
         }
         else {
@@ -304 +302 @@
     }
     catch (SQLException ex){
-        System.err.println(ex);
+        System.err.println("METSFileGroup.writeSQL(): "+ex);
         return false;
     }
     
     // get the filegroup reference now
-    connection.execute(select.toString());
-    
     try {
-        ResultSet results = connection.getResultSet();
-        if (results == null) {
+        results = statement.executeQuery(select.toString());
+        if (results.first()) {
+        sqlId = results.getInt("FileGroupRef");
+        } else {
+        statement.close();
         return false;
         }
-        results.first();
-        sqlId = results.getInt("FileGroupRef");
-    }
-    catch (SQLException sqlex) {
-        System.out.println(sqlex);
+        statement.close();
+    } catch (SQLException sqlex) {
+        System.err.println("METSFileGroup.writeSQL(): "+sqlex);
         return false;
     }
-    
     // iterate over the child groups
     Iterator childIter = childGroups.iterator();
@@ -330 +326 @@
         
         if (!fileGroup.writeSQL(document, Integer.toString(sqlId), false, connection)){
+        System.err.println("METSFileGroup.writeSQL(): Couldn't write FileGroup");
         return false;
         }
@@ -337 +334 @@
     childIter = children.iterator();
     while (childIter.hasNext()){
-        METSFile file = (METSFile) childIter.next();
-        
+        METSFile file = (METSFile) childIter.next();        
         if (!file.writeSQL(sqlId, connection)){
+        System.err.println("METSFileGroup.writeSQL(): Couldn't write File");
         return false;
         }
@@ -371 +368 @@
         select.setWhere(where);
         
-        connection.execute(select.toString());
+        Statement statement = connection.createStatement();
         
         // parse through the child groups
-        ResultSet childSet = connection.getResultSet();
-        // clone the connection cos we are still usign the old result set
-        GS3SQLConnection cloned_connection = connection.cloneConnection();
+        ResultSet childSet = statement.executeQuery(select.toString());
         if (childSet.first()) {
         do {
-            METSFileGroup fileGroup = METSFileGroup.readSQL(document, cloned_connection, childSet);
+            METSFileGroup fileGroup = METSFileGroup.readSQL(document, connection, childSet);
             if (fileGroup != null) {
             group.addGroup(fileGroup);
@@ -386 +381 @@
         while (childSet.next());
         }
-        
         // now scan for file members
         select = new GS3SQLSelect("files");
         select.addField("*");
-        whereItem = new GS3SQLWhereItem("FileGroupRef", "=", Integer.toString(groupRef),
-                        GS3SQLField.INTEGER_TYPE);
+        whereItem = new GS3SQLWhereItem("FileGroupRef", "=", Integer.toString(groupRef), GS3SQLField.INTEGER_TYPE);
         where = new GS3SQLWhere(whereItem);
         select.setWhere(where);
-        connection.execute(select.toString());
-        
-        ResultSet childFileSet = connection.getResultSet();
-        if (childFileSet != null && childFileSet.first()) {
+        ResultSet childFileSet = statement.executeQuery(select.toString());
+        if (childFileSet.first()) {
         do {
-            METSFile file = METSFile.readSQL(cloned_connection, childFileSet);
+            METSFile file = METSFile.readSQL(connection, childFileSet);
             if (file != null) {
             group.addFile(file);
@@ -406 +397 @@
         while (childFileSet.next());
         }
-        cloned_connection.close();
-        cloned_connection = null;
+        statement.close();
         return group;
     }
     catch (SQLException sqlEx){
-        System.out.println(sqlEx);
+        System.err.println("METSFileGroup.readSQL(): "+sqlEx);
         System.exit(1);
     }

branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/metadata/METSFileSet.java

@@ -16 +16 @@
 
 import java.sql.SQLException;
+import java.sql.Statement;
 import java.sql.ResultSet;
 
@@ -232 +233 @@
         insert.addValue("FileSecID", "test"); // TODO: remove magic string
         
-        if (!connection.execute(insert.toString())){
+        Statement statement = null;
+        try {
+        statement = connection.createStatement();
+        statement.execute(insert.toString());
+        } catch (SQLException e) {
+        System.err.println("METSFileSet.writeSQL(): "+e);
         return false;
         }
@@ -246 +252 @@
         
         try {
-        connection.execute(select.toString());
-        
-        ResultSet set = connection.getResultSet();
-        set.first();
-        int sectionRef = set.getInt("FileSectionRef");
-        
-        this.reference = Integer.toString(sectionRef);
+        ResultSet set = statement.executeQuery(select.toString());
+        if (set.first()) {
+            int sectionRef = set.getInt("FileSectionRef");
+            
+            this.reference = Integer.toString(sectionRef);
+        }
+        statement.close();
         }
         catch (SQLException ex){
-        System.out.println(ex);
+        System.out.println("METSFileSet.writeSQL(): "+ex);
         return false;
         }
     }
     
+    if (this.reference == null) {
+        return false;
+    }
     // write out the children
     while (groups.hasNext()){
@@ -281 +290 @@
     GS3SQLWhereItem whereItem = new GS3SQLWhereItem("DocID", "=", document.getID().toString());
     select.setWhere(new GS3SQLWhere(whereItem));
-    connection.execute(select.toString());
+
+    Statement statement = null;
     
     // Get the identifier for this file set, etc.
-    ResultSet sections = connection.getResultSet();
-    int fileSetRef;
+    int fileSetRef = -1;
     try {
-        sections.first();
-        fileSetRef     = sections.getInt("FileSectionRef");
-        set.reference = Integer.toString(fileSetRef);
+        statement = connection.createStatement();
+        ResultSet sections = statement.executeQuery(select.toString());
+        if (sections.first()) {
+        fileSetRef = sections.getInt("FileSectionRef");
+        set.reference = Integer.toString(fileSetRef);
+        } else {
+        statement.close();
+        return null;
+        }
+        
     }
     catch (SQLException ex){
-        System.out.println(ex);
+        System.err.println("METSFileSet.readSQL() "+ex);
         return null;
     }
-    
     // Get child file groups
     select = new GS3SQLSelect("filegroups");
@@ -307 +322 @@
     where.add(whereItem);
     select.setWhere(where);
-    connection.execute(select.toString());
-    
     // start going through the matching file groups
-    // clone the connection cos we are still usign the old result set
-    GS3SQLConnection cloned_connection = connection.cloneConnection();
     try {
-        ResultSet resultSet = connection.getResultSet();
-        resultSet.first();
-        do {
-        METSFileGroup filegroup = METSFileGroup.readSQL(document, cloned_connection, resultSet);
-        if (filegroup != null) {
-            set.addGroup(filegroup);
-        }
-        } while (resultSet.next());
-
-        cloned_connection.close();
-        cloned_connection = null;
+        ResultSet resultSet = statement.executeQuery(select.toString());
+        if (resultSet.first()) {
+        do {
+            METSFileGroup filegroup = METSFileGroup.readSQL(document, connection, resultSet);
+            if (filegroup != null) {
+            set.addGroup(filegroup);
+            }
+        } while (resultSet.next());
+        }
+        statement.close();
     }
     catch (SQLException sqlEx) {
-        System.out.println(sqlEx);
-        sqlEx.printStackTrace();
+        System.out.println("METSFileSet.readSQL(): "+sqlEx);
         System.exit(1);
     }
-    
     return set;
     }

branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/metadata/METSNamespace.java

@@ -6 +6 @@
 import java.util.Iterator;
 import java.sql.SQLException;
+import java.sql.Statement;
 import java.sql.ResultSet;
 
@@ -150 +151 @@
 
     // Execute the action
-    connection.execute(action.toString());
-
+    Statement statement = null;
+    try {
+        statement = connection.createStatement();
+        statement.execute(action.toString());
+    } catch (SQLException e) {
+        System.err.println("METSNamespace.writeSQL(): "+e);
+        return false;
+    }
     // then get the namespace reference number if needsbe...
     if (this.id == null) {
@@ -161 +168 @@
         where.add(where);
         try {
-        connection.execute(select.toString());
-      
-        ResultSet result = connection.getResultSet();
-        result.last();
-        this.id = Integer.toString(result.getInt("NamespaceRef"));
+        ResultSet result  = statement.executeQuery(select.toString());
+            if (result.last()) {
+            this.id = Integer.toString(result.getInt("NamespaceRef"));
+        }
+        statement.close();
         }
         catch (SQLException sqlex){
         this.id = null;
-        System.err.println(sqlex);
+        System.err.println("METSNamespace.writeSQL(): "+sqlex);
         return false;
         }
@@ -201 +208 @@
         select.setWhere(where);
 
-        connection.execute(select.toString());
-      
-        ResultSet valuesSet = connection.getResultSet();
-        if (valuesSet != null && valuesSet.first()) {
+        Statement statement = connection.createStatement();
+        ResultSet valuesSet = statement.executeQuery(select.toString());
+        if (valuesSet.first()) {
         do {
             String label = valuesSet.getString("Label");
@@ -213 +219 @@
         while (valuesSet.next());
         }
-
+        statement.close();
         return namespace;
     }
     catch (java.net.MalformedURLException urlEx){
-        System.out.println(urlEx);
+        System.err.println("METSNamespace.readSQL(): "+urlEx);
     }
     catch (SQLException sqlEx){
-        System.out.println(sqlEx);
+        System.err.println("METSNamespace.readSQL(): "+sqlEx);
     }    
     return null;

branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/metadata/METSStructure.java

@@ -10 +10 @@
 
 import java.sql.SQLException;
+import java.sql.Statement;
 import java.sql.ResultSet;
 
@@ -180 +181 @@
     { 
     int sqlRef = -1;
-    ResultSet results;
-
+    ResultSet results = null;
+    Statement statement = null;
+    
     // Prepare query to see if this structure has already been written
     GS3SQLSelect select = new GS3SQLSelect("structure");
@@ -190 +192 @@
     where.add(item);
     select.setWhere(where);
-
+    
     // attempt to execute the query & get the current structure's reference
     try {
-        connection.execute(select.toString());
-        results = connection.getResultSet();
-        if (results != null &&
-        results.first()){
+        statement = connection.createStatement();
+        results = statement.executeQuery(select.toString());
+        if (results.first()){
         sqlRef = results.getInt("structureRef");
         }
-        else { 
-        results = null;
-        }
-        
-        if (results != null) {
-        results.close();
-        }
     }
     catch (SQLException sqlEx) {
-        System.err.print(sqlEx);
+        System.err.print("METSStructure.writeSQL(): "+sqlEx);
         return false;
     }
     
     // insert a new structure if it wasn't there previously
-    if (results == null) {
+    if (sqlRef == -1) {
         GS3SQLInsert insert = new GS3SQLInsert("structure");
         insert.addValue("DocID", document.getID().toString());
@@ -220 +214 @@
         insert.addValue("Label", this.label);
         
-        if (!connection.execute(insert.toString())) {
+        try {
+        statement.execute(insert.toString());
+        
+        // get the new structure reference by re-running the original select object
+        results = statement.executeQuery(select.toString());
+        if (results.first()) {
+            sqlRef = results.getInt("StructureRef");
+        } 
+        } catch (SQLException sqlEx) {
+        System.err.print("METSStructure.writeSQL(): "+sqlEx);
         return false;
         }
         
-        // get the new structure reference by re-running the original select object
-        connection.execute(select.toString());
-
-        try {
-        results = connection.getResultSet();
-        results.first();
-        sqlRef = results.getInt("StructureRef");
-        }
-        catch (SQLException sql) {
-        System.err.println(sql);
-        return false;
-        }
     }
     else {
@@ -244 +235 @@
         update.addValue("Label", this.label);
         
-        connection.execute(update.toString());
-    }
-    
+        try {
+        statement.execute(update.toString());
+        } catch (SQLException sqlEx) {
+        System.err.print("METSStructure.writeSQL(): "+sqlEx);
+        return false;
+        }
+    }
+    
+    // close the statement
+    try {
+        statement.close();
+    } catch (SQLException e) {
+        System.err.println("METSStructure.writeSQL(): "+e);
+    }
     // write out the child groups (Divisions) now...    
     Iterator groups = this.children.values().iterator();
@@ -296 +298 @@
         select.setWhere(where);
 
-        connection.execute(select.toString());
+        Statement statement = connection.createStatement();
+        ResultSet divisionSet = statement.executeQuery(select.toString());
 
         // parse through the divisions
-        ResultSet divisionSet = connection.getResultSet();
-        // use a new connection for the following bit, cos we still want to use results from the last execute
-        GS3SQLConnection cloned_connection = connection.cloneConnection();
-        if (divisionSet != null && divisionSet.first()) {
+        if (divisionSet.first()) {
         do {
-            METSDivision division = METSDivision.readSQL(cloned_connection, divisionSet);
+            METSDivision division = METSDivision.readSQL(connection, divisionSet);
             if (division != null) {
             structure.addDivision(division);
@@ -311 +311 @@
         while (divisionSet.next());
         }
-        cloned_connection.close();
-        cloned_connection = null;
+        statement.close();
         return structure;
     }
-    catch (SQLException sqlEx)
-        { System.out.println(sqlEx + " " + select.toString());
-        sqlEx.printStackTrace();
+    catch (SQLException sqlEx) {
+        System.err.println("METSStructure.readSQL(): "+ sqlEx + " " + select.toString());
         System.exit(1);
-        }
+    }
     return null;
     }

branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/metadata/METSStructureSet.java

@@ -10 +10 @@
 
 import java.sql.SQLException;
+import java.sql.Statement;
 import java.sql.ResultSet;
 
@@ -157 +158 @@
     GS3SQLWhereItem whereItem = new GS3SQLWhereItem("DocID", "=", document.getID().toString());
     select.setWhere(new GS3SQLWhere(whereItem));
-    connection.execute(select.toString());
-    // clone the connection cos we are still usign the old result set
-    GS3SQLConnection cloned_connection = connection.cloneConnection();
-
+    
     // start going through the matching metadata blocks
     try {
-        ResultSet resultSet = connection.getResultSet();
-        resultSet.first();
-        do {
-        METSStructure structure = METSStructure.readSQL(document, cloned_connection, resultSet);
-        if (structure != null) {
-            set.addStructure(structure);
-        }
-        } while (resultSet.next());
-        cloned_connection.close();
-        cloned_connection = null;
+        Statement statement = connection.createStatement();
+        ResultSet resultSet = statement.executeQuery(select.toString());
+        if (resultSet.first()) {
+        do {
+            METSStructure structure = METSStructure.readSQL(document, connection, resultSet);
+            if (structure != null) {
+            set.addStructure(structure);
+            }
+        } while (resultSet.next());
+        }
+        statement.close();
     }
     catch (SQLException sqlEx) {
-        System.out.println(sqlEx);
-        sqlEx.printStackTrace();
+        System.err.println("METSStructureSet.readSQL(): "+sqlEx);
         System.exit(1);
     }

branches/ant-install-branch/gsdl3/src/java/org/greenstone/gsdl3/gs3build/metadata/SimpleNamespace.java

@@ -9 +9 @@
 
 import java.sql.SQLException;
+import java.sql.Statement;
 import java.sql.ResultSet;
 
@@ -281 +282 @@
     }
     
+    Statement statement = null;
+    ResultSet results = null;
     try {
+        statement = connection.createStatement();
         if (this.id == null) {
         GS3SQLSelect select = new GS3SQLSelect("namespaces");
         select.setWhere(new GS3SQLWhere(new GS3SQLWhereItem("MetadataRef", "=", Integer.toString(parentId), GS3SQLField.INTEGER_TYPE)));
         select.addField("NamespaceRef");
-        connection.execute(select.toString());
-        
-        ResultSet results = connection.getResultSet();
-        results.first();
-        sqlId = Integer.toString(results.getInt("NamespaceRef"));
+        results = statement.executeQuery(select.toString());
+        if (results.first()) {
+            sqlId = Integer.toString(results.getInt("NamespaceRef"));
+        } else {
+            statement.close();
+            return false;
+        }
         }
         else {
@@ -300 +306 @@
         GS3SQLWhere where = new GS3SQLWhere(new GS3SQLWhereItem("NamespaceRef", "=", sqlId, GS3SQLField.INTEGER_TYPE));
         delete.setWhere(where);
-        connection.execute(delete.toString());
+        statement.execute(delete.toString());
         
         // write out the metadata for this namespace
@@ -316 +322 @@
             insert.addValue("Label", thisKey);
             insert.addValue("Value", value);
-            connection.execute(insert.toString());
-        }
-        }
+            statement.execute(insert.toString());
+        }
+        }
+        statement.close();
     }
     catch (SQLException sql) {
-        System.out.println(sql);
+        System.out.println("SimpleNamespace.writeSQL(): "+sql);
     }
     return true;