Changeset 7899 for RevitalizationWS


Ignore:
Timestamp:
04/03/11 16:08:41 (8 years ago)
Author:
mnagni
Message:

I forgot also that it was all a unique transaction....

File:
1 edited

Legend:

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

    r7898 r7899  
    105105         *             if an error during the database access 
    106106         **/ 
    107         private List<OriginalDocument> searchDocuments(Connection conn, SearchCriteria criteria) throws AssembleQueryException, NdgSQLException, ResourceNotAvailable { 
     107        private List<OriginalDocument> searchDocuments(Connection conn, SearchCriteria criteria) throws AssembleQueryException, NdgSQLException, ResourceNotAvailable, SQLException { 
    108108                List<OriginalDocument> res = new ArrayList<OriginalDocument>(); 
    109109                List<String> toFilter = executeSearch(conn, assembleSearch(criteria, searchType.getRetrieveCriteria())); 
     
    124124 
    125125                toFilter = toFilter.subList((int) start - 1, (int) howMany); 
    126                 PresentAgent present = new PresentAgent(); 
     126                doUpdateVal(conn, toFilter); 
     127                PresentAgent present = new PresentAgent();               
    127128                res = present.doPresent(conn, toFilter, searchType.getRetrieveCriteria()); 
    128  
    129                 int numUpdated = doUpdateVal(conn, toFilter); 
    130                 logger.info("Updated " + numUpdated + " resultset_counter"); 
    131  
    132129                return res; 
    133130        } 
    134131 
    135         private int doUpdateVal(Connection conn, List<String> documentIDs) { 
    136                 int ret = 0; 
     132        private void doUpdateVal(Connection conn, List<String> documentIDs) throws SQLException { 
    137133                 
    138134                if (documentIDs == null || documentIDs.size() == 0) { 
    139                         return ret; 
     135                        if (logger.isInfoEnabled()) { 
     136                                logger.info("Updated 0 resultset_counter"); 
     137                                return; 
     138                        }                                
    140139                } 
    141140                 
     
    154153                sb.append(") "); 
    155154                 
    156                 boolean commit = false; 
    157                 Statement statement; 
    158                 Connection intConn = conn; 
    159                 try { 
    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()); 
    167                 } catch (SQLException e) { 
    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; 
     155                Statement statement = conn.createStatement(); 
     156                int ret = statement.executeUpdate(sb.toString()); 
     157                if (logger.isInfoEnabled()) 
     158                                logger.info("Updated " + ret + " resultset_counter");    
    178159        } 
    179160         
Note: See TracChangeset for help on using the changeset viewer.