(file_name)
| 10 | # Helper to generate a query baseline |
| 11 | # |
| 12 | def generate_query_baseline(file_name): |
| 13 | sqltoolsservice_args = [mssqltoolsservice.get_executable_path()] |
| 14 | with io.open(file_name, 'wb') as baseline: |
| 15 | tools_service_process = subprocess.Popen( |
| 16 | sqltoolsservice_args, |
| 17 | bufsize=0, |
| 18 | stdin=subprocess.PIPE, |
| 19 | stdout=baseline) |
| 20 | |
| 21 | # Before running this script, enter a real server name. |
| 22 | parameters = {u'OwnerUri': u'connectionservicetest', |
| 23 | u'Connection': |
| 24 | {u'ServerName': u'*', |
| 25 | u'DatabaseName': u'AdventureWorks2014', |
| 26 | u'UserName': u'*', |
| 27 | u'Password': u'*', |
| 28 | u'AuthenticationType': u'Integrated'} |
| 29 | } |
| 30 | |
| 31 | writer = json_rpc_client.JsonRpcWriter(tools_service_process.stdin) |
| 32 | writer.send_request(u'connection/connect', parameters, request_id=1) |
| 33 | |
| 34 | time.sleep(2) |
| 35 | |
| 36 | parameters = {u'OwnerUri': u'connectionservicetest', |
| 37 | u'Query': "select * from HumanResources.Department"} |
| 38 | writer.send_request(u'query/executeString', parameters, request_id=2) |
| 39 | |
| 40 | time.sleep(5) |
| 41 | parameters = {u'OwnerUri': u'connectionservicetest', |
| 42 | u'BatchIndex': 0, |
| 43 | u'ResultSetIndex': 0, |
| 44 | u'RowsStartIndex': 0, |
| 45 | u'RowsCount': 16} |
| 46 | |
| 47 | writer.send_request(u'query/subset', parameters, request_id=3) |
| 48 | # submit raw request. |
| 49 | time.sleep(5) |
| 50 | tools_service_process.kill() |
| 51 | |
| 52 | |
| 53 | if __name__ == '__main__': |
no test coverage detected