lib/forklift/transports/mysql.rb in forklift_etl-1.0.17 vs lib/forklift/transports/mysql.rb in forklift_etl-1.0.18

@@ -166,14 +166,19 @@
           cols << row[:Field]
         end
         cols
       end
 
-      def dump(file)
+      def dump(file, options=[])
+        # example options: 
+        # options.push '--max_allowed_packet=512M'
+        # options.push '--set-gtid-purged=OFF'
         cmd = "mysqldump"
         cmd << " -u#{config[:username]}" unless config[:username].nil?
         cmd << " -p#{config[:password]}" unless config[:password].nil?
-        cmd << " --max_allowed_packet=512M"
+        options.each do |o|
+          cmd << " #{o} "
+        end
         cmd << " #{config[:database]}"
         cmd << " | gzip > #{file}"
         forklift.logger.log "Dumping #{config['database']} to #{file}"
         forklift.logger.debug cmd
         `#{cmd}`