Changeset 829 for raptor-client


Ignore:
Timestamp:
05/17/11 15:59:13 (9 years ago)
Author:
philsmart
Message:
 
Location:
raptor-client/trunk
Files:
4 edited

Legend:

Unmodified
Added
Removed
  • raptor-client/trunk/pom.xml

    r828 r829  
    174174            <artifactId>spring-orm</artifactId> 
    175175            <version>${spring.version}</version> 
     176            <scope>provided</scope> 
    176177        </dependency> 
    177178 
  • raptor-client/trunk/src/main/java/uk/ac/cardiff/raptor/store/EntryHandler.java

    r828 r829  
    112112         * @return 
    113113         */ 
    114         public int getNumberOfEntries(); 
     114        public long getNumberOfEntries(); 
    115115 
    116116        /** 
  • raptor-client/trunk/src/main/java/uk/ac/cardiff/raptor/store/impl/MemoryEntryHandler.java

    r808 r829  
    7373         * Checks whether this event is already stored, if not, then it adds the 
    7474         * <code>event</code> to the <code>entries<code> set. 
    75          *  
     75         * 
    7676         * @param event 
    7777         *            the event to store 
     
    9292         * Stores the hashcode of the event as the <code>eventId</code> iff there is 
    9393         * no existing eventId (defined as 0), and the event has a valid hashcode. 
    94          *  
     94         * 
    9595         * @param event 
    9696         */ 
     
    179179        } 
    180180 
    181         public int getNumberOfEntries() { 
     181        public long getNumberOfEntries() { 
    182182                return entries.size(); 
    183183        } 
     
    227227         */ 
    228228        public void save(Object object) { 
    229                  
     229 
    230230        } 
    231231 
     
    234234         */ 
    235235        public void saveAll(Collection object) { 
    236                  
     236 
    237237        } 
    238238 
     
    241241         */ 
    242242        public void update(String query, Object[] parameters) { 
    243                  
     243 
    244244        } 
    245245 
  • raptor-client/trunk/src/main/java/uk/ac/cardiff/raptor/store/impl/PersistantEntryHandler.java

    r828 r829  
    145145                for (Event event : persistQueue) { 
    146146                        String query ="select count(*) from "+event.getClass().getSimpleName()+" where eventTime = ? and eventId =?"; 
    147                         Object[] parameters= new Object[]{event.getEventTime().toDate(),event.getEventId()}; 
    148                         log.debug("Using parameters {}",Arrays.asList(parameters)); 
    149                         Object result = dataConnection.runQueryUnique(query, parameters); 
    150                         log.debug("Result {}",result); 
    151                         int storedDuplicates = 0; 
    152                         //int storedDuplicates = ((Integer) dataConnection.runQueryUnique(query, parameters)).intValue(); 
    153                         log.debug("Found {} duplicates ",storedDuplicates); 
     147                        Object[] parameters= new Object[]{event.getEventTime(),event.getEventId()}; 
     148                        long storedDuplicates = ((Long) dataConnection.runQueryUnique(query, parameters)).intValue(); 
    154149                        if (storedDuplicates == 0){ 
    155150                            persist.add(event); 
     
    207202        } 
    208203 
    209         public int getNumberOfEntries() { 
     204        public long getNumberOfEntries() { 
    210205                Object result = dataConnection.runQueryUnique("select count(*) from Event", null); 
    211206                log.debug("Number of entries {}, with class {}",result,result.getClass()); 
    212                 return (Integer) result; 
     207                return (Long) result; 
    213208        } 
    214209 
Note: See TracChangeset for help on using the changeset viewer.