| 621 | |
| 622 | |
| 623 | class QueryMessage(_QueryMessage): |
| 624 | opcode = 0x07 |
| 625 | name = 'QUERY' |
| 626 | |
| 627 | def __init__(self, query, consistency_level, serial_consistency_level=None, |
| 628 | fetch_size=None, paging_state=None, timestamp=None, continuous_paging_options=None, keyspace=None): |
| 629 | self.query = query |
| 630 | super(QueryMessage, self).__init__(None, consistency_level, serial_consistency_level, fetch_size, |
| 631 | paging_state, timestamp, False, continuous_paging_options, keyspace) |
| 632 | |
| 633 | def send_body(self, f, protocol_version): |
| 634 | write_longstring(f, self.query) |
| 635 | self._write_query_params(f, protocol_version) |
| 636 | |
| 637 | |
| 638 | class ExecuteMessage(_QueryMessage): |
no outgoing calls