feat: Proto column feature tests and samples

google/cloud/spanner_v1/_helpers.py

@@ -268,9 +268,9 @@ def _parse_value_pb(value_pb, field_type, field_name, column_info=None):
     elif type_code == TypeCode.PROTO:
         bytes_value = base64.b64decode(value_pb.string_value)
         if column_info is not None and column_info.get(field_name) is not None:
-            proto_message = column_info.get(field_name)
-            if isinstance(proto_message, Message):
-                proto_message = proto_message.__deepcopy__()
+            default_proto_message = column_info.get(field_name)
+            if isinstance(default_proto_message, Message):
+                proto_message = type(default_proto_message)()
                 proto_message.ParseFromString(bytes_value)
                 return proto_message
         return bytes_value

samples/samples/conftest.py

@@ -116,7 +116,11 @@ def multi_region_instance_config(spanner_client):
 
 @pytest.fixture(scope="module")
 def proto_descriptor_file():
-    return open("../../samples/samples/testdata/descriptors.pb", 'rb').read()
+    import os
+
+    dirname = os.path.dirname(__file__)
+    filename = os.path.join(dirname, "testdata/descriptors.pb")
+    return open(filename, "rb").read()
 
 
 @pytest.fixture(scope="module")
@@ -209,12 +213,13 @@ def database_ddl():
 
 @pytest.fixture(scope="module")
 def sample_database(
-  spanner_client,
-  sample_instance,
-  database_id,
-  database_ddl,
-  database_dialect,
-  proto_descriptor_file):
+    spanner_client,
+    sample_instance,
+    database_id,
+    database_ddl,
+    database_dialect,
+    proto_descriptor_file,
+):
     if database_dialect == DatabaseDialect.POSTGRESQL:
         sample_database = sample_instance.database(
           database_id,
@@ -240,9 +245,9 @@ def sample_database(
         return
 
     sample_database = sample_instance.database(
-      database_id,
-      ddl_statements=database_ddl,
-      proto_descriptors=proto_descriptor_file
+        database_id,
+        ddl_statements=database_ddl,
+        proto_descriptors=proto_descriptor_file,
     )
 
     if not sample_database.exists():