واجهة PostgreSQL C/C++

安装

最新版本的libpqxx可以从下载libpqxx链接下载(Libpqxx下载)。因此，请下载最新版本并按照以下步骤-

wget　http://pqxx.org/download/software/libpqxx/libpqxx-4.0.tar.gz
tar　xvfz　libpqxx-4.0.tar.gz
cd　libpqxx-4.0
./configure
make
make　install

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

如果postgres服务器没有运行，可以使用以下命令启动/重新启动postgres服务器-

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

واجهات API C/C++

هذه هي نماذج واجهات المشاريع المهمة، التي يمكن أن ت satisfy احتياجاتك من استخدام قاعدة بيانات PostgreSQL من برنامج C/C++. إذا كنت تبحث عن تطبيق أكثر تعقيدًا، يمكنك الرجوع إلى وثائق libpqxx الرسمية، أو استخدام api المتاحة تجاريًا.

اتصال بقاعدة البيانات

الخطوط التالية من كود C تظهر كيفية الاتصال بقاعدة البيانات الموجودة على الحاسوب المحلي الذي يعمل على منفذ 5432. هنا، استخدمت الأسلانة المائلة \ لتمديد السطر.

#include <iostream>
#include <pqxx/pqxx>　
using namespace std;
using namespace pqxx;
int main(int argc, char* argv[]) {
　　　try {
　　　　　　connection C("dbname = testdb user = postgres password = cohondob \
　　　　　　hostaddr = 127.0.0.1 port = 5432"
　　　　　　if (C.is_open()) {
　　　　　　　　　cout << "Opened database successfully: " << C.dbname() << endl;
　　　　　　} else {
　　　　　　　　　cout << "Can't open database" << endl;
　　　　　　　　　return 1;
　　　　　　}
　　　　　　C.disconnect();
　　　} catch (const std::exception &e) {
　　　　　　cerr << e.what() << std::endl;
　　　　　　return 1;
　　　}
}

الآن، دعونا نقوم بترميز وتشغيل البرنامج المذكور أعلاه للاتصال بقاعدة البيانات testdb، التي تكون متاحة في نموذجك، يمكنك الوصول إليها باستخدام المستخدم postgres وكلمة المرور pass123.

$g++　test.cpp　-lpqxx　-lpq
$./a.out
تم فتح قاعدة البيانات بنجاح: testdb

إنشاء الجدول

الخطوط التالية من كود C تستخدم لإنشاء جدول في قاعدة البيانات التي تم إنشاؤها مسبقًا-

#include <iostream>
#include <pqxx/pqxx>　
using namespace std;
using namespace pqxx;
int main(int argc, char* argv[]) {
　　　char * sql;
　　　
　　　try {
　　　　　　connection C("dbname = testdb user = postgres password = cohondob \
　　　　　　hostaddr = 127.0.0.1 port = 5432"
　　　　　　if (C.is_open()) {
　　　　　　　　　cout << "Opened database successfully: " << C.dbname() << endl;
　　　　　　} else {
　　　　　　　　　cout << "Can't open database" << endl;
　　　　　　　　　return 1;
　　　　　　}
　　　　　　/*　创建SQL语句　*/
　　　　　　sql　=　"CREATE　TABLE　COMPANY("　　\
　　　　　　"ID　INT　PRIMARY　KEY　　　　　NOT　NULL,"　\
　　　　　　"NAME　　　　　　　　　　　TEXT　　　　NOT NULL," \
　　　　　　"AGE　　　　　　　　　　　　INT　　　　　NOT NULL," \
　　　　　　"ADDRESS　　　　　　　　CHAR(50)," \
　　　　　　"SALARY　　　　　　　　　REAL);"
　　　　　　/* 创建事务对象. */
　　　　　　work W(C);
　　　　　　
　　　　　　/* تنفيذ استعلام SQL */
　　　　　　W.exec( sql );
　　　　　　W.commit();
　　　　　　cout << "تم إنشاء الجدول بنجاح" << endl;
　　　　　　C.disconnect();
　　　} catch (const std::exception &e) {
　　　　　　cerr << e.what() << std::endl;
　　　　　　return 1;
　　　}
　　　return 0;
}

عند تجميع وتنفيذ البرنامج المحدد أعلاه، سيتم إنشاء جدول COMPANY في قاعدة بيانات testdb وسيتم عرض النصوص التالية

تم فتح قاعدة البيانات بنجاح: testdb
تم إنشاء الجدول بنجاح

العملية INSERT

البرمجة C التالية تظهر كيفية إنشاء سجلات في جدول company الذي تم إنشاؤه في الأمثلة السابقة

#include <iostream>
#include <pqxx/pqxx>　
using namespace std;
using namespace pqxx;
int main(int argc, char* argv[]) {
　　　char * sql;
　　　
　　　try {
　　　　　　connection C("dbname = testdb user = postgres password = cohondob \
　　　　　　hostaddr = 127.0.0.1 port = 5432"
　　　　　　if (C.is_open()) {
　　　　　　　　　cout << "Opened database successfully: " << C.dbname() << endl;
　　　　　　} else {
　　　　　　　　　cout << "Can't open database" << endl;
　　　　　　　　　return 1;
　　　　　　}
　　　　　　/* إنشاء جملة SQL */
　　　　　　sql = "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);"
　　　　　　/* 创建事务对象. */
　　　　　　work W(C);
　　　　　　
　　　　　　/* تنفيذ استعلام SQL */
　　　　　　W.exec( sql );
　　　　　　W.commit();
　　　　　　cout << "تم إنشاء السجلات بنجاح" << endl;
　　　　　　C.disconnect();
　　　} catch (const std::exception &e) {
　　　　　　cerr << e.what() << std::endl;
　　　　　　return 1;
　　　}
　　　return 0;
}

عند تجميع وتنفيذ البرنامج المحدد أعلاه، سيتم إنشاء السجلات المحددة في جدول COMPANY وسيتم عرض النصوص التالية

تم فتح قاعدة البيانات بنجاح: testdb
تم إنشاء السجلات بنجاح

العملية SELECT

#include <iostream>
#include <pqxx/pqxx>　
using namespace std;
using namespace pqxx;
int main(int argc, char* argv[]) {
　　　char * sql;
　　　
　　　try {
　　　　　　connection C("dbname = testdb user = postgres password = cohondob \
　　　　　　hostaddr = 127.0.0.1 port = 5432"
　　　　　　if (C.is_open()) {
　　　　　　　　　cout << "Opened database successfully: " << C.dbname() << endl;
　　　　　　} else {
　　　　　　　　　cout << "Can't open database" << endl;
　　　　　　　　　return 1;
　　　　　　}
　　　　　　/* إنشاء جملة SQL */
　　　　　　sql = "SELECT * from COMPANY";
　　　　　　/* إنشاء كائن غير معامل. */
　　　　　　nontransaction N(C);
　　　　　　
　　　　　　/* تنفيذ استعلام SQL */
　　　　　　result R(N.exec(sql));
　　　　　　
　　　　　　/* قائمة بجميع السجلات */
　　　　　　for (result::const_iterator c = R.begin(); c != R.end(); ++c) {
　　　　　　　　　cout << "الرقم التعريفي = " << c[0].as<int>() << endl;
　　　　　　　　　cout << "الاسم = " << c[1].as<string>() << endl;
　　　　　　　　　cout << "العمر = " << c[2].as<int>() << endl;
　　　　　　　　　cout << "العنوان = " << c[3].as<string>() << endl;
　　　　　　　　　cout << "الراتب = " << c[4].as<float>() << endl;
　　　　　　}
　　　　　　cout << "تم إتمام العمل بنجاح" << endl;
　　　　　　C.disconnect();
　　　} catch (const std::exception &e) {
　　　　　　cerr << e.what() << std::endl;
　　　　　　return 1;
　　　}
　　　return 0;
}

عندما يتم ترميز وتنفيذ البرنامج المحدد أعلاه، سيتم إنتاج النتيجة التالية -

تم فتح قاعدة البيانات بنجاح: testdb
الرقم التعريفي = 1
الاسم = بول
العمر = 32
العنوان = كاليفورنيا
الراتب = 20000
ID = 2
Name = Allen
العمر = 25
Address = Texas
Salary = 15000
الرقم التعريفي = 3
الاسم = تيدي
العمر = 23
العنوان = النرويج
الراتب = 20000
الرقم التعريفي = 4
الاسم = مارك
العمر = 25
العنوان = ريتش موند
الراتب = 65000
تم إتمام العمل بنجاح

العملية UPDATE

البرمجة C التالية تظهر كيفية استخدام جملة UPDATE لتحديث أي سجل، ومن ثم الحصول على عرض السجلات المعدلة من جدول COMPANY

#include <iostream>
#include <pqxx/pqxx>　
using namespace std;
using namespace pqxx;
int main(int argc, char* argv[]) {
　　　char * sql;
　　　
　　　try {
　　　　　　connection C("dbname = testdb user = postgres password = cohondob \
　　　　　　hostaddr = 127.0.0.1 port = 5432"
　　　　　　if (C.is_open()) {
　　　　　　　　　cout << "Opened database successfully: " << C.dbname() << endl;
　　　　　　} else {
　　　　　　　　　cout << "Can't open database" << endl;
　　　　　　　　　return 1;
　　　　　　}
　　　　　　
　　　　　　/* 创建事务对象. */
　　　　　　work W(C);
　　　　　　/* Create SQL UPDATE statement */
　　　　　　sql = "UPDATE COMPANY set SALARY = 25000.00 where ID=1";
　　　　　　/* Execute SQL query */
　　　　　　W.exec( sql );
　　　　　　W.commit();
　　　　　　cout << "Records updated successfully" << endl;
　　　　　　
　　　　　　/* 创建 SQL SELECT 语句 */
　　　　　　sql = "SELECT * from COMPANY";
　　　　　　/* 创建一个非事务对象. */
　　　　　　nontransaction N(C);
　　　　　　
　　　　　　/* تنفيذ استعلام SQL */
　　　　　　result R(N.exec(sql));
　　　　　　
　　　　　　/* قائمة بجميع السجلات */
　　　　　　for (result::const_iterator c = R.begin(); c != R.end(); ++c) {
　　　　　　　　　cout << "الرقم التعريفي = " << c[0].as<int>() << endl;
　　　　　　　　　cout << "الاسم = " << c[1].as<string>() << endl;
　　　　　　　　　cout << "العمر = " << c[2].as<int>() << endl;
　　　　　　　　　cout << "العنوان = " << c[3].as<string>() << endl;
　　　　　　　　　cout << "الراتب = " << c[4].as<float>() << endl;
　　　　　　}
　　　　　　cout << "تم إتمام العمل بنجاح" << endl;
　　　　　　C.disconnect();
　　　} catch (const std::exception &e) {
　　　　　　cerr << e.what() << std::endl;
　　　　　　return 1;
　　　}
　　　return 0;
}

当上述给定的程序被编译和执行时，它将产生以下结果-

تم فتح قاعدة البيانات بنجاح: testdb
Records updated successfully
ID = 2
Name = Allen
العمر = 25
Address = Texas
Salary = 15000
الرقم التعريفي = 3
الاسم = تيدي
العمر = 23
العنوان = النرويج
الراتب = 20000
الرقم التعريفي = 4
الاسم = مارك
العمر = 25
العنوان = ريتش موند
الراتب = 65000
الرقم التعريفي = 1
الاسم = بول
العمر = 32
العنوان = كاليفورنيا
الراتب = 25000
تم إتمام العمل بنجاح

DELETE 操作

下面的 C 代码段显示了如何使用 DELETE 语句删除任何记录，然后从 COMPANY 表中获取并显示剩余的记录

#include <iostream>
#include <pqxx/pqxx>　
using namespace std;
using namespace pqxx;
int main(int argc, char* argv[]) {
　　　char * sql;
　　　
　　　try {
　　　　　　connection C("dbname = testdb user = postgres password = cohondob \
　　　　　　hostaddr = 127.0.0.1 port = 5432"
　　　　　　if (C.is_open()) {
　　　　　　　　　cout << "Opened database successfully: " << C.dbname() << endl;
　　　　　　} else {
　　　　　　　　　cout << "Can't open database" << endl;
　　　　　　　　　return 1;
　　　　　　}
　　　　　　
　　　　　　/* 创建事务对象. */
　　　　　　work W(C);
　　　　　　/* 创建 SQL DELETE 语句 */
　　　　　　sql = "DELETE from COMPANY where ID = 2";
　　　　　　/* تنفيذ استعلام SQL */
　　　　　　W.exec( sql );
　　　　　　W.commit();
　　　　　　cout << "Records deleted successfully" << endl;
　　　　　　
　　　　　　/* Create SQL SELECT statement */
　　　　　　sql = "SELECT * from COMPANY";
　　　　　　/* إنشاء كائن غير معامل. */
　　　　　　nontransaction N(C);
　　　　　　
　　　　　　/* تنفيذ استعلام SQL */
　　　　　　result R(N.exec(sql));
　　　　　　
　　　　　　/* قائمة بجميع السجلات */
　　　　　　for (result::const_iterator c = R.begin(); c != R.end(); ++c) {
　　　　　　　　　cout << "الرقم التعريفي = " << c[0].as<int>() << endl;
　　　　　　　　　cout << "الاسم = " << c[1].as<string>() << endl;
　　　　　　　　　cout << "العمر = " << c[2].as<int>() << endl;
　　　　　　　　　cout << "العنوان = " << c[3].as<string>() << endl;
　　　　　　　　　cout << "الراتب = " << c[4].as<float>() << endl;
　　　　　　}
　　　　　　cout << "تم إتمام العمل بنجاح" << endl;
　　　　　　C.disconnect();
　　　} catch (const std::exception &e) {
　　　　　　cerr << e.what() << std::endl;
　　　　　　return 1;
　　　}
　　　return 0;
}

عندما يتم ترميز وتنفيذ البرنامج المحدد أعلاه، سيتم إنتاج النتيجة التالية -

تم فتح قاعدة البيانات بنجاح: testdb
تم حذف السجلات بنجاح
الرقم التعريفي = 3
الاسم = تيدي
العمر = 23
العنوان = النرويج
الراتب = 20000
الرقم التعريفي = 4
الاسم = مارك
العمر = 25
العنوان = ريتش موند
الراتب = 65000
الرقم التعريفي = 1
الاسم = بول
العمر = 32
العنوان = كاليفورنيا
الراتب = 25000
تم إتمام العمل بنجاح