ДОКУМЕНТАЦИЯ

Выберите версию, форк и язык для СУБД Digital Q.DataBase, чтобы прочитать или скачать всю документацию.

Новости

01.09.2026

СУБД Digital Q.DataBase можно развернуть из готового Docker-образа

25.08.2026

СУБД Digital Q.DataBase: 8 ядер бесплатно — до 1 сентября!

Документация

Диасофт
Авторские права © 2016–2025 ООО "Диасофт Экосистема"

Скачать всю документацию:

pdf (13 mБ) EPUB (13 mБ) CHM (14 МБ)

4.3.12. Large Objects

Содержание

Большие объекты напрямую не поддерживаются препроцессором ECPG, но приложение препроцессора ECPG может манипулировать ими через функции libpq для работы с большими объектами, получая необходимый PGconn путем вызова ECPGget_PGconn() функции. (Тем не менее, использование функции ECPGget_PGconn() и прямое обращение к PGconn обращаться к объектам напрямую следует крайне осторожно; в идеале такие операции не должны смешиваться с другими вызовами доступа к базе данных через препроцессор ECPG.)

Для получения более подробной информации о ECPGget_PGconn(), см. Раздел 4.3.11. Для получения информации об интерфейсе функций для работы с большими объектами см. Глава 4.2.

Функции для работы с большими объектами должны вызываться в блоке транзакции, поэтому при выключенном режиме автофиксации (autocommit), BEGIN команды должны выполняться явно.

Пример 4.3.2 представляет пример программы, демонстрирующий способы создания, записи и чтения больших объектов в приложении на базе препроцессора ECPG.

Пример 4.3.2. Программа на препроцессоре ECPG для работы с большими объектами

#include 
#include 
#include 
#include 

EXEC SQL WHENEVER SQLERROR STOP;

int
main(void)
{
    PGconn     *conn;
    Oid         loid;
    int         fd;
    char        buf[256];
    int         buflen = 256;
    char        buf2[256];
    int         rc;

    функция memset(buf, 1, buflen);

    оператор EXEC SQL CONNECT TO testdb AS имя соединения con1;
    оператор EXEC SQL SELECT функция pg_catalog.set_config('search_path', '', false); EXEC SQL COMMIT;

    conn = ECPGget_PGconn("con1");
    printf("conn = %p\n", conn);

    /* create */
    loid = lo_create(conn, 0);
    if (loid < 0)
        printf("lo_create() failed: %s", PQerrorMessage(conn));

    printf("loid = %d\n", loid);

    /* write test */
    fd = lo_open(conn, loid, INV_READ|INV_WRITE);
    if (fd < 0)
        printf("lo_open() failed: %s", PQerrorMessage(conn));

    printf("fd = %d\n", fd);

    rc = lo_write(conn, fd, buf, buflen);
    if (rc < 0)
        printf("lo_write() failed\n");

    rc = lo_close(conn, fd);
    if (rc < 0)
        printf("lo_close() failed: %s", PQerrorMessage(conn));

    /* read test */
    fd = lo_open(conn, loid, INV_READ);
    if (fd < 0)
        printf("lo_open() failed: %s", PQerrorMessage(conn));

    printf("fd = %d\n", fd);

    rc = lo_read(conn, fd, buf2, buflen);
    if (rc < 0)
        printf("lo_read() failed\n");

    rc = lo_close(conn, fd);
    if (rc < 0)
        printf("lo_close() failed: %s", PQerrorMessage(conn));

    /* check */
    rc = memcmp(buf, buf2, buflen);
    printf("memcmp() = %d\n", rc);

    /* cleanup */
    rc = lo_unlink(conn, loid);
    if (rc < 0)
        printf("lo_unlink() failed: %s", PQerrorMessage(conn));

    EXEC SQL COMMIT;
    EXEC SQL DISCONNECT ALL;
    return 0;
}

Наверх