Contents

require 'cassandra_object/associations/one_to_many'
require 'cassandra_object/associations/one_to_one'

module CassandraObject
  module Associations
    extend ActiveSupport::Concern
    
    included do
      class_inheritable_hash :associations
    end

    module ClassMethods
      def column_family_configuration
        super << {:Name=>"#{name}Relationships", :CompareWith=>"UTF8Type", :CompareSubcolumnsWith=>"TimeUUIDType", :ColumnType=>"Super"}
      end
      
      def association(association_name, options= {})
        if options[:unique]
          write_inheritable_hash(:associations, {association_name => OneToOneAssociation.new(association_name, self, options)})
        else
          write_inheritable_hash(:associations, {association_name => OneToManyAssociation.new(association_name, self, options)})
        end
      end
      
      def remove(key)
        begin
          ActiveSupport::Notifications.instrument("remove.cassandra_object", :key => key) do
            connection.remove("#{name}Relationships", key.to_s, :consistency => write_consistency_for_thrift)
          end
        rescue Cassandra::AccessError => e
          raise e unless e.message =~ /Invalid column family/
        end
        super
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
gotime-cassandra_object-0.8.2	lib/cassandra_object/associations.rb
gotime-cassandra_object-0.8.1	lib/cassandra_object/associations.rb
gotime-cassandra_object-0.8.0	lib/cassandra_object/associations.rb
gotime-cassandra_object-0.7.8	lib/cassandra_object/associations.rb
gotime-cassandra_object-0.7.7	lib/cassandra_object/associations.rb
gotime-cassandra_object-0.7.6	lib/cassandra_object/associations.rb
gotime-cassandra_object-0.7.5	lib/cassandra_object/associations.rb
gotime-cassandra_object-0.7.4	lib/cassandra_object/associations.rb
gotime-cassandra_object-0.7.3	lib/cassandra_object/associations.rb