| #!/usr/bin/env python |
| # |
| # Copyright 2007 Google Inc. |
| # |
| # Licensed under the Apache License, Version 2.0 (the "License"); |
| # you may not use this file except in compliance with the License. |
| # You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, software |
| # distributed under the License is distributed on an "AS IS" BASIS, |
| # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| # See the License for the specific language governing permissions and |
| # limitations under the License. |
| # |
| |
| |
| |
| import sys |
| _b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1')) |
| import google |
| from google.net.proto2.python.public import descriptor as _descriptor |
| from google.net.proto2.python.public import message as _message |
| from google.net.proto2.python.public import reflection as _reflection |
| from google.net.proto2.python.public import symbol_database as _symbol_database |
| from google.net.proto2.proto import descriptor_pb2 |
| import sys |
| try: |
| __import__('google.net.rpc.python.rpc_internals_lite') |
| __import__('google.net.rpc.python.pywraprpc_lite') |
| rpc_internals = sys.modules.get('google.net.rpc.python.rpc_internals_lite') |
| pywraprpc = sys.modules.get('google.net.rpc.python.pywraprpc_lite') |
| _client_stub_base_class = rpc_internals.StubbyRPCBaseStub |
| except ImportError: |
| _client_stub_base_class = object |
| try: |
| __import__('google.net.rpc.python.rpcserver') |
| rpcserver = sys.modules.get('google.net.rpc.python.rpcserver') |
| _server_stub_base_class = rpcserver.BaseRpcServer |
| except ImportError: |
| _server_stub_base_class = object |
| |
| |
| _sym_db = _symbol_database.Default() |
| |
| |
| from google.storage.speckle.proto import client_pb2 as google_dot_storage_dot_speckle_dot_proto_dot_client__pb2 |
| |
| |
| DESCRIPTOR = _descriptor.FileDescriptor( |
| name='storage/speckle/proto/sql.proto', |
| package='speckle.sql', |
| serialized_pb=_b('\n\x1fstorage/speckle/proto/sql.proto\x12\x0bspeckle.sql\x1a\"storage/speckle/proto/client.proto\"\x8c\x03\n\x0b\x45xecRequest\x12\x10\n\x08instance\x18\x01 \x02(\t\x12\x14\n\x0cstatement_id\x18\x02 \x01(\x04\x12\x11\n\tstatement\x18\x03 \x01(\t\x12\x31\n\rbind_variable\x18\x04 \x03(\x0b\x32\x1a.speckle.BindVariableProto\x12\x15\n\rconnection_id\x18\x05 \x02(\x0c\x12%\n\x07options\x18\x06 \x01(\x0b\x32\x14.speckle.ExecOptions\x12I\n\x0estatement_type\x18\t \x01(\x0e\x32&.speckle.sql.ExecRequest.StatementType:\tSTATEMENT\x12\"\n\x05\x62\x61tch\x18\n \x01(\x0b\x32\x13.speckle.BatchProto\x12\x12\n\nrequest_id\x18\x0b \x01(\x04\"N\n\rStatementType\x12\r\n\tSTATEMENT\x10\x01\x12\x16\n\x12PREPARED_STATEMENT\x10\x02\x12\x16\n\x12\x43\x41LLABLE_STATEMENT\x10\x03\"b\n\x0c\x45xecResponse\x12$\n\x06result\x18\x01 \x01(\x0b\x32\x14.speckle.ResultProto\x12,\n\rsql_exception\x18\x02 \x01(\x0b\x32\x15.speckle.SqlException\"j\n\rExecOpRequest\x12\x10\n\x08instance\x18\x01 \x02(\t\x12\x15\n\rconnection_id\x18\x02 \x02(\x0c\x12\x1c\n\x02op\x18\x03 \x02(\x0b\x32\x10.speckle.OpProto\x12\x12\n\nrequest_id\x18\x08 \x01(\x04\"\xed\x01\n\x0e\x45xecOpResponse\x12\x12\n\nnative_sql\x18\x01 \x01(\t\x12%\n\tsavepoint\x18\x02 \x01(\x0b\x32\x12.speckle.SavePoint\x12,\n\rsql_exception\x18\x03 \x01(\x0b\x32\x15.speckle.SqlException\x12$\n\x06result\x18\x04 \x01(\x0b\x32\x14.speckle.ResultProto\x12\x30\n\x10\x63\x61\x63hed_rpc_error\x18\x05 \x01(\x0b\x32\x16.speckle.RpcErrorProto\x12\x1a\n\x0e\x63\x61\x63hed_payload\x18\x06 \x01(\x0c\x42\x02\x08\x01\"\xaa\x01\n\x0fMetadataRequest\x12\x10\n\x08instance\x18\x01 \x02(\t\x12\'\n\x08metadata\x18\x03 \x02(\x0e\x32\x15.speckle.MetadataType\x12\x31\n\rbind_variable\x18\x04 \x03(\x0b\x32\x1a.speckle.BindVariableProto\x12\x15\n\rconnection_id\x18\x05 \x02(\x0c\x12\x12\n\nrequest_id\x18\x08 \x01(\x04\"\xaa\x01\n\x10MetadataResponse\x12$\n\x06result\x18\x01 \x01(\x0b\x32\x14.speckle.ResultProto\x12\x42\n\x16jdbc_database_metadata\x18\x02 \x01(\x0b\x32\".speckle.JdbcDatabaseMetaDataProto\x12,\n\rsql_exception\x18\x03 \x01(\x0b\x32\x15.speckle.SqlException\"\xac\x01\n\x15OpenConnectionRequest\x12\x10\n\x08instance\x18\x01 \x02(\t\x12#\n\x08property\x18\x02 \x03(\x0b\x32\x11.speckle.Property\x12\x1b\n\x10protocol_version\x18\x05 \x01(\x04:\x01\x31\x12?\n\x0b\x63lient_type\x18\x06 \x01(\x0e\x32\x13.speckle.ClientType:\x15\x43LIENT_TYPE_JAVA_JDBC\"\x86\x01\n\x16OpenConnectionResponse\x12\x15\n\rconnection_id\x18\x01 \x01(\x0c\x12,\n\rsql_exception\x18\x02 \x01(\x0b\x32\x15.speckle.SqlException\x12\'\n\x08warnings\x18\x06 \x03(\x0b\x32\x15.speckle.SqlException\"A\n\x16\x43loseConnectionRequest\x12\x10\n\x08instance\x18\x01 \x02(\t\x12\x15\n\rconnection_id\x18\x02 \x02(\x0c\"G\n\x17\x43loseConnectionResponse\x12,\n\rsql_exception\x18\x01 \x01(\x0b\x32\x15.speckle.SqlException2\xac\x03\n\nSqlService\x12?\n\x04\x45xec\x12\x18.speckle.sql.ExecRequest\x1a\x19.speckle.sql.ExecResponse\"\x02P\x01\x12\x45\n\x06\x45xecOp\x12\x1a.speckle.sql.ExecOpRequest\x1a\x1b.speckle.sql.ExecOpResponse\"\x02P\x01\x12N\n\x0bGetMetadata\x12\x1c.speckle.sql.MetadataRequest\x1a\x1d.speckle.sql.MetadataResponse\"\x02P\x01\x12\x64\n\x0eOpenConnection\x12\".speckle.sql.OpenConnectionRequest\x1a#.speckle.sql.OpenConnectionResponse\"\tP\x01\x9a\x01\x04read\x12`\n\x0f\x43loseConnection\x12#.speckle.sql.CloseConnectionRequest\x1a$.speckle.sql.CloseConnectionResponse\"\x02P\x01\x42.\n\x1b\x63om.google.protos.cloud.sql\x10\x02 \x02(\x02P\x01\x80\x01\x00\x88\x01\x00\x90\x01\x00') |
| , |
| dependencies=[google_dot_storage_dot_speckle_dot_proto_dot_client__pb2.DESCRIPTOR,]) |
| _sym_db.RegisterFileDescriptor(DESCRIPTOR) |
| |
| |
| |
| _EXECREQUEST_STATEMENTTYPE = _descriptor.EnumDescriptor( |
| name='StatementType', |
| full_name='speckle.sql.ExecRequest.StatementType', |
| filename=None, |
| file=DESCRIPTOR, |
| values=[ |
| _descriptor.EnumValueDescriptor( |
| name='STATEMENT', index=0, number=1, |
| options=None, |
| type=None), |
| _descriptor.EnumValueDescriptor( |
| name='PREPARED_STATEMENT', index=1, number=2, |
| options=None, |
| type=None), |
| _descriptor.EnumValueDescriptor( |
| name='CALLABLE_STATEMENT', index=2, number=3, |
| options=None, |
| type=None), |
| ], |
| containing_type=None, |
| options=None, |
| serialized_start=403, |
| serialized_end=481, |
| ) |
| _sym_db.RegisterEnumDescriptor(_EXECREQUEST_STATEMENTTYPE) |
| |
| |
| _EXECREQUEST = _descriptor.Descriptor( |
| name='ExecRequest', |
| full_name='speckle.sql.ExecRequest', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='instance', full_name='speckle.sql.ExecRequest.instance', index=0, |
| number=1, type=9, cpp_type=9, label=2, |
| has_default_value=False, default_value=_b("").decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='statement_id', full_name='speckle.sql.ExecRequest.statement_id', index=1, |
| number=2, type=4, cpp_type=4, label=1, |
| has_default_value=False, default_value=0, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='statement', full_name='speckle.sql.ExecRequest.statement', index=2, |
| number=3, type=9, cpp_type=9, label=1, |
| has_default_value=False, default_value=_b("").decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='bind_variable', full_name='speckle.sql.ExecRequest.bind_variable', index=3, |
| number=4, type=11, cpp_type=10, label=3, |
| has_default_value=False, default_value=[], |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='connection_id', full_name='speckle.sql.ExecRequest.connection_id', index=4, |
| number=5, type=12, cpp_type=9, label=2, |
| has_default_value=False, default_value=_b(""), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='options', full_name='speckle.sql.ExecRequest.options', index=5, |
| number=6, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='statement_type', full_name='speckle.sql.ExecRequest.statement_type', index=6, |
| number=9, type=14, cpp_type=8, label=1, |
| has_default_value=True, default_value=1, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='batch', full_name='speckle.sql.ExecRequest.batch', index=7, |
| number=10, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='request_id', full_name='speckle.sql.ExecRequest.request_id', index=8, |
| number=11, type=4, cpp_type=4, label=1, |
| has_default_value=False, default_value=0, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| _EXECREQUEST_STATEMENTTYPE, |
| ], |
| options=None, |
| is_extendable=False, |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=85, |
| serialized_end=481, |
| ) |
| |
| |
| _EXECRESPONSE = _descriptor.Descriptor( |
| name='ExecResponse', |
| full_name='speckle.sql.ExecResponse', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='result', full_name='speckle.sql.ExecResponse.result', index=0, |
| number=1, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='sql_exception', full_name='speckle.sql.ExecResponse.sql_exception', index=1, |
| number=2, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| options=None, |
| is_extendable=False, |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=483, |
| serialized_end=581, |
| ) |
| |
| |
| _EXECOPREQUEST = _descriptor.Descriptor( |
| name='ExecOpRequest', |
| full_name='speckle.sql.ExecOpRequest', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='instance', full_name='speckle.sql.ExecOpRequest.instance', index=0, |
| number=1, type=9, cpp_type=9, label=2, |
| has_default_value=False, default_value=_b("").decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='connection_id', full_name='speckle.sql.ExecOpRequest.connection_id', index=1, |
| number=2, type=12, cpp_type=9, label=2, |
| has_default_value=False, default_value=_b(""), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='op', full_name='speckle.sql.ExecOpRequest.op', index=2, |
| number=3, type=11, cpp_type=10, label=2, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='request_id', full_name='speckle.sql.ExecOpRequest.request_id', index=3, |
| number=8, type=4, cpp_type=4, label=1, |
| has_default_value=False, default_value=0, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| options=None, |
| is_extendable=False, |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=583, |
| serialized_end=689, |
| ) |
| |
| |
| _EXECOPRESPONSE = _descriptor.Descriptor( |
| name='ExecOpResponse', |
| full_name='speckle.sql.ExecOpResponse', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='native_sql', full_name='speckle.sql.ExecOpResponse.native_sql', index=0, |
| number=1, type=9, cpp_type=9, label=1, |
| has_default_value=False, default_value=_b("").decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='savepoint', full_name='speckle.sql.ExecOpResponse.savepoint', index=1, |
| number=2, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='sql_exception', full_name='speckle.sql.ExecOpResponse.sql_exception', index=2, |
| number=3, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='result', full_name='speckle.sql.ExecOpResponse.result', index=3, |
| number=4, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='cached_rpc_error', full_name='speckle.sql.ExecOpResponse.cached_rpc_error', index=4, |
| number=5, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='cached_payload', full_name='speckle.sql.ExecOpResponse.cached_payload', index=5, |
| number=6, type=12, cpp_type=9, label=1, |
| has_default_value=False, default_value=_b(""), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\010\001'))), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| options=None, |
| is_extendable=False, |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=692, |
| serialized_end=929, |
| ) |
| |
| |
| _METADATAREQUEST = _descriptor.Descriptor( |
| name='MetadataRequest', |
| full_name='speckle.sql.MetadataRequest', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='instance', full_name='speckle.sql.MetadataRequest.instance', index=0, |
| number=1, type=9, cpp_type=9, label=2, |
| has_default_value=False, default_value=_b("").decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='metadata', full_name='speckle.sql.MetadataRequest.metadata', index=1, |
| number=3, type=14, cpp_type=8, label=2, |
| has_default_value=False, default_value=1, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='bind_variable', full_name='speckle.sql.MetadataRequest.bind_variable', index=2, |
| number=4, type=11, cpp_type=10, label=3, |
| has_default_value=False, default_value=[], |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='connection_id', full_name='speckle.sql.MetadataRequest.connection_id', index=3, |
| number=5, type=12, cpp_type=9, label=2, |
| has_default_value=False, default_value=_b(""), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='request_id', full_name='speckle.sql.MetadataRequest.request_id', index=4, |
| number=8, type=4, cpp_type=4, label=1, |
| has_default_value=False, default_value=0, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| options=None, |
| is_extendable=False, |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=932, |
| serialized_end=1102, |
| ) |
| |
| |
| _METADATARESPONSE = _descriptor.Descriptor( |
| name='MetadataResponse', |
| full_name='speckle.sql.MetadataResponse', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='result', full_name='speckle.sql.MetadataResponse.result', index=0, |
| number=1, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='jdbc_database_metadata', full_name='speckle.sql.MetadataResponse.jdbc_database_metadata', index=1, |
| number=2, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='sql_exception', full_name='speckle.sql.MetadataResponse.sql_exception', index=2, |
| number=3, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| options=None, |
| is_extendable=False, |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=1105, |
| serialized_end=1275, |
| ) |
| |
| |
| _OPENCONNECTIONREQUEST = _descriptor.Descriptor( |
| name='OpenConnectionRequest', |
| full_name='speckle.sql.OpenConnectionRequest', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='instance', full_name='speckle.sql.OpenConnectionRequest.instance', index=0, |
| number=1, type=9, cpp_type=9, label=2, |
| has_default_value=False, default_value=_b("").decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='property', full_name='speckle.sql.OpenConnectionRequest.property', index=1, |
| number=2, type=11, cpp_type=10, label=3, |
| has_default_value=False, default_value=[], |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='protocol_version', full_name='speckle.sql.OpenConnectionRequest.protocol_version', index=2, |
| number=5, type=4, cpp_type=4, label=1, |
| has_default_value=True, default_value=1, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='client_type', full_name='speckle.sql.OpenConnectionRequest.client_type', index=3, |
| number=6, type=14, cpp_type=8, label=1, |
| has_default_value=True, default_value=1, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| options=None, |
| is_extendable=False, |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=1278, |
| serialized_end=1450, |
| ) |
| |
| |
| _OPENCONNECTIONRESPONSE = _descriptor.Descriptor( |
| name='OpenConnectionResponse', |
| full_name='speckle.sql.OpenConnectionResponse', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='connection_id', full_name='speckle.sql.OpenConnectionResponse.connection_id', index=0, |
| number=1, type=12, cpp_type=9, label=1, |
| has_default_value=False, default_value=_b(""), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='sql_exception', full_name='speckle.sql.OpenConnectionResponse.sql_exception', index=1, |
| number=2, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='warnings', full_name='speckle.sql.OpenConnectionResponse.warnings', index=2, |
| number=6, type=11, cpp_type=10, label=3, |
| has_default_value=False, default_value=[], |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| options=None, |
| is_extendable=False, |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=1453, |
| serialized_end=1587, |
| ) |
| |
| |
| _CLOSECONNECTIONREQUEST = _descriptor.Descriptor( |
| name='CloseConnectionRequest', |
| full_name='speckle.sql.CloseConnectionRequest', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='instance', full_name='speckle.sql.CloseConnectionRequest.instance', index=0, |
| number=1, type=9, cpp_type=9, label=2, |
| has_default_value=False, default_value=_b("").decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| _descriptor.FieldDescriptor( |
| name='connection_id', full_name='speckle.sql.CloseConnectionRequest.connection_id', index=1, |
| number=2, type=12, cpp_type=9, label=2, |
| has_default_value=False, default_value=_b(""), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| options=None, |
| is_extendable=False, |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=1589, |
| serialized_end=1654, |
| ) |
| |
| |
| _CLOSECONNECTIONRESPONSE = _descriptor.Descriptor( |
| name='CloseConnectionResponse', |
| full_name='speckle.sql.CloseConnectionResponse', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='sql_exception', full_name='speckle.sql.CloseConnectionResponse.sql_exception', index=0, |
| number=1, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| options=None), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| options=None, |
| is_extendable=False, |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=1656, |
| serialized_end=1727, |
| ) |
| |
| _EXECREQUEST.fields_by_name['bind_variable'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._BINDVARIABLEPROTO |
| _EXECREQUEST.fields_by_name['options'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._EXECOPTIONS |
| _EXECREQUEST.fields_by_name['statement_type'].enum_type = _EXECREQUEST_STATEMENTTYPE |
| _EXECREQUEST.fields_by_name['batch'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._BATCHPROTO |
| _EXECREQUEST_STATEMENTTYPE.containing_type = _EXECREQUEST |
| _EXECRESPONSE.fields_by_name['result'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._RESULTPROTO |
| _EXECRESPONSE.fields_by_name['sql_exception'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._SQLEXCEPTION |
| _EXECOPREQUEST.fields_by_name['op'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._OPPROTO |
| _EXECOPRESPONSE.fields_by_name['savepoint'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._SAVEPOINT |
| _EXECOPRESPONSE.fields_by_name['sql_exception'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._SQLEXCEPTION |
| _EXECOPRESPONSE.fields_by_name['result'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._RESULTPROTO |
| _EXECOPRESPONSE.fields_by_name['cached_rpc_error'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._RPCERRORPROTO |
| _METADATAREQUEST.fields_by_name['metadata'].enum_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._METADATATYPE |
| _METADATAREQUEST.fields_by_name['bind_variable'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._BINDVARIABLEPROTO |
| _METADATARESPONSE.fields_by_name['result'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._RESULTPROTO |
| _METADATARESPONSE.fields_by_name['jdbc_database_metadata'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._JDBCDATABASEMETADATAPROTO |
| _METADATARESPONSE.fields_by_name['sql_exception'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._SQLEXCEPTION |
| _OPENCONNECTIONREQUEST.fields_by_name['property'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._PROPERTY |
| _OPENCONNECTIONREQUEST.fields_by_name['client_type'].enum_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._CLIENTTYPE |
| _OPENCONNECTIONRESPONSE.fields_by_name['sql_exception'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._SQLEXCEPTION |
| _OPENCONNECTIONRESPONSE.fields_by_name['warnings'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._SQLEXCEPTION |
| _CLOSECONNECTIONRESPONSE.fields_by_name['sql_exception'].message_type = google_dot_storage_dot_speckle_dot_proto_dot_client__pb2._SQLEXCEPTION |
| DESCRIPTOR.message_types_by_name['ExecRequest'] = _EXECREQUEST |
| DESCRIPTOR.message_types_by_name['ExecResponse'] = _EXECRESPONSE |
| DESCRIPTOR.message_types_by_name['ExecOpRequest'] = _EXECOPREQUEST |
| DESCRIPTOR.message_types_by_name['ExecOpResponse'] = _EXECOPRESPONSE |
| DESCRIPTOR.message_types_by_name['MetadataRequest'] = _METADATAREQUEST |
| DESCRIPTOR.message_types_by_name['MetadataResponse'] = _METADATARESPONSE |
| DESCRIPTOR.message_types_by_name['OpenConnectionRequest'] = _OPENCONNECTIONREQUEST |
| DESCRIPTOR.message_types_by_name['OpenConnectionResponse'] = _OPENCONNECTIONRESPONSE |
| DESCRIPTOR.message_types_by_name['CloseConnectionRequest'] = _CLOSECONNECTIONREQUEST |
| DESCRIPTOR.message_types_by_name['CloseConnectionResponse'] = _CLOSECONNECTIONRESPONSE |
| |
| ExecRequest = _reflection.GeneratedProtocolMessageType('ExecRequest', (_message.Message,), dict( |
| DESCRIPTOR = _EXECREQUEST, |
| __module__ = 'google.storage.speckle.proto.sql_pb2' |
| |
| )) |
| _sym_db.RegisterMessage(ExecRequest) |
| |
| ExecResponse = _reflection.GeneratedProtocolMessageType('ExecResponse', (_message.Message,), dict( |
| DESCRIPTOR = _EXECRESPONSE, |
| __module__ = 'google.storage.speckle.proto.sql_pb2' |
| |
| )) |
| _sym_db.RegisterMessage(ExecResponse) |
| |
| ExecOpRequest = _reflection.GeneratedProtocolMessageType('ExecOpRequest', (_message.Message,), dict( |
| DESCRIPTOR = _EXECOPREQUEST, |
| __module__ = 'google.storage.speckle.proto.sql_pb2' |
| |
| )) |
| _sym_db.RegisterMessage(ExecOpRequest) |
| |
| ExecOpResponse = _reflection.GeneratedProtocolMessageType('ExecOpResponse', (_message.Message,), dict( |
| DESCRIPTOR = _EXECOPRESPONSE, |
| __module__ = 'google.storage.speckle.proto.sql_pb2' |
| |
| )) |
| _sym_db.RegisterMessage(ExecOpResponse) |
| |
| MetadataRequest = _reflection.GeneratedProtocolMessageType('MetadataRequest', (_message.Message,), dict( |
| DESCRIPTOR = _METADATAREQUEST, |
| __module__ = 'google.storage.speckle.proto.sql_pb2' |
| |
| )) |
| _sym_db.RegisterMessage(MetadataRequest) |
| |
| MetadataResponse = _reflection.GeneratedProtocolMessageType('MetadataResponse', (_message.Message,), dict( |
| DESCRIPTOR = _METADATARESPONSE, |
| __module__ = 'google.storage.speckle.proto.sql_pb2' |
| |
| )) |
| _sym_db.RegisterMessage(MetadataResponse) |
| |
| OpenConnectionRequest = _reflection.GeneratedProtocolMessageType('OpenConnectionRequest', (_message.Message,), dict( |
| DESCRIPTOR = _OPENCONNECTIONREQUEST, |
| __module__ = 'google.storage.speckle.proto.sql_pb2' |
| |
| )) |
| _sym_db.RegisterMessage(OpenConnectionRequest) |
| |
| OpenConnectionResponse = _reflection.GeneratedProtocolMessageType('OpenConnectionResponse', (_message.Message,), dict( |
| DESCRIPTOR = _OPENCONNECTIONRESPONSE, |
| __module__ = 'google.storage.speckle.proto.sql_pb2' |
| |
| )) |
| _sym_db.RegisterMessage(OpenConnectionResponse) |
| |
| CloseConnectionRequest = _reflection.GeneratedProtocolMessageType('CloseConnectionRequest', (_message.Message,), dict( |
| DESCRIPTOR = _CLOSECONNECTIONREQUEST, |
| __module__ = 'google.storage.speckle.proto.sql_pb2' |
| |
| )) |
| _sym_db.RegisterMessage(CloseConnectionRequest) |
| |
| CloseConnectionResponse = _reflection.GeneratedProtocolMessageType('CloseConnectionResponse', (_message.Message,), dict( |
| DESCRIPTOR = _CLOSECONNECTIONRESPONSE, |
| __module__ = 'google.storage.speckle.proto.sql_pb2' |
| |
| )) |
| _sym_db.RegisterMessage(CloseConnectionResponse) |
| |
| |
| DESCRIPTOR.has_options = True |
| DESCRIPTOR._options = _descriptor._ParseOptions(descriptor_pb2.FileOptions(), _b('\n\033com.google.protos.cloud.sql\020\002 \002(\002P\001\200\001\000\210\001\000\220\001\000')) |
| _EXECOPRESPONSE.fields_by_name['cached_payload'].has_options = True |
| _EXECOPRESPONSE.fields_by_name['cached_payload']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\010\001')) |
| |
| |
| class _SqlService_ClientBaseStub(_client_stub_base_class): |
| """Makes Stubby RPC calls to a SqlService server.""" |
| |
| __slots__ = ( |
| '_protorpc_Exec', '_full_name_Exec', |
| '_protorpc_ExecOp', '_full_name_ExecOp', |
| '_protorpc_GetMetadata', '_full_name_GetMetadata', |
| '_protorpc_OpenConnection', '_full_name_OpenConnection', |
| '_protorpc_CloseConnection', '_full_name_CloseConnection', |
| ) |
| |
| def __init__(self, rpc_stub): |
| self._stub = rpc_stub |
| |
| self._protorpc_Exec = pywraprpc.RPC() |
| self._protorpc_Exec.set_fail_fast(True) |
| self._full_name_Exec = self._stub.GetFullMethodName( |
| 'Exec') |
| |
| self._protorpc_ExecOp = pywraprpc.RPC() |
| self._protorpc_ExecOp.set_fail_fast(True) |
| self._full_name_ExecOp = self._stub.GetFullMethodName( |
| 'ExecOp') |
| |
| self._protorpc_GetMetadata = pywraprpc.RPC() |
| self._protorpc_GetMetadata.set_fail_fast(True) |
| self._full_name_GetMetadata = self._stub.GetFullMethodName( |
| 'GetMetadata') |
| |
| self._protorpc_OpenConnection = pywraprpc.RPC() |
| self._protorpc_OpenConnection.set_fail_fast(True) |
| self._full_name_OpenConnection = self._stub.GetFullMethodName( |
| 'OpenConnection') |
| |
| self._protorpc_CloseConnection = pywraprpc.RPC() |
| self._protorpc_CloseConnection.set_fail_fast(True) |
| self._full_name_CloseConnection = self._stub.GetFullMethodName( |
| 'CloseConnection') |
| |
| def Exec(self, request, rpc=None, callback=None, response=None): |
| """Make a Exec RPC call. |
| |
| Args: |
| request: a ExecRequest instance. |
| rpc: Optional RPC instance to use for the call. |
| callback: Optional final callback. Will be called as |
| callback(rpc, result) when the rpc completes. If None, the |
| call is synchronous. |
| response: Optional ProtocolMessage to be filled in with response. |
| |
| Returns: |
| The ExecResponse if callback is None. Otherwise, returns None. |
| """ |
| |
| if response is None: |
| response = ExecResponse |
| return self._MakeCall(rpc, |
| self._full_name_Exec, |
| 'Exec', |
| request, |
| response, |
| callback, |
| self._protorpc_Exec) |
| |
| def ExecOp(self, request, rpc=None, callback=None, response=None): |
| """Make a ExecOp RPC call. |
| |
| Args: |
| request: a ExecOpRequest instance. |
| rpc: Optional RPC instance to use for the call. |
| callback: Optional final callback. Will be called as |
| callback(rpc, result) when the rpc completes. If None, the |
| call is synchronous. |
| response: Optional ProtocolMessage to be filled in with response. |
| |
| Returns: |
| The ExecOpResponse if callback is None. Otherwise, returns None. |
| """ |
| |
| if response is None: |
| response = ExecOpResponse |
| return self._MakeCall(rpc, |
| self._full_name_ExecOp, |
| 'ExecOp', |
| request, |
| response, |
| callback, |
| self._protorpc_ExecOp) |
| |
| def GetMetadata(self, request, rpc=None, callback=None, response=None): |
| """Make a GetMetadata RPC call. |
| |
| Args: |
| request: a MetadataRequest instance. |
| rpc: Optional RPC instance to use for the call. |
| callback: Optional final callback. Will be called as |
| callback(rpc, result) when the rpc completes. If None, the |
| call is synchronous. |
| response: Optional ProtocolMessage to be filled in with response. |
| |
| Returns: |
| The MetadataResponse if callback is None. Otherwise, returns None. |
| """ |
| |
| if response is None: |
| response = MetadataResponse |
| return self._MakeCall(rpc, |
| self._full_name_GetMetadata, |
| 'GetMetadata', |
| request, |
| response, |
| callback, |
| self._protorpc_GetMetadata) |
| |
| def OpenConnection(self, request, rpc=None, callback=None, response=None): |
| """Make a OpenConnection RPC call. |
| |
| Args: |
| request: a OpenConnectionRequest instance. |
| rpc: Optional RPC instance to use for the call. |
| callback: Optional final callback. Will be called as |
| callback(rpc, result) when the rpc completes. If None, the |
| call is synchronous. |
| response: Optional ProtocolMessage to be filled in with response. |
| |
| Returns: |
| The OpenConnectionResponse if callback is None. Otherwise, returns None. |
| """ |
| |
| if response is None: |
| response = OpenConnectionResponse |
| return self._MakeCall(rpc, |
| self._full_name_OpenConnection, |
| 'OpenConnection', |
| request, |
| response, |
| callback, |
| self._protorpc_OpenConnection) |
| |
| def CloseConnection(self, request, rpc=None, callback=None, response=None): |
| """Make a CloseConnection RPC call. |
| |
| Args: |
| request: a CloseConnectionRequest instance. |
| rpc: Optional RPC instance to use for the call. |
| callback: Optional final callback. Will be called as |
| callback(rpc, result) when the rpc completes. If None, the |
| call is synchronous. |
| response: Optional ProtocolMessage to be filled in with response. |
| |
| Returns: |
| The CloseConnectionResponse if callback is None. Otherwise, returns None. |
| """ |
| |
| if response is None: |
| response = CloseConnectionResponse |
| return self._MakeCall(rpc, |
| self._full_name_CloseConnection, |
| 'CloseConnection', |
| request, |
| response, |
| callback, |
| self._protorpc_CloseConnection) |
| |
| |
| class _SqlService_ClientStub(_SqlService_ClientBaseStub): |
| __slots__ = ('_params',) |
| def __init__(self, rpc_stub_parameters, service_name): |
| if service_name is None: |
| service_name = 'SqlService' |
| _SqlService_ClientBaseStub.__init__(self, pywraprpc.RPC_GenericStub(service_name, rpc_stub_parameters)) |
| self._params = rpc_stub_parameters |
| |
| |
| class _SqlService_RPC2ClientStub(_SqlService_ClientBaseStub): |
| __slots__ = () |
| def __init__(self, server, channel, service_name): |
| if service_name is None: |
| service_name = 'SqlService' |
| if channel is not None: |
| if channel.version() == 1: |
| raise RuntimeError('Expecting an RPC2 channel to create the stub') |
| _SqlService_ClientBaseStub.__init__(self, pywraprpc.RPC_GenericStub(service_name, channel)) |
| elif server is not None: |
| _SqlService_ClientBaseStub.__init__(self, pywraprpc.RPC_GenericStub(service_name, pywraprpc.NewClientChannel(server))) |
| else: |
| raise RuntimeError('Invalid argument combination to create a stub') |
| |
| |
| class SqlService(_server_stub_base_class): |
| """Base class for SqlService Stubby servers.""" |
| |
| @classmethod |
| def _MethodSignatures(cls): |
| """Returns a dict of {<method-name>: (<request-type>, <response-type>)}.""" |
| return { |
| 'Exec': (ExecRequest, ExecResponse), |
| 'ExecOp': (ExecOpRequest, ExecOpResponse), |
| 'GetMetadata': (MetadataRequest, MetadataResponse), |
| 'OpenConnection': (OpenConnectionRequest, OpenConnectionResponse), |
| 'CloseConnection': (CloseConnectionRequest, CloseConnectionResponse), |
| } |
| |
| @classmethod |
| def _StreamMethodSignatures(cls): |
| """Returns a dict of {<method-name>: (<request-type>, <stream-type>, <response-type>)}.""" |
| return { |
| } |
| |
| def __init__(self, *args, **kwargs): |
| """Creates a Stubby RPC server. |
| |
| See BaseRpcServer.__init__ in rpcserver.py for detail on arguments. |
| """ |
| if _server_stub_base_class is object: |
| raise NotImplementedError('Add //net/rpc/python:rpcserver as a ' |
| 'dependency for Stubby server support.') |
| _server_stub_base_class.__init__(self, 'speckle.sql.SqlService', *args, **kwargs) |
| |
| @staticmethod |
| def NewStub(rpc_stub_parameters, service_name=None): |
| """Creates a new SqlService Stubby client stub. |
| |
| Args: |
| rpc_stub_parameters: an RPC_StubParameter instance. |
| service_name: the service name used by the Stubby server. |
| """ |
| |
| if _client_stub_base_class is object: |
| raise RuntimeError('Add //net/rpc/python as a dependency to use Stubby') |
| return _SqlService_ClientStub(rpc_stub_parameters, service_name) |
| |
| @staticmethod |
| def NewRPC2Stub(server=None, channel=None, service_name=None): |
| """Creates a new SqlService Stubby2 client stub. |
| |
| Args: |
| server: host:port or bns address. |
| channel: directly use a channel to create a stub. Will ignore server |
| argument if this is specified. |
| service_name: the service name used by the Stubby server. |
| """ |
| |
| if _client_stub_base_class is object: |
| raise RuntimeError('Add //net/rpc/python as a dependency to use Stubby') |
| return _SqlService_RPC2ClientStub(server, channel, service_name) |
| |
| def Exec(self, rpc, request, response): |
| """Handles a Exec RPC call. You should override this. |
| |
| Args: |
| rpc: a Stubby RPC object |
| request: a ExecRequest that contains the client request |
| response: a ExecResponse that should be modified to send the response |
| """ |
| raise NotImplementedError |
| |
| |
| def ExecOp(self, rpc, request, response): |
| """Handles a ExecOp RPC call. You should override this. |
| |
| Args: |
| rpc: a Stubby RPC object |
| request: a ExecOpRequest that contains the client request |
| response: a ExecOpResponse that should be modified to send the response |
| """ |
| raise NotImplementedError |
| |
| |
| def GetMetadata(self, rpc, request, response): |
| """Handles a GetMetadata RPC call. You should override this. |
| |
| Args: |
| rpc: a Stubby RPC object |
| request: a MetadataRequest that contains the client request |
| response: a MetadataResponse that should be modified to send the response |
| """ |
| raise NotImplementedError |
| |
| |
| def OpenConnection(self, rpc, request, response): |
| """Handles a OpenConnection RPC call. You should override this. |
| |
| Args: |
| rpc: a Stubby RPC object |
| request: a OpenConnectionRequest that contains the client request |
| response: a OpenConnectionResponse that should be modified to send the response |
| """ |
| raise NotImplementedError |
| |
| |
| def CloseConnection(self, rpc, request, response): |
| """Handles a CloseConnection RPC call. You should override this. |
| |
| Args: |
| rpc: a Stubby RPC object |
| request: a CloseConnectionRequest that contains the client request |
| response: a CloseConnectionResponse that should be modified to send the response |
| """ |
| raise NotImplementedError |
| |
| def _AddMethodAttributes(self): |
| """Sets attributes on Python RPC handlers. |
| |
| See BaseRpcServer in rpcserver.py for details. |
| """ |
| rpcserver._GetHandlerDecorator( |
| getattr(self.Exec, '__func__'), |
| ExecRequest, |
| ExecResponse, |
| None, |
| 'INTEGRITY') |
| rpcserver._GetHandlerDecorator( |
| getattr(self.ExecOp, '__func__'), |
| ExecOpRequest, |
| ExecOpResponse, |
| None, |
| 'INTEGRITY') |
| rpcserver._GetHandlerDecorator( |
| getattr(self.GetMetadata, '__func__'), |
| MetadataRequest, |
| MetadataResponse, |
| None, |
| 'INTEGRITY') |
| rpcserver._GetHandlerDecorator( |
| getattr(self.OpenConnection, '__func__'), |
| OpenConnectionRequest, |
| OpenConnectionResponse, |
| None, |
| 'INTEGRITY') |
| rpcserver._GetHandlerDecorator( |
| getattr(self.CloseConnection, '__func__'), |
| CloseConnectionRequest, |
| CloseConnectionResponse, |
| None, |
| 'INTEGRITY') |
| |
| |
