Commitfd1ab6d

committed

Updated thrift files and added check for protocol version

1 parentfcc262f commitfd1ab6dCopy full SHA for fd1ab6d

File tree

+3960

-324

lines changed

src/databricks/sql
- client.py
- thrift_api/TCLIService
  - ttypes.py
- thrift_backend.py

+3960

-324

lines changed

Lines changed: 9 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -5,6 +5,7 @@`
`5`	`5`	`importrequests`
`6`	`6`	`importjson`
`7`	`7`	`importos`
	`8`	`+fromdatabricks.sql.thrift_api.TCLIServiceimportttypes`
`8`	`9`
`9`	`10`	`fromdatabricks.sqlimport__version__`
`10`	`11`	`fromdatabricks.sqlimport*`
`@@ -225,6 +226,9 @@ def __del__(self):`
`225`	`226`	`defget_session_id(self):`
`226`	`227`	`returnself.thrift_backend.handle_to_id(self._session_handle)`
`227`	`228`
	`229`	`+defget_session_protocol_version(self):`
	`230`	`+returnself.thrift_backend.handle_to_protocol_version(self._session_handle)`
	`231`	`+`
`228`	`232`	`defget_session_id_hex(self):`
`229`	`233`	`returnself.thrift_backend.handle_to_hex_id(self._session_handle)`
`230`	`234`
`@@ -501,6 +505,11 @@ def execute(`
`501`	`505`	`"""`
`502`	`506`	`ifparametersisNone:`
`503`	`507`	`parameters= []`
	`508`	`+elif (`
	`509`	`+self.connection.get_session_protocol_version()`
	`510`	`+<ttypes.TProtocolVersion.SPARK_CLI_SERVICE_PROTOCOL_V8`
	`511`	`+ ):`
	`512`	`+raiseError("Parameterized operations are not supported by this server")`
`504`	`513`	`else:`
`505`	`514`	`parameters=named_parameters_to_tsparkparams(parameters)`
`506`	`515`

Comments

(0)