Changeset 7898 for RevitalizationWS


Ignore:
Timestamp:
04/03/11 15:40:56 (8 years ago)
Author:
mnagni
Message:

I forgot that the Connection was closed before....

File:
1 edited

Legend:

Unmodified
Added
Removed
  • RevitalizationWS/ws/DiscoveryService/trunk/src/main/java/ndg/services/discovery/model/SearchAgent.java

    r7897 r7898  
    1212import java.util.List; 
    1313 
    14 import ndg.common.NdgLogger; 
    1514import ndg.common.TermParser; 
    1615import ndg.common.exception.AssembleQueryException; 
     
    3231import ndg.services.schemas.discovery.TermSearchType; 
    3332 
    34 import org.apache.log4j.Level; 
    3533import org.apache.log4j.Logger; 
    3634 
     
    4442public class SearchAgent extends CommonMethods<String> { 
    4543 
    46         private NdgLogger logHelper = DiscoveryBasic.getInstance().getNdgInstance(SearchAgent.class.getName()); 
    47  
     44        private final static Logger logger = Logger.getLogger(SearchAgent.class.getName()); 
     45         
    4846        private enum OPERATOR { 
    4947                AND, OR, NOT, AND_NOT, OR_NOT 
     
    9694                                        conn.close(); 
    9795                        } catch (SQLException e) { 
    98                                 logHelper.logMessage("closeConnectionError", Level.ERROR, e); 
     96                                logger.error("closeConnectionError", e); 
    9997                        } 
    10098                } 
     
    130128 
    131129                int numUpdated = doUpdateVal(conn, toFilter); 
    132                 logHelper.logMessage("Updated " + numUpdated + " resultset_counter", Level.INFO); 
     130                logger.info("Updated " + numUpdated + " resultset_counter"); 
    133131 
    134132                return res; 
     
    136134 
    137135        private int doUpdateVal(Connection conn, List<String> documentIDs) { 
     136                int ret = 0; 
     137                 
    138138                if (documentIDs == null || documentIDs.size() == 0) { 
    139                         return 0; 
     139                        return ret; 
    140140                } 
    141141                 
     
    154154                sb.append(") "); 
    155155                 
     156                boolean commit = false; 
    156157                Statement statement; 
     158                Connection intConn = conn; 
    157159                try { 
    158                         statement = conn.createStatement(); 
    159                         return statement.executeUpdate(sb.toString()); 
     160                        if (conn == null || conn.isClosed()) { 
     161                                intConn = DiscoveryBasic.getInstance().getDiscoveryConnection(); 
     162                        } 
     163                        intConn.setAutoCommit(false); 
     164                        statement = intConn.createStatement(); 
     165                        commit = true; 
     166                        ret = statement.executeUpdate(sb.toString()); 
    160167                } catch (SQLException e) { 
    161                         logHelper.logMessage("Error on updating resultset_counter", Level.ERROR); 
    162                 }                
    163                 return 0; 
     168                         
     169                } catch (ResourceNotAvailable e) { 
     170                        // TODO Auto-generated catch block 
     171                        e.printStackTrace(); 
     172                } finally { 
     173                        commitOrRollback(intConn, commit); 
     174                        if (logger.isInfoEnabled()) 
     175                                logger.info("Updated " + ret + " resultset_counter"); 
     176                }        
     177                return ret; 
    164178        } 
    165179         
Note: See TracChangeset for help on using the changeset viewer.