lib/data_miner/step/sql.rb in data_miner-2.4.0 vs lib/data_miner/step/sql.rb in data_miner-2.4.1

@@ -110,8 +110,23 @@
         unless child.success?
           raise RuntimeError, "[data_miner] Failed: #{argv.join(' ').inspect} (#{child.err.inspect})"
         end
         nil
       end
+
+      def sqlite3(path)
+        argv = [
+          'sqlite3',
+          config[:database]
+        ]
+        File.open(path) do |f|
+          pid = POSIX::Spawn.spawn(*(argv+[{:in => f}]))
+          ::Process.waitpid pid
+        end
+        unless $?.success?
+          raise RuntimeError, %{[data_miner] Failed: "cat #{path} | #{argv.join(' ')}"}
+        end
+        nil
+      end
     end
   end
 end