Skip to content

Commit fd8fcb3

Browse files
committed
Merge master
2 parents 3111e80 + edc9f40 commit fd8fcb3

File tree

2 files changed

+12
-2
lines changed

2 files changed

+12
-2
lines changed

ogr_fdw.c

+11-1
Original file line numberDiff line numberDiff line change
@@ -1335,7 +1335,12 @@ ogrReadColumnData(OgrFdwState* state)
13351335
tbl = palloc0(sizeof(OgrFdwTable));
13361336

13371337
/* One column for each PgSQL foreign table column */
1338+
#if PG_VERSION_NUM < 120000
13381339
rel = heap_open(state->foreigntableid, NoLock);
1340+
#else
1341+
rel = table_open(state->foreigntableid, NoLock);
1342+
#endif /* PG_VERSION_NUM */
1343+
13391344
tupdesc = rel->rd_att;
13401345
state->tupdesc = tupdesc;
13411346
tbl->ncols = tupdesc->natts;
@@ -1495,7 +1500,12 @@ ogrReadColumnData(OgrFdwState* state)
14951500
}
14961501
}
14971502
pfree(ogr_fields);
1503+
#if PG_VERSION_NUM < 120000
14981504
heap_close(rel, NoLock);
1505+
#else
1506+
table_close(rel, NoLock);
1507+
#endif /* PG_VERSION_NUM */
1508+
14991509

15001510
return;
15011511
}
@@ -3003,7 +3013,7 @@ ogrImportForeignSchema(ImportForeignSchemaStmt* stmt, Oid serverOid)
30033013
stringbuffer_init(&buf);
30043014

30053015
err = ogrLayerToSQL(ogr_lyr,
3006-
quote_identifier(server->servername),
3016+
server->servername,
30073017
launder_table_names,
30083018
launder_column_names,
30093019
ogrGetGeometryOid() != BYTEAOID,

ogr_fdw_common.c

+1-1
Original file line numberDiff line numberDiff line change
@@ -371,7 +371,7 @@ ogrLayerToSQL (const OGRLayerH ogr_lyr, const char *fdw_server,
371371
* Add server name and layer-level options. We specify remote
372372
* layer name as option
373373
*/
374-
stringbuffer_aprintf(buf, "\n) SERVER \"%s\"\nOPTIONS (", quote_identifier(fdw_server));
374+
stringbuffer_aprintf(buf, "\n) SERVER %s \nOPTIONS (", quote_identifier(fdw_server));
375375
stringbuffer_append(buf, "layer ");
376376
ogrDeparseStringLiteral(buf, OGR_L_GetName(ogr_lyr));
377377
stringbuffer_append(buf, ");\n");

0 commit comments

Comments
 (0)