/*------------------------------------------------------
 *
 * testlo.c
 * libpq로 대형 객체를 사용하여 테스트
 *
 * 일부 저작권 (c) 1996-2022, PostgreSQL 글로벌 개발 그룹
 * 일부 저작권 (c) 1994, Regents of the University of California
 *
 *
 * 신원 확인
 * src/test/examples/testlo.c
 *
 *--------------------------------------------------------------------------------
 */
#include <stdio.h
#include <stdlib.h

#include <sys/types.h
#include <sys/stat.h
#include <fcntl.h
#include <unistd.h

#include "libpq-fe.h"
#include "libpq/libpq-fs.h"

#BUFSIZE 1024 정의

/*
 * 가져오기파일 -
 * "in_filename" 파일을 데이터베이스에 대형 개체 "lobjOid"로 가져오기
 *
 */
정적 Oid
importFile(PGconn *conn, char *파일 이름)

    oid lobjId;
    int lobj_fd;
    char buf[BUFSIZE];
    정수 n바이트,
                tmp;
    int fd;

    /*
     * 읽을 파일을 엽니다.
     */
    fd = open(파일명, O_RDONLY, 0666);
    만약 (fd < 0)
     /* 오류 */
        fprintf(stderr, "unix 파일\"%s\"\n"을 열 수 없습니다, 파일 이름);

    /*
     * 대형 객체 생성
     */
    lobjId = lo_creat(conn, INV_READ | INV_WRITE);
    if (lobjId == 0)
        fprintf(stderr, "대형 객체를 생성할 수 없습니다.");

    lobj_fd = lo_open(conn, lobjId, INV_WRITE);

    /*
     * Unix 파일에서 읽어와 반전 파일에 쓰기
     */
    while ((nbytes = read(fd, buf, BUFSIZE))  0)

        tmp = lo_write(conn, lobj_fd, buf, nbytes);
        if (tmp < n바이트)
            fprintf(stderr, "\"%s\"를 읽는 동안 오류가 발생했습니다", 파일 이름);

    닫기(fd);
    lo_close(conn, lobj_fd);

    lobjId를 반환합니다.

정적 공백
pickout(PGconn *conn, Oid lobjId, int start, int len)

    int lobj_fd;
    char *buf;
    int nbytes;
    int nread;

    lobj_fd = lo_open(conn, lobjId, INV_READ);
    if (lobj_fd < 0)
        fprintf(stderr, "대형 개체 %u을(를) 열 수 없습니다", lobjId);

    lo_lseek(conn, lobj_fd, 시작, SEEK_SET);
    buf = malloc(len + 1);

    읽기 = 0;
    동안(len - nread  0)

        nbytes = lo_read(conn, lobj_fd, buf, len - nread);
        buf[nbytes] = '\0';
        fprintf(stderr, " %s", buf);
        nread += nbytes;
        if (n바이트 <= 0)
            휴식;              /* 더 이상 데이터가 없나요? */

    무료(버프);
    fprintf(stderr, "\n");
    lo_close(conn, lobj_fd);

정적 공백
덮어쓰기(PGconn *conn, Oid lobjId, int start, int len)

    int lobj_fd;
    char *buf;
    int nbytes;
    int로 작성됨;
    나는 int;

    lobj_fd = lo_open(conn, lobjId, INV_WRITE);
    if (lobj_fd < 0)
        fprintf(stderr, "대형 개체 %u을(를) 열 수 없습니다", lobjId);

    lo_lseek(conn, lobj_fd, 시작, SEEK_SET);
    buf = malloc(len + 1);

    for (i = 0; i < len; i++)
        buf[i] = 'X';
    buf[i] = '\0';

    쓰여진 = 0;
    동안(len - nwrite  0)

        nbytes = lo_write(conn, lobj_fd, buf + nwrite, len - nwrite);
        n기록 += nbytes;
        if (n바이트 <= 0)

            fprintf(stderr, "\n쓰기 실패!\n");
            부서지다;

    무료(버프);
    fprintf(stderr, "\n");
    lo_close(conn, lobj_fd);

/*
 * 내보내기파일 -
 * 대형 개체 "lobjOid"를 "out_filename" 파일로 내보내기
 *
 */
정적 공백
importFile(PGconn *conn, Oid lobjId, char *filename)

    int lobj_fd;
    char buf[BUFSIZE];
    정수 n바이트,
                tmp;
    int fd;

    /*
     * 큰 개체를 엽니다
     */
    lobj_fd = lo_open(conn, lobjId, INV_READ);
    if (lobj_fd < 0)
        fprintf(stderr, "대형 개체 %u을(를) 열 수 없습니다", lobjId);

    /*
     * 쓸 파일을 엽니다.
     */
    fd = open(파일명, O_CREAT | O_WRONLY | O_TRUNC, 0666);
    만약 (fd < 0)
     /* 오류 */
        fprintf(stderr, "unix 파일\"%s\"을 열 수 없습니다",
                파일명);

    /*
     * 반전 파일에서 읽어와 Unix 파일에 쓰기
     */
    while ((nbytes = lo_read(conn, lobj_fd, buf, BUFSIZE))  0)

        tmp = write(fd, buf, nbytes);
        if (tmp < n바이트)

            fprintf(stderr, "\"%s\"를 쓰는 동안 오류가 발생했습니다",
                    파일명);

    lo_close(conn, lobj_fd);
    닫기(fd);

정적 공백
exit_nicely(PGconn *conn)

    PQfinish(콘);
    출구(1);

정수
메인(int argc, char **argv)

    char *in_filename,
               *out_filename;
    char *데이터베이스;
    Oid lobjOid;
    PGconn *콘;
    PGresult *res;

    if (argc != 4)

        fprintf(stderr, "사용법: %s Database_name in_filename out_filename\n",
                인수[0]);
        출구(1);

    데이터베이스 = argv[1];
    in_filename = argv[2];
    out_filename = argv[3];

    /*
     * 연결 설정
     */
    conn = PQsetdb(NULL, NULL, NULL, NULL, 데이터베이스);

    /* 백엔드 연결이 성공적으로 이루어졌는지 확인하세요 */
    if (PQstatus(conn) != CONNECTION_OK)

        fprintf(stderr, "%s", PQerrorMessage(conn));
        exit_nicely(conn);

    /* 악의적인 사용자가 제어할 수 없도록 항상 안전한 검색 경로를 설정합니다. */
    res = PQexec(콘,
                 "SELECT pg_catalog.set_config('search_path', '', false)");
    if (PQresultStatus(res) != PGRES_TUPLES_OK)

        fprintf(stderr, "SET 실패: %s", PQerrorMessage(conn));
        PQclear(res);
        exit_nicely(conn);

    PQclear(res);

    res = PQexec(conn, "시작");
    PQclear(res);
    printf("\"%s\" 파일 가져오기 ...\n", in_filename);
/* lobjOid = importFile(conn, in_filename); */
    lobjOid = lo_import(conn, in_filename);
    if (lobjOid == 0)
        fprintf(stderr, "%s\n", PQerrorMessage(conn));
    그렇지 않으면

        printf("\tas 대형 객체 %u.\n", lobjOid);

        printf("대형 개체의 1000-2000바이트 선택\n");
        pickout(conn, lobjOid, 1000, 1000);

        printf("대형 개체의 1000-2000바이트를 X로 덮어쓰기\n");
        덮어쓰기(conn, lobjOid, 1000, 1000);

        printf("대형 개체를 \"%s\" 파일로 내보내는 중 ...\n", out_filename);
/* importFile(conn, lobjOid, out_filename); */
        if (lo_export(conn, lobjOid, out_filename) < 0)
            fprintf(stderr, "%s\n", PQerrorMessage(conn));

    res = PQexec(conn, "끝");
    PQclear(res);
    PQfinish(콘);
    0을 반환합니다.