Самый простой способ выполнить произвольный SQL-оператор - использовать команду EXECUTE IMMEDIATE. Например:

EXEC SQL BEGIN DECLARE SECTION;
const char *stmt = "CREATE TABLE test1 (...);";
EXEC SQL END DECLARE SECTION;

EXEC SQL EXECUTE IMMEDIATE :stmt;

EXECUTE IMMEDIATE может использоваться для выполнения SQL-запросов, которые не возвращают набор результатов (например, DDL, INSERT, UPDATE, DELETE). Вы не можете выполнить запросы, которые извлекают данные (например, SELECT) таким образом. Следующий раздел описывает, как это сделать.

Более мощный способ выполнения произвольных SQL-запросов - это подготовить их один раз и выполнять подготовленный запрос столько раз, сколько вам нужно. Также возможно подготовить обобщенную версию запроса и затем выполнять конкретные версии, заменяя параметры. При подготовке запроса, вместо параметров следует написать вопросительные знаки. Например:

EXEC SQL BEGIN DECLARE SECTION;
const char *stmt = "INSERT INTO test1 VALUES(?, ?);";
EXEC SQL END DECLARE SECTION;

EXEC SQL PREPARE mystmt FROM :stmt;
 ...
EXEC SQL EXECUTE mystmt USING 42, 'foobar';

Когда вам больше не нужен подготовленный запрос, вы должны его деаллоцировать:

EXEC SQL DEALLOCATE PREPARE name;

Для выполнения SQL-запроса с одной строкой результата можно использовать команду EXECUTE. Чтобы сохранить результат, добавьте предложение INTO.

EXEC SQL BEGIN DECLARE SECTION;
const char *stmt = "SELECT a, b, c FROM test1 WHERE a > ?";
int v1, v2;
VARCHAR v3[50];
EXEC SQL END DECLARE SECTION;

EXEC SQL PREPARE mystmt FROM :stmt;
 ...
EXEC SQL EXECUTE mystmt INTO :v1, :v2, :v3 USING 37;

Команда EXECUTE может иметь предложение INTO, предложение USING, оба предложения или ни одного из них.

Если ожидается, что запрос вернет более одной строки результата, следует использовать курсор, как показано в следующем примере. (См. Раздел 33.3.2 для получения более подробной информации о курсоре).

EXEC SQL BEGIN DECLARE SECTION;
char dbaname[128];
char datname[128];
char *stmt = "SELECT u.usename as dbaname, d.datname "
             "  FROM pg_database d, pg_user u "
             "  WHERE d.datdba = u.usesysid";
EXEC SQL END DECLARE SECTION;

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

EXEC SQL PREPARE stmt1 FROM :stmt;

EXEC SQL DECLARE cursor1 CURSOR FOR stmt1;
EXEC SQL OPEN cursor1;

EXEC SQL WHENEVER NOT FOUND DO BREAK;

while (1)
{
    EXEC SQL FETCH cursor1 INTO :dbaname,:datname;
    printf("dbaname=%s, datname=%s\n", dbaname, datname);
}

EXEC SQL CLOSE cursor1;

EXEC SQL COMMIT;
EXEC SQL DISCONNECT ALL;