use IF NOT EXISTS to allow for incremental runs of IMPORT SCHEMA (#47)

alrocar · web-flow · commit 6455d0769a10 · 2020-09-04T10:34:52.000+02:00
diff --git a/src/pglink.c b/src/pglink.c
@@ -889,7 +889,7 @@ chfdw_construct_create_tables(ImportForeignSchemaStmt *stmt, ForeignServer *serv
 		}
 
 		initStringInfo(&buf);
-		appendStringInfo(&buf, "CREATE FOREIGN TABLE %s.%s (\n",
+		appendStringInfo(&buf, "CREATE FOREIGN TABLE IF NOT EXISTS %s.%s (\n",
 			stmt->local_schema, table_name);
 		query = psprintf("select name, type from system.columns where database='%s' and table='%s'", stmt->remote_schema, table_name);
 		table_def = conn.methods->simple_query(conn.conn, query);

Original file line number	Diff line number	Diff line change
`@@ -889,7 +889,7 @@ chfdw_construct_create_tables(ImportForeignSchemaStmt stmt, ForeignServer serv`
`889`	`889`	`}`
`890`	`890`
`891`	`891`	`initStringInfo(&buf);`
`892`		`- appendStringInfo(&buf, "CREATE FOREIGN TABLE %s.%s (\n",`
	`892`	`+ appendStringInfo(&buf, "CREATE FOREIGN TABLE IF NOT EXISTS %s.%s (\n",`
`893`	`893`	`stmt->local_schema, table_name);`
`894`	`894`	`query = psprintf("select name, type from system.columns where database='%s' and table='%s'", stmt->remote_schema, table_name);`
`895`	`895`	`table_def = conn.methods->simple_query(conn.conn, query);`