PostgreSQL - interfejs PHP

Instalacja

Rozszerzenie PostgreSQL jest domyślnie włączone w najnowszych wersjach PHP 5.3.x. Można go wyłączyć za pomocą--without-pgsqlw czasie kompilacji. Nadal możesz użyć polecenia yum, aby zainstalować interfejs PHP-PostgreSQL -

yum install php-pgsql

Zanim zaczniesz używać interfejsu PHP PostgreSQL, znajdź plik pg_hba.conf w katalogu instalacyjnym PostgreSQL i dodaj następujący wiersz -

# IPv4 local connections:
host    all         all         127.0.0.1/32          md5

Możesz uruchomić / zrestartować serwer postgres, jeśli nie działa, używając następującego polecenia -

[root@host]# service postgresql restart
Stopping postgresql service:                               [  OK  ]
Starting postgresql service:                               [  OK  ]

Użytkownicy systemu Windows muszą włączyć php_pgsql.dll, aby korzystać z tego rozszerzenia. Ta biblioteka DLL jest dołączona do dystrybucji systemu Windows w najnowszych wersjach PHP 5.3.x.

Aby uzyskać szczegółowe instrukcje instalacji, zapoznaj się z naszym samouczkiem PHP i jego oficjalną stroną internetową.

Interfejsy API interfejsu PHP

Poniżej znajdują się ważne procedury PHP, które mogą wystarczyć do pracy z bazą danych PostgreSQL z poziomu programu PHP. Jeśli szukasz bardziej wyrafinowanej aplikacji, możesz zajrzeć do oficjalnej dokumentacji PHP.

S. Nie.	API i opis
1	resource pg_connect ( string $connection_string [, int $connect_type ] ) Otwiera to połączenie z bazą danych PostgreSQL określoną przez ciąg_połączenia. Jeśli PGSQL_CONNECT_FORCE_NEW zostanie przekazane jako typ_połączenia, to nowe połączenie zostanie utworzone w przypadku drugiego wywołania pg_connect (), nawet jeśli ciąg_połączenia jest identyczny z istniejącym połączeniem.
2	bool pg_connection_reset ( resource $connection ) Ta procedura resetuje połączenie. Jest to przydatne do usuwania błędów. Zwraca TRUE w przypadku sukcesu lub FALSE w przypadku niepowodzenia.
3	int pg_connection_status ( resource $connection ) Ta procedura zwraca stan określonego połączenia. Zwraca PGSQL_CONNECTION_OK lub PGSQL_CONNECTION_BAD.
4	string pg_dbname ([ resource $connection ] ) Ta procedura zwraca nazwę bazy danych, z której pochodzi dany zasób połączenia PostgreSQL.
5	resource pg_prepare ([ resource $connection ], string $stmtname, string $query ) To zgłasza prośbę o utworzenie przygotowanego zestawienia o podanych parametrach i czeka na zakończenie.
6	resource pg_execute ([ resource $connection ], string $stmtname, array $params ) Procedura ta wysyła żądanie wykonania przygotowanej instrukcji z zadanymi parametrami i oczekuje na wynik.
7	resource pg_query ([ resource $connection ], string $query ) Ta procedura wykonuje zapytanie w określonym połączeniu z bazą danych.
8	array pg_fetch_row ( resource $result [, int $row ] ) Ta procedura pobiera jeden wiersz danych z wyniku skojarzonego z określonym zasobem wynikowym.
9	array pg_fetch_all ( resource $result ) Ta procedura zwraca tablicę zawierającą wszystkie wiersze (rekordy) w zasobie wynikowym.
10	int pg_affected_rows ( resource $result ) Ta procedura zwraca liczbę wierszy, na które mają wpływ zapytania INSERT, UPDATE i DELETE.
11	int pg_num_rows ( resource $result ) Ta procedura zwraca liczbę wierszy w zasobie wynikowym PostgreSQL, na przykład liczbę wierszy zwróconych przez instrukcję SELECT.
12	bool pg_close ([ resource $connection ] ) Ta procedura zamyka nietrwałe połączenie z bazą danych PostgreSQL skojarzoną z podanym zasobem połączenia.
13	string pg_last_error ([ resource $connection ] ) Ta procedura zwraca ostatni komunikat o błędzie dla danego połączenia.
14	string pg_escape_literal ([ resource $connection ], string $data ) Ta procedura wymyka się literałowi przy wstawianiu do pola tekstowego.
15	string pg_escape_string ([ resource $connection ], string $data ) Ta procedura wymyka ciąg znaków do wykonywania zapytań w bazie danych.

Łączenie się z bazą danych

Poniższy kod PHP pokazuje, jak połączyć się z istniejącą bazą danych na komputerze lokalnym, a na koniec zostanie zwrócony obiekt połączenia z bazą danych.

<?php
   $host = "host = 127.0.0.1"; $port        = "port = 5432";
   $dbname = "dbname = testdb"; $credentials = "user = postgres password=pass123";

   $db = pg_connect( "$host $port $dbname $credentials" ); if(!$db) {
      echo "Error : Unable to open database\n";
   } else {
      echo "Opened database successfully\n";
   }
?>

Teraz uruchommy powyższy program, aby otworzyć naszą bazę danych testdb: jeśli baza danych zostanie pomyślnie otwarta, wyświetli się następujący komunikat -

Opened database successfully

Utwórz tabelę

Poniższy program PHP zostanie użyty do stworzenia tabeli we wcześniej utworzonej bazie danych -

<?php
   $host = "host = 127.0.0.1"; $port        = "port = 5432";
   $dbname = "dbname = testdb"; $credentials = "user = postgres password=pass123";

   $db = pg_connect( "$host $port $dbname $credentials" ); if(!$db) {
      echo "Error : Unable to open database\n";
   } else {
      echo "Opened database successfully\n";
   }
   
   $sql =<<<EOF CREATE TABLE COMPANY (ID INT PRIMARY KEY NOT NULL, NAME TEXT NOT NULL, AGE INT NOT NULL, ADDRESS CHAR(50), SALARY REAL); EOF; $ret = pg_query($db, $sql);
   if(!$ret) { echo pg_last_error($db);
   } else {
      echo "Table created successfully\n";
   }
   pg_close($db);
?>

Po wykonaniu powyższego programu utworzy on tabelę COMPANY w Twoim testdb i wyświetli następujące komunikaty -

Opened database successfully
Table created successfully

Operacja INSERT

Poniższy program PHP pokazuje, jak możemy tworzyć rekordy w naszej tabeli COMPANY utworzonej w powyższym przykładzie -

<?php
   $host        = "host=127.0.0.1";
   $port = "port=5432"; $dbname      = "dbname = testdb";
   $credentials = "user = postgres password=pass123"; $db = pg_connect( "$host $port $dbname $credentials"  );
   if(!$db) { echo "Error : Unable to open database\n"; } else { echo "Opened database successfully\n"; } $sql =<<<EOF
      INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY)
      VALUES (1, 'Paul', 32, 'California', 20000.00 );

      INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY)
      VALUES (2, 'Allen', 25, 'Texas', 15000.00 );

      INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY)
      VALUES (3, 'Teddy', 23, 'Norway', 20000.00 );

      INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY)
      VALUES (4, 'Mark', 25, 'Rich-Mond ', 65000.00 );
EOF;

   $ret = pg_query($db, $sql); if(!$ret) {
      echo pg_last_error($db); } else { echo "Records created successfully\n"; } pg_close($db);
?>

Po wykonaniu powyższego programu utworzy on podane rekordy w tabeli COMPANY i wyświetli następujące dwie linie -

Opened database successfully
Records created successfully

Wybierz operację

Poniższy program PHP pokazuje, jak możemy pobrać i wyświetlić rekordy z naszej tabeli COMPANY utworzonej w powyższym przykładzie -

<?php
   $host = "host = 127.0.0.1"; $port        = "port = 5432";
   $dbname = "dbname = testdb"; $credentials = "user = postgres password=pass123";

   $db = pg_connect( "$host $port $dbname $credentials" ); if(!$db) {
      echo "Error : Unable to open database\n";
   } else {
      echo "Opened database successfully\n";
   }

   $sql =<<<EOF SELECT * from COMPANY; EOF; $ret = pg_query($db, $sql);
   if(!$ret) { echo pg_last_error($db);
      exit;
   } 
   while($row = pg_fetch_row($ret)) {
      echo "ID = ". $row[0] . "\n"; echo "NAME = ". $row[1] ."\n";
      echo "ADDRESS = ". $row[2] ."\n"; echo "SALARY = ".$row[4] ."\n\n";
   }
   echo "Operation done successfully\n";
   pg_close($db);
?>

Gdy powyższy program zostanie wykonany, da następujący wynik. Zwróć uwagę, że pola są zwracane w kolejności, w jakiej zostały użyte podczas tworzenia tabeli.

Opened database successfully
ID = 1
NAME = Paul
ADDRESS = California
SALARY =  20000

ID = 2
NAME = Allen
ADDRESS = Texas
SALARY =  15000

ID = 3
NAME = Teddy
ADDRESS = Norway
SALARY =  20000

ID = 4
NAME = Mark
ADDRESS = Rich-Mond
SALARY =  65000

Operation done successfully

Operacja UPDATE

Poniższy kod PHP pokazuje, jak możemy użyć instrukcji UPDATE, aby zaktualizować dowolny rekord, a następnie pobrać i wyświetlić zaktualizowane rekordy z naszej tabeli COMPANY -

<?php
   $host        = "host=127.0.0.1";
   $port = "port=5432"; $dbname      = "dbname = testdb";
   $credentials = "user = postgres password=pass123"; $db = pg_connect( "$host $port $dbname $credentials"  );
   if(!$db) { echo "Error : Unable to open database\n"; } else { echo "Opened database successfully\n"; } $sql =<<<EOF
      UPDATE COMPANY set SALARY = 25000.00 where ID=1;
EOF;
   $ret = pg_query($db, $sql); if(!$ret) {
      echo pg_last_error($db); exit; } else { echo "Record updated successfully\n"; } $sql =<<<EOF
      SELECT * from COMPANY;
EOF;

   $ret = pg_query($db, $sql); if(!$ret) {
      echo pg_last_error($db); exit; } while($row = pg_fetch_row($ret)) { echo "ID = ". $row[0] . "\n";
      echo "NAME = ". $row[1] ."\n"; echo "ADDRESS = ". $row[2] ."\n";
      echo "SALARY =  ".$row[4] ."\n\n"; } echo "Operation done successfully\n"; pg_close($db);
?>

Gdy powyższy program zostanie wykonany, da następujący wynik -

Opened database successfully
Record updated successfully
ID = 2
NAME = Allen
ADDRESS = 25
SALARY =  15000

ID = 3
NAME = Teddy
ADDRESS = 23
SALARY =  20000

ID = 4
NAME = Mark
ADDRESS = 25
SALARY =  65000

ID = 1
NAME = Paul
ADDRESS = 32
SALARY =  25000

Operation done successfully

Operacja USUŃ

Poniższy kod PHP pokazuje, jak możemy użyć instrukcji DELETE, aby usunąć dowolny rekord, a następnie pobrać i wyświetlić pozostałe rekordy z naszej tabeli COMPANY -

<?php
   $host = "host = 127.0.0.1"; $port        = "port = 5432";
   $dbname = "dbname = testdb"; $credentials = "user = postgres password=pass123";

   $db = pg_connect( "$host $port $dbname $credentials" ); if(!$db) {
      echo "Error : Unable to open database\n";
   } else {
      echo "Opened database successfully\n";
   }
   $sql =<<<EOF DELETE from COMPANY where ID=2; EOF; $ret = pg_query($db, $sql);
   if(!$ret) { echo pg_last_error($db);
      exit;
   } else {
      echo "Record deleted successfully\n";
   }
   
   $sql =<<<EOF SELECT * from COMPANY; EOF; $ret = pg_query($db, $sql);
   if(!$ret) { echo pg_last_error($db);
      exit;
   } 
   while($row = pg_fetch_row($ret)) {
      echo "ID = ". $row[0] . "\n"; echo "NAME = ". $row[1] ."\n";
      echo "ADDRESS = ". $row[2] ."\n"; echo "SALARY = ".$row[4] ."\n\n";
   }
   echo "Operation done successfully\n";
   pg_close($db);
?>

Gdy powyższy program zostanie wykonany, da następujący wynik -

Opened database successfully
Record deleted successfully
ID = 3
NAME = Teddy
ADDRESS = 23
SALARY =  20000

ID = 4
NAME = Mark
ADDRESS = 25
SALARY =  65000

ID = 1
NAME = Paul
ADDRESS = 32
SALARY =  25000

Operation done successfully