(self, f, protocol_version)
| 649 | paging_state, timestamp, skip_meta, continuous_paging_options) |
| 650 | |
| 651 | def _write_query_params(self, f, protocol_version): |
| 652 | if protocol_version == 1: |
| 653 | if self.serial_consistency_level: |
| 654 | raise UnsupportedOperation( |
| 655 | "Serial consistency levels require the use of protocol version " |
| 656 | "2 or higher. Consider setting Cluster.protocol_version to 2 " |
| 657 | "to support serial consistency levels.") |
| 658 | if self.fetch_size or self.paging_state: |
| 659 | raise UnsupportedOperation( |
| 660 | "Automatic query paging may only be used with protocol version " |
| 661 | "2 or higher. Consider setting Cluster.protocol_version to 2.") |
| 662 | write_short(f, len(self.query_params)) |
| 663 | for param in self.query_params: |
| 664 | write_value(f, param) |
| 665 | write_consistency_level(f, self.consistency_level) |
| 666 | else: |
| 667 | super(ExecuteMessage, self)._write_query_params(f, protocol_version) |
| 668 | |
| 669 | def send_body(self, f, protocol_version): |
| 670 | write_string(f, self.query_id) |
no test coverage detected