Sha256: d51536d7f6ed4b32e4027539916836ad72d707088848e790e89d9cb5d8f61a22
Contents?: true
Size: 1.61 KB
Versions: 35
Compression:
Stored size: 1.61 KB
Contents
module CassandraObject
module Associations
extend ActiveSupport::Concern
extend ActiveSupport::Autoload
# TODO: is this the convention?
include ActiveRecord::Reflection
include ActiveRecord::Associations
include ActiveRecord::AutosaveAssociation
autoload :OneToMany
autoload :OneToOne
included do
class_inheritable_hash :associations
end
module ClassMethods
def relationships_column_family=(column_family)
@relationships_column_family = column_family
end
def relationships_column_family
@relationships_column_family || "#{name}Relationships"
end
def column_family_configuration
super << {:Name=>relationships_column_family, :CompareWith=>"UTF8Type", :CompareSubcolumnsWith=>"TimeUUIDType", :ColumnType=>"Super"}
end
def association(association_name, options= {})
if options[:unique]
write_inheritable_hash(:associations, {association_name => OneToOne.new(association_name, self, options)})
else
write_inheritable_hash(:associations, {association_name => OneToMany.new(association_name, self, options)})
end
end
def remove(key)
begin
ActiveSupport::Notifications.instrument("remove.cassandra_object", column_family: relationships_column_family, key: key) do
connection.remove(relationships_column_family, key.to_s, consistency: thrift_write_consistency)
end
rescue Cassandra::AccessError => e
raise e unless e.message =~ /Invalid column family/
end
super
end
end
end
end
Version data entries
35 entries across 35 versions & 1 rubygems