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") {