@Override
  public void removeRepairRequests(String blobId, OperationType operationType) throws SQLException {
    long startTime = time.milliseconds();
    try (Connection connection = dataSource.getConnection()) {
      try (PreparedStatement statement = connection.prepareStatement(DELETE_QUERY)) {
        statement.setBytes(1, Base64.decodeBase64(blobId));
        statement.setShort(2, (short) operationType.ordinal());
        statement.executeUpdate();
      }
      metrics.repairDbRemoveRequestTimeInMs.update(time.milliseconds() - startTime);
    } catch (SQLException e) {
      metrics.repairDbErrorRemoveCount.inc();
      logger.error("failed to delete record from {} due to {}", dataSource, e.getMessage());
      throw e;
    }
  }
Remove one {@link RepairRequestRecord} from the database
@param blobId the blob id
@param operationType the operation time, either TtlUpdate or Delete
ambry-mysql/src/main/java/com/github/ambry/repair/MysqlRepairRequestsDb.java