Create request of request type passed in.
(self, request_type, parameters, owner_uri)
| 61 | logger.info(u'Sql Tools Client Initialized') |
| 62 | |
| 63 | def create_request(self, request_type, parameters, owner_uri): |
| 64 | """ |
| 65 | Create request of request type passed in. |
| 66 | """ |
| 67 | request = None |
| 68 | self.current_id = str(uuid.uuid4().int) |
| 69 | |
| 70 | if request_type == u'connection_request': |
| 71 | logger.info(u'SqlToolsClient connection request Id %s and owner Uri %s', |
| 72 | self.current_id, owner_uri) |
| 73 | request = connection.ConnectionRequest(self.current_id, owner_uri, self.json_rpc_client, |
| 74 | parameters) |
| 75 | |
| 76 | if request_type == u'query_execute_string_request': |
| 77 | logger.info(u'SqlToolsClient execute string request Id %s and owner Uri %s', |
| 78 | self.current_id, owner_uri) |
| 79 | request = query.QueryExecuteStringRequest(self.current_id, owner_uri, |
| 80 | self.json_rpc_client, parameters) |
| 81 | |
| 82 | if request_type == u'query_subset_request': |
| 83 | logger.info(u'SqlToolsClient subset request Id %s and owner Uri %s', |
| 84 | self.current_id, owner_uri) |
| 85 | request = query.QuerySubsetRequest(self.current_id, owner_uri, |
| 86 | self.json_rpc_client, parameters) |
| 87 | |
| 88 | return request |
| 89 | |
| 90 | def shutdown(self): |
| 91 | self.json_rpc_client.shutdown() |
no outgoing calls
no test coverage detected