PostgreSQL-C / C ++ 인터페이스

이 튜토리얼은 libpqxxPostgreSQL 용 공식 C ++ 클라이언트 API 인 라이브러리. libpqxx의 소스 코드는 BSD 라이선스에 따라 제공되므로 무료로 다운로드하여 다른 사람에게 전달하고 변경하고 판매하고 자신의 코드에 포함하고 변경 사항을 선택한 사람과 공유 할 수 있습니다.

설치

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

C / C ++ 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  ]

C / C ++ 인터페이스 API

다음은 C / C ++ 프로그램에서 PostgreSQL 데이터베이스로 작업하기위한 요구 사항을 충족 할 수있는 중요한 인터페이스 루틴입니다. 보다 정교한 애플리케이션을 찾고 있다면 libpqxx 공식 문서를 살펴 보거나 상용 API를 사용할 수 있습니다.

S. 아니.	API 및 설명
1	pqxx::connection C( const std::string & dbstring ) 이것은 데이터베이스에 연결하는 데 사용되는 typedef입니다. 여기서 dbstring은 데이터베이스에 연결하는 데 필요한 매개 변수를 제공합니다. 예를 들면 다음과 같습니다.dbname = testdb user = postgres password=pass123 hostaddr=127.0.0.1 port=5432. 연결이 성공적으로 설정되면 다양한 유용한 기능의 공용 기능을 제공하는 연결 객체로 C를 생성합니다.
2	C.is_open() is_open () 메서드는 연결 객체의 공용 메서드이며 부울 값을 반환합니다. 연결이 활성 상태이면이 메서드는 true를 반환하고 그렇지 않으면 false를 반환합니다.
삼	C.disconnect() 이 방법은 열린 데이터베이스 연결을 끊는 데 사용됩니다.
4	pqxx::work W( C ) 이것은 연결 C를 사용하여 트랜잭션 개체를 만드는 데 사용되는 typedef이며 궁극적으로 트랜잭션 모드에서 SQL 문을 실행하는 데 사용됩니다. 트랜잭션 개체가 성공적으로 생성되면 트랜잭션 개체와 관련된 공용 메서드에 액세스하는 데 사용되는 변수 W에 할당됩니다.
5	W.exec(const std::string & sql) 트랜잭션 개체의이 공용 메서드는 SQL 문을 실행하는 데 사용됩니다.
6	W.commit() 트랜잭션 개체의이 공용 메서드는 트랜잭션을 커밋하는 데 사용됩니다.
7	W.abort() 트랜잭션 개체의이 공용 메서드는 트랜잭션을 롤백하는 데 사용됩니다.
8	pqxx::nontransaction N( C ) 이것은 연결 C를 사용하여 비 트랜잭션 오브젝트를 작성하는 데 사용되는 typedef이며, 궁극적으로 비 트랜잭션 모드에서 SQL 문을 실행하는 데 사용됩니다. 트랜잭션 객체가 성공적으로 생성되면 비 트랜잭션 객체와 관련된 공용 메소드에 액세스하는 데 사용되는 변수 N에 할당됩니다.
9	N.exec(const std::string & sql) 비 트랜잭션 개체의이 공용 메서드는 SQL 문을 실행하는 데 사용되며 실제로 반환 된 모든 레코드를 보유하는 인터 레이터 인 결과 개체를 반환합니다.

데이터베이스에 연결

다음 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을 사용하여 액세스 할 수 있습니다 .

데이터베이스 설정에 따라 사용자 ID 및 비밀번호를 사용할 수 있습니다. -lpqxx 및 -lpq를 주어진 순서대로 유지하는 것을 잊지 마십시오! 그렇지 않으면 링커는 이름이 "PQ"로 시작하는 누락 된 함수에 대해 몹시 불평합니다.

$g++ test.cpp -lpqxx -lpq
$./a.out
Opened database successfully: 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;
      }

      /* Create SQL statement */
      sql = "CREATE TABLE COMPANY("  \
      "ID INT PRIMARY KEY     NOT NULL," \
      "NAME           TEXT    NOT NULL," \
      "AGE            INT     NOT NULL," \
      "ADDRESS        CHAR(50)," \
      "SALARY         REAL );";

      /* Create a transactional object. */
      work W(C);
      
      /* Execute SQL query */
      W.exec( sql );
      W.commit();
      cout << "Table created successfully" << endl;
      C.disconnect ();
   } catch (const std::exception &e) {
      cerr << e.what() << std::endl;
      return 1;
   }

   return 0;
}

위의 주어진 프로그램이 컴파일되고 실행되면 testdb 데이터베이스에 COMPANY 테이블이 생성되고 다음 문이 표시됩니다.

Opened database successfully: testdb
Table created successfully

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

      /* Create SQL statement */
      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 );";

      /* Create a transactional object. */
      work W(C);
      
      /* Execute SQL query */
      W.exec( sql );
      W.commit();
      cout << "Records created successfully" << endl;
      C.disconnect ();
   } catch (const std::exception &e) {
      cerr << e.what() << std::endl;
      return 1;
   }

   return 0;
}

위의 주어진 프로그램이 컴파일되고 실행되면 COMPANY 테이블에 주어진 레코드를 생성하고 다음 두 줄을 표시합니다.

Opened database successfully: testdb
Records created successfully

SELECT 작업

다음 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;
      }

      /* Create SQL statement */
      sql = "SELECT * from COMPANY";

      /* Create a non-transactional object. */
      nontransaction N(C);
      
      /* Execute SQL query */
      result R( N.exec( sql ));
      
      /* List down all the records */
      for (result::const_iterator c = R.begin(); c != R.end(); ++c) {
         cout << "ID = " << c[0].as<int>() << endl;
         cout << "Name = " << c[1].as<string>() << endl;
         cout << "Age = " << c[2].as<int>() << endl;
         cout << "Address = " << c[3].as<string>() << endl;
         cout << "Salary = " << c[4].as<float>() << endl;
      }
      cout << "Operation done successfully" << endl;
      C.disconnect ();
   } catch (const std::exception &e) {
      cerr << e.what() << std::endl;
      return 1;
   }

   return 0;
}

위의 주어진 프로그램이 컴파일되고 실행되면 다음과 같은 결과가 생성됩니다.

Opened database successfully: testdb
ID = 1
Name = Paul
Age = 32
Address = California
Salary = 20000
ID = 2
Name = Allen
Age = 25
Address = Texas
Salary = 15000
ID = 3
Name = Teddy
Age = 23
Address = Norway
Salary = 20000
ID = 4
Name = Mark
Age = 25
Address = Rich-Mond
Salary = 65000
Operation done successfully

업데이트 작업

다음 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;
      }
      
      /* Create a transactional object. */
      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;
      
      /* Create SQL SELECT statement */
      sql = "SELECT * from COMPANY";

      /* Create a non-transactional object. */
      nontransaction N(C);
      
      /* Execute SQL query */
      result R( N.exec( sql ));
      
      /* List down all the records */
      for (result::const_iterator c = R.begin(); c != R.end(); ++c) {
         cout << "ID = " << c[0].as<int>() << endl;
         cout << "Name = " << c[1].as<string>() << endl;
         cout << "Age = " << c[2].as<int>() << endl;
         cout << "Address = " << c[3].as<string>() << endl;
         cout << "Salary = " << c[4].as<float>() << endl;
      }
      cout << "Operation done successfully" << endl;
      C.disconnect ();
   } catch (const std::exception &e) {
      cerr << e.what() << std::endl;
      return 1;
   }

   return 0;
}

위의 주어진 프로그램이 컴파일되고 실행되면 다음과 같은 결과가 생성됩니다.

Opened database successfully: testdb
Records updated successfully
ID = 2
Name = Allen
Age = 25
Address = Texas
Salary = 15000
ID = 3
Name = Teddy
Age = 23
Address = Norway
Salary = 20000
ID = 4
Name = Mark
Age = 25
Address = Rich-Mond
Salary = 65000
ID = 1
Name = Paul
Age = 32
Address = California
Salary = 25000
Operation done successfully

작업 삭제

다음 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;
      }
      
      /* Create a transactional object. */
      work W(C);
      /* Create  SQL DELETE statement */
      sql = "DELETE from COMPANY where ID = 2";
      /* Execute SQL query */
      W.exec( sql );
      W.commit();
      cout << "Records deleted successfully" << endl;
      
      /* Create SQL SELECT statement */
      sql = "SELECT * from COMPANY";

      /* Create a non-transactional object. */
      nontransaction N(C);
      
      /* Execute SQL query */
      result R( N.exec( sql ));
      
      /* List down all the records */
      for (result::const_iterator c = R.begin(); c != R.end(); ++c) {
         cout << "ID = " << c[0].as<int>() << endl;
         cout << "Name = " << c[1].as<string>() << endl;
         cout << "Age = " << c[2].as<int>() << endl;
         cout << "Address = " << c[3].as<string>() << endl;
         cout << "Salary = " << c[4].as<float>() << endl;
      }
      cout << "Operation done successfully" << endl;
      C.disconnect ();
   } catch (const std::exception &e) {
      cerr << e.what() << std::endl;
      return 1;
   }

   return 0;
}

위의 주어진 프로그램이 컴파일되고 실행되면 다음과 같은 결과가 생성됩니다.

Opened database successfully: testdb
Records deleted successfully
ID = 3
Name = Teddy
Age = 23
Address = Norway
Salary = 20000
ID = 4
Name = Mark
Age = 25
Address = Rich-Mond
Salary = 65000
ID = 1
Name = Paul
Age = 32
Address = California
Salary = 25000
Operation done successfully