| 779 | self.recv_prepared_metadata(f, protocol_version, user_type_map) |
| 780 | |
| 781 | def recv_results_metadata(self, f, user_type_map): |
| 782 | flags = read_int(f) |
| 783 | colcount = read_int(f) |
| 784 | |
| 785 | if flags & self._HAS_MORE_PAGES_FLAG: |
| 786 | self.paging_state = read_binary_longstring(f) |
| 787 | |
| 788 | no_meta = bool(flags & self._NO_METADATA_FLAG) |
| 789 | if no_meta: |
| 790 | return |
| 791 | |
| 792 | if flags & self._CONTINUOUS_PAGING_FLAG: |
| 793 | self.continuous_paging_seq = read_int(f) |
| 794 | self.continuous_paging_last = flags & self._CONTINUOUS_PAGING_LAST_FLAG |
| 795 | |
| 796 | if flags & self._METADATA_ID_FLAG: |
| 797 | self.result_metadata_id = read_binary_string(f) |
| 798 | |
| 799 | glob_tblspec = bool(flags & self._FLAGS_GLOBAL_TABLES_SPEC) |
| 800 | if glob_tblspec: |
| 801 | ksname = read_string(f) |
| 802 | cfname = read_string(f) |
| 803 | column_metadata = [] |
| 804 | for _ in range(colcount): |
| 805 | if glob_tblspec: |
| 806 | colksname = ksname |
| 807 | colcfname = cfname |
| 808 | else: |
| 809 | colksname = read_string(f) |
| 810 | colcfname = read_string(f) |
| 811 | colname = read_string(f) |
| 812 | coltype = self.read_type(f, user_type_map) |
| 813 | column_metadata.append((colksname, colcfname, colname, coltype)) |
| 814 | |
| 815 | self.column_metadata = column_metadata |
| 816 | |
| 817 | def recv_prepared_metadata(self, f, protocol_version, user_type_map): |
| 818 | flags = read_int(f) |