sharpetronics/PostgreSQL
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-06-03 00:02:26 -04:00
Code Issues Projects Releases Wiki Activity

Fix some minor issues in view pretty-printing.

Browse Source 
Code review for commit 2f582f76b1945929ff07116cd4639747ce9bb8a1: don't use
a static variable for what ought to be a deparse_context field, fix
non-multibyte-safe test for spaces, avoid useless and potentially O(N^2)
(though admittedly with a very small constant) calculations of wrap
positions when we aren't going to wrap.
This commit is contained in:
Tom Lane 2012-12-24 17:52:27 -05:00
parent de4cf42af9
commit 7ec225d3d6
2 changed files with 120 additions and 108 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
doc/src/sgml/func.sgml
View File

@ -13820,7 +13820,7 @@ SELECT pg_type_is_visible('myschema.widget'::regtype);
<row> <row>
<entry><literal><function>pg_get_viewdef(<parameter>view_name</parameter>, <parameter>pretty_bool</>)</function></literal></entry> <entry><literal><function>pg_get_viewdef(<parameter>view_name</parameter>, <parameter>pretty_bool</>)</function></literal></entry>
<entry><type>text</type></entry> <entry><type>text</type></entry>
<entry>get underlying <command>SELECT</command> command for view, <entry>get underlying <command>SELECT</command> command for view;
lines with fields are wrapped to 80 columns if <parameter>pretty_bool</parameter> is true (<emphasis>deprecated</emphasis>)</entry> lines with fields are wrapped to 80 columns if <parameter>pretty_bool</parameter> is true (<emphasis>deprecated</emphasis>)</entry>
</row> </row>
<row> <row>
@ -13831,14 +13831,15 @@ SELECT pg_type_is_visible('myschema.widget'::regtype);
<row> <row>
<entry><literal><function>pg_get_viewdef(<parameter>view_oid</parameter>, <parameter>pretty_bool</>)</function></literal></entry> <entry><literal><function>pg_get_viewdef(<parameter>view_oid</parameter>, <parameter>pretty_bool</>)</function></literal></entry>
<entry><type>text</type></entry> <entry><type>text</type></entry>
<entry>get underlying <command>SELECT</command> command for view, <entry>get underlying <command>SELECT</command> command for view;
lines with fields are wrapped to 80 columns if <parameter>pretty_bool</parameter> is true</entry> lines with fields are wrapped to 80 columns if <parameter>pretty_bool</parameter> is true</entry>
</row> </row>
<row> <row>
<entry><literal><function>pg_get_viewdef(<parameter>view_oid</parameter>, <parameter>wrap_int</>)</function></literal></entry> <entry><literal><function>pg_get_viewdef(<parameter>view_oid</parameter>, <parameter>wrap_column_int</>)</function></literal></entry>
<entry><type>text</type></entry> <entry><type>text</type></entry>
<entry>get underlying <command>SELECT</command> command for view, <entry>get underlying <command>SELECT</command> command for view;
wrapping lines with fields as specified, pretty printing is implied</entry> lines with fields are wrapped to specified number of columns,
pretty printing is implied</entry>
</row> </row>
<row> <row>
<entry><literal><function>pg_options_to_table(<parameter>reloptions</parameter>)</function></literal></entry> <entry><literal><function>pg_options_to_table(<parameter>reloptions</parameter>)</function></literal></entry>

217
src/backend/utils/adt/ruleutils.c
View File

@ -73,7 +73,8 @@
#define PRETTYFLAG_PAREN 1 #define PRETTYFLAG_PAREN 1
#define PRETTYFLAG_INDENT 2 #define PRETTYFLAG_INDENT 2
#define PRETTY_WRAP_DEFAULT 79 /* Default line length for pretty-print wrapping */
#define WRAP_COLUMN_DEFAULT 79
/* macro to test if pretty action needed */ /* macro to test if pretty action needed */
#define PRETTY_PAREN(context) ((context)->prettyFlags & PRETTYFLAG_PAREN) #define PRETTY_PAREN(context) ((context)->prettyFlags & PRETTYFLAG_PAREN)
@ -93,6 +94,7 @@ typedef struct
List *windowClause; /* Current query level's WINDOW clause */ List *windowClause; /* Current query level's WINDOW clause */
List *windowTList; /* targetlist for resolving WINDOW clause */ List *windowTList; /* targetlist for resolving WINDOW clause */
int prettyFlags; /* enabling of pretty-print functions */ int prettyFlags; /* enabling of pretty-print functions */
int wrapColumn; /* max line length, or -1 for no limit */
int indentLevel; /* current indent level for prettyprint */ int indentLevel; /* current indent level for prettyprint */
bool varprefix; /* TRUE to print prefixes on Vars */ bool varprefix; /* TRUE to print prefixes on Vars */
} deparse_context; } deparse_context;
@ -138,7 +140,6 @@ static SPIPlanPtr plan_getrulebyoid = NULL;
static const char *query_getrulebyoid = "SELECT * FROM pg_catalog.pg_rewrite WHERE oid = $1"; static const char *query_getrulebyoid = "SELECT * FROM pg_catalog.pg_rewrite WHERE oid = $1";
static SPIPlanPtr plan_getviewrule = NULL; static SPIPlanPtr plan_getviewrule = NULL;
static const char *query_getviewrule = "SELECT * FROM pg_catalog.pg_rewrite WHERE ev_class = $1 AND rulename = $2"; static const char *query_getviewrule = "SELECT * FROM pg_catalog.pg_rewrite WHERE ev_class = $1 AND rulename = $2";
static int pretty_wrap = PRETTY_WRAP_DEFAULT;
/* GUC parameters */ /* GUC parameters */
bool quote_all_identifiers = false; bool quote_all_identifiers = false;
@ -155,7 +156,8 @@ bool quote_all_identifiers = false;
static char *deparse_expression_pretty(Node *expr, List *dpcontext, static char *deparse_expression_pretty(Node *expr, List *dpcontext,
bool forceprefix, bool showimplicit, bool forceprefix, bool showimplicit,
int prettyFlags, int startIndent); int prettyFlags, int startIndent);
static char *pg_get_viewdef_worker(Oid viewoid, int prettyFlags); static char *pg_get_viewdef_worker(Oid viewoid,
int prettyFlags, int wrapColumn);
static char *pg_get_triggerdef_worker(Oid trigid, bool pretty); static char *pg_get_triggerdef_worker(Oid trigid, bool pretty);
static void decompile_column_index_array(Datum column_index_array, Oid relId, static void decompile_column_index_array(Datum column_index_array, Oid relId,
StringInfo buf); StringInfo buf);
@ -183,9 +185,10 @@ static void pop_ancestor_plan(deparse_namespace *dpns,
static void make_ruledef(StringInfo buf, HeapTuple ruletup, TupleDesc rulettc, static void make_ruledef(StringInfo buf, HeapTuple ruletup, TupleDesc rulettc,
int prettyFlags); int prettyFlags);
static void make_viewdef(StringInfo buf, HeapTuple ruletup, TupleDesc rulettc, static void make_viewdef(StringInfo buf, HeapTuple ruletup, TupleDesc rulettc,
int prettyFlags); int prettyFlags, int wrapColumn);
static void get_query_def(Query *query, StringInfo buf, List *parentnamespace, static void get_query_def(Query *query, StringInfo buf, List *parentnamespace,
TupleDesc resultDesc, int prettyFlags, int startIndent); TupleDesc resultDesc,
int prettyFlags, int wrapColumn, int startIndent);
static void get_values_def(List *values_lists, deparse_context *context); static void get_values_def(List *values_lists, deparse_context *context);
static void get_with_clause(Query *query, deparse_context *context); static void get_with_clause(Query *query, deparse_context *context);
static void get_select_query_def(Query *query, deparse_context *context, static void get_select_query_def(Query *query, deparse_context *context,
@ -367,7 +370,7 @@ pg_get_viewdef(PG_FUNCTION_ARGS)
/* By OID */ /* By OID */
Oid viewoid = PG_GETARG_OID(0); Oid viewoid = PG_GETARG_OID(0);
PG_RETURN_TEXT_P(string_to_text(pg_get_viewdef_worker(viewoid, 0))); PG_RETURN_TEXT_P(string_to_text(pg_get_viewdef_worker(viewoid, 0, -1)));
} }
@ -380,7 +383,7 @@ pg_get_viewdef_ext(PG_FUNCTION_ARGS)
int prettyFlags; int prettyFlags;
prettyFlags = pretty ? PRETTYFLAG_PAREN | PRETTYFLAG_INDENT : 0; prettyFlags = pretty ? PRETTYFLAG_PAREN | PRETTYFLAG_INDENT : 0;
PG_RETURN_TEXT_P(string_to_text(pg_get_viewdef_worker(viewoid, prettyFlags))); PG_RETURN_TEXT_P(string_to_text(pg_get_viewdef_worker(viewoid, prettyFlags, WRAP_COLUMN_DEFAULT)));
} }
Datum Datum
@ -394,9 +397,7 @@ pg_get_viewdef_wrap(PG_FUNCTION_ARGS)
/* calling this implies we want pretty printing */ /* calling this implies we want pretty printing */
prettyFlags = PRETTYFLAG_PAREN | PRETTYFLAG_INDENT; prettyFlags = PRETTYFLAG_PAREN | PRETTYFLAG_INDENT;
pretty_wrap = wrap; result = pg_get_viewdef_worker(viewoid, prettyFlags, wrap);
result = pg_get_viewdef_worker(viewoid, prettyFlags);
pretty_wrap = PRETTY_WRAP_DEFAULT;
PG_RETURN_TEXT_P(string_to_text(result)); PG_RETURN_TEXT_P(string_to_text(result));
} }
@ -412,7 +413,7 @@ pg_get_viewdef_name(PG_FUNCTION_ARGS)
viewrel = makeRangeVarFromNameList(textToQualifiedNameList(viewname)); viewrel = makeRangeVarFromNameList(textToQualifiedNameList(viewname));
viewoid = RangeVarGetRelid(viewrel, NoLock, false); viewoid = RangeVarGetRelid(viewrel, NoLock, false);
PG_RETURN_TEXT_P(string_to_text(pg_get_viewdef_worker(viewoid, 0))); PG_RETURN_TEXT_P(string_to_text(pg_get_viewdef_worker(viewoid, 0, -1)));
} }
@ -432,14 +433,14 @@ pg_get_viewdef_name_ext(PG_FUNCTION_ARGS)
viewrel = makeRangeVarFromNameList(textToQualifiedNameList(viewname)); viewrel = makeRangeVarFromNameList(textToQualifiedNameList(viewname));
viewoid = RangeVarGetRelid(viewrel, NoLock, false); viewoid = RangeVarGetRelid(viewrel, NoLock, false);
PG_RETURN_TEXT_P(string_to_text(pg_get_viewdef_worker(viewoid, prettyFlags))); PG_RETURN_TEXT_P(string_to_text(pg_get_viewdef_worker(viewoid, prettyFlags, WRAP_COLUMN_DEFAULT)));
} }
/* /*
* Common code for by-OID and by-name variants of pg_get_viewdef * Common code for by-OID and by-name variants of pg_get_viewdef
*/ */
static char * static char *
pg_get_viewdef_worker(Oid viewoid, int prettyFlags) pg_get_viewdef_worker(Oid viewoid, int prettyFlags, int wrapColumn)
{ {
Datum args[2]; Datum args[2];
char nulls[2]; char nulls[2];
@ -497,7 +498,7 @@ pg_get_viewdef_worker(Oid viewoid, int prettyFlags)
*/ */
ruletup = SPI_tuptable->vals[0]; ruletup = SPI_tuptable->vals[0];
rulettc = SPI_tuptable->tupdesc; rulettc = SPI_tuptable->tupdesc;
make_viewdef(&buf, ruletup, rulettc, prettyFlags); make_viewdef(&buf, ruletup, rulettc, prettyFlags, wrapColumn);
} }
/* /*
@ -699,6 +700,7 @@ pg_get_triggerdef_worker(Oid trigid, bool pretty)
context.windowTList = NIL; context.windowTList = NIL;
context.varprefix = true; context.varprefix = true;
context.prettyFlags = pretty ? PRETTYFLAG_PAREN : 0; context.prettyFlags = pretty ? PRETTYFLAG_PAREN : 0;
context.wrapColumn = WRAP_COLUMN_DEFAULT;
context.indentLevel = PRETTYINDENT_STD; context.indentLevel = PRETTYINDENT_STD;
get_rule_expr(qual, &context, false); get_rule_expr(qual, &context, false);
@ -2145,6 +2147,7 @@ deparse_expression_pretty(Node *expr, List *dpcontext,
context.windowTList = NIL; context.windowTList = NIL;
context.varprefix = forceprefix; context.varprefix = forceprefix;
context.prettyFlags = prettyFlags; context.prettyFlags = prettyFlags;
context.wrapColumn = WRAP_COLUMN_DEFAULT;
context.indentLevel = startIndent; context.indentLevel = startIndent;
get_rule_expr(expr, &context, showimplicit); get_rule_expr(expr, &context, showimplicit);
@ -2523,6 +2526,7 @@ make_ruledef(StringInfo buf, HeapTuple ruletup, TupleDesc rulettc,
context.windowTList = NIL; context.windowTList = NIL;
context.varprefix = (list_length(query->rtable) != 1); context.varprefix = (list_length(query->rtable) != 1);
context.prettyFlags = prettyFlags; context.prettyFlags = prettyFlags;
context.wrapColumn = WRAP_COLUMN_DEFAULT;
context.indentLevel = PRETTYINDENT_STD; context.indentLevel = PRETTYINDENT_STD;
memset(&dpns, 0, sizeof(dpns)); memset(&dpns, 0, sizeof(dpns));
@ -2548,7 +2552,8 @@ make_ruledef(StringInfo buf, HeapTuple ruletup, TupleDesc rulettc,
foreach(action, actions) foreach(action, actions)
{ {
query = (Query *) lfirst(action); query = (Query *) lfirst(action);
get_query_def(query, buf, NIL, NULL, prettyFlags, 0); get_query_def(query, buf, NIL, NULL,
prettyFlags, WRAP_COLUMN_DEFAULT, 0);
if (prettyFlags) if (prettyFlags)
appendStringInfo(buf, ";\n"); appendStringInfo(buf, ";\n");
else else
@ -2565,7 +2570,8 @@ make_ruledef(StringInfo buf, HeapTuple ruletup, TupleDesc rulettc,
Query *query; Query *query;
query = (Query *) linitial(actions); query = (Query *) linitial(actions);
get_query_def(query, buf, NIL, NULL, prettyFlags, 0); get_query_def(query, buf, NIL, NULL,
prettyFlags, WRAP_COLUMN_DEFAULT, 0);
appendStringInfo(buf, ";"); appendStringInfo(buf, ";");
} }
} }
@ -2578,7 +2584,7 @@ make_ruledef(StringInfo buf, HeapTuple ruletup, TupleDesc rulettc,
*/ */
static void static void
make_viewdef(StringInfo buf, HeapTuple ruletup, TupleDesc rulettc, make_viewdef(StringInfo buf, HeapTuple ruletup, TupleDesc rulettc,
int prettyFlags) int prettyFlags, int wrapColumn)
{ {
Query *query; Query *query;
char ev_type; char ev_type;
@ -2633,7 +2639,7 @@ make_viewdef(StringInfo buf, HeapTuple ruletup, TupleDesc rulettc,
ev_relation = heap_open(ev_class, AccessShareLock); ev_relation = heap_open(ev_class, AccessShareLock);
get_query_def(query, buf, NIL, RelationGetDescr(ev_relation), get_query_def(query, buf, NIL, RelationGetDescr(ev_relation),
prettyFlags, 0); prettyFlags, wrapColumn, 0);
appendStringInfo(buf, ";"); appendStringInfo(buf, ";");
heap_close(ev_relation, AccessShareLock); heap_close(ev_relation, AccessShareLock);
@ -2649,7 +2655,8 @@ make_viewdef(StringInfo buf, HeapTuple ruletup, TupleDesc rulettc,
*/ */
static void static void
get_query_def(Query *query, StringInfo buf, List *parentnamespace, get_query_def(Query *query, StringInfo buf, List *parentnamespace,
TupleDesc resultDesc, int prettyFlags, int startIndent) TupleDesc resultDesc,
int prettyFlags, int wrapColumn, int startIndent)
{ {
deparse_context context; deparse_context context;
deparse_namespace dpns; deparse_namespace dpns;
@ -2669,6 +2676,7 @@ get_query_def(Query *query, StringInfo buf, List *parentnamespace,
context.varprefix = (parentnamespace != NIL || context.varprefix = (parentnamespace != NIL ||
list_length(query->rtable) != 1); list_length(query->rtable) != 1);
context.prettyFlags = prettyFlags; context.prettyFlags = prettyFlags;
context.wrapColumn = wrapColumn;
context.indentLevel = startIndent; context.indentLevel = startIndent;
memset(&dpns, 0, sizeof(dpns)); memset(&dpns, 0, sizeof(dpns));
@ -2804,7 +2812,8 @@ get_with_clause(Query *query, deparse_context *context)
if (PRETTY_INDENT(context)) if (PRETTY_INDENT(context))
appendContextKeyword(context, "", 0, 0, 0); appendContextKeyword(context, "", 0, 0, 0);
get_query_def((Query *) cte->ctequery, buf, context->namespaces, NULL, get_query_def((Query *) cte->ctequery, buf, context->namespaces, NULL,
context->prettyFlags, context->indentLevel); context->prettyFlags, context->wrapColumn,
context->indentLevel);
if (PRETTY_INDENT(context)) if (PRETTY_INDENT(context))
appendContextKeyword(context, "", 0, 0, 0); appendContextKeyword(context, "", 0, 0, 0);
appendStringInfoChar(buf, ')'); appendStringInfoChar(buf, ')');
@ -3034,10 +3043,14 @@ get_target_list(List *targetList, deparse_context *context,
TupleDesc resultDesc) TupleDesc resultDesc)
{ {
StringInfo buf = context->buf; StringInfo buf = context->buf;
StringInfoData targetbuf;
bool last_was_multiline = false;
char *sep; char *sep;
int colno; int colno;
ListCell *l; ListCell *l;
bool last_was_multiline = false;
/* we use targetbuf to hold each TLE's text temporarily */
initStringInfo(&targetbuf);
sep = " "; sep = " ";
colno = 0; colno = 0;
@ -3046,10 +3059,6 @@ get_target_list(List *targetList, deparse_context *context,
TargetEntry *tle = (TargetEntry *) lfirst(l); TargetEntry *tle = (TargetEntry *) lfirst(l);
char *colname; char *colname;
char *attname; char *attname;
StringInfoData targetbuf;
int leading_nl_pos = -1;
char *trailing_nl;
int pos;
if (tle->resjunk) if (tle->resjunk)
continue; /* ignore junk entries */ continue; /* ignore junk entries */
@ -3059,11 +3068,10 @@ get_target_list(List *targetList, deparse_context *context,
colno++; colno++;
/* /*
* Put the new field spec into targetbuf so we can decide after we've * Put the new field text into targetbuf so we can decide after we've
* got it whether or not it needs to go on a new line. * got it whether or not it needs to go on a new line.
*/ */
resetStringInfo(&targetbuf);
initStringInfo(&targetbuf);
context->buf = &targetbuf; context->buf = &targetbuf;
/* /*
@ -3104,63 +3112,60 @@ get_target_list(List *targetList, deparse_context *context,
appendStringInfo(&targetbuf, " AS %s", quote_identifier(colname)); appendStringInfo(&targetbuf, " AS %s", quote_identifier(colname));
} }
/* Restore context buffer */ /* Restore context's output buffer */
context->buf = buf; context->buf = buf;
/* Does the new field start with whitespace plus a new line? */ /* Consider line-wrapping if enabled */
if (PRETTY_INDENT(context) && context->wrapColumn >= 0)
for (pos = 0; pos < targetbuf.len; pos++)
{ {
if (targetbuf.data[pos] == '\n') int leading_nl_pos = -1;
char *trailing_nl;
int pos;
/* Does the new field start with whitespace plus a new line? */
for (pos = 0; pos < targetbuf.len; pos++)
{ {
leading_nl_pos = pos; if (targetbuf.data[pos] == '\n')
break; {
leading_nl_pos = pos;
break;
}
if (targetbuf.data[pos] != ' ')
break;
} }
if (targetbuf.data[pos] > ' ')
break;
}
/* Locate the start of the current line in the buffer */ /* Locate the start of the current line in the output buffer */
trailing_nl = strrchr(buf->data, '\n');
if (trailing_nl == NULL)
trailing_nl = buf->data;
else
trailing_nl++;
trailing_nl = (strrchr(buf->data, '\n')); /*
if (trailing_nl == NULL) * If the field we're adding is the first in the list, or it
trailing_nl = buf->data; * already has a leading newline, don't add anything. Otherwise,
else * add a newline, plus some indentation, if either the new field
trailing_nl++; * would cause an overflow or the last field used more than one
* line.
*/
if (colno > 1 &&
leading_nl_pos == -1 &&
((strlen(trailing_nl) + strlen(targetbuf.data) > context->wrapColumn) ||
last_was_multiline))
appendContextKeyword(context, "", -PRETTYINDENT_STD,
PRETTYINDENT_STD, PRETTYINDENT_VAR);
/* /* Remember this field's multiline status for next iteration */
* If the field we're adding is the first in the list, or it already last_was_multiline =
* has a leading newline, or wrap mode is disabled (pretty_wrap < 0), (strchr(targetbuf.data + leading_nl_pos + 1, '\n') != NULL);
* don't add anything. Otherwise, add a newline, plus some
* indentation, if either the new field would cause an overflow or the
* last field used more than one line.
*/
if (colno > 1 &&
leading_nl_pos == -1 &&
pretty_wrap >= 0 &&
((strlen(trailing_nl) + strlen(targetbuf.data) > pretty_wrap) ||
last_was_multiline))
{
appendContextKeyword(context, "", -PRETTYINDENT_STD,
PRETTYINDENT_STD, PRETTYINDENT_VAR);
} }
/* Add the new field */ /* Add the new field */
appendStringInfoString(buf, targetbuf.data); appendStringInfoString(buf, targetbuf.data);
/* Keep track of this field's status for next iteration */
last_was_multiline =
(strchr(targetbuf.data + leading_nl_pos + 1, '\n') != NULL);
/* cleanup */
pfree(targetbuf.data);
} }
/* clean up */
pfree(targetbuf.data);
} }
static void static void
@ -3187,7 +3192,8 @@ get_setop_query(Node *setOp, Query *query, deparse_context *context,
if (need_paren) if (need_paren)
appendStringInfoChar(buf, '('); appendStringInfoChar(buf, '(');
get_query_def(subquery, buf, context->namespaces, resultDesc, get_query_def(subquery, buf, context->namespaces, resultDesc,
context->prettyFlags, context->indentLevel); context->prettyFlags, context->wrapColumn,
context->indentLevel);
if (need_paren) if (need_paren)
appendStringInfoChar(buf, ')'); appendStringInfoChar(buf, ')');
} }
@ -3603,7 +3609,8 @@ get_insert_query_def(Query *query, deparse_context *context)
{ {
/* Add the SELECT */ /* Add the SELECT */
get_query_def(select_rte->subquery, buf, NIL, NULL, get_query_def(select_rte->subquery, buf, NIL, NULL,
context->prettyFlags, context->indentLevel); context->prettyFlags, context->wrapColumn,
context->indentLevel);
} }
else if (values_rte) else if (values_rte)
{ {
@ -6517,7 +6524,8 @@ get_sublink_expr(SubLink *sublink, deparse_context *context)
appendStringInfoChar(buf, '('); appendStringInfoChar(buf, '(');
get_query_def(query, buf, context->namespaces, NULL, get_query_def(query, buf, context->namespaces, NULL,
context->prettyFlags, context->indentLevel); context->prettyFlags, context->wrapColumn,
context->indentLevel);
if (need_paren) if (need_paren)
appendStringInfo(buf, "))"); appendStringInfo(buf, "))");
@ -6571,47 +6579,49 @@ get_from_clause(Query *query, const char *prefix, deparse_context *context)
} }
else else
{ {
StringInfoData targetbuf; StringInfoData itembuf;
char *trailing_nl;
appendStringInfoString(buf, ", "); appendStringInfoString(buf, ", ");
initStringInfo(&targetbuf); /*
context->buf = &targetbuf; * Put the new FROM item's text into itembuf so we can decide
* after we've got it whether or not it needs to go on a new line.
*/
initStringInfo(&itembuf);
context->buf = &itembuf;
get_from_clause_item(jtnode, query, context); get_from_clause_item(jtnode, query, context);
/* Restore context's output buffer */
context->buf = buf; context->buf = buf;
/* Locate the start of the current line in the buffer */ /* Consider line-wrapping if enabled */
if (PRETTY_INDENT(context) && context->wrapColumn >= 0)
trailing_nl = (strrchr(buf->data, '\n'));
if (trailing_nl == NULL)
trailing_nl = buf->data;
else
trailing_nl++;
/*
* Add a newline, plus some indentation, if pretty_wrap is on and
* the new from-clause item would cause an overflow.
*/
if (pretty_wrap >= 0 &&
(strlen(trailing_nl) + strlen(targetbuf.data) > pretty_wrap))
{ {
appendContextKeyword(context, "", -PRETTYINDENT_STD, char *trailing_nl;
PRETTYINDENT_STD, PRETTYINDENT_VAR);
/* Locate the start of the current line in the buffer */
trailing_nl = strrchr(buf->data, '\n');
if (trailing_nl == NULL)
trailing_nl = buf->data;
else
trailing_nl++;
/*
* Add a newline, plus some indentation, if the new item would
* cause an overflow.
*/
if (strlen(trailing_nl) + strlen(itembuf.data) > context->wrapColumn)
appendContextKeyword(context, "", -PRETTYINDENT_STD,
PRETTYINDENT_STD, PRETTYINDENT_VAR);
} }
/* Add the new item */ /* Add the new item */
appendStringInfoString(buf, itembuf.data);
appendStringInfoString(buf, targetbuf.data); /* clean up */
pfree(itembuf.data);
/* cleanup */
pfree(targetbuf.data);
} }
} }
} }
@ -6639,7 +6649,8 @@ get_from_clause_item(Node *jtnode, Query *query, deparse_context *context)
/* Subquery RTE */ /* Subquery RTE */
appendStringInfoChar(buf, '('); appendStringInfoChar(buf, '(');
get_query_def(rte->subquery, buf, context->namespaces, NULL, get_query_def(rte->subquery, buf, context->namespaces, NULL,
context->prettyFlags, context->indentLevel); context->prettyFlags, context->wrapColumn,
context->indentLevel);
appendStringInfoChar(buf, ')'); appendStringInfoChar(buf, ')');
break; break;
case RTE_FUNCTION: case RTE_FUNCTION: