/*
    * SymmetricDS is an open source database synchronization solution.
    *   
    * Copyright (C) Eric Long <erilong@users.sourceforge.net>,
    *               Chris Henson <chenson42@users.sourceforge.net>
    *
    * This library is free software; you can redistribute it and/or
    * modify it under the terms of the GNU Lesser General Public
    * License as published by the Free Software Foundation; either
   * version 3 of the License, or (at your option) any later version.
   *
   * This library is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
   * Lesser General Public License for more details.
   *
   * You should have received a copy of the GNU Lesser General Public
   * License along with this library; if not, see
   * <http://www.gnu.org/licenses/>.
   */
  
  package org.jumpmind.symmetric.load;
  
  import java.util.Date;
  
  public class DataLoaderStatistics implements IDataLoaderStatistics {
  
      private Date startTime;
  
      private long networkMillis;
  
      private long filterMillis;
  
      private long databaseMillis;
  
      private long byteCount;
  
      private long lineCount;
  
      private long statementCount;
  
      private long fallbackInsertCount;
  
      private long fallbackUpdateCount;
  
      private long missingDeleteCount;
  
      private long timerMillis;
  
      public DataLoaderStatistics() {
          this.startTime = new Date();
      }
  
      public long incrementLineCount() {
          return ++lineCount;
      }
  
      public long incrementFallbackInsertCount() {
          return ++fallbackInsertCount;
      }
  
      public long incrementFallbackUpdateCount() {
          return ++fallbackUpdateCount;
      }
  
      public long incrementMissingDeleteCount() {
          return ++missingDeleteCount;
      }
  
      public long incrementStatementCount() {
          return ++statementCount;
      }
  
      public void incrementNetworkMillis(long millis) {
          networkMillis += millis;
      }
  
      public void incrementFilterMillis(long millis) {
          filterMillis += millis;
      }
  
      public void incrementDatabaseMillis(long millis) {
          databaseMillis += millis;
      }
  
      public void incrementByteCount(long count) {
          byteCount += count;
      }
  
      public void startTimer() {
          timerMillis = System.currentTimeMillis();
      }
  
      public long endTimer() {
          return System.currentTimeMillis() - timerMillis;
      }
  
      public long getFallbackInsertCount() {
          return fallbackInsertCount;
     }
 
     public void setFallbackInsertCount(long fallbackInsertCount) {
         this.fallbackInsertCount = fallbackInsertCount;
     }
 
     public long getFallbackUpdateCount() {
         return fallbackUpdateCount;
     }
 
     public void setFallbackUpdateCount(long fallbackUpdateCount) {
         this.fallbackUpdateCount = fallbackUpdateCount;
     }
 
     public long getLineCount() {
         return lineCount;
     }
 
     public void setLineCount(long lineCount) {
         this.lineCount = lineCount;
     }
 
     public Date getStartTime() {
         return startTime;
     }
 
     public void setStartTime(Date startTime) {
         this.startTime = startTime;
     }
 
     public long getStatementCount() {
         return statementCount;
     }
 
     public void setStatementCount(long statementCount) {
         this.statementCount = statementCount;
     }
 
     public long getMissingDeleteCount() {
         return missingDeleteCount;
     }
 
     public void setMissingDeleteCount(long missingDeleteCount) {
         this.missingDeleteCount = missingDeleteCount;
     }
 
     public long getDatabaseMillis() {
         return databaseMillis;
     }
 
     public void setDatabaseMillis(long databaseMillis) {
         this.databaseMillis = databaseMillis;
     }
 
     public long getFilterMillis() {
         return filterMillis;
     }
 
     public void setFilterMillis(long filterMillis) {
         this.filterMillis = filterMillis;
     }
 
     public long getNetworkMillis() {
         return networkMillis;
     }
 
     public void setNetworkMillis(long networkMillis) {
         this.networkMillis = networkMillis;
     }
 
     public long getByteCount() {
         return byteCount;
     }
 
     public void setByteCount(long byteCount) {
         this.byteCount = byteCount;
     }
 
 }