pass 2 more parameters to public API for sql queries

Author: FChataigner

dataikuapi/dss/sqlquery.py

@@ -7,7 +7,7 @@ class DSSSQLQuery(object):
     """
     A connection to a database or database-like on which queries can be run through DSS
     """
-    def __init__(self, client, query, connection, database, dataset_full_name, pre_queries, post_queries, type, extra_conf, script_steps, script_input_schema, script_output_schema, script_report_location):
+    def __init__(self, client, query, connection, database, dataset_full_name, pre_queries, post_queries, type, extra_conf, script_steps, script_input_schema, script_output_schema, script_report_location, read_timestamp_without_timezone_as_string, read_date_as_string):
         self.client = client
 
         self.streaming_session = self.client._perform_json(
@@ -24,7 +24,9 @@ def __init__(self, client, query, connection, database, dataset_full_name, pre_q
                     "scriptSteps" : script_steps,
                     "scriptInputSchema" : script_input_schema,
                     "scriptOutputSchema" : script_output_schema,
-                    "scriptReportLocation" : script_report_location
+                    "scriptReportLocation" : script_report_location,
+                    "readTimestampWithoutTimezoneAsString" : read_timestamp_without_timezone_as_string,
+                    "readDateAsString" : read_date_as_string
                 })
         self.queryId = self.streaming_session['queryId']
 

dataikuapi/dssclient.py

@@ -182,7 +182,7 @@ def get_plugin(self, plugin_id):
     # SQL queries
     ########################################################
 
-    def sql_query(self, query, connection=None, database=None, dataset_full_name=None, pre_queries=None, post_queries=None, type='sql', extra_conf={}, script_steps=None, script_input_schema=None, script_output_schema=None, script_report_location=None):
+    def sql_query(self, query, connection=None, database=None, dataset_full_name=None, pre_queries=None, post_queries=None, type='sql', extra_conf={}, script_steps=None, script_input_schema=None, script_output_schema=None, script_report_location=None, read_timestamp_without_timezone_as_string=True, read_date_as_string=False):
         """
         Initiate a SQL, Hive or Impala query and get a handle to retrieve the results of the query.
         Internally, the query is run by DSS. The  database to run the query on is specified either by 
@@ -199,7 +199,7 @@ def sql_query(self, query, connection=None, database=None, dataset_full_name=Non
         
         :returns: A :class:`dataikuapi.dss.sqlquery.DSSSQLQuery` query handle
         """
-        return DSSSQLQuery(self, query, connection, database, dataset_full_name, pre_queries, post_queries, type, extra_conf, script_steps, script_input_schema, script_output_schema, script_report_location)
+        return DSSSQLQuery(self, query, connection, database, dataset_full_name, pre_queries, post_queries, type, extra_conf, script_steps, script_input_schema, script_output_schema, script_report_location, read_timestamp_without_timezone_as_string, read_date_as_string)
 
     ########################################################
     # Users