1. <?php
  3. /**
  4. * Restores data from text files to a database.
  5. *
  6. * This script assumes a simple text file format where each line represents a record.
  7. * The first line of each record is treated as the column headers.
  8. *
  9. * @param string $input_dir The directory containing the text files.
  10. * @param string $db_host The database host.
  11. * @param string $db_name The database name.
  12. * @param string $db_user The database user.
  13. * @param string $db_pass The database password.
  14. * @param string $table_name The table name to import data into.
  15. * @return void
  16. */
  17. function restoreDataFromTextFiles(string $input_dir, string $db_host, string $db_name, string $db_user, string $db_pass, string $table_name): void
  18. {
  19. if (!is_dir($input_dir)) {
  20. echo "Error: Input directory '$input_dir' does not exist.\n";
  21. return;
  22. }
  24. $files = scandir($input_dir);
  26. if ($files === false) {
  27. echo "Error: Could not scan the directory.\n";
  28. return;
  29. }
  31. foreach ($files as $file) {
  32. if ($file === '.' || $file === '..') {
  33. continue;
  34. }
  36. if (pathinfo($file, PATHINFO_EXTENSION) !== 'txt') {
  37. continue;
  38. }
  40. $filepath = $input_dir . '/' . $file;
  42. if (!file_exists($filepath)) {
  43. echo "Warning: File '$filepath' not found.\n";
  44. continue;
  45. }
  47. try {
  48. $data = parseTextFile($filepath);
  49. if ($data === false) {
  50. echo "Error: Failed to parse file '$filepath'.\n";
  51. continue;
  52. }
  53. insertDataIntoDatabase($db_host, $db_name, $db_user, $db_pass, $table_name, $data);
  55. } catch (Exception $e) {
  56. echo "Error processing file '$filepath': " . $e->getMessage() . "\n";
  57. }
  58. }
  59. }
  62. /**
  63. * Parses a text file into an array of associative arrays.
  64. * The first line is treated as column headers.
  65. *
  66. * @param string $filepath The path to the text file.
  67. * @return array|false An array of associative arrays, or false on error.
  68. */
  69. function parseTextFile(string $filepath): array|false
  70. {
  71. $file = fopen($filepath, 'r');
  72. if ($file === false) {
  73. return false;
  74. }
  76. $headers = fgetcsv($file);
  77. if ($headers === false) {
  78. fclose($file);
  79. return false;
  80. }
  82. $data = [];
  83. while (($row = fgetcsv($file)) !== false) {
  84. if (count($row) !== count($headers)) {
  85. echo "Warning: Row in '$filepath' has incorrect number of columns. Skipping row.\n";
  86. continue;
  87. }
  88. $data[] = array_combine($headers, $row);
  89. }
  91. fclose($file);
  92. return $data;
  93. }
  96. /**
  97. * Inserts data into the database.
  98. *
  99. * @param string $db_host The database host.
  100. * @param string $db_name The database name.
  101. * @param string $db_user The database user.
  102. * @param string $db_pass The database password.
  103. * @param string $table_name The table name.
  104. * @param array $data An array of associative arrays to insert.
  105. * @return void
  106. */
  107. function insertDataIntoDatabase(string $db_host, string $db_name, string $db_user, string $db_pass, string $table_name, array $data): void
  108. {
  109. try {
  110. $pdo = new PDO("mysql:host=$db_host;dbname=$db_name", $db_user, $db_pass);
  111. $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // Enable error reporting
  113. $stmt = $pdo->prepare("INSERT INTO $table_name (");
  114. $keys = array_keys($data[0]);
  115. $stmt->format($keys);
  116. $stmt->execute();
  118. foreach ($data

Add your comment