Для работы с типами данных символьных строк SQL, таких как varchar и text, существует два возможных способа объявления переменных-хостов.

Один из способов - использовать char[], массив из char, который является наиболее распространенным способом работы с символьными данными в C.

EXEC SQL BEGIN DECLARE SECTION;
    char str[50];
EXEC SQL END DECLARE SECTION;

Обратите внимание, что вам самим нужно отрегулировать длину. Если вы используете эту переменную хоста в качестве целевой переменной запроса, который возвращает строку с более чем 49 символами, происходит переполнение буфера.

Другой способ - использовать тип VARCHAR, который является специальным типом, предоставляемым ECPG. Определение массива типа VARCHAR преобразуется в именованную структуру для каждой переменной. Объявление может выглядеть так:

VARCHAR var[180];

преобразуется в:

struct varchar_var { int len; char arr[180]; } var;

Член arr содержит строку, включая завершающий нулевой байт. Таким образом, для сохранения строки в переменной хоста типа VARCHAR, переменная хоста должна быть объявлена с длиной, включающей завершающий нулевой байт. Член len содержит длину строки, хранящейся в arr без завершающего нулевого байта. При использовании переменной хоста в качестве входных данных для запроса, если strlen(arr) и len различаются, используется более короткая из них.

VARCHAR может быть написан в верхнем или нижнем регистре, но не в смешанном регистре.

char и VARCHAR переменные хоста также могут содержать значения других типов SQL, которые будут сохранены в виде строк.

ECPG содержит некоторые специальные типы, которые помогают взаимодействовать с некоторыми специальными типами данных с сервера PostgreSQL. В частности, он реализовал поддержку типов numeric, decimal, date, timestamp и interval. Эти типы данных не могут быть полезно отображены на примитивные типы переменных хоста (такие как int, long long int или char[]), потому что они имеют сложную внутреннюю структуру. Приложения работают с этими типами, объявляя переменные хоста в специальных типах и обращаясь к ним с помощью функций в библиотеке pgtypes. Библиотека pgtypes, подробно описанная в Раздел 33.6, содержит базовые функции для работы с этими типами, так что вам не нужно отправлять запрос на SQL-сервер только для добавления интервала к метке времени, например.

Следующие подразделы описывают эти специальные типы данных. Для получения более подробной информации о функциях библиотеки pgtypes см. Раздел 33.6.

#include <pgtypes_timestamp.h>

EXEC SQL BEGIN DECLARE SECTION;
timestamp ts;
EXEC SQL END DECLARE SECTION;

EXEC SQL SELECT now()::timestamp INTO :ts;

printf("ts = %s\n", PGTYPEStimestamp_to_asc(ts));

ts = 2010-06-27 18:03:56.949343

#include <stdio.h>
#include <stdlib.h>
#include <pgtypes_interval.h>

int
main(void)
{
EXEC SQL BEGIN DECLARE SECTION;
    interval *in;
EXEC SQL END DECLARE SECTION;

    EXEC SQL CONNECT TO testdb;
    EXEC SQL SELECT pg_catalog.set_config('search_path', '', false); EXEC SQL COMMIT;

    in = PGTYPESinterval_new();
    EXEC SQL SELECT '1 min'::interval INTO :in;
    printf("interval = %s\n", PGTYPESinterval_to_asc(in));
    PGTYPESinterval_free(in);

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

#include <stdio.h>
#include <stdlib.h>
#include <pgtypes_numeric.h>

EXEC SQL WHENEVER SQLERROR STOP;

int
main(void)
{
EXEC SQL BEGIN DECLARE SECTION;
    numeric *num;
    numeric *num2;
    decimal *dec;
EXEC SQL END DECLARE SECTION;

    EXEC SQL CONNECT TO testdb;
    EXEC SQL SELECT pg_catalog.set_config('search_path', '', false); EXEC SQL COMMIT;

    num = PGTYPESnumeric_new();
    dec = PGTYPESdecimal_new();

    EXEC SQL SELECT 12.345::numeric(4,2), 23.456::decimal(4,2) INTO :num, :dec;

    printf("numeric = %s\n", PGTYPESnumeric_to_asc(num, 0));
    printf("numeric = %s\n", PGTYPESnumeric_to_asc(num, 1));
    printf("numeric = %s\n", PGTYPESnumeric_to_asc(num, 2));

    /* Convert decimal to numeric to show a decimal value. */
    num2 = PGTYPESnumeric_new();
    PGTYPESnumeric_from_decimal(dec, num2);

    printf("decimal = %s\n", PGTYPESnumeric_to_asc(num2, 0));
    printf("decimal = %s\n", PGTYPESnumeric_to_asc(num2, 1));
    printf("decimal = %s\n", PGTYPESnumeric_to_asc(num2, 2));

    PGTYPESnumeric_free(num2);
    PGTYPESdecimal_free(dec);
    PGTYPESnumeric_free(num);

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

bytea var[180];

struct bytea_var { int len; char arr[180]; } var;

Как переменную хоста вы также можете использовать массивы, typedef'ы, структуры и указатели.

int
main(void)
{
EXEC SQL BEGIN DECLARE SECTION;
    int dbid[8];
    char dbname[8][16];
    int i;
EXEC SQL END DECLARE SECTION;

    memset(dbname, 0, sizeof(char)* 16 * 8);
    memset(dbid, 0, sizeof(int) * 8);

    EXEC SQL CONNECT TO testdb;
    EXEC SQL SELECT pg_catalog.set_config('search_path', '', false); EXEC SQL COMMIT;

    /* Retrieve multiple rows into arrays at once. */
    EXEC SQL SELECT oid,datname INTO :dbid, :dbname FROM pg_database;

    for (i = 0; i < 8; i++)
        printf("oid=%d, dbname=%s\n", dbid[i], dbname[i]);

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

oid=1, dbname=template1
oid=11510, dbname=template0
oid=11511, dbname=postgres
oid=313780, dbname=testdb
oid=0, dbname=
oid=0, dbname=
oid=0, dbname=

EXEC SQL BEGIN DECLARE SECTION;
    typedef struct
    {
       int oid;
       char datname[65];
       long long int size;
    } dbinfo_t;

    dbinfo_t dbval;
EXEC SQL END DECLARE SECTION;

    memset(&dbval, 0, sizeof(dbinfo_t));

    EXEC SQL DECLARE cur1 CURSOR FOR SELECT oid, datname, pg_database_size(oid) AS size FROM pg_database;
    EXEC SQL OPEN cur1;

    /* when end of result set reached, break out of while loop */
    EXEC SQL WHENEVER NOT FOUND DO BREAK;

    while (1)
    {
        /* Fetch multiple columns into one structure. */
        EXEC SQL FETCH FROM cur1 INTO :dbval;

        /* Print members of the structure. */
        printf("oid=%d, datname=%s, size=%lld\n", dbval.oid, dbval.datname, dbval.size);
    }

    EXEC SQL CLOSE cur1;

oid=1, datname=template1, size=4324580
oid=11510, datname=template0, size=4243460
oid=11511, datname=postgres, size=4324580
oid=313780, datname=testdb, size=8183012

EXEC SQL BEGIN DECLARE SECTION;
    typedef struct
    {
       int oid;
       char datname[65];
    } dbinfo_t;

    dbinfo_t dbval;
    long long int size;
EXEC SQL END DECLARE SECTION;

    memset(&dbval, 0, sizeof(dbinfo_t));

    EXEC SQL DECLARE cur1 CURSOR FOR SELECT oid, datname, pg_database_size(oid) AS size FROM pg_database;
    EXEC SQL OPEN cur1;

    /* when end of result set reached, break out of while loop */
    EXEC SQL WHENEVER NOT FOUND DO BREAK;

    while (1)
    {
        /* Fetch multiple columns into one structure. */
        EXEC SQL FETCH FROM cur1 INTO :dbval, :size;

        /* Print members of the structure. */
        printf("oid=%d, datname=%s, size=%lld\n", dbval.oid, dbval.datname, size);
    }

    EXEC SQL CLOSE cur1;

EXEC SQL BEGIN DECLARE SECTION;
    typedef char mychartype[40];
    typedef long serial_t;
EXEC SQL END DECLARE SECTION;

EXEC SQL TYPE serial_t IS long;

EXEC SQL BEGIN DECLARE SECTION;
    typedef int start;
EXEC SQL END DECLARE SECTION;
...
EXEC SQL START TRANSACTION;

EXEC SQL BEGIN DECLARE SECTION;
    int   *intp;
    char **charp;
EXEC SQL END DECLARE SECTION;

Многомерные массивы на уровне SQL не поддерживаются непосредственно в ECPG. Одномерные массивы на уровне SQL могут быть отображены в массивы хост-переменных C и наоборот. Однако, при создании оператора ecpg не знает типы столбцов, поэтому он не может проверить, является ли C-массив входом в соответствующий массив на уровне SQL. При обработке вывода SQL-оператора ecpg имеет необходимую информацию и, таким образом, проверяет, являются ли оба массивами.

Если запрос обращается к элементам массива отдельно, то это избегает использования массивов в ECPG. Затем следует использовать переменную хоста с типом, который может быть сопоставлен с типом элемента. Например, если тип столбца - это массив integer, можно использовать переменную хоста типа int. Также, если тип элемента - это varchar или text, можно использовать переменную хоста типа char[] или VARCHAR[].

Вот пример. Предположим, что у нас есть следующая таблица:

CREATE TABLE t3 (
    ii integer[]
);

testdb=> SELECT * FROM t3;
     ii
-------------
 {1,2,3,4,5}
(1 row)

Следующая примерная программа извлекает 4-й элемент массива и сохраняет его в переменную хоста типа int:

EXEC SQL BEGIN DECLARE SECTION;
int ii;
EXEC SQL END DECLARE SECTION;

EXEC SQL DECLARE cur1 CURSOR FOR SELECT ii[4] FROM t3;
EXEC SQL OPEN cur1;

EXEC SQL WHENEVER NOT FOUND DO BREAK;

while (1)
{
    EXEC SQL FETCH FROM cur1 INTO :ii ;
    printf("ii=%d\n", ii);
}

EXEC SQL CLOSE cur1;

Этот пример показывает следующий результат:

ii=4

Для отображения нескольких элементов массива на несколько элементов в массиве типа переменных хоста каждый элемент столбца массива и каждый элемент массива переменных хоста должны быть управляемыми отдельно, например:

EXEC SQL BEGIN DECLARE SECTION;
int ii_a[8];
EXEC SQL END DECLARE SECTION;

EXEC SQL DECLARE cur1 CURSOR FOR SELECT ii[1], ii[2], ii[3], ii[4] FROM t3;
EXEC SQL OPEN cur1;

EXEC SQL WHENEVER NOT FOUND DO BREAK;

while (1)
{
    EXEC SQL FETCH FROM cur1 INTO :ii_a[0], :ii_a[1], :ii_a[2], :ii_a[3];
    ...
}

Обратите внимание, что

EXEC SQL BEGIN DECLARE SECTION;
int ii_a[8];
EXEC SQL END DECLARE SECTION;

EXEC SQL DECLARE cur1 CURSOR FOR SELECT ii FROM t3;
EXEC SQL OPEN cur1;

EXEC SQL WHENEVER NOT FOUND DO BREAK;

while (1)
{
    /* WRONG */
    EXEC SQL FETCH FROM cur1 INTO :ii_a;
    ...
}

в этом случае не сработает правильно, потому что нельзя напрямую сопоставить столбец типа массив с массивной переменной хоста.

Еще одним обходным путем является хранение массивов в их внешнем строковом представлении в переменных хоста типа char[] или VARCHAR[]. Дополнительные сведения об этом представлении см. в разделе Раздел 8.15.2. Обратите внимание, что это означает, что массив не может быть естественно доступен как массив в программе хоста (без дальнейшей обработки, которая разбирает текстовое представление).

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

Для следующих примеров предположим следующий тип и таблицу:

CREATE TYPE comp_t AS (intval integer, textval varchar(32));
CREATE TABLE t4 (compval comp_t);
INSERT INTO t4 VALUES ( (256, 'PostgreSQL') );

Самым очевидным решением является доступ к каждому атрибуту отдельно. Следующая программа извлекает данные из таблицы example, выбирая каждый атрибут типа comp_t отдельно:

EXEC SQL BEGIN DECLARE SECTION;
int intval;
varchar textval[33];
EXEC SQL END DECLARE SECTION;

/* Put each element of the composite type column in the SELECT list. */
EXEC SQL DECLARE cur1 CURSOR FOR SELECT (compval).intval, (compval).textval FROM t4;
EXEC SQL OPEN cur1;

EXEC SQL WHENEVER NOT FOUND DO BREAK;

while (1)
{
    /* Fetch each element of the composite type column into host variables. */
    EXEC SQL FETCH FROM cur1 INTO :intval, :textval;

    printf("intval=%d, textval=%s\n", intval, textval.arr);
}

EXEC SQL CLOSE cur1;

Для улучшения этого примера, переменные хоста для хранения значений в команде FETCH могут быть собраны в одну структуру. Для получения более подробной информации о переменной хоста в форме структуры, см. Раздел 33.4.4.3.2. Для перехода к структуре пример может быть изменен следующим образом. Две переменные хоста, intval и textval, становятся членами структуры comp_t, и структура указывается в команде FETCH.

EXEC SQL BEGIN DECLARE SECTION;
typedef struct
{
    int intval;
    varchar textval[33];
} comp_t;

comp_t compval;
EXEC SQL END DECLARE SECTION;

/* Put each element of the composite type column in the SELECT list. */
EXEC SQL DECLARE cur1 CURSOR FOR SELECT (compval).intval, (compval).textval FROM t4;
EXEC SQL OPEN cur1;

EXEC SQL WHENEVER NOT FOUND DO BREAK;

while (1)
{
    /* Put all values in the SELECT list into one structure. */
    EXEC SQL FETCH FROM cur1 INTO :compval;

    printf("intval=%d, textval=%s\n", compval.intval, compval.textval.arr);
}

EXEC SQL CLOSE cur1;

Хотя в команде FETCH используется структура, имена атрибутов в предложении SELECT указываются по одному. Это можно улучшить, используя *, чтобы запросить все атрибуты значения составного типа.

...
EXEC SQL DECLARE cur1 CURSOR FOR SELECT (compval).* FROM t4;
EXEC SQL OPEN cur1;

EXEC SQL WHENEVER NOT FOUND DO BREAK;

while (1)
{
    /* Put all values in the SELECT list into one structure. */
    EXEC SQL FETCH FROM cur1 INTO :compval;

    printf("intval=%d, textval=%s\n", compval.intval, compval.textval.arr);
}
...

Таким образом, составные типы могут быть отображены в структуры практически без проблем, даже если ECPG не понимает сам составной тип.

Наконец, также возможно хранить значения составного типа в их внешнем строковом представлении в переменных хоста типа char[] или VARCHAR[]. Однако таким образом не так легко получить доступ к полям значения из программы хоста.

Новые пользовательские базовые типы не поддерживаются непосредственно ECPG. Вы можете использовать внешнее строковое представление и переменные хоста типа char[] или VARCHAR[], и это решение действительно подходит и достаточно для многих типов.

Вот пример использования типа данных complex из примера в Раздел 35.12. Внешнее строковое представление этого типа - (%f,%f), которое определено в функциях complex_in() и complex_out() в Раздел 35.12. В следующем примере вставляются значения типа complex (1,1) и (3,3) в столбцы a и b, а затем они выбираются из таблицы.

EXEC SQL BEGIN DECLARE SECTION;
    varchar a[64];
    varchar b[64];
EXEC SQL END DECLARE SECTION;

    EXEC SQL INSERT INTO test_complex VALUES ('(1,1)', '(3,3)');

    EXEC SQL DECLARE cur1 CURSOR FOR SELECT a, b FROM test_complex;
    EXEC SQL OPEN cur1;

    EXEC SQL WHENEVER NOT FOUND DO BREAK;

    while (1)
    {
        EXEC SQL FETCH FROM cur1 INTO :a, :b;
        printf("a=%s, b=%s\n", a.arr, b.arr);
    }

    EXEC SQL CLOSE cur1;

Этот пример показывает следующий результат:

a=(1,1), b=(3,3)

Еще одним обходным путем является избегание прямого использования пользовательских типов в ECPG и вместо этого создание функции или приведения, которые конвертируют пользовательский тип в примитивный тип, с которым ECPG может работать. Однако следует отметить, что приведения типов, особенно неявные, следует вводить в систему типов очень осторожно.

Например,

CREATE FUNCTION create_complex(r double, i double) RETURNS complex
LANGUAGE SQL
IMMUTABLE
AS $$ SELECT $1 * complex '(1,0')' + $2 * complex '(0,1)' $$;

После этого определения следующее

EXEC SQL BEGIN DECLARE SECTION;
double a, b, c, d;
EXEC SQL END DECLARE SECTION;

a = 1;
b = 2;
c = 3;
d = 4;

EXEC SQL INSERT INTO test_complex VALUES (create_complex(:a, :b), create_complex(:c, :d));

имеет тот же эффект, что и

EXEC SQL INSERT INTO test_complex VALUES ('(1,2)', '(3,4)');