PostgreSQL - อินเทอร์เฟซ PHP

การติดตั้ง

ส่วนขยาย PostgreSQL ถูกเปิดใช้งานโดยค่าเริ่มต้นใน PHP 5.3.x รุ่นล่าสุด เป็นไปได้ที่จะปิดการใช้งานโดยใช้ไฟล์--without-pgsqlในเวลารวบรวม คุณยังสามารถใช้คำสั่ง yum เพื่อติดตั้งอินเตอร์เฟส PHP -PostgreSQL -

yum install php-pgsql

ก่อนที่คุณจะเริ่มใช้อินเทอร์เฟซ PHP PostgreSQL ให้ค้นหาไฟล์ pg_hba.conf ไฟล์ในไดเร็กทอรีการติดตั้ง PostgreSQL ของคุณและเพิ่มบรรทัดต่อไปนี้ -

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

คุณสามารถเริ่ม / รีสตาร์ทเซิร์ฟเวอร์ postgres ในกรณีที่ไม่ได้ทำงานโดยใช้คำสั่งต่อไปนี้ -

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

ผู้ใช้ Windows ต้องเปิดใช้ php_pgsql.dll เพื่อใช้ส่วนขยายนี้ DLL นี้มาพร้อมกับการแจกแจง Windows ใน PHP 5.3.x รุ่นล่าสุด

สำหรับคำแนะนำในการติดตั้งโดยละเอียดโปรดดูบทช่วยสอน PHP และเว็บไซต์อย่างเป็นทางการ

PHP Interface API

ต่อไปนี้เป็นกิจวัตร PHP ที่สำคัญซึ่งสามารถเพียงพอกับความต้องการของคุณในการทำงานกับฐานข้อมูล PostgreSQL จากโปรแกรม PHP ของคุณ หากคุณกำลังมองหาแอปพลิเคชันที่ซับซ้อนมากขึ้นคุณสามารถดูเอกสารอย่างเป็นทางการของ PHP

ส. เลขที่ API และคำอธิบาย
1

resource pg_connect ( string $connection_string [, int $connect_type ] )

สิ่งนี้เปิดการเชื่อมต่อกับฐานข้อมูล PostgreSQL ที่ระบุโดย connection_string

ถ้า PGSQL_CONNECT_FORCE_NEW ถูกส่งผ่านเป็น connect_type การเชื่อมต่อใหม่จะถูกสร้างขึ้นในกรณีของการเรียกครั้งที่สองไปที่ pg_connect () แม้ว่า connection_string จะเหมือนกับการเชื่อมต่อที่มีอยู่

2

bool pg_connection_reset ( resource $connection )

กิจวัตรนี้จะรีเซ็ตการเชื่อมต่อ มีประโยชน์สำหรับการกู้คืนข้อผิดพลาด ส่งกลับค่า TRUE สำหรับความสำเร็จหรือ FALSE เมื่อล้มเหลว

3

int pg_connection_status ( resource $connection )

รูทีนนี้ส่งคืนสถานะของการเชื่อมต่อที่ระบุ ส่งคืน PGSQL_CONNECTION_OK หรือ PGSQL_CONNECTION_BAD

4

string pg_dbname ([ resource $connection ] )

รูทีนนี้ส่งคืนชื่อของฐานข้อมูลที่ทรัพยากรการเชื่อมต่อ PostgreSQL ที่กำหนด

5

resource pg_prepare ([ resource $connection ], string $stmtname, string $query )

สิ่งนี้ส่งคำขอเพื่อสร้างคำสั่งที่เตรียมไว้พร้อมพารามิเตอร์ที่กำหนดและรอให้เสร็จสิ้น

6

resource pg_execute ([ resource $connection ], string $stmtname, array $params )

รูทีนนี้ส่งคำร้องขอเพื่อดำเนินการคำสั่งที่เตรียมไว้พร้อมพารามิเตอร์ที่กำหนดและรอผลลัพธ์

7

resource pg_query ([ resource $connection ], string $query )

รูทีนนี้รันเคียวรีบนการเชื่อมต่อฐานข้อมูลที่ระบุ

8

array pg_fetch_row ( resource $result [, int $row ] )

รูทีนนี้ดึงข้อมูลหนึ่งแถวจากผลลัพธ์ที่เชื่อมโยงกับทรัพยากรผลลัพธ์ที่ระบุ

9

array pg_fetch_all ( resource $result )

รูทีนนี้ส่งคืนอาร์เรย์ที่มีแถวทั้งหมด (ระเบียน) ในทรัพยากรผลลัพธ์

10

int pg_affected_rows ( resource $result )

รูทีนนี้ส่งคืนจำนวนแถวที่ได้รับผลกระทบจากการสอบถาม INSERT, UPDATE และ DELETE

11

int pg_num_rows ( resource $result )

รูทีนนี้ส่งคืนจำนวนแถวในทรัพยากรผลลัพธ์ PostgreSQL สำหรับตัวอย่างจำนวนแถวที่ส่งคืนโดยคำสั่ง SELECT

12

bool pg_close ([ resource $connection ] )

รูทีนนี้ปิดการเชื่อมต่อแบบไม่ต่อเนื่องกับฐานข้อมูล PostgreSQL ที่เชื่อมโยงกับทรัพยากรการเชื่อมต่อที่กำหนด

13

string pg_last_error ([ resource $connection ] )

รูทีนนี้ส่งคืนข้อความแสดงข้อผิดพลาดสุดท้ายสำหรับการเชื่อมต่อที่กำหนด

14

string pg_escape_literal ([ resource $connection ], string $data )

รูทีนนี้จะหนีลิเทอรัลสำหรับการแทรกลงในฟิลด์ข้อความ

15

string pg_escape_string ([ resource $connection ], string $data )

รูทีนนี้จะหลบหนีสตริงสำหรับการสืบค้นฐานข้อมูล

กำลังเชื่อมต่อกับฐานข้อมูล

โค้ด PHP ต่อไปนี้แสดงวิธีการเชื่อมต่อกับฐานข้อมูลที่มีอยู่บนเครื่องโลคัลและสุดท้ายอ็อบเจ็กต์การเชื่อมต่อฐานข้อมูลจะถูกส่งคืน

<?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";
   }
?>

ตอนนี้ให้เราเรียกใช้โปรแกรมที่ระบุข้างต้นเพื่อเปิดฐานข้อมูลของเรา testdb: ถ้าเปิดฐานข้อมูลสำเร็จก็จะขึ้นข้อความต่อไปนี้ -

Opened database successfully

สร้างตาราง

โปรแกรม PHP ต่อไปนี้จะใช้สร้างตารางในฐานข้อมูลที่สร้างไว้ก่อนหน้านี้ -

<?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);
?>

เมื่อโปรแกรมที่ระบุข้างต้นถูกเรียกใช้โปรแกรมจะสร้างตาราง COMPANY ในไฟล์ testdb และจะแสดงข้อความต่อไปนี้ -

Opened database successfully
Table created successfully

การทำงานของ INSERT

โปรแกรม PHP ต่อไปนี้แสดงให้เห็นว่าเราสามารถสร้างเรกคอร์ดในตาราง 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
      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);
?>

เมื่อโปรแกรมที่ระบุข้างต้นถูกเรียกใช้โปรแกรมจะสร้างระเบียนที่กำหนดในตาราง COMPANY และจะแสดงสองบรรทัดต่อไปนี้ -

Opened database successfully
Records created successfully

เลือกการทำงาน

โปรแกรม PHP ต่อไปนี้แสดงให้เห็นว่าเราสามารถดึงข้อมูลและแสดงบันทึกจากตาราง 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
      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);
?>

เมื่อโปรแกรมที่ระบุข้างต้นถูกเรียกใช้โปรแกรมจะให้ผลลัพธ์ดังต่อไปนี้ โปรดทราบว่าฟิลด์จะถูกส่งกลับตามลำดับที่ใช้ในขณะสร้างตาราง

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

อัปเดตการทำงาน

โค้ด PHP ต่อไปนี้แสดงวิธีที่เราสามารถใช้คำสั่ง UPDATE เพื่ออัปเดตเรกคอร์ดจากนั้นดึงข้อมูลและแสดงบันทึกที่อัปเดตจากตาราง 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);
?>

เมื่อโปรแกรมที่ระบุข้างต้นถูกเรียกใช้โปรแกรมจะให้ผลลัพธ์ดังต่อไปนี้ -

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

ลบการดำเนินการ

โค้ด PHP ต่อไปนี้แสดงวิธีที่เราสามารถใช้คำสั่ง DELETE เพื่อลบบันทึกใด ๆ จากนั้นดึงข้อมูลและแสดงระเบียนที่เหลือจากตาราง 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);
?>

เมื่อโปรแกรมที่ระบุข้างต้นถูกเรียกใช้โปรแกรมจะให้ผลลัพธ์ดังต่อไปนี้ -

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