diff options
Diffstat (limited to 'src/backend/tcop/dest.c')
| -rw-r--r-- | src/backend/tcop/dest.c | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/src/backend/tcop/dest.c b/src/backend/tcop/dest.c index da39f43f38c..28081c37654 100644 --- a/src/backend/tcop/dest.c +++ b/src/backend/tcop/dest.c @@ -28,6 +28,7 @@ #include "postgres.h" +#include "access/printsimple.h" #include "access/printtup.h" #include "access/xact.h" #include "commands/copy.h" @@ -76,6 +77,11 @@ static DestReceiver debugtupDR = { DestDebug }; +static DestReceiver printsimpleDR = { + printsimple, printsimple_startup, donothingCleanup, donothingCleanup, + DestRemoteSimple +}; + static DestReceiver spi_printtupDR = { spi_printtup, spi_dest_startup, donothingCleanup, donothingCleanup, DestSPI @@ -108,6 +114,9 @@ CreateDestReceiver(CommandDest dest) case DestRemoteExecute: return printtup_create_DR(dest); + case DestRemoteSimple: + return &printsimpleDR; + case DestNone: return &donothingDR; @@ -151,6 +160,7 @@ EndCommand(const char *commandTag, CommandDest dest) { case DestRemote: case DestRemoteExecute: + case DestRemoteSimple: /* * We assume the commandTag is plain ASCII and therefore requires @@ -191,6 +201,7 @@ NullCommand(CommandDest dest) { case DestRemote: case DestRemoteExecute: + case DestRemoteSimple: /* * tell the fe that we saw an empty query string. In protocols @@ -233,6 +244,7 @@ ReadyForQuery(CommandDest dest) { case DestRemote: case DestRemoteExecute: + case DestRemoteSimple: if (PG_PROTOCOL_MAJOR(FrontendProtocol) >= 3) { StringInfoData buf; |