(self, connection_params)
| 164 | return cloned_mssqlcli_client |
| 165 | |
| 166 | def _execute_connection_request_with(self, connection_params): |
| 167 | if self.is_connected: |
| 168 | return self.owner_uri, [] |
| 169 | |
| 170 | connection_request = self.sql_tools_client.create_request( |
| 171 | self.sql_tools_client.CONNECTION_REQUEST, |
| 172 | connection_params, |
| 173 | self.owner_uri |
| 174 | ) |
| 175 | connection_request.execute() |
| 176 | error_messages = [] |
| 177 | response = None |
| 178 | |
| 179 | while not connection_request.completed(): |
| 180 | response = connection_request.get_response() |
| 181 | |
| 182 | if isinstance(response, connectionservice.ConnectionCompleteEvent): |
| 183 | if response.error_message: |
| 184 | error_messages.append(u'Error message: {}'.format(response.error_message)) |
| 185 | if response.messages: |
| 186 | logger.error(response.messages) |
| 187 | else: |
| 188 | time.sleep(time_wait_if_no_response) |
| 189 | |
| 190 | if response and response.connection_id: |
| 191 | assert response.owner_uri == self.owner_uri |
| 192 | self.is_connected = True |
| 193 | self.server_version = response.server_version |
| 194 | self.server_edition = response.server_edition |
| 195 | self.is_cloud = response.is_cloud |
| 196 | self.connected_database = response.connected_database |
| 197 | |
| 198 | logger.info(u'Connection Successful. Connection Id: %s Connected database" %s', |
| 199 | response.connection_id, response.connected_database) |
| 200 | |
| 201 | return self.owner_uri, error_messages |
| 202 | |
| 203 | return None, error_messages |
| 204 | |
| 205 | def _execute_query_execute_request_for(self, query): |
| 206 | if not self.is_connected: |
no test coverage detected