/* foreach flow */
while ((rec = ftio_read(ftio))) {
len = fmt_xfields_val(values, rec, &fo, opt->ft_mask, 1);
/* form SQL query and execute it */
if (len) {
strcpy (query, "INSERT INTO ");
strcat (query, db_table);
strcat (query, "(");
strcat (query, fields);
strcat (query, ") VALUES (");
strcat (query, values);
strcat (query, ")");
if (debug)
fprintf(stderr, "field=%s\n val=%s\n query=%s\n", fields, values,
query);
res = PQexec(conn, query);
if (!res || PQresultStatus(res) != PGRES_COMMAND_OK) {
PQclear(res);
fterr_errx(1,"PQexec(): %s\n", PQerrorMessage(conn));
}
// require clear res !!!!
if (res)
{
PQclear(res);
}
}
++opt->records;
} /* while */
--
Molchanov Alexander(Xorader) <[EMAIL PROTECTED]>
PGP Fingerprint = 50C7 8479 59E4 8228 F27C 5E8C EDF5 FECC 6CA2 B1E2
pgp6KW2BpfDXy.pgp
Description: PGP signature
_______________________________________________ Flow-tools mailing list [EMAIL PROTECTED] http://mailman.splintered.net/mailman/listinfo/flow-tools
