jackross/threequel

module Threequel
  module SQL
    class Command
      SUCCESS = { :message => 'Command executed successfully', :status => :success }
      attr_reader :name

      def initialize(unsanitized_sql, name = 'Anonymous Command', opts = {})
        @name            = name
        @opts            = opts.reverse_merge(default_opts)
        @statement_array = SQL::StatementArray.new(unsanitized_sql, name, @opts)
        yield self if block_given?
      end
      delegate :sql, :statements, :to => :@statement_array

      def execute_on(connection)
        statements.each do |statement|
          statement.command_name = @name
          result = statement.execute_on connection

          return result if result[:status] == :failure
        end
        SUCCESS
      end

      def attributes
        { :sql => sql, :command => @name, :statement => nil }
      end

      def inspect
        sql
      end

      private
      def default_opts
        {}
      end

    end
  end
end