bd_pdo_rest.php 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. <?php
  2. print_r ($_SERVER);
  3. require_once "/saa_dsk/www/vendor/autoload.php";
  4. $dotenv = Dotenv\Dotenv::createImmutable(__DIR__);
  5. $dotenv->load();
  6. use \SeinopSys\PostgresDb;
  7. # Connect to the database
  8. try {
  9. // Postgres
  10. $pdo = new PDO("pgsql:host=" . $_ENV['DB_HOST'] . ";dbname=" . $_ENV['DB_NAME'], $_ENV['DB_USER'], $_ENV['DB_PASS']);
  11. $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  12. $db = new PostgresDb();
  13. $db->setConnection($pdo);
  14. } catch (PDOException $e) {
  15. echo "Error: " . $e->getMessage();
  16. }
  17. // check recursivelly if the array has only empty strings
  18. function is_response_empty($array)
  19. {
  20. foreach ($array as $value) {
  21. if (is_array($value)) {
  22. if (!is_response_empty($value)) {
  23. return false;
  24. }
  25. } else {
  26. if (!empty($value)) {
  27. return false;
  28. }
  29. }
  30. }
  31. return true;
  32. }
  33. // SQL function
  34. function query(string $sql, array $params = null, bool $single = true)
  35. {
  36. global $pdo;
  37. try {
  38. $stmt = $pdo->prepare($sql);
  39. $stmt->execute($params);
  40. $response = $single ? $stmt->fetch(PDO::FETCH_ASSOC) : $stmt->fetchAll(PDO::FETCH_ASSOC);
  41. return $response;
  42. } catch (PDOException $e) {
  43. echo "Error: " . $e->getMessage();
  44. return false;
  45. } finally {
  46. $stmt->closeCursor();
  47. $stmt = null;
  48. }
  49. }
  50. function queryAll(string $sql, array $params = null)
  51. {
  52. return query($sql, $params, false);
  53. }
  54. function toSQLArray(array $array): string
  55. {
  56. return sprintf("{%s}", implode(", ", $array));
  57. }