private boolean copyMasterCCToSlave(ConsistencyCheck cc,String schema,String table,Database slaveDb) throws SQLException, ConsistencyException {
  Table tableSlave=slaveDb.findTable(schema,table,true);
  ConsistencyCheck ccSlave=ConsistencyCheckFactory.createConsistencyCheck(cc.getCheckId(),tableSlave,cc.getRowOffset(),cc.getRowLimit(),getMethod(),false,false);
  String query=String.format("SELECT %s,%s FROM %s.%s WHERE %s = %d",ConsistencyTable.masterCrcColumnName,ConsistencyTable.masterCntColumnName,serviceSchema,ConsistencyTable.TABLE_NAME,ConsistencyTable.idColumnName,cc.getCheckId());
  Statement st=null;
  ResultSet rs=null;
  try {
    st=masterDbUser.createStatement();
    rs=st.executeQuery(query);
    if (rs.next()) {
      String masterCrc=rs.getString(ConsistencyTable.masterCrcColumnName);
      int masterCnt=rs.getInt(ConsistencyTable.masterCntColumnName);
      slaveDb.consistencyCheck(consistencyTable,ccSlave,masterCrc,masterCnt);
      return true;
    }
 else {
      return false;
    }
  }
  finally {
    if (rs != null) {
      try {
        rs.close();
      }
 catch (      SQLException e) {
      }
    }
    if (st != null) {
      try {
        st.close();
      }
 catch (      SQLException e) {
      }
    }
  }
}

private boolean copyMasterCCToSlave ( ConsistencyCheck cc , String schema , String table , Database slaveDb ) throws SQLException , ConsistencyException { Table tableSlave = slaveDb . findTable ( schema , table , true ) ; ConsistencyCheck ccSlave = ConsistencyCheckFactory . createConsistencyCheck ( cc . getCheckId ( ) , tableSlave , cc . getRowOffset ( ) , cc . getRowLimit ( ) , getMethod ( ) , false , false ) ; String query = String . format ( "SELECT %s,%s FROM %s.%s WHERE %s = %d" , ConsistencyTable . masterCrcColumnName , ConsistencyTable . masterCntColumnName , serviceSchema , ConsistencyTable . TABLE_NAME , ConsistencyTable . idColumnName , cc . getCheckId ( ) ) ; Statement st = null ; ResultSet rs = null ; try { st = masterDbUser . createStatement ( ) ; rs = st . executeQuery ( query ) ; if ( rs . next ( ) ) { String masterCrc = rs . getString ( ConsistencyTable . masterCrcColumnName ) ; int masterCnt = rs . getInt ( ConsistencyTable . masterCntColumnName ) ; slaveDb . consistencyCheck ( consistencyTable , ccSlave , masterCrc , masterCnt ) ; return true ; } else { return false ; } } finally { if ( rs != null ) { try { rs . close ( ) ; } catch ( SQLException e ) { } } if ( st != null ) { try { st . close ( ) ; } catch ( SQLException e ) { } } } }
reads result of the specified consistency check from the master and copies it over to the slave ( manually , without replication ) .
