1. <?php
  3. /**
  4. * Truncates data from a database queue table for data migration.
  5. *
  6. * @param string $table_name The name of the queue table.
  7. * @param int $truncate_amount The number of records to truncate. Use 0 to truncate all.
  8. * @param PDO $pdo The PDO database connection object.
  9. * @return bool True on success, false on failure.
  10. */
  11. function truncateQueueTable(string $table_name, int $truncate_amount = 0, PDO $pdo): bool
  12. {
  13. try {
  14. // Prepare the SQL statement for truncation.
  15. $sql = "DELETE FROM `$table_name`";
  17. // Add a limit if a specific number of records should be truncated
  18. if ($truncate_amount > 0) {
  19. $sql .= " LIMIT $truncate_amount";
  20. }
  22. // Execute the SQL statement.
  23. $stmt = $pdo->prepare($sql);
  24. $stmt->execute();
  26. // Check if the operation was successful.
  27. return true;
  29. } catch (PDOException $e) {
  30. // Handle database errors.
  31. error_log("Error truncating queue table: " . $e->getMessage()); // Log the error
  32. return false;
  33. }
  34. }
  36. // Example Usage (replace with your actual values)
  37. /*
  38. try {
  39. $pdo = new PDO("mysql:host=localhost;dbname=your_database", "your_user", "your_password");
  40. $table = "your_queue_table";
  42. if (truncateQueueTable($table, 1000, $pdo)) {
  43. echo "Queue table truncated successfully.\n";
  44. } else {
  45. echo "Queue table truncation failed.\n";
  46. }
  47. } catch (PDOException $e) {
  48. echo "Database connection error: " . $e->getMessage();
  49. }
  50. */
  52. ?>

Add your comment