Row builder

.gitignore

@@ -13,3 +13,5 @@
 /venv
 /lib/cassandra_murmur3.*
 /node_modules
+/*.gem
+/.bundle/*

.nav

@@ -0,0 +1,2 @@
+features
+api

.rubocop.yml

@@ -2,13 +2,15 @@ inherit_from: .rubocop_todo.yml
 
 #### The following group of customizations is questionable. ####
 
-# We currently exclude types.rb and fetchers.rb because auto-correct results in an
-# infinite loop in RuboCop.
 AllCops:
   TargetRubyVersion: 1.9
   Exclude:
-    - 'lib/cassandra/types.rb'
-    - 'lib/cassandra/cluster/schema/fetchers.rb'
+    - 'spec/**/*'
+    - 'benchmarking/**/*'
+    - 'support/**/*'
+    - 'integration/**/*'
+    - 'features/**/*'
+    - 'tmp/**/*'
 
 # We shouldn't rescue Exception!
 Lint/RescueException:
@@ -25,26 +27,42 @@ Metrics/ModuleLength:
 Metrics/ClassLength:
   Enabled: false
 
+Metrics/ParameterLists:
+  Enabled: false
+
+Style/MultilineBlockLayout:
+  Enabled: false
+
 Style/MultilineTernaryOperator:
   Enabled: false
 
+Style/PredicateName:
+  NamePrefixBlacklist: is_, have_
+  NameWhitelist: is_a?
+
 Style/SingleLineBlockParams:
   Enabled: false
 
 Style/SignalException:
   EnforcedStyle: only_raise
 
+Style/TrivialAccessors:
+  Enabled: false
+
 Lint/EndAlignment:
   AutoCorrect: true
 
 Style/IfUnlessModifier:
-  MaxLineLength: 90
+  MaxLineLength: 120
+
+Style/RaiseArgs:
+  Enabled: false
 
 Style/WhileUntilModifier:
-  MaxLineLength: 90
+  MaxLineLength: 120
 
 Metrics/LineLength:
-  Max: 90
+  Max: 120
   # To make it possible to copy or click on URIs in the code, we allow lines
   # contaning a URI to be longer than Max.
   AllowHeredoc: true

.rubocop_todo.yml

@@ -190,29 +190,6 @@ Style/OpMethod:
     - 'lib/cassandra/protocol/requests/query_request.rb'
     - 'lib/cassandra/protocol/responses/ready_response.rb'
 
-# Offense count: 14
-# Configuration parameters: NamePrefix, NamePrefixBlacklist, NameWhitelist.
-# NamePrefix: is_, has_, have_
-# NamePrefixBlacklist: is_, has_, have_
-# NameWhitelist: is_a?
-Style/PredicateName:
-  Exclude:
-    - 'lib/cassandra/cluster/registry.rb'
-    - 'lib/cassandra/cluster/schema.rb'
-    - 'lib/cassandra/function.rb'
-    - 'lib/cassandra/keyspace.rb'
-    - 'lib/cassandra/load_balancing.rb'
-    - 'lib/cassandra/load_balancing/policies/dc_aware_round_robin.rb'
-    - 'lib/cassandra/load_balancing/policies/round_robin.rb'
-    - 'lib/cassandra/load_balancing/policies/token_aware.rb'
-    - 'lib/cassandra/table.rb'
-    - 'lib/cassandra/udt.rb'
-
-# Offense count: 2
-# Configuration parameters: EnforcedStyle, SupportedStyles.
-# SupportedStyles: compact, exploded
-#Style/RaiseArgs:
-#  Enabled: false
 
 # Offense count: 46
 # Cop supports --auto-correct.

CHANGELOG.md

@@ -1,10 +1,81 @@
 # master
+
+# 3.2.0
+
 Features:
+* [RUBY-294](https://datastax-oss.atlassian.net/browse/RUBY-294) Support MRI 2.4.x. Thanks, @lautis, for this contribution!
 
 Bug Fixes:
-* [RUBY-161] Protocol version negotiation in mixed version clusters should not fall back to v1 unless it is truly warranted.    
+* [RUBY-291](https://datastax-oss.atlassian.net/browse/RUBY-291) Driver fails to connect to cluster when a table column type has a quoted name.
+* [RUBY-292](https://datastax-oss.atlassian.net/browse/RUBY-292) Driver sporadically crashes with "undefined method 'ip'" error.
+Thanks, @grosser, for the fix!
+* [RUBY-295](https://datastax-oss.atlassian.net/browse/RUBY-295) When a custom address resolver is configured, 
+consult it when handling all host events, and thus prevent the creation of invalid Host objects.
+
+# 3.1.0
+Features:
+* Do not mark a host as down if there are active connections.
+* Update Keyspace metadata to include collection of indexes defined in the keyspace.
+* Update Table metadata to include trigger-collection and view-collection metadata. Also include the cdc attribute,
+  introduced in C* 3.8. More details [here.](http://cassandra.apache.org/doc/latest/operating/cdc.html)
+* Added execution profiles to encapsulate a group of request execution options.
+* Added support for v5 beta protocol. This will always be a "work-in-progress" since the protocol is under
+  development and the driver is not necessarily updated to the latest revision of it.
+* Make prepared statement cache not be scoped by host and optimistically execute prepared statements on hosts where
+  we are not sure the statement is already prepared. The motivation is that in the steady state, all nodes have
+  prepared statements already, so there is no need to prepare statements before executing them. If the guess is wrong,
+  the client will prepare and execute at that point.
+* Expose various cluster attributes with getters.
+
+Bug Fixes:
+* [RUBY-235](https://datastax-oss.atlassian.net/browse/RUBY-235) execution_info.retries resets retry count when switching hosts.
+* [RUBY-255](https://datastax-oss.atlassian.net/browse/RUBY-255) ControlConnection.peer_ip ignores peers that are missing critical information in system.peers.
+* [RUBY-264](https://datastax-oss.atlassian.net/browse/RUBY-264) Table erroneously reported as using compact storage.
+
+# 3.0.3
+
+Bug Fixes:
+* [RUBY-241](https://datastax-oss.atlassian.net/browse/RUBY-241) Materialied views sometimes have nil ref to base-table.
+
+# 3.0.2
+
+Bug Fixes:
+* [RUBY-219](https://datastax-oss.atlassian.net/browse/RUBY-219) Sometimes get stack trace in metadata.rb due to failure in SortedSet initialization.
+* [RUBY-220](https://datastax-oss.atlassian.net/browse/RUBY-220) Improve support for custom types.
+* [RUBY-231](https://datastax-oss.atlassian.net/browse/RUBY-231) Driver ignores explicitly specified nil timeout (to indicate no time limit on query execution).
+* [RUBY-233](https://datastax-oss.atlassian.net/browse/RUBY-233) Client timeout errors are retried for non-idempotent statements. 
+
+# 3.0.0 GA
+Features:
+* Increased default request timeout (the `timeout` option to `Cassandra.cluster`), from 10 seconds to 12 seconds 
+  because C* defaults to a 10 second timeout internally. The extra two seconds is buffer so that the client can
+  report the timeout in the server. This is also consistent with the Java driver.
+* Expand :client_timestamps cluster configuration option to allow user to specify his own generator for client timestamps.
+
+Bug Fixes:
+* [RUBY-207](https://datastax-oss.atlassian.net/browse/RUBY-207) Get NoMethodError when handling a write-timeout error using a downgrading consistency retry policy.
+* [RUBY-214](https://datastax-oss.atlassian.net/browse/RUBY-214) Client timestamps in JRuby are not fine-grained enough, causing timestamp collisions and lost rows in C*.
 
 Breaking Changes:
+* The Datacenter-aware load balancing policy (Cassandra::LoadBalancing::Policies::DCAwareRoundRobin) defaults to using
+  nodes in the local DC only. In prior releases, the policy would fall back to remote nodes after exhausting local nodes.
+  Specify a positive value (or nil for unlimited) for `max_remote_hosts_to_use` when initializing the policy to allow remote node use. 
+
+# 3.0.0 rc2
+Features:
+* Add protocol_version configuration option to allow the user to force the protocol version to use for communication with nodes.
+* Expose listen_address and broadcast_address in `Cassandra::Host` if available.
+* Add support for materialized views in the schema metadata.
+* Add support for Cassandra indexes in the schema metadata.
+* Add or expose the id, options, keyspace, partition_key, clustering_columns, and clustering_order attributes to table and view schema objects.
+* Add crc_check_chance and extensions attributes to ColumnContainer options.
+* Make cluster configuration options list publicly available. (Thanks, Evan Prothro!)
+
+Bug Fixes:
+* [RUBY-161](https://datastax-oss.atlassian.net/browse/RUBY-161) Protocol version negotiation in mixed version clusters should not fall back to v1 unless it is truly warranted.    
+* [RUBY-180](https://datastax-oss.atlassian.net/browse/RUBY-180) Column ordering is not deterministic in Table metadata.
+* [RUBY-185](https://datastax-oss.atlassian.net/browse/RUBY-185) Internal columns in static-compact and dense tables should be ignored.
+* [RUBY-186](https://datastax-oss.atlassian.net/browse/RUBY-186) Custom type column metadata should be parsed properly for C* 3.x schemas. 
 
 # 3.0.0 rc1
 
@@ -13,9 +84,9 @@ Features:
 * Add Cassandra::Logger class to make it easy for users to enable debug logging in the client.
 
 Bug Fixes:
-* [RUBY-154] Improve batch request performance, which had regressed in 3.0.0 beta1.
-* [RUBY-155] Request timeout timer should not include request queuing time.
-* [RUBY-156] Do not drop response frames that follow a frame containing a warning.
+* [RUBY-154](https://datastax-oss.atlassian.net/browse/RUBY-154) Improve batch request performance, which had regressed in 3.0.0 beta1.
+* [RUBY-155](https://datastax-oss.atlassian.net/browse/RUBY-155) Request timeout timer should not include request queuing time.
+* [RUBY-156](https://datastax-oss.atlassian.net/browse/RUBY-156) Do not drop response frames that follow a frame containing a warning.
 
 # 3.0.0 beta1
 
@@ -35,10 +106,10 @@ Features:
 
 Bug Fixes:
 
-* [RUBY-143] Retry querying system table for metadata of new hosts when prior attempts fail, ultimately enabling use of new hosts.
-* [RUBY-150] Fixed a protocol decoding error that occurred when multiple messages are available in a stream.
-* [RUBY-151] Decode incomplete UDTs properly.
-* [RUBY-120] Tuples and UDTs can be used in sets and hash keys.
+* [RUBY-143](https://datastax-oss.atlassian.net/browse/RUBY-143) Retry querying system table for metadata of new hosts when prior attempts fail, ultimately enabling use of new hosts.
+* [RUBY-150](https://datastax-oss.atlassian.net/browse/RUBY-150) Fixed a protocol decoding error that occurred when multiple messages are available in a stream.
+* [RUBY-151](https://datastax-oss.atlassian.net/browse/RUBY-151) Decode incomplete UDTs properly.
+* [RUBY-120](https://datastax-oss.atlassian.net/browse/RUBY-120) Tuples and UDTs can be used in sets and hash keys.
 
 Breaking Changes:
 
@@ -48,6 +119,16 @@ Breaking Changes:
 * Unavailable errors are retried on the next host in the load balancing plan by default.
 * Statement execution no longer retried on timeouts, unless `:idempotent => true` has been specified when executing.
 
+# 2.1.7
+Bug Fixes:
+* [RUBY-255](https://datastax-oss.atlassian.net/browse/RUBY-255) ControlConnection.peer_ip ignores peers that are missing critical information in system.peers.
+
+# 2.1.6
+Bug Fixes:
+
+* [RUBY-202](https://datastax-oss.atlassian.net/browse/RUBY-202) Allow password authenticator to be used for LDAP authentication. This is actually a backport of
+     RUBY-169 for the 3.0.0 release.
+
 # 2.1.5
 
 Features:
@@ -56,25 +137,25 @@ Features:
 
 Bug Fixes:
 
-* [RUBY-128] Fix decoding of large values in maps, sets and lists.
+* [RUBY-128](https://datastax-oss.atlassian.net/browse/RUBY-128) Fix decoding of large values in maps, sets and lists.
 
 # 2.1.4
 
 Features:
 
-* [RUBY-119] Use `require 'datastax/cassandra'` to avoid namespace conflicts
-* [RUBY-90] Add support for disabling nagle algorithm (tcp nodelay), enabled by default.
-* [RUBY-70] Add support for client-side timestamps, disabled by default.
-* [RUBY-114] Add support for serial consistency in batch requests.
+* [RUBY-90](https://datastax-oss.atlassian.net/browse/RUBY-90) Add support for disabling nagle algorithm (tcp nodelay), enabled by default.
+* [RUBY-70](https://datastax-oss.atlassian.net/browse/RUBY-70) Add support for client-side timestamps, disabled by default.
+* [RUBY-114](https://datastax-oss.atlassian.net/browse/RUBY-114) Add support for serial consistency in batch requests.
 
 Bug Fixes:
 
-* [RUBY-103] Don't regenerate schema metadata for the same replication
+* [RUBY-103](https://datastax-oss.atlassian.net/browse/RUBY-103) Don't regenerate schema metadata for the same replication
   strategies and options
-* [RUBY-102] Allow custom types in schema metadata
-* [RUBY-97] Allow disabling of the initial population of schema metadata
-* [RUBY-95] Speed up generation of large token maps
-* [RUBY-116] fix thread leak on connection error
+* [RUBY-102](https://datastax-oss.atlassian.net/browse/RUBY-102) Allow custom types in schema metadata
+* [RUBY-97](https://datastax-oss.atlassian.net/browse/RUBY-97) Allow disabling of the initial population of schema metadata
+* [RUBY-95](https://datastax-oss.atlassian.net/browse/RUBY-95) Speed up generation of large token maps
+* [RUBY-116](https://datastax-oss.atlassian.net/browse/RUBY-116) fix thread leak on connection error
+* [RUBY-119](https://datastax-oss.atlassian.net/browse/RUBY-119) Use `require 'datastax/cassandra'` to avoid namespace conflicts
 
 Breaking Changes:
 
@@ -93,7 +174,7 @@ Release removing accidental debug code from 2.1.1.
 
 Bug Fixes:
 
-* [RUBY-98] Use of undefined class variable in `Table#create_partition_key`
+* [RUBY-98](https://datastax-oss.atlassian.net/browse/RUBY-98) Use of undefined class variable in `Table#create_partition_key`
 
 # 2.1.0
 
@@ -111,13 +192,13 @@ Breaking Changes:
 
 Bug Fixes:
 
-* [RUBY-93] Reconnection can overflow the stack
+* [RUBY-93](https://datastax-oss.atlassian.net/browse/RUBY-93) Reconnection can overflow the stack
 
 # 2.0.1
 
 Bug Fixes:
 
-* [RUBY-87] Decoder corrupts incomplete response buffer
+* [RUBY-87](https://datastax-oss.atlassian.net/browse/RUBY-87) Decoder corrupts incomplete response buffer
 
 # 2.0.0
 

CONTRIBUTING.md

@@ -5,18 +5,30 @@
 All code has bugs, but if you report them they can be squashed.
 
 The best bug reports include everything that is needed to reliably reproduce the bug.
+
+### Running the Test Suite
+
 Try to write a test case and include it in your report (have a look at the
-[regression test suite](spec/integration/regression_spec.rb) if you need inspiration).
-Submit defect reports to our [Jira](https://datastax-oss.atlassian.net/projects/RUBY/issues).
+[regression test suite](spec/regressions) if you need inspiration).
+
+1. Bundle with `bundle install`
+1. Run the unit test suite with `rake rspec`
+  * Using this rake task will install necessary ruby extensions as a prerequisite
+  * For `bundle exec rspec` to be successful, run `bundle exec rake compile` once, beforehand
 
 If it's not possible to write a test case, for example because the bug only happens in
-very particular circumstances, or is not deterministic, make sure you include as much
-information as you can about the situation. The version of the ruby driver is an absolute
-must, the version of Ruby and Cassandra are also very important. If there is a stack trace
-from the error make sure to include that (unfortunately the asynchronous nature of the
-ruby driver means that the stack traces are not always as revealing as they could be).
+very particular circumstances, or is not deterministic, please still report the bug!
+
+### Opening a ticket
+
+Submit defect reports to our [Jira](https://datastax-oss.atlassian.net/projects/RUBY/issues). Include:
+
+* The `cassandra-driver` version (`bundle show cassandra-driver | sed 's/.*\///'`)
+* The Ruby version (`ruby -v`)
+* The Cassandra version (2nd line printed when running `cqlsh`)
+* A stack trace from the error, if there is one
 
-##Pull Requests
+## Pull Requests
 
 If you're able to fix a bug yourself, you can
 [fork the repository](https://help.github.com/articles/fork-a-repo/) and submit a

Gemfile

@@ -2,10 +2,10 @@ source 'https://rubygems.org/'
 
 gemspec
 
-gem 'snappy',        :group => [:development, :test]
-gem 'lz4-ruby',      :group => [:development, :test]
-gem 'rake-compiler', :group => [:development, :test]
-gem 'cliver',        :group => [:development, :test]
+gem 'snappy',        group: [:development, :test]
+gem 'lz4-ruby',      group: [:development, :test]
+gem 'rake-compiler', group: [:development, :test]
+gem 'cliver',        group: [:development, :test]
 
 group :development do
   platforms :mri_19 do

Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    cassandra-driver (3.0.0.rc.1)
+    cassandra-driver (3.2.1.rc.1)
       ione (~> 1.2)
 
 GEM
@@ -40,9 +40,9 @@ GEM
     ffi (1.9.10)
     ffi (1.9.10-java)
     gherkin (3.2.0)
-    ione (1.2.3)
-    json (1.8.3)
-    json (1.8.3-java)
+    ione (1.2.4)
+    json (1.8.6)
+    json (1.8.6-java)
     lz4-ruby (0.3.3)
     lz4-ruby (0.3.3-java)
     minitest (4.7.5)
@@ -121,4 +121,4 @@ DEPENDENCIES
   yard
 
 BUNDLED WITH
-   1.11.2
+   1.14.6

LICENSE

@@ -1,4 +1,4 @@
-Copyright 2013-2016 DataStax, Inc.
+Copyright 2013-2017 DataStax, Inc.
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.