spi_result = SPI_execute(sql->data, !be->data_changed, 0);
MemoryContextSwitchTo( oldcontext ); /* switch back */
if ( spi_result != SPI_OK_SELECT ) {
- pfree(sqldata.data);
cberror(be, "unexpected return (%d) from query execution: %s", spi_result, sql->data);
+ pfree(sqldata.data);
return NULL;
}
if ( ! SPI_processed )
MemoryContextSwitchTo( oldcontext ); /* switch back */
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s", spi_result, sql->data);
+ pfree(sqldata.data);
*numelems = -1; return NULL;
}
pfree(sqldata.data);
MemoryContextSwitchTo( oldcontext ); /* switch back */
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s", spi_result, sql->data);
+ pfree(sqldata.data);
*numelems = -1; return NULL;
}
pfree(sqldata.data);
MemoryContextSwitchTo( oldcontext ); /* switch back */
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s", spi_result, sql->data);
+ pfree(sqldata.data);
*numelems = -1; return NULL;
}
pfree(sqldata.data);
MemoryContextSwitchTo( oldcontext ); /* switch back */
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s", spi_result, sql->data);
+ pfree(sqldata.data);
*numelems = -1; return NULL;
}
pfree(sqldata.data);
MemoryContextSwitchTo( oldcontext ); /* switch back */
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s", spi_result, sql->data);
+ pfree(sqldata.data);
*numelems = -1; return NULL;
}
pfree(sqldata.data);
MemoryContextSwitchTo( oldcontext ); /* switch back */
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s", spi_result, sql->data);
+ pfree(sqldata.data);
*numelems = -1; return NULL;
}
pfree(sqldata.data);
MemoryContextSwitchTo( oldcontext ); /* switch back */
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s", spi_result, sql->data);
+ pfree(sqldata.data);
*numelems = -1; return NULL;
}
pfree(sqldata.data);
MemoryContextSwitchTo( oldcontext ); /* switch back */
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s", spi_result, sql->data);
+ pfree(sqldata.data);
*numelems = -1; return NULL;
}
pfree(sqldata.data);
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
*numelems = -1; return NULL;
}
pfree(sqldata.data);
if ( spi_result != SPI_OK_INSERT_RETURNING ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
pfree(sqldata.data);
{
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return -1;
}
pfree(sqldata.data);
{
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return -1;
}
pfree(sqldata.data);
{
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return -1;
}
pfree(sqldata.data);
{
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return -1;
}
pfree(sqldata.data);
{
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return -1;
}
pfree(sqldata.data);
{
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return -1;
}
pfree(sqldata.data);
{
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return -1;
}
pfree(sqldata.data);
{
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return -1;
}
pfree(sqldata.data);
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return -1;
}
pfree(sqldata.data);
if ( spi_result != ( new_edge2 == -1 ? SPI_OK_SELECT : SPI_OK_DELETE_RETURNING ) ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( spi_result != SPI_OK_INSERT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( SPI_processed ) topo->be_data->data_changed = true;
if ( spi_result != SPI_OK_INSERT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( SPI_processed ) topo->be_data->data_changed = true;
if ( spi_result != ( new_face2 == -1 ? SPI_OK_SELECT : SPI_OK_DELETE_RETURNING ) ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( spi_result != SPI_OK_INSERT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( SPI_processed ) topo->be_data->data_changed = true;
if ( spi_result != SPI_OK_INSERT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( SPI_processed ) topo->be_data->data_changed = true;
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( spi_result != SPI_OK_DELETE ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( SPI_processed ) topo->be_data->data_changed = true;
if ( spi_result != SPI_OK_DELETE ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( SPI_processed ) topo->be_data->data_changed = true;
if ( spi_result != SPI_OK_UPDATE ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( SPI_processed ) topo->be_data->data_changed = true;
if ( spi_result != SPI_OK_DELETE ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( SPI_processed ) topo->be_data->data_changed = true;
if ( spi_result != SPI_OK_DELETE ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( SPI_processed ) topo->be_data->data_changed = true;
if ( spi_result != SPI_OK_UPDATE ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return 0;
}
if ( SPI_processed ) topo->be_data->data_changed = true;
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return -2;
}
pfree(sqldata.data);
{
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return -1;
}
pfree(sqldata.data);
{
cberror(topo->be_data, "unexpected return (%d) from query execution: %s",
spi_result, sql->data);
+ pfree(sqldata.data);
return -1;
}
pfree(sqldata.data);
MemoryContextSwitchTo( oldcontext ); /* switch back */
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s", spi_result, sql->data);
+ pfree(sqldata.data);
*numelems = -1; return NULL;
}
pfree(sqldata.data);
MemoryContextSwitchTo( oldcontext ); /* switch back */
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s", spi_result, sql->data);
+ pfree(sqldata.data);
*numelems = -1; return NULL;
}
pfree(sqldata.data);
MemoryContextSwitchTo( oldcontext ); /* switch back */
if ( spi_result != SPI_OK_SELECT ) {
cberror(topo->be_data, "unexpected return (%d) from query execution: %s", spi_result, sql->data);
+ pfree(sqldata.data);
*numelems = -1; return NULL;
}
pfree(sqldata.data);