1 package DBIx::Data::Collection::Set;
4 use Method::Signatures::Simple;
5 use Data::Perl::Stream::Array;
7 has _store => (is => 'ro', required => 1, init_arg => 'store');
9 has _class => (is => 'ro', predicate => '_has_class');
11 has _set_over => (is => 'ro', required => 1, init_arg => 'set_over');
13 ## member cache (all members)
15 has _member_cache => (
16 is => 'rw', lazy_build => 1,
17 predicate => '_member_cache_built',
20 method _build__member_cache {
21 my $stream = $self->_new_raw_stream;
23 while (my ($raw) = $stream->next) {
25 if (my ($obj) = $self->_key_cache_get_raw($raw)) {
26 $self->_merge($obj, $raw)
28 $self->_add_to_key_cache($self->_inflate($raw))
36 method _add_to_member_cache ($to_add) {
37 return unless $self->_member_cache_built;
38 push @{$self->_member_cache}, $to_add;
42 ## key cache - by primary/unique key
44 has _key_cache => (is => 'ro', default => sub { {} });
46 method _add_to_key_cache ($to_add) {
47 $self->_key_cache->{$self->_object_to_id($to_add)} = $to_add;
51 method _key_cache_has_raw ($raw) {
52 exists $self->_key_cache->{$self->_raw_to_id($raw)}
55 method _key_cache_has_object ($obj) {
56 exists $self->_key_cache->{$self->_object_to_id($obj)}
59 method _key_cache_get_raw ($raw) {
60 my $id = $self->_raw_to_id($raw);
61 exists $self->_key_cache->{$id}
62 ? ($self->_key_cache->{$id})
66 method _key_cache_get_object ($obj) {
67 $self->_key_cache_get_raw($self->_deflate($obj))
72 method _new_raw_stream {
73 $self->_store->new_select_command([])->execute;
76 ## thunking between the store representation and the set representation
78 # _inflate is raw data -> final repr
79 # _deflate is final repr -> raw data
80 # _merge takes final repr + raw data and updates the repr
81 # (this is used for pk-generated values and later lazy loading)
83 method _inflate ($raw) {
84 bless($raw, $self->_class) if $self->_has_class;
88 method _deflate ($obj) {
92 method _merge ($obj, $raw) {
93 @{$obj}{keys %$raw} = values %$raw;
99 method _raw_to_id ($raw) {
100 # XXX must escape this. or do something else.
101 join ';', map $raw->{$_}, @{$self->_set_over}
104 method _object_to_id ($obj) {
105 $self->_raw_to_id($self->_deflate($obj));
109 @{$self->_member_cache};
113 Data::Perl::Stream::Array->new(array => $self->_member_cache);
117 $self->_add_to_store($new);
118 $self->_add_to_caches($new);
122 method _add_to_store ($new) {
123 my $new_raw = $self->_deflate($new);
124 $self->_merge($new, $self->_store->new_insert_command($new_raw)->execute);
128 method _add_to_caches ($new) {
129 $self->_add_to_member_cache($new);
130 $self->_add_to_key_cache($new);