python/google/storage/speckle/proto/sql_pb2.py

   1 #!/usr/bin/env python
   2 #
   3 # Copyright 2007 Google Inc.
   4 #
   5 # Licensed under the Apache License, Version 2.0 (the "License");
   6 # you may not use this file except in compliance with the License.
   7 # You may obtain a copy of the License at
   8 #
   9 #     http://www.apache.org/licenses/LICENSE-2.0
  10 #
  11 # Unless required by applicable law or agreed to in writing, software
  12 # distributed under the License is distributed on an "AS IS" BASIS,
  13 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14 # See the License for the specific language governing permissions and
  15 # limitations under the License.
  16 #
  17
  18
  19
  20 import sys
  21 _b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
  22 from google.net.proto2.python.public import descriptor as _descriptor
  23 from google.net.proto2.python.public import message as _message
  24 from google.net.proto2.python.public import reflection as _reflection
  25 from google.net.proto2.proto import descriptor_pb2
  26 import sys
  27 try:
  28   __import__('google.net.rpc.python.rpc_internals_lite')
  29   __import__('google.net.rpc.python.pywraprpc_lite')
  30   rpc_internals = sys.modules.get('google.net.rpc.python.rpc_internals_lite')
  31   pywraprpc = sys.modules.get('google.net.rpc.python.pywraprpc_lite')
  32   _client_stub_base_class = rpc_internals.StubbyRPCBaseStub
  33 except ImportError:
  34   _client_stub_base_class = object
  35 try:
  36   __import__('google.net.rpc.python.rpcserver')
  37   rpcserver = sys.modules.get('google.net.rpc.python.rpcserver')
  38   _server_stub_base_class = rpcserver.BaseRpcServer
  39 except ImportError:
  40   _server_stub_base_class = object
  41
  42
  43
  44 import google.storage.speckle.proto.client_pb2
  45
  46
  47 DESCRIPTOR = _descriptor.FileDescriptor(
  48   name='storage/speckle/proto/sql.proto',
  49   package='speckle.sql',
  50   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\xa5\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]\n\x0eOpenConnection\x12\".speckle.sql.OpenConnectionRequest\x1a#.speckle.sql.OpenConnectionResponse\"\x02P\x01\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')
  51 )
  52
  53
  54
  55 _EXECREQUEST_STATEMENTTYPE = _descriptor.EnumDescriptor(
  56   name='StatementType',
  57   full_name='speckle.sql.ExecRequest.StatementType',
  58   filename=None,
  59   file=DESCRIPTOR,
  60   values=[
  61     _descriptor.EnumValueDescriptor(
  62       name='STATEMENT', index=0, number=1,
  63       options=None,
  64       type=None),
  65     _descriptor.EnumValueDescriptor(
  66       name='PREPARED_STATEMENT', index=1, number=2,
  67       options=None,
  68       type=None),
  69     _descriptor.EnumValueDescriptor(
  70       name='CALLABLE_STATEMENT', index=2, number=3,
  71       options=None,
  72       type=None),
  73   ],
  74   containing_type=None,
  75   options=None,
  76   serialized_start=403,
  77   serialized_end=481,
  78 )
  79
  80
  81 _EXECREQUEST = _descriptor.Descriptor(
  82   name='ExecRequest',
  83   full_name='speckle.sql.ExecRequest',
  84   filename=None,
  85   file=DESCRIPTOR,
  86   containing_type=None,
  87   fields=[
  88     _descriptor.FieldDescriptor(
  89       name='instance', full_name='speckle.sql.ExecRequest.instance', index=0,
  90       number=1, type=9, cpp_type=9, label=2,
  91       has_default_value=False, default_value=_b("").decode('utf-8'),
  92       message_type=None, enum_type=None, containing_type=None,
  93       is_extension=False, extension_scope=None,
  94       options=None),
  95     _descriptor.FieldDescriptor(
  96       name='statement_id', full_name='speckle.sql.ExecRequest.statement_id', index=1,
  97       number=2, type=4, cpp_type=4, label=1,
  98       has_default_value=False, default_value=0,
  99       message_type=None, enum_type=None, containing_type=None,
 100       is_extension=False, extension_scope=None,
 101       options=None),
 102     _descriptor.FieldDescriptor(
 103       name='statement', full_name='speckle.sql.ExecRequest.statement', index=2,
 104       number=3, type=9, cpp_type=9, label=1,
 105       has_default_value=False, default_value=_b("").decode('utf-8'),
 106       message_type=None, enum_type=None, containing_type=None,
 107       is_extension=False, extension_scope=None,
 108       options=None),
 109     _descriptor.FieldDescriptor(
 110       name='bind_variable', full_name='speckle.sql.ExecRequest.bind_variable', index=3,
 111       number=4, type=11, cpp_type=10, label=3,
 112       has_default_value=False, default_value=[],
 113       message_type=None, enum_type=None, containing_type=None,
 114       is_extension=False, extension_scope=None,
 115       options=None),
 116     _descriptor.FieldDescriptor(
 117       name='connection_id', full_name='speckle.sql.ExecRequest.connection_id', index=4,
 118       number=5, type=12, cpp_type=9, label=2,
 119       has_default_value=False, default_value=_b(""),
 120       message_type=None, enum_type=None, containing_type=None,
 121       is_extension=False, extension_scope=None,
 122       options=None),
 123     _descriptor.FieldDescriptor(
 124       name='options', full_name='speckle.sql.ExecRequest.options', index=5,
 125       number=6, type=11, cpp_type=10, label=1,
 126       has_default_value=False, default_value=None,
 127       message_type=None, enum_type=None, containing_type=None,
 128       is_extension=False, extension_scope=None,
 129       options=None),
 130     _descriptor.FieldDescriptor(
 131       name='statement_type', full_name='speckle.sql.ExecRequest.statement_type', index=6,
 132       number=9, type=14, cpp_type=8, label=1,
 133       has_default_value=True, default_value=1,
 134       message_type=None, enum_type=None, containing_type=None,
 135       is_extension=False, extension_scope=None,
 136       options=None),
 137     _descriptor.FieldDescriptor(
 138       name='batch', full_name='speckle.sql.ExecRequest.batch', index=7,
 139       number=10, type=11, cpp_type=10, label=1,
 140       has_default_value=False, default_value=None,
 141       message_type=None, enum_type=None, containing_type=None,
 142       is_extension=False, extension_scope=None,
 143       options=None),
 144     _descriptor.FieldDescriptor(
 145       name='request_id', full_name='speckle.sql.ExecRequest.request_id', index=8,
 146       number=11, type=4, cpp_type=4, label=1,
 147       has_default_value=False, default_value=0,
 148       message_type=None, enum_type=None, containing_type=None,
 149       is_extension=False, extension_scope=None,
 150       options=None),
 151   ],
 152   extensions=[
 153   ],
 154   nested_types=[],
 155   enum_types=[
 156     _EXECREQUEST_STATEMENTTYPE,
 157   ],
 158   options=None,
 159   is_extendable=False,
 160   extension_ranges=[],
 161   serialized_start=85,
 162   serialized_end=481,
 163 )
 164
 165
 166 _EXECRESPONSE = _descriptor.Descriptor(
 167   name='ExecResponse',
 168   full_name='speckle.sql.ExecResponse',
 169   filename=None,
 170   file=DESCRIPTOR,
 171   containing_type=None,
 172   fields=[
 173     _descriptor.FieldDescriptor(
 174       name='result', full_name='speckle.sql.ExecResponse.result', index=0,
 175       number=1, type=11, cpp_type=10, label=1,
 176       has_default_value=False, default_value=None,
 177       message_type=None, enum_type=None, containing_type=None,
 178       is_extension=False, extension_scope=None,
 179       options=None),
 180     _descriptor.FieldDescriptor(
 181       name='sql_exception', full_name='speckle.sql.ExecResponse.sql_exception', index=1,
 182       number=2, type=11, cpp_type=10, label=1,
 183       has_default_value=False, default_value=None,
 184       message_type=None, enum_type=None, containing_type=None,
 185       is_extension=False, extension_scope=None,
 186       options=None),
 187   ],
 188   extensions=[
 189   ],
 190   nested_types=[],
 191   enum_types=[
 192   ],
 193   options=None,
 194   is_extendable=False,
 195   extension_ranges=[],
 196   serialized_start=483,
 197   serialized_end=581,
 198 )
 199
 200
 201 _EXECOPREQUEST = _descriptor.Descriptor(
 202   name='ExecOpRequest',
 203   full_name='speckle.sql.ExecOpRequest',
 204   filename=None,
 205   file=DESCRIPTOR,
 206   containing_type=None,
 207   fields=[
 208     _descriptor.FieldDescriptor(
 209       name='instance', full_name='speckle.sql.ExecOpRequest.instance', index=0,
 210       number=1, type=9, cpp_type=9, label=2,
 211       has_default_value=False, default_value=_b("").decode('utf-8'),
 212       message_type=None, enum_type=None, containing_type=None,
 213       is_extension=False, extension_scope=None,
 214       options=None),
 215     _descriptor.FieldDescriptor(
 216       name='connection_id', full_name='speckle.sql.ExecOpRequest.connection_id', index=1,
 217       number=2, type=12, cpp_type=9, label=2,
 218       has_default_value=False, default_value=_b(""),
 219       message_type=None, enum_type=None, containing_type=None,
 220       is_extension=False, extension_scope=None,
 221       options=None),
 222     _descriptor.FieldDescriptor(
 223       name='op', full_name='speckle.sql.ExecOpRequest.op', index=2,
 224       number=3, type=11, cpp_type=10, label=2,
 225       has_default_value=False, default_value=None,
 226       message_type=None, enum_type=None, containing_type=None,
 227       is_extension=False, extension_scope=None,
 228       options=None),
 229     _descriptor.FieldDescriptor(
 230       name='request_id', full_name='speckle.sql.ExecOpRequest.request_id', index=3,
 231       number=8, type=4, cpp_type=4, label=1,
 232       has_default_value=False, default_value=0,
 233       message_type=None, enum_type=None, containing_type=None,
 234       is_extension=False, extension_scope=None,
 235       options=None),
 236   ],
 237   extensions=[
 238   ],
 239   nested_types=[],
 240   enum_types=[
 241   ],
 242   options=None,
 243   is_extendable=False,
 244   extension_ranges=[],
 245   serialized_start=583,
 246   serialized_end=689,
 247 )
 248
 249
 250 _EXECOPRESPONSE = _descriptor.Descriptor(
 251   name='ExecOpResponse',
 252   full_name='speckle.sql.ExecOpResponse',
 253   filename=None,
 254   file=DESCRIPTOR,
 255   containing_type=None,
 256   fields=[
 257     _descriptor.FieldDescriptor(
 258       name='native_sql', full_name='speckle.sql.ExecOpResponse.native_sql', index=0,
 259       number=1, type=9, cpp_type=9, label=1,
 260       has_default_value=False, default_value=_b("").decode('utf-8'),
 261       message_type=None, enum_type=None, containing_type=None,
 262       is_extension=False, extension_scope=None,
 263       options=None),
 264     _descriptor.FieldDescriptor(
 265       name='savepoint', full_name='speckle.sql.ExecOpResponse.savepoint', index=1,
 266       number=2, type=11, cpp_type=10, label=1,
 267       has_default_value=False, default_value=None,
 268       message_type=None, enum_type=None, containing_type=None,
 269       is_extension=False, extension_scope=None,
 270       options=None),
 271     _descriptor.FieldDescriptor(
 272       name='sql_exception', full_name='speckle.sql.ExecOpResponse.sql_exception', index=2,
 273       number=3, type=11, cpp_type=10, label=1,
 274       has_default_value=False, default_value=None,
 275       message_type=None, enum_type=None, containing_type=None,
 276       is_extension=False, extension_scope=None,
 277       options=None),
 278     _descriptor.FieldDescriptor(
 279       name='result', full_name='speckle.sql.ExecOpResponse.result', index=3,
 280       number=4, type=11, cpp_type=10, label=1,
 281       has_default_value=False, default_value=None,
 282       message_type=None, enum_type=None, containing_type=None,
 283       is_extension=False, extension_scope=None,
 284       options=None),
 285     _descriptor.FieldDescriptor(
 286       name='cached_rpc_error', full_name='speckle.sql.ExecOpResponse.cached_rpc_error', index=4,
 287       number=5, type=11, cpp_type=10, label=1,
 288       has_default_value=False, default_value=None,
 289       message_type=None, enum_type=None, containing_type=None,
 290       is_extension=False, extension_scope=None,
 291       options=None),
 292     _descriptor.FieldDescriptor(
 293       name='cached_payload', full_name='speckle.sql.ExecOpResponse.cached_payload', index=5,
 294       number=6, type=12, cpp_type=9, label=1,
 295       has_default_value=False, default_value=_b(""),
 296       message_type=None, enum_type=None, containing_type=None,
 297       is_extension=False, extension_scope=None,
 298       options=_descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\010\001'))),
 299   ],
 300   extensions=[
 301   ],
 302   nested_types=[],
 303   enum_types=[
 304   ],
 305   options=None,
 306   is_extendable=False,
 307   extension_ranges=[],
 308   serialized_start=692,
 309   serialized_end=929,
 310 )
 311
 312
 313 _METADATAREQUEST = _descriptor.Descriptor(
 314   name='MetadataRequest',
 315   full_name='speckle.sql.MetadataRequest',
 316   filename=None,
 317   file=DESCRIPTOR,
 318   containing_type=None,
 319   fields=[
 320     _descriptor.FieldDescriptor(
 321       name='instance', full_name='speckle.sql.MetadataRequest.instance', index=0,
 322       number=1, type=9, cpp_type=9, label=2,
 323       has_default_value=False, default_value=_b("").decode('utf-8'),
 324       message_type=None, enum_type=None, containing_type=None,
 325       is_extension=False, extension_scope=None,
 326       options=None),
 327     _descriptor.FieldDescriptor(
 328       name='metadata', full_name='speckle.sql.MetadataRequest.metadata', index=1,
 329       number=3, type=14, cpp_type=8, label=2,
 330       has_default_value=False, default_value=1,
 331       message_type=None, enum_type=None, containing_type=None,
 332       is_extension=False, extension_scope=None,
 333       options=None),
 334     _descriptor.FieldDescriptor(
 335       name='bind_variable', full_name='speckle.sql.MetadataRequest.bind_variable', index=2,
 336       number=4, type=11, cpp_type=10, label=3,
 337       has_default_value=False, default_value=[],
 338       message_type=None, enum_type=None, containing_type=None,
 339       is_extension=False, extension_scope=None,
 340       options=None),
 341     _descriptor.FieldDescriptor(
 342       name='connection_id', full_name='speckle.sql.MetadataRequest.connection_id', index=3,
 343       number=5, type=12, cpp_type=9, label=2,
 344       has_default_value=False, default_value=_b(""),
 345       message_type=None, enum_type=None, containing_type=None,
 346       is_extension=False, extension_scope=None,
 347       options=None),
 348     _descriptor.FieldDescriptor(
 349       name='request_id', full_name='speckle.sql.MetadataRequest.request_id', index=4,
 350       number=8, type=4, cpp_type=4, label=1,
 351       has_default_value=False, default_value=0,
 352       message_type=None, enum_type=None, containing_type=None,
 353       is_extension=False, extension_scope=None,
 354       options=None),
 355   ],
 356   extensions=[
 357   ],
 358   nested_types=[],
 359   enum_types=[
 360   ],
 361   options=None,
 362   is_extendable=False,
 363   extension_ranges=[],
 364   serialized_start=932,
 365   serialized_end=1102,
 366 )
 367
 368
 369 _METADATARESPONSE = _descriptor.Descriptor(
 370   name='MetadataResponse',
 371   full_name='speckle.sql.MetadataResponse',
 372   filename=None,
 373   file=DESCRIPTOR,
 374   containing_type=None,
 375   fields=[
 376     _descriptor.FieldDescriptor(
 377       name='result', full_name='speckle.sql.MetadataResponse.result', index=0,
 378       number=1, type=11, cpp_type=10, label=1,
 379       has_default_value=False, default_value=None,
 380       message_type=None, enum_type=None, containing_type=None,
 381       is_extension=False, extension_scope=None,
 382       options=None),
 383     _descriptor.FieldDescriptor(
 384       name='jdbc_database_metadata', full_name='speckle.sql.MetadataResponse.jdbc_database_metadata', index=1,
 385       number=2, type=11, cpp_type=10, label=1,
 386       has_default_value=False, default_value=None,
 387       message_type=None, enum_type=None, containing_type=None,
 388       is_extension=False, extension_scope=None,
 389       options=None),
 390     _descriptor.FieldDescriptor(
 391       name='sql_exception', full_name='speckle.sql.MetadataResponse.sql_exception', index=2,
 392       number=3, type=11, cpp_type=10, label=1,
 393       has_default_value=False, default_value=None,
 394       message_type=None, enum_type=None, containing_type=None,
 395       is_extension=False, extension_scope=None,
 396       options=None),
 397   ],
 398   extensions=[
 399   ],
 400   nested_types=[],
 401   enum_types=[
 402   ],
 403   options=None,
 404   is_extendable=False,
 405   extension_ranges=[],
 406   serialized_start=1105,
 407   serialized_end=1275,
 408 )
 409
 410
 411 _OPENCONNECTIONREQUEST = _descriptor.Descriptor(
 412   name='OpenConnectionRequest',
 413   full_name='speckle.sql.OpenConnectionRequest',
 414   filename=None,
 415   file=DESCRIPTOR,
 416   containing_type=None,
 417   fields=[
 418     _descriptor.FieldDescriptor(
 419       name='instance', full_name='speckle.sql.OpenConnectionRequest.instance', index=0,
 420       number=1, type=9, cpp_type=9, label=2,
 421       has_default_value=False, default_value=_b("").decode('utf-8'),
 422       message_type=None, enum_type=None, containing_type=None,
 423       is_extension=False, extension_scope=None,
 424       options=None),
 425     _descriptor.FieldDescriptor(
 426       name='property', full_name='speckle.sql.OpenConnectionRequest.property', index=1,
 427       number=2, type=11, cpp_type=10, label=3,
 428       has_default_value=False, default_value=[],
 429       message_type=None, enum_type=None, containing_type=None,
 430       is_extension=False, extension_scope=None,
 431       options=None),
 432     _descriptor.FieldDescriptor(
 433       name='protocol_version', full_name='speckle.sql.OpenConnectionRequest.protocol_version', index=2,
 434       number=5, type=4, cpp_type=4, label=1,
 435       has_default_value=True, default_value=1,
 436       message_type=None, enum_type=None, containing_type=None,
 437       is_extension=False, extension_scope=None,
 438       options=None),
 439     _descriptor.FieldDescriptor(
 440       name='client_type', full_name='speckle.sql.OpenConnectionRequest.client_type', index=3,
 441       number=6, type=14, cpp_type=8, label=1,
 442       has_default_value=True, default_value=1,
 443       message_type=None, enum_type=None, containing_type=None,
 444       is_extension=False, extension_scope=None,
 445       options=None),
 446   ],
 447   extensions=[
 448   ],
 449   nested_types=[],
 450   enum_types=[
 451   ],
 452   options=None,
 453   is_extendable=False,
 454   extension_ranges=[],
 455   serialized_start=1278,
 456   serialized_end=1450,
 457 )
 458
 459
 460 _OPENCONNECTIONRESPONSE = _descriptor.Descriptor(
 461   name='OpenConnectionResponse',
 462   full_name='speckle.sql.OpenConnectionResponse',
 463   filename=None,
 464   file=DESCRIPTOR,
 465   containing_type=None,
 466   fields=[
 467     _descriptor.FieldDescriptor(
 468       name='connection_id', full_name='speckle.sql.OpenConnectionResponse.connection_id', index=0,
 469       number=1, type=12, cpp_type=9, label=1,
 470       has_default_value=False, default_value=_b(""),
 471       message_type=None, enum_type=None, containing_type=None,
 472       is_extension=False, extension_scope=None,
 473       options=None),
 474     _descriptor.FieldDescriptor(
 475       name='sql_exception', full_name='speckle.sql.OpenConnectionResponse.sql_exception', index=1,
 476       number=2, type=11, cpp_type=10, label=1,
 477       has_default_value=False, default_value=None,
 478       message_type=None, enum_type=None, containing_type=None,
 479       is_extension=False, extension_scope=None,
 480       options=None),
 481     _descriptor.FieldDescriptor(
 482       name='warnings', full_name='speckle.sql.OpenConnectionResponse.warnings', index=2,
 483       number=6, type=11, cpp_type=10, label=3,
 484       has_default_value=False, default_value=[],
 485       message_type=None, enum_type=None, containing_type=None,
 486       is_extension=False, extension_scope=None,
 487       options=None),
 488   ],
 489   extensions=[
 490   ],
 491   nested_types=[],
 492   enum_types=[
 493   ],
 494   options=None,
 495   is_extendable=False,
 496   extension_ranges=[],
 497   serialized_start=1453,
 498   serialized_end=1587,
 499 )
 500
 501
 502 _CLOSECONNECTIONREQUEST = _descriptor.Descriptor(
 503   name='CloseConnectionRequest',
 504   full_name='speckle.sql.CloseConnectionRequest',
 505   filename=None,
 506   file=DESCRIPTOR,
 507   containing_type=None,
 508   fields=[
 509     _descriptor.FieldDescriptor(
 510       name='instance', full_name='speckle.sql.CloseConnectionRequest.instance', index=0,
 511       number=1, type=9, cpp_type=9, label=2,
 512       has_default_value=False, default_value=_b("").decode('utf-8'),
 513       message_type=None, enum_type=None, containing_type=None,
 514       is_extension=False, extension_scope=None,
 515       options=None),
 516     _descriptor.FieldDescriptor(
 517       name='connection_id', full_name='speckle.sql.CloseConnectionRequest.connection_id', index=1,
 518       number=2, type=12, cpp_type=9, label=2,
 519       has_default_value=False, default_value=_b(""),
 520       message_type=None, enum_type=None, containing_type=None,
 521       is_extension=False, extension_scope=None,
 522       options=None),
 523   ],
 524   extensions=[
 525   ],
 526   nested_types=[],
 527   enum_types=[
 528   ],
 529   options=None,
 530   is_extendable=False,
 531   extension_ranges=[],
 532   serialized_start=1589,
 533   serialized_end=1654,
 534 )
 535
 536
 537 _CLOSECONNECTIONRESPONSE = _descriptor.Descriptor(
 538   name='CloseConnectionResponse',
 539   full_name='speckle.sql.CloseConnectionResponse',
 540   filename=None,
 541   file=DESCRIPTOR,
 542   containing_type=None,
 543   fields=[
 544     _descriptor.FieldDescriptor(
 545       name='sql_exception', full_name='speckle.sql.CloseConnectionResponse.sql_exception', index=0,
 546       number=1, type=11, cpp_type=10, label=1,
 547       has_default_value=False, default_value=None,
 548       message_type=None, enum_type=None, containing_type=None,
 549       is_extension=False, extension_scope=None,
 550       options=None),
 551   ],
 552   extensions=[
 553   ],
 554   nested_types=[],
 555   enum_types=[
 556   ],
 557   options=None,
 558   is_extendable=False,
 559   extension_ranges=[],
 560   serialized_start=1656,
 561   serialized_end=1727,
 562 )
 563
 564 _EXECREQUEST.fields_by_name['bind_variable'].message_type = google.storage.speckle.proto.client_pb2._BINDVARIABLEPROTO
 565 _EXECREQUEST.fields_by_name['options'].message_type = google.storage.speckle.proto.client_pb2._EXECOPTIONS
 566 _EXECREQUEST.fields_by_name['statement_type'].enum_type = _EXECREQUEST_STATEMENTTYPE
 567 _EXECREQUEST.fields_by_name['batch'].message_type = google.storage.speckle.proto.client_pb2._BATCHPROTO
 568 _EXECREQUEST_STATEMENTTYPE.containing_type = _EXECREQUEST
 569 _EXECRESPONSE.fields_by_name['result'].message_type = google.storage.speckle.proto.client_pb2._RESULTPROTO
 570 _EXECRESPONSE.fields_by_name['sql_exception'].message_type = google.storage.speckle.proto.client_pb2._SQLEXCEPTION
 571 _EXECOPREQUEST.fields_by_name['op'].message_type = google.storage.speckle.proto.client_pb2._OPPROTO
 572 _EXECOPRESPONSE.fields_by_name['savepoint'].message_type = google.storage.speckle.proto.client_pb2._SAVEPOINT
 573 _EXECOPRESPONSE.fields_by_name['sql_exception'].message_type = google.storage.speckle.proto.client_pb2._SQLEXCEPTION
 574 _EXECOPRESPONSE.fields_by_name['result'].message_type = google.storage.speckle.proto.client_pb2._RESULTPROTO
 575 _EXECOPRESPONSE.fields_by_name['cached_rpc_error'].message_type = google.storage.speckle.proto.client_pb2._RPCERRORPROTO
 576 _METADATAREQUEST.fields_by_name['metadata'].enum_type = google.storage.speckle.proto.client_pb2._METADATATYPE
 577 _METADATAREQUEST.fields_by_name['bind_variable'].message_type = google.storage.speckle.proto.client_pb2._BINDVARIABLEPROTO
 578 _METADATARESPONSE.fields_by_name['result'].message_type = google.storage.speckle.proto.client_pb2._RESULTPROTO
 579 _METADATARESPONSE.fields_by_name['jdbc_database_metadata'].message_type = google.storage.speckle.proto.client_pb2._JDBCDATABASEMETADATAPROTO
 580 _METADATARESPONSE.fields_by_name['sql_exception'].message_type = google.storage.speckle.proto.client_pb2._SQLEXCEPTION
 581 _OPENCONNECTIONREQUEST.fields_by_name['property'].message_type = google.storage.speckle.proto.client_pb2._PROPERTY
 582 _OPENCONNECTIONREQUEST.fields_by_name['client_type'].enum_type = google.storage.speckle.proto.client_pb2._CLIENTTYPE
 583 _OPENCONNECTIONRESPONSE.fields_by_name['sql_exception'].message_type = google.storage.speckle.proto.client_pb2._SQLEXCEPTION
 584 _OPENCONNECTIONRESPONSE.fields_by_name['warnings'].message_type = google.storage.speckle.proto.client_pb2._SQLEXCEPTION
 585 _CLOSECONNECTIONRESPONSE.fields_by_name['sql_exception'].message_type = google.storage.speckle.proto.client_pb2._SQLEXCEPTION
 586 DESCRIPTOR.message_types_by_name['ExecRequest'] = _EXECREQUEST
 587 DESCRIPTOR.message_types_by_name['ExecResponse'] = _EXECRESPONSE
 588 DESCRIPTOR.message_types_by_name['ExecOpRequest'] = _EXECOPREQUEST
 589 DESCRIPTOR.message_types_by_name['ExecOpResponse'] = _EXECOPRESPONSE
 590 DESCRIPTOR.message_types_by_name['MetadataRequest'] = _METADATAREQUEST
 591 DESCRIPTOR.message_types_by_name['MetadataResponse'] = _METADATARESPONSE
 592 DESCRIPTOR.message_types_by_name['OpenConnectionRequest'] = _OPENCONNECTIONREQUEST
 593 DESCRIPTOR.message_types_by_name['OpenConnectionResponse'] = _OPENCONNECTIONRESPONSE
 594 DESCRIPTOR.message_types_by_name['CloseConnectionRequest'] = _CLOSECONNECTIONREQUEST
 595 DESCRIPTOR.message_types_by_name['CloseConnectionResponse'] = _CLOSECONNECTIONRESPONSE
 596
 597 ExecRequest = _reflection.GeneratedProtocolMessageType('ExecRequest', (_message.Message,), dict(
 598   DESCRIPTOR = _EXECREQUEST,
 599   __module__ = 'google.storage.speckle.proto.sql_pb2'
 600
 601   ))
 602
 603 ExecResponse = _reflection.GeneratedProtocolMessageType('ExecResponse', (_message.Message,), dict(
 604   DESCRIPTOR = _EXECRESPONSE,
 605   __module__ = 'google.storage.speckle.proto.sql_pb2'
 606
 607   ))
 608
 609 ExecOpRequest = _reflection.GeneratedProtocolMessageType('ExecOpRequest', (_message.Message,), dict(
 610   DESCRIPTOR = _EXECOPREQUEST,
 611   __module__ = 'google.storage.speckle.proto.sql_pb2'
 612
 613   ))
 614
 615 ExecOpResponse = _reflection.GeneratedProtocolMessageType('ExecOpResponse', (_message.Message,), dict(
 616   DESCRIPTOR = _EXECOPRESPONSE,
 617   __module__ = 'google.storage.speckle.proto.sql_pb2'
 618
 619   ))
 620
 621 MetadataRequest = _reflection.GeneratedProtocolMessageType('MetadataRequest', (_message.Message,), dict(
 622   DESCRIPTOR = _METADATAREQUEST,
 623   __module__ = 'google.storage.speckle.proto.sql_pb2'
 624
 625   ))
 626
 627 MetadataResponse = _reflection.GeneratedProtocolMessageType('MetadataResponse', (_message.Message,), dict(
 628   DESCRIPTOR = _METADATARESPONSE,
 629   __module__ = 'google.storage.speckle.proto.sql_pb2'
 630
 631   ))
 632
 633 OpenConnectionRequest = _reflection.GeneratedProtocolMessageType('OpenConnectionRequest', (_message.Message,), dict(
 634   DESCRIPTOR = _OPENCONNECTIONREQUEST,
 635   __module__ = 'google.storage.speckle.proto.sql_pb2'
 636
 637   ))
 638
 639 OpenConnectionResponse = _reflection.GeneratedProtocolMessageType('OpenConnectionResponse', (_message.Message,), dict(
 640   DESCRIPTOR = _OPENCONNECTIONRESPONSE,
 641   __module__ = 'google.storage.speckle.proto.sql_pb2'
 642
 643   ))
 644
 645 CloseConnectionRequest = _reflection.GeneratedProtocolMessageType('CloseConnectionRequest', (_message.Message,), dict(
 646   DESCRIPTOR = _CLOSECONNECTIONREQUEST,
 647   __module__ = 'google.storage.speckle.proto.sql_pb2'
 648
 649   ))
 650
 651 CloseConnectionResponse = _reflection.GeneratedProtocolMessageType('CloseConnectionResponse', (_message.Message,), dict(
 652   DESCRIPTOR = _CLOSECONNECTIONRESPONSE,
 653   __module__ = 'google.storage.speckle.proto.sql_pb2'
 654
 655   ))
 656
 657
 658 DESCRIPTOR.has_options = True
 659 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'))
 660 _EXECOPRESPONSE.fields_by_name['cached_payload'].has_options = True
 661 _EXECOPRESPONSE.fields_by_name['cached_payload']._options = _descriptor._ParseOptions(descriptor_pb2.FieldOptions(), _b('\010\001'))
 662
 663
 664 class _SqlService_ClientBaseStub(_client_stub_base_class):
 665   """Makes Stubby RPC calls to a SqlService server."""
 666
 667   __slots__ = (
 668       '_protorpc_Exec', '_full_name_Exec',
 669       '_protorpc_ExecOp', '_full_name_ExecOp',
 670       '_protorpc_GetMetadata', '_full_name_GetMetadata',
 671       '_protorpc_OpenConnection', '_full_name_OpenConnection',
 672       '_protorpc_CloseConnection', '_full_name_CloseConnection',
 673   )
 674
 675   def __init__(self, rpc_stub):
 676     self._stub = rpc_stub
 677
 678     self._protorpc_Exec = pywraprpc.RPC()
 679     self._protorpc_Exec.set_fail_fast(True)
 680     self._full_name_Exec = self._stub.GetFullMethodName(
 681         'Exec')
 682
 683     self._protorpc_ExecOp = pywraprpc.RPC()
 684     self._protorpc_ExecOp.set_fail_fast(True)
 685     self._full_name_ExecOp = self._stub.GetFullMethodName(
 686         'ExecOp')
 687
 688     self._protorpc_GetMetadata = pywraprpc.RPC()
 689     self._protorpc_GetMetadata.set_fail_fast(True)
 690     self._full_name_GetMetadata = self._stub.GetFullMethodName(
 691         'GetMetadata')
 692
 693     self._protorpc_OpenConnection = pywraprpc.RPC()
 694     self._protorpc_OpenConnection.set_fail_fast(True)
 695     self._full_name_OpenConnection = self._stub.GetFullMethodName(
 696         'OpenConnection')
 697
 698     self._protorpc_CloseConnection = pywraprpc.RPC()
 699     self._protorpc_CloseConnection.set_fail_fast(True)
 700     self._full_name_CloseConnection = self._stub.GetFullMethodName(
 701         'CloseConnection')
 702
 703   def Exec(self, request, rpc=None, callback=None, response=None):
 704     """Make a Exec RPC call.
 705
 706     Args:
 707       request: a ExecRequest instance.
 708       rpc: Optional RPC instance to use for the call.
 709       callback: Optional final callback. Will be called as
 710           callback(rpc, result) when the rpc completes. If None, the
 711           call is synchronous.
 712       response: Optional ProtocolMessage to be filled in with response.
 713
 714     Returns:
 715       The ExecResponse if callback is None. Otherwise, returns None.
 716     """
 717
 718     if response is None:
 719       response = ExecResponse
 720     return self._MakeCall(rpc,
 721                           self._full_name_Exec,
 722                           'Exec',
 723                           request,
 724                           response,
 725                           callback,
 726                           self._protorpc_Exec)
 727
 728   def ExecOp(self, request, rpc=None, callback=None, response=None):
 729     """Make a ExecOp RPC call.
 730
 731     Args:
 732       request: a ExecOpRequest instance.
 733       rpc: Optional RPC instance to use for the call.
 734       callback: Optional final callback. Will be called as
 735           callback(rpc, result) when the rpc completes. If None, the
 736           call is synchronous.
 737       response: Optional ProtocolMessage to be filled in with response.
 738
 739     Returns:
 740       The ExecOpResponse if callback is None. Otherwise, returns None.
 741     """
 742
 743     if response is None:
 744       response = ExecOpResponse
 745     return self._MakeCall(rpc,
 746                           self._full_name_ExecOp,
 747                           'ExecOp',
 748                           request,
 749                           response,
 750                           callback,
 751                           self._protorpc_ExecOp)
 752
 753   def GetMetadata(self, request, rpc=None, callback=None, response=None):
 754     """Make a GetMetadata RPC call.
 755
 756     Args:
 757       request: a MetadataRequest instance.
 758       rpc: Optional RPC instance to use for the call.
 759       callback: Optional final callback. Will be called as
 760           callback(rpc, result) when the rpc completes. If None, the
 761           call is synchronous.
 762       response: Optional ProtocolMessage to be filled in with response.
 763
 764     Returns:
 765       The MetadataResponse if callback is None. Otherwise, returns None.
 766     """
 767
 768     if response is None:
 769       response = MetadataResponse
 770     return self._MakeCall(rpc,
 771                           self._full_name_GetMetadata,
 772                           'GetMetadata',
 773                           request,
 774                           response,
 775                           callback,
 776                           self._protorpc_GetMetadata)
 777
 778   def OpenConnection(self, request, rpc=None, callback=None, response=None):
 779     """Make a OpenConnection RPC call.
 780
 781     Args:
 782       request: a OpenConnectionRequest instance.
 783       rpc: Optional RPC instance to use for the call.
 784       callback: Optional final callback. Will be called as
 785           callback(rpc, result) when the rpc completes. If None, the
 786           call is synchronous.
 787       response: Optional ProtocolMessage to be filled in with response.
 788
 789     Returns:
 790       The OpenConnectionResponse if callback is None. Otherwise, returns None.
 791     """
 792
 793     if response is None:
 794       response = OpenConnectionResponse
 795     return self._MakeCall(rpc,
 796                           self._full_name_OpenConnection,
 797                           'OpenConnection',
 798                           request,
 799                           response,
 800                           callback,
 801                           self._protorpc_OpenConnection)
 802
 803   def CloseConnection(self, request, rpc=None, callback=None, response=None):
 804     """Make a CloseConnection RPC call.
 805
 806     Args:
 807       request: a CloseConnectionRequest instance.
 808       rpc: Optional RPC instance to use for the call.
 809       callback: Optional final callback. Will be called as
 810           callback(rpc, result) when the rpc completes. If None, the
 811           call is synchronous.
 812       response: Optional ProtocolMessage to be filled in with response.
 813
 814     Returns:
 815       The CloseConnectionResponse if callback is None. Otherwise, returns None.
 816     """
 817
 818     if response is None:
 819       response = CloseConnectionResponse
 820     return self._MakeCall(rpc,
 821                           self._full_name_CloseConnection,
 822                           'CloseConnection',
 823                           request,
 824                           response,
 825                           callback,
 826                           self._protorpc_CloseConnection)
 827
 828
 829 class _SqlService_ClientStub(_SqlService_ClientBaseStub):
 830   __slots__ = ('_params',)
 831   def __init__(self, rpc_stub_parameters, service_name):
 832     if service_name is None:
 833       service_name = 'SqlService'
 834     _SqlService_ClientBaseStub.__init__(self, pywraprpc.RPC_GenericStub(service_name, rpc_stub_parameters))
 835     self._params = rpc_stub_parameters
 836
 837
 838 class _SqlService_RPC2ClientStub(_SqlService_ClientBaseStub):
 839   __slots__ = ()
 840   def __init__(self, server, channel, service_name):
 841     if service_name is None:
 842       service_name = 'SqlService'
 843     if channel is not None:
 844       if channel.version() == 1:
 845         raise RuntimeError('Expecting an RPC2 channel to create the stub')
 846       _SqlService_ClientBaseStub.__init__(self, pywraprpc.RPC_GenericStub(service_name, channel))
 847     elif server is not None:
 848       _SqlService_ClientBaseStub.__init__(self, pywraprpc.RPC_GenericStub(service_name, pywraprpc.NewClientChannel(server)))
 849     else:
 850       raise RuntimeError('Invalid argument combination to create a stub')
 851
 852
 853 class SqlService(_server_stub_base_class):
 854   """Base class for SqlService Stubby servers."""
 855
 856   @classmethod
 857   def _MethodSignatures(cls):
 858     """Returns a dict of {<method-name>: (<request-type>, <response-type>)}."""
 859     return {
 860       'Exec': (ExecRequest, ExecResponse),
 861       'ExecOp': (ExecOpRequest, ExecOpResponse),
 862       'GetMetadata': (MetadataRequest, MetadataResponse),
 863       'OpenConnection': (OpenConnectionRequest, OpenConnectionResponse),
 864       'CloseConnection': (CloseConnectionRequest, CloseConnectionResponse),
 865       }
 866
 867   @classmethod
 868   def _StreamMethodSignatures(cls):
 869     """Returns a dict of {<method-name>: (<request-type>, <stream-type>, <response-type>)}."""
 870     return {
 871       }
 872
 873   def __init__(self, *args, **kwargs):
 874     """Creates a Stubby RPC server.
 875
 876     See BaseRpcServer.__init__ in rpcserver.py for detail on arguments.
 877     """
 878     if _server_stub_base_class is object:
 879       raise NotImplementedError('Add //net/rpc/python:rpcserver as a '
 880                                 'dependency for Stubby server support.')
 881     _server_stub_base_class.__init__(self, 'speckle.sql.SqlService', *args, **kwargs)
 882
 883   @staticmethod
 884   def NewStub(rpc_stub_parameters, service_name=None):
 885     """Creates a new SqlService Stubby client stub.
 886
 887     Args:
 888       rpc_stub_parameters: an RPC_StubParameter instance.
 889       service_name: the service name used by the Stubby server.
 890     """
 891
 892     if _client_stub_base_class is object:
 893       raise RuntimeError('Add //net/rpc/python as a dependency to use Stubby')
 894     return _SqlService_ClientStub(rpc_stub_parameters, service_name)
 895
 896   @staticmethod
 897   def NewRPC2Stub(server=None, channel=None, service_name=None):
 898     """Creates a new SqlService Stubby2 client stub.
 899
 900     Args:
 901       server: host:port or bns address.
 902       channel: directly use a channel to create a stub. Will ignore server
 903           argument if this is specified.
 904       service_name: the service name used by the Stubby server.
 905     """
 906
 907     if _client_stub_base_class is object:
 908       raise RuntimeError('Add //net/rpc/python as a dependency to use Stubby')
 909     return _SqlService_RPC2ClientStub(server, channel, service_name)
 910
 911   def Exec(self, rpc, request, response):
 912     """Handles a Exec RPC call. You should override this.
 913
 914     Args:
 915       rpc: a Stubby RPC object
 916       request: a ExecRequest that contains the client request
 917       response: a ExecResponse that should be modified to send the response
 918     """
 919     raise NotImplementedError
 920
 921
 922   def ExecOp(self, rpc, request, response):
 923     """Handles a ExecOp RPC call. You should override this.
 924
 925     Args:
 926       rpc: a Stubby RPC object
 927       request: a ExecOpRequest that contains the client request
 928       response: a ExecOpResponse that should be modified to send the response
 929     """
 930     raise NotImplementedError
 931
 932
 933   def GetMetadata(self, rpc, request, response):
 934     """Handles a GetMetadata RPC call. You should override this.
 935
 936     Args:
 937       rpc: a Stubby RPC object
 938       request: a MetadataRequest that contains the client request
 939       response: a MetadataResponse that should be modified to send the response
 940     """
 941     raise NotImplementedError
 942
 943
 944   def OpenConnection(self, rpc, request, response):
 945     """Handles a OpenConnection RPC call. You should override this.
 946
 947     Args:
 948       rpc: a Stubby RPC object
 949       request: a OpenConnectionRequest that contains the client request
 950       response: a OpenConnectionResponse that should be modified to send the response
 951     """
 952     raise NotImplementedError
 953
 954
 955   def CloseConnection(self, rpc, request, response):
 956     """Handles a CloseConnection RPC call. You should override this.
 957
 958     Args:
 959       rpc: a Stubby RPC object
 960       request: a CloseConnectionRequest that contains the client request
 961       response: a CloseConnectionResponse that should be modified to send the response
 962     """
 963     raise NotImplementedError
 964
 965   def _AddMethodAttributes(self):
 966     """Sets attributes on Python RPC handlers.
 967
 968     See BaseRpcServer in rpcserver.py for details.
 969     """
 970     rpcserver._GetHandlerDecorator(
 971         self.Exec.im_func,
 972         ExecRequest,
 973         ExecResponse,
 974         None,
 975         'none')
 976     rpcserver._GetHandlerDecorator(
 977         self.ExecOp.im_func,
 978         ExecOpRequest,
 979         ExecOpResponse,
 980         None,
 981         'none')
 982     rpcserver._GetHandlerDecorator(
 983         self.GetMetadata.im_func,
 984         MetadataRequest,
 985         MetadataResponse,
 986         None,
 987         'none')
 988     rpcserver._GetHandlerDecorator(
 989         self.OpenConnection.im_func,
 990         OpenConnectionRequest,
 991         OpenConnectionResponse,
 992         None,
 993         'none')
 994     rpcserver._GetHandlerDecorator(
 995         self.CloseConnection.im_func,
 996         CloseConnectionRequest,
 997         CloseConnectionResponse,
 998         None,
 999         'none')
1000
1001