Method: DatabricksSQL#sql_request

Defined in:
lib/dbx/databricks/sql.rb

#sql_request(sql) ⇒ Object

POST request object POST /api/2.0/sql/statements



20
21
22
23
24
25
26
27
28
29
 
# File 'lib/dbx/databricks/sql.rb', line 20

def sql_request(sql)
  params = {
    "statement" => sql,
    "wait_timeout" => "0s",
    "warehouse_id" => @warehouse
  }
  request = Net::HTTP::Post.new(sql_uri.request_uri, request_headers)
  request.body = params.to_json
  request
end