Remove duplicate try-except blocks (DRY principle)

Per review feedback, eliminated code duplication:
- Combined two separate try-except blocks into one
- Single exception handler now checks column_encryption_policy to decide path
- Maintains same error reporting behavior
- Follows Python's DRY (Don't Repeat Yourself) principle

This makes the code cleaner and more maintainable.

Co-authored-by: mykaul <[email protected]>

Author: Copilot

cassandra/protocol.py

@@ -732,36 +732,28 @@ def decode_val(val, col_md, col_desc):
 
             def decode_row(row):
                 return tuple(decode_val(val, col_md, col_desc) for val, col_md, col_desc in zip(row, column_metadata, col_descs))
-
-            try:
-                self.parsed_rows = [decode_row(row) for row in rows]
-            except Exception:
-                for row in rows:
-                    for val, col_md, col_desc in zip(row, column_metadata, col_descs):
-                        try:
-                            decode_val(val, col_md, col_desc)
-                        except Exception as e:
-                            raise DriverException('Failed decoding result column "%s" of type %s: %s' % (col_md[2],
-                                                                                                         col_md[3].cql_parameterized_type(),
-                                                                                                         str(e)))
         else:
             # Simple path without encryption - just decode raw bytes directly
             def decode_row(row):
                 return tuple(col_md[3].from_binary(val, protocol_version) for val, col_md in zip(row, column_metadata))
 
-            try:
-                self.parsed_rows = [decode_row(row) for row in rows]
-            except Exception:
-                # Create col_descs only if needed for error reporting
+        try:
+            self.parsed_rows = [decode_row(row) for row in rows]
+        except Exception:
+            # Create col_descs only if needed for error reporting
+            if not column_encryption_policy:
                 col_descs = [ColDesc(md[0], md[1], md[2]) for md in column_metadata]
-                for row in rows:
-                    for val, col_md, col_desc in zip(row, column_metadata, col_descs):
-                        try:
+            for row in rows:
+                for val, col_md, col_desc in zip(row, column_metadata, col_descs):
+                    try:
+                        if column_encryption_policy:
+                            decode_val(val, col_md, col_desc)
+                        else:
                             col_md[3].from_binary(val, protocol_version)
-                        except Exception as e:
-                            raise DriverException('Failed decoding result column "%s" of type %s: %s' % (col_md[2],
-                                                                                                         col_md[3].cql_parameterized_type(),
-                                                                                                         str(e)))
+                    except Exception as e:
+                        raise DriverException('Failed decoding result column "%s" of type %s: %s' % (col_md[2],
+                                                                                                     col_md[3].cql_parameterized_type(),
+                                                                                                     str(e)))
 
     def recv_results_prepared(self, f, protocol_version, user_type_map):
         self.query_id = read_binary_string(f)