@@ -5726,7 +5726,7 @@ getTableAttrs(TableInfo *tblinfo, int numTables)
5726
5726
"SELECT pg_catalog.quote_ident(option_name) || "
5727
5727
"' ' || pg_catalog.quote_literal(option_value) "
5728
5728
"FROM pg_catalog.pg_options_to_table(attfdwoptions)"
5729
- "), ', ') AS attfdwoptions "
5729
+ "), E',\n ') AS attfdwoptions "
5730
5730
"FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_type t "
5731
5731
"ON a.atttypid = t.oid "
5732
5732
"WHERE a.attrelid = '%u'::pg_catalog.oid "
@@ -6557,7 +6557,7 @@ getForeignDataWrappers(int *numForeignDataWrappers)
6557
6557
"SELECT quote_ident(option_name) || ' ' || "
6558
6558
"quote_literal(option_value) "
6559
6559
"FROM pg_options_to_table(fdwoptions)"
6560
- "), ', ') AS fdwoptions "
6560
+ "), E',\n ') AS fdwoptions "
6561
6561
"FROM pg_foreign_data_wrapper" ,
6562
6562
username_subquery );
6563
6563
}
@@ -6571,7 +6571,7 @@ getForeignDataWrappers(int *numForeignDataWrappers)
6571
6571
"SELECT quote_ident(option_name) || ' ' || "
6572
6572
"quote_literal(option_value) "
6573
6573
"FROM pg_options_to_table(fdwoptions)"
6574
- "), ', ') AS fdwoptions "
6574
+ "), E',\n ') AS fdwoptions "
6575
6575
"FROM pg_foreign_data_wrapper" ,
6576
6576
username_subquery );
6577
6577
}
@@ -6660,7 +6660,7 @@ getForeignServers(int *numForeignServers)
6660
6660
"SELECT quote_ident(option_name) || ' ' || "
6661
6661
"quote_literal(option_value) "
6662
6662
"FROM pg_options_to_table(srvoptions)"
6663
- "), ', ') AS srvoptions "
6663
+ "), E',\n ') AS srvoptions "
6664
6664
"FROM pg_foreign_server" ,
6665
6665
username_subquery );
6666
6666
@@ -11575,7 +11575,7 @@ dumpForeignDataWrapper(Archive *fout, FdwInfo *fdwinfo)
11575
11575
appendPQExpBuffer (q , " VALIDATOR %s" , fdwinfo -> fdwvalidator );
11576
11576
11577
11577
if (strlen (fdwinfo -> fdwoptions ) > 0 )
11578
- appendPQExpBuffer (q , " OPTIONS (%s )" , fdwinfo -> fdwoptions );
11578
+ appendPQExpBuffer (q , " OPTIONS (\n %s\n )" , fdwinfo -> fdwoptions );
11579
11579
11580
11580
appendPQExpBuffer (q , ";\n" );
11581
11581
@@ -11679,7 +11679,7 @@ dumpForeignServer(Archive *fout, ForeignServerInfo *srvinfo)
11679
11679
appendPQExpBuffer (q , "%s" , fmtId (fdwname ));
11680
11680
11681
11681
if (srvinfo -> srvoptions && strlen (srvinfo -> srvoptions ) > 0 )
11682
- appendPQExpBuffer (q , " OPTIONS (%s )" , srvinfo -> srvoptions );
11682
+ appendPQExpBuffer (q , " OPTIONS (\n %s\n )" , srvinfo -> srvoptions );
11683
11683
11684
11684
appendPQExpBuffer (q , ";\n" );
11685
11685
@@ -11770,7 +11770,7 @@ dumpUserMappings(Archive *fout,
11770
11770
"SELECT quote_ident(option_name) || ' ' || "
11771
11771
"quote_literal(option_value) "
11772
11772
"FROM pg_options_to_table(umoptions)"
11773
- "), ', ') AS umoptions "
11773
+ "), E',\n ') AS umoptions "
11774
11774
"FROM pg_user_mappings "
11775
11775
"WHERE srvid = '%u' "
11776
11776
"ORDER BY usename" ,
@@ -11796,7 +11796,7 @@ dumpUserMappings(Archive *fout,
11796
11796
appendPQExpBuffer (q , " SERVER %s" , fmtId (servername ));
11797
11797
11798
11798
if (umoptions && strlen (umoptions ) > 0 )
11799
- appendPQExpBuffer (q , " OPTIONS (%s )" , umoptions );
11799
+ appendPQExpBuffer (q , " OPTIONS (\n %s\n )" , umoptions );
11800
11800
11801
11801
appendPQExpBuffer (q , ";\n" );
11802
11802
@@ -12431,7 +12431,7 @@ dumpTableSchema(Archive *fout, TableInfo *tbinfo)
12431
12431
"SELECT pg_catalog.quote_ident(option_name) || "
12432
12432
"' ' || pg_catalog.quote_literal(option_value) "
12433
12433
"FROM pg_catalog.pg_options_to_table(ftoptions)"
12434
- "), ', ') AS ftoptions "
12434
+ "), E',\n ') AS ftoptions "
12435
12435
"FROM pg_catalog.pg_foreign_table ft "
12436
12436
"JOIN pg_catalog.pg_foreign_server fs "
12437
12437
"ON (fs.oid = ft.ftserver) "
@@ -12660,7 +12660,7 @@ dumpTableSchema(Archive *fout, TableInfo *tbinfo)
12660
12660
12661
12661
/* Dump generic options if any */
12662
12662
if (ftoptions && ftoptions [0 ])
12663
- appendPQExpBuffer (q , "\nOPTIONS (%s )" , ftoptions );
12663
+ appendPQExpBuffer (q , "\nOPTIONS (\n %s\n )" , ftoptions );
12664
12664
12665
12665
appendPQExpBuffer (q , ";\n" );
12666
12666
@@ -12860,7 +12860,7 @@ dumpTableSchema(Archive *fout, TableInfo *tbinfo)
12860
12860
fmtId (tbinfo -> dobj .name ));
12861
12861
appendPQExpBuffer (q , "ALTER COLUMN %s " ,
12862
12862
fmtId (tbinfo -> attnames [j ]));
12863
- appendPQExpBuffer (q , "OPTIONS (%s );\n" ,
12863
+ appendPQExpBuffer (q , "OPTIONS (\n %s\n );\n" ,
12864
12864
tbinfo -> attfdwoptions [j ]);
12865
12865
}
12866
12866
}
0 commit comments