(self, f, protocol_version, user_type_map)
| 815 | self.column_metadata = column_metadata |
| 816 | |
| 817 | def recv_prepared_metadata(self, f, protocol_version, user_type_map): |
| 818 | flags = read_int(f) |
| 819 | colcount = read_int(f) |
| 820 | pk_indexes = None |
| 821 | if protocol_version >= 4: |
| 822 | num_pk_indexes = read_int(f) |
| 823 | pk_indexes = [read_short(f) for _ in range(num_pk_indexes)] |
| 824 | |
| 825 | glob_tblspec = bool(flags & self._FLAGS_GLOBAL_TABLES_SPEC) |
| 826 | if glob_tblspec: |
| 827 | ksname = read_string(f) |
| 828 | cfname = read_string(f) |
| 829 | bind_metadata = [] |
| 830 | for _ in range(colcount): |
| 831 | if glob_tblspec: |
| 832 | colksname = ksname |
| 833 | colcfname = cfname |
| 834 | else: |
| 835 | colksname = read_string(f) |
| 836 | colcfname = read_string(f) |
| 837 | colname = read_string(f) |
| 838 | coltype = self.read_type(f, user_type_map) |
| 839 | bind_metadata.append(ColumnMetadata(colksname, colcfname, colname, coltype)) |
| 840 | |
| 841 | if protocol_version >= 2: |
| 842 | self.recv_results_metadata(f, user_type_map) |
| 843 | |
| 844 | self.bind_metadata = bind_metadata |
| 845 | self.pk_indexes = pk_indexes |
| 846 | |
| 847 | def recv_results_schema_change(self, f, protocol_version): |
| 848 | self.schema_change_event = EventMessage.recv_schema_change(f, protocol_version) |
no test coverage detected