Skip to content

Commit 2c984c4

Browse files
authored
RUBY-293: Support query flags as an int for v5 connections (#263)
1 parent ef10e07 commit 2c984c4

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

lib/cassandra/protocol/requests/query_request.rb

+10-2
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,14 @@ def payload?
5151
!!@payload
5252
end
5353

54+
def append_flags(buffer,flags,protocol_version)
55+
if protocol_version < 5
56+
buffer.append(flags.chr)
57+
else
58+
buffer.append_int(flags)
59+
end
60+
end
61+
5462
def write(buffer, protocol_version, encoder)
5563
buffer.append_long_string(@cql)
5664
buffer.append_consistency(@consistency)
@@ -63,10 +71,10 @@ def write(buffer, protocol_version, encoder)
6371
if @values && !@values.empty?
6472
flags |= 0x01
6573
flags |= 0x40 if protocol_version > 2 && !@names.empty?
66-
buffer.append(flags.chr)
74+
append_flags(buffer, flags, protocol_version)
6775
encoder.write_parameters(buffer, @values, @type_hints, @names)
6876
else
69-
buffer.append(flags.chr)
77+
append_flags(buffer, flags, protocol_version)
7078
end
7179
buffer.append_int(@page_size) if @page_size
7280
buffer.append_bytes(@paging_state) if @paging_state

0 commit comments

Comments
 (0)