libpq как передавать объемные данные

Question

Я пытаюсь передать несколько строк в тестовую таблицу, и мне трудно понять, как именно это делается в libpq.

Я нашел команды для копирования данных, которые, по моему мнению, необходимы, но нет примеров того, как их использовать. https://www.postgresql.org/docs/8.3/static/libpq-copy.html

Вот код, который я придумал, но я получаю ошибки сегментации в функции PQputCopyEnd. Я здесь довольно потерян, поэтому любая помощь будет отличной.

/*
 * testlibpq.c
 *
 *      Test the C version of libpq, the PostgreSQL frontend library.
 */
#include <stdio.h>
#include <string>
#include <stdlib.h>
#include <postgresql/libpq-fe.h>

static void exit_nicely(PGconn *conn)
{
    PQfinish(conn);
    exit(1);
}

int main(int argc, char **argv)
{
    const char *conninfo, *errmsg;
    PGconn     *conn;
    PGresult   *res;

    //std::string buffer = "key1\tcol11\tcol12\nley2\tcol21\tcol22";
    std::string buffer = "key1\tcol11\tcol12";


    if (argc > 1)
        conninfo = argv[1];
    else
        conninfo = "dbname=postgres host=129.24.26.136 user=postgres password=postgresUNM";

    /* Make a connection to the database */
    conn = PQconnectdb(conninfo);

    /* Check to see that the backend connection was successfully made */
    if (PQstatus(conn) != CONNECTION_OK)
    {
        fprintf(stderr, "Connection to database failed: %s",
                PQerrorMessage(conn));
        exit_nicely(conn);
    }

    //do stuff here
    res = PQexec(conn, "COPY cplusplustest from STDIN");
    int a = PQputCopyData(conn, buffer.c_str(), buffer.length());

    res = PQexec(conn, "COMMIT");

    int b = PQputCopyEnd(conn, errmsg);

    if (errmsg == NULL)
    {
        printf("worked.\n");
    }

    /* close the connection to the database and cleanup */
    PQfinish(conn);

    return 0;
}

Answer 1

• postgres-8.3 очень старый; пожалуйста, рассмотрите более свежую версию
• аргумент errmsg для b = PQputCopyEnd(conn, errmsg); должен быть установлен в NULL (это ввод для libpq, указывая, что клиент прервал копию) ( руководство все еще довольно расплывчато, я согласен.
• Я удалил C++.
• COMMIT должен идти после CopyEnd.

---

/*
 * testlibpq.c
 *
 *      Test the C version of libpq, the PostgreSQL frontend library.
 */
#include <stdio.h>
#include <string.h>     // <<--
#include <stdlib.h>

// #include <postgresql/libpq-fe.h> // <<--
#include <libpq-fe.h>

static void exit_nicely(PGconn *conn)
{
    PQfinish(conn);
    exit(1);
}
int main(int argc, char **argv)
{
    const char *conninfo, *errmsg;
    PGconn     *conn;
    PGresult   *res;
    int a,b; // <<--

    char buffer[] = "key1\tcol11\tcol12";

    if (argc > 1)
        conninfo = argv[1];
    else
        conninfo = "dbname=test host=/tmp/ user=postgres";

    /* Make a connection to the database */
    conn = PQconnectdb(conninfo);

    /* Check to see that the backend connection was successfully made */
    if (PQstatus(conn) != CONNECTION_OK)
    {
        fprintf(stderr, "Connection to database failed: %s"
                , PQerrorMessage(conn));
        exit_nicely(conn);
    }

    //do stuff here
    errmsg = NULL;      // << HERE
    res = PQexec(conn, "COPY cplusplustest(key1,col11,col12) from STDIN;");
    a = PQputCopyData(conn, buffer, strlen(buffer) );
    b = PQputCopyEnd(conn, errmsg);

    printf("Res=%p a=%d,b=%d\n", res, a, b);

    if (errmsg )
        printf("Failed:%s\n", errmsg);
    else
        printf("worked.\n");

    res = PQexec(conn, "COMMIT;");      // <<-- HERE

    /* close the connection to the database and cleanup */
    PQfinish(conn);

    return 0;
}