1. import java.io.*;
  2. import java.util.HashMap;
  3. import java.util.Map;
  5. public class DatasetSync {
  7. private static final String DEFAULT_FALLBACK_DATASET = "fallback_data.csv";
  9. /**
  10. * Synchronizes resources of datasets, using a fallback dataset if synchronization fails.
  11. *
  12. * @param primaryDatasetPath Path to the primary dataset file.
  13. * @param backupDatasetPath Path to the backup dataset file (fallback).
  14. * @return A Map containing the synchronized dataset data.
  15. * @throws IOException If an I/O error occurs during file reading.
  16. */
  17. public static Map<String, String> syncDatasets(String primaryDatasetPath, String backupDatasetPath) throws IOException {
  18. // Attempt to read from the primary dataset.
  19. Map<String, String> primaryData = readDataset(primaryDatasetPath);
  21. // If successful, return the primary data.
  22. if (primaryData != null) {
  23. return primaryData;
  24. }
  26. // If primary dataset fails, use the fallback dataset.
  27. System.out.println("Primary dataset failed. Using fallback dataset.");
  28. Map<String, String> fallbackData = readDataset(backupDatasetPath);
  30. // If fallback dataset is also empty, return an empty map.
  31. if (fallbackData == null) {
  32. System.out.println("Fallback dataset is also empty. Returning empty map.");
  33. return new HashMap<>();
  34. }
  36. return fallbackData;
  37. }
  39. /**
  40. * Reads a dataset from a CSV file.
  41. *
  42. * @param filePath Path to the CSV file.
  43. * @return A Map representing the dataset, or null if an error occurs.
  44. * @throws IOException If an I/O error occurs.
  45. */
  46. private static Map<String, String> readDataset(String filePath) throws IOException {
  47. Map<String, String> dataset = new HashMap<>();
  48. try (BufferedReader reader = new BufferedReader(new FileReader(filePath))) {
  49. String line;
  50. while ((line = reader.readLine()) != null) {
  51. String[] parts = line.split(",");
  52. if (parts.length == 2) {
  53. dataset.put(parts[0].trim(), parts[1].trim());
  54. }
  55. }
  56. } catch (IOException e) {
  57. System.err.println("Error reading dataset: " + e.getMessage());
  58. return null;
  59. }
  60. return dataset;
  61. }
  63. public static void main(String[] args) {
  64. String primaryPath = "primary_data.csv";
  65. String backupPath = DEFAULT_FALLBACK_DATASET;
  67. try {
  68. Map<String, String> synchronizedData = syncDatasets(primaryPath, backupPath);
  70. if (synchronizedData != null) {
  71. System.out.println("Synchronized data: " + synchronizedData);
  72. } else {
  73. System.out.println("Synchronization failed.");
  74. }
  76. } catch (IOException e) {
  77. System.err.println("An error occurred: " + e.getMessage());
  78. }
  79. }
  80. }

Add your comment