Contents

module Blazer
  module Adapters
    class HiveAdapter < BaseAdapter
      def run_statement(statement, comment)
        columns = []
        rows = []
        error = nil

        begin
          result = client.execute("#{statement} /*#{comment}*/")
          columns = result.any? ? result.first.keys : []
          rows = result.map(&:values)
        rescue => e
          error = e.message
        end

        [columns, rows, error]
      end

      def tables
        client.execute("SHOW TABLES").map { |r| r["tab_name"] }
      end

      def preview_statement
        "SELECT * FROM {table} LIMIT 10"
      end

      # https://cwiki.apache.org/confluence/display/Hive/LanguageManual+Types#LanguageManualTypes-StringsstringStrings
      def quoting
        :backslash_escape
      end

      # has variable substitution, but sets for session
      # https://cwiki.apache.org/confluence/display/Hive/LanguageManual+VariableSubstitution
      def parameter_binding
      end

      protected

      def client
        @client ||= begin
          uri = URI.parse(settings["url"])
          Hexspace::Client.new(
            host: uri.host,
            port: uri.port,
            username: uri.user,
            password: uri.password,
            database: uri.path.delete_prefix("/"),
            mode: uri.scheme.to_sym
          )
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 2 rubygems

Version	Path
blazer-3.2.0	lib/blazer/adapters/hive_adapter.rb
blazer-3.1.0	lib/blazer/adapters/hive_adapter.rb
blazer-3.0.4	lib/blazer/adapters/hive_adapter.rb
blazer_xlsx-3.0.8	lib/blazer/adapters/hive_adapter.rb