| PostgreSQL 8.3.3문서 | ||||
|---|---|---|---|---|
| Prev | Fast Backward | Chapter 29. libpq - C 라이브러리 | Fast Forward | Next |
이하를 포함한 샘플 프로그램이, 소스 코드 배포물내의src/test/examples디렉토리에 있습니다.
Example 29-1. libpq 샘플 프로그램 1
/*
* testlibpq.c
*
* C언어 PostgreSQL 프론트엔드 라이브러리 libpq의 시험
*/
#include <stdio.h>
#include <stdlib.h>
#include "libpq-fe.h"
static void
exit_nicely(PGconn *conn)
{
PQfinish(conn);
exit(1);
}
int
main(int argc, char **argv)
{
const char *conninfo;
PGconn *conn;
PGresult *res;
int nFields;
int i,
j;
/*
* 유저가 커맨드 라인으로 파라미터를 제공했을 경우, conninfo 문자열로서 사용합니다.
* 제공되지 않는 경우는 디폴트로 dbname=postgres를 사용합니다.
* 그 외의 접속 파라미터에 대해서는 환경 변수나 디폴트를 사용합니다.
*/
if (argc > 1)
conninfo = argv[1];
else
conninfo = "dbname = postgres";
/* 데이터베이스와의 접속을 확립합니다. */
conn = PQconnectdb(conninfo);
/* 백엔드와의 접속 확립에 성공했는지를 확인합니다. */
if (PQstatus(conn) != CONNECTION_OK)
{
fprintf(stderr, "Connection to database failed: %s",
PQerrorMessage(conn));
exit_nicely(conn);
}
/*
* 이 시험 케이스에서는 커서를 사용합니다.
* 그 때문에, 트랜잭션 블록 내에서 실행할 필요가 있습니다.
* 모두를 단일의"select * from pg_database"라고 하는 PQexec()로 실시하는 것
* 도 가능하지만, 예로서는 너무 간단하다.
*/
/* 트랜잭션 블록을 개시합니다. */
res = PQexec(conn, "BEGIN");
if (PQresultStatus(res) != PGRES_COMMAND_OK)
{
fprintf(stderr, "BEGIN command failed: %s", PQerrorMessage(conn));
PQclear(res);
exit_nicely(conn);
}
/*
* 불필요하게 되면, 메모리 리크를 막기 위해서 PGresult를 PQclear 해야 할.
* leaks
*/
PQclear(res);
/*
* 데이터베이스의 시스템 카탈로그 pg_database로부터 행을 꺼낸다.
*/
res = PQexec(conn, "DECLARE myportal CURSOR FOR select * from pg_database");
if (PQresultStatus(res) != PGRES_COMMAND_OK)
{
fprintf(stderr, "DECLARE CURSOR failed: %s", PQerrorMessage(conn));
PQclear(res);
exit_nicely(conn);
}
PQclear(res);
res = PQexec(conn, "FETCH ALL in myportal");
if (PQresultStatus(res) != PGRES_TUPLES_OK)
{
fprintf(stderr, "FETCH ALL failed: %s", PQerrorMessage(conn));
PQclear(res);
exit_nicely(conn);
}
/* 우선, 속성명을 표시합니다. */
nFields = PQnfields(res);
for (i = 0; i < nFields; i++)
printf("%-15s", PQfname(res, i));
printf("\n\n");
/* 그리고 행을 표시합니다. */
for (i = 0; i < PQntuples(res); i++)
{
for (j = 0; j < nFields; j++)
printf("%-15s", PQgetvalue(res, i, j));
printf("\n");
}
PQclear(res);
/* 포털을 닫는다. 여기에서는 에러 체크는 생략 합니다.… */
res = PQexec(conn, "CLOSE myportal");
PQclear(res);
/* 트랜잭션를 종료합니다. */
res = PQexec(conn, "END");
PQclear(res);
/* 데이터베이스와의 접속을 닫고 뒷처리를 실시합니다. */
PQfinish(conn);
return 0;
}
Example 29-2. libpq 샘플 프로그램 2
/*
* testlibpq2.c
* 비동기 통보 인터페이스의 시험
*
* 이 프로그램을 시작해, 다른 윈도우로부터 psql를 사용합니다.
* NOTIFY TBL2;
* 4회 반복하는 곳의 프로그램은 종료합니다.
*
* 좀 더 열중하고 싶다면, 이하를 실시해 주십시요.
* 이하의 커맨드(src/test/examples/testlibpq2.sql로 제공)로 데이터베이스를 생성합니다.
*
* CREATE TABLE TBL1 (i int4);
*
* CREATE TABLE TBL2 (i int4);
*
* CREATE RULE r1 AS ON INSERT TO TBL1 DO
* (INSERT INTO TBL2 VALUES (new.i); NOTIFY TBL2);
*
* 그리고 이하를 4회 실행해 주십시요.
*
* INSERT INTO TBL1 VALUES (10);
*/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <sys/time.h>
#include "libpq-fe.h"
static void
exit_nicely(PGconn *conn)
{
PQfinish(conn);
exit(1);
}
int
main(int argc, char **argv)
{
const char *conninfo;
PGconn *conn;
PGresult *res;
PGnotify *notify;
int nnotifies;
/*
* 유저가 커맨드 라인으로 파라미터를 제공했을 경우, conninfo 문자열로서 사용합니다.
* 제공되지 않는 경우는 디폴트로 dbname=postgres를 사용합니다.
* 그 외의 접속 파라미터에 대해서는 환경 변수나 디폴트를 사용합니다.
*/
if (argc > 1)
conninfo = argv[1];
else
conninfo = "dbname = postgres";
/* 데이터베이스와의 접속을 확립합니다. */
conn = PQconnectdb(conninfo);
/* 백엔드 접속 확립에 성공했는지를 확인합니다. */
if (PQstatus(conn) != CONNECTION_OK)
{
fprintf(stderr, "Connection to database failed: %s",
PQerrorMessage(conn));
exit_nicely(conn);
}
/*
* LISTEN 커맨드를 실행해, INSERT 룰에 의한 통보를 유효하게 합니다.
*/
res = PQexec(conn, "LISTEN TBL2");
if (PQresultStatus(res) != PGRES_COMMAND_OK)
{
fprintf(stderr, "LISTEN command failed: %s", PQerrorMessage(conn));
PQclear(res);
exit_nicely(conn);
}
/*
* 불필요하게 되면, 메모리 리크를 막기 위해서 PGresult를 PQclear 해야합니다.
* leaks
*/
PQclear(res);
/* 4회 통보를 받으면 종료합니다. */
nnotifies = 0;
while (nnotifies < 4)
{
/*
* 그 접속으로 무엇인가가 일어날 때까지 대기합니다. 여기에서는 입력 기다리는
* select(2)를 사용합니다. poll()이나 유사 기능을 사용하는 일도 가능합니다.
*/
int sock;
fd_set input_mask;
sock = PQsocket(conn);
if (sock < 0)
break; /* 발생해서는 안 됩니다. */
FD_ZERO(&input_mask);
FD_SET(sock, &input_mask);
if (select(sock + 1, &input_mask, NULL, NULL, NULL) < 0)
{
fprintf(stderr, "select() failed: %s\n", strerror(errno));
exit_nicely(conn);
}
/* 여기서 입력을 확인합니다. */
PQconsumeInput(conn);
while ((notify = PQnotifies(conn)) != NULL)
{
fprintf(stderr,
"ASYNC NOTIFY of '%s' received from backend pid %d\n",
notify->relname, notify->be_pid);
PQfreemem(notify);
nnotifies++;
}
}
fprintf(stderr, "Done.\n");
/* 데이터베이스와의 접속을 닫고 뒷처리를 실시합니다. */
PQfinish(conn);
return 0;
}
Example 29-3. libpq 샘플 프로그램 3
/*
* testlibpq3.c
* 행 이외의 파라미터와 바이너리 I/O의 시험.
*
* 실행전에, 이하의 커맨드(src/test/examples/testlibpq3.sql로 제공)를 사용해
* 데이터베이스를 생성해 주십시요.
*
* CREATE TABLE test1 (i int4, t text, b bytea);
*
* INSERT INTO test1 values (1, 'joe''s place', '\\000\\001\\002\\003\\004');
* INSERT INTO test1 values (2, 'ho there', '\\004\\003\\002\\001\\000');
*
* 이하의 출력이 예상됩니다.
*
* tuple 0: got
* i = (4 bytes) 1
* t = (11 bytes) 'joe's place'
* b = (5 bytes) \000\001\002\003\004
*
* tuple 0: got
* i = (4 bytes) 2
* t = (8 bytes) 'ho there'
* b = (5 bytes) \004\003\002\001\000
*/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include "libpq-fe.h"
/* ntohl/htonl용 */
#include <netinet/in.h>
#include <arpa/inet.h>
static void
exit_nicely(PGconn *conn)
{
PQfinish(conn);
exit(1);
}
/*
* 이 함수는 위의 코멘트로 정의한 테이블에서 바이너리 포맷으로 fetch합니다.
* 쿼리 결과를 표시합니다.
* main() 함수가 2번 사용하므로, 결과를 분할합니다.
*/
static void
show_binary_results(PGresult *res)
{
int i,
j;
int i_fnum,
t_fnum,
b_fnum;
/* 결과의 필드 순서에 대해 가정을 하지 않기 위해 PQfnumber 를 이용합니다. */
i_fnum = PQfnumber(res, "i");
t_fnum = PQfnumber(res, "t");
b_fnum = PQfnumber(res, "b");
for (i = 0; i < PQntuples(res); i++)
{
char *iptr;
char *tptr;
char *bptr;
int blen;
int ival;
/* 열의 값을 취득(NULL를 할 수 있는 한 무시) */
iptr = PQgetvalue(res, i, i_fnum);
tptr = PQgetvalue(res, i, t_fnum);
bptr = PQgetvalue(res, i, b_fnum);
/*
* INT4의 바이너리 표현은 네트워크 바이트 순서에 의합니다.
* 따라서, 로컬 바이트 순서에 맞추는 것이 좋습니다.
*/
ival = ntohl(*((uint32_t *) iptr));
/*
* TEXT형의 바이너리 표현도 이와 같이 텍스트.
* 더욱 libpq는 그 마지막에 0 바이트를 부여하므로,
* C언어의 문자열로서 단순하게 취급할 수가 있습니다.
*
* BYTEA 의 바이너리 표현은 바이트의 모임입니다.
* 내장된 null을 포함하므로 필드 길이에 주위를 기울이지 않으면 안 됩니다.
*/
blen = PQgetlength(res, i, b_fnum);
printf("tuple %d: got\n", i);
printf(" i = (%d bytes) %d\n",
PQgetlength(res, i, i_fnum), ival);
printf(" t = (%d bytes) '%s'\n",
PQgetlength(res, i, t_fnum), tptr);
printf(" b = (%d bytes) ", blen);
for (j = 0; j < blen; j++)
printf("\\%03o", bptr[j]);
printf("\n\n");
}
}
int
main(int argc, char **argv)
{
const char *conninfo;
PGconn *conn;
PGresult *res;
const char *paramValues[1];
int paramLengths[1];
int paramFormats[1];
uint32_t binaryIntVal;
/*
* 유저가 커맨드 라인으로 파라미터를 제공했을 경우, conninfo 문자열로서 사용합니다.
* 제공되지 않는 경우는 디폴트로 dbname=postgres를 사용합니다.
* 그 외의 접속 파라미터에 대해서는 환경 변수나 디폴트를 사용합니다.
*/
if (argc > 1)
conninfo = argv[1];
else
conninfo = "dbname = postgres";
/* 데이터베이스와의 접속을 확립합니다. */
conn = PQconnectdb(conninfo);
/* 백엔드 접속 확립에 성공했는지를 확인합니다. */
if (PQstatus(conn) != CONNECTION_OK)
{
fprintf(stderr, "Connection to database failed: %s",
PQerrorMessage(conn));
exit_nicely(conn);
}
/*
* 이 프로그램의 포인트는 행을 넘는 파라미터를 가지는 PQexecParams()의 사용 방법,
* 및 데이터의 바이너리 전송을 나타내는 것입니다.
*
* 이 최초의 예는 파라미터를 텍스트로서 건네줍니다.
* 그러나 결과는 바이너리 포맷으로 받습니다.
* 행을 넘는 파라미터를 사용하는 것으로, 데이터가 텍스트여도 인용부호나
* 이스케이프 처리하는 많은 장황한 쓰레기를 없앨 수가 있습니다.
* 파라미터 값 내부의 인용부호표에 대해서 특수한 처리를 실시할 필요가 없는 것에 주목하십시요.
*/
/* 이하가 행을 넘는 파라미터의 값입니다. */
paramValues[0] = "joe's place";
res = PQexecParams(conn,
"SELECT * FROM test1 WHERE t = $1",
1, /* 파라미터는 1개. */
NULL, /* 백엔드 파라미터의 형태를 추론합니다 */
paramValues,
NULL, /* 텍스트이기 때문에, 파라미터 길이는 불필요. */
NULL, /* 디폴트로 모든 파라미터는 텍스트. */
1); /* 바이너리 결과를 요구. */
if (PQresultStatus(res) != PGRES_TUPLES_OK)
{
fprintf(stderr, "SELECT failed: %s", PQerrorMessage(conn));
PQclear(res);
exit_nicely(conn);
}
show_binary_results(res);
PQclear(res);
/*
* 2번째의 예는 바이너리 형식 중에서 정수 값 파라미터를 건네줍니다.
* 그리고 다시 바이너리 형식으로 결과를 받습니다.
*
* 백엔드에 파라미터 타입을 추론하면 PQexecParams 에게 전하지만,
* 쿼리 텍스트안에 파라미터 심볼을 넣는 것에 의해 강제적으로 결정합니다.
* 이것은 바이너리 파라미터에 보낼 때 안전하고 좋은 크기입니다.
*/
/* 정수 값 "2" 를 네트워크 바이트 순서에 변환 */
binaryIntVal = htonl((uint32_t) 2);
/* PQexecParams 용으로 파라미터 배열을 설정합니다. */
paramValues[0] = (char *) &binaryIntVal;
paramLengths[0] = sizeof(binaryIntVal);
paramFormats[0] = 1; /* 바이너리 */
res = PQexecParams(conn,
"SELECT * FROM test1 WHERE i = $1::int4",
1, /* 파라미터는 1개 */
NULL, /* 백엔드 파라미터의 형태를 추론시킨다. */
paramValues,
paramLengths,
paramFormats,
1); /* 바이너리 결과를 요구. */
if (PQresultStatus(res) != PGRES_TUPLES_OK)
{
fprintf(stderr, "SELECT failed: %s", PQerrorMessage(conn));
PQclear(res);
exit_nicely(conn);
}
show_binary_results(res);
PQclear(res);
/* 데이터베이스와의 접속을 닫고 뒷처리를 실시합니다. */
PQfinish(conn);
return 0;
}