| diff --git a/backup/data.go b/backup/data.go
|
| index 68bc2cb..5bf1e4e 100644
|
| --- a/backup/data.go
|
| +++ b/backup/data.go
|
| @@ -82,7 +82,14 @@ func CopyTableOut(connectionPool *dbconn.DBConn, table Table, destinationToWrite
|
| sendToDestinationCommand = fmt.Sprintf("| %s backup_data %s", pluginConfig.ExecutablePath, pluginConfig.ConfigPath)
|
| }
|
|
|
| - copyCommand := fmt.Sprintf("PROGRAM '%s%s %s %s'", checkPipeExistsCommand, customPipeThroughCommand, sendToDestinationCommand, destinationToWrite)
|
| + var copyCommand string
|
| +
|
| + if customPipeThroughCommand == "cat -" && MustGetFlagString(options.PLUGIN_CONFIG) != "" {
|
| + sendToDestinationCommand = fmt.Sprintf("%s backup_data %s", pluginConfig.ExecutablePath, pluginConfig.ConfigPath)
|
| + copyCommand = fmt.Sprintf("PROGRAM '%s %s'", sendToDestinationCommand, destinationToWrite)
|
| + } else {
|
| + copyCommand = fmt.Sprintf("PROGRAM '%s%s %s %s'", checkPipeExistsCommand, customPipeThroughCommand, sendToDestinationCommand, destinationToWrite)
|
| + }
|
|
|
| columnNames := ""
|
| if connectionPool.Version.AtLeast("7") {
|