Changeset 29

Timestamp:

04/23/09 02:54:47 (15 years ago)

Author:

nanardon

Message:

• fix Sql driver

Location:

LATMOS-Accounts/lib/LATMOS/Accounts/Bases

Files:

• Sql (copied) (copied from LATMOS-Accounts/lib/LATMOS/Accounts/Bases/SQL)
• Sql.pm (copied) (copied from LATMOS-Accounts/lib/LATMOS/Accounts/Bases/SQL.pm) (1 diff)
• Sql/Group.pm (modified) (3 diffs)
• Sql/User.pm (modified) (3 diffs)
• Sql/objects.pm (moved) (moved from LATMOS-Accounts/lib/LATMOS/Accounts/Bases/SQL/object.pm) (5 diffs)

LATMOS-Accounts/lib/LATMOS/Accounts/Bases/Sql.pm

@@ -1 @@
-package LATMOS::Accounts::Bases::SQL;
+package LATMOS::Accounts::Bases::Sql;
 
 use 5.010000;

LATMOS-Accounts/lib/LATMOS/Accounts/Bases/Sql/Group.pm

@@ -1 @@
-package LATMOS::Accounts::Bases::SQL::User;
+package LATMOS::Accounts::Bases::Sql::Group;
 
 use 5.010000;
@@ -5 +5 @@
 use warnings;
 
-use base qw(LATMOS::Accounts::Bases::SQL::objects);
+use base qw(LATMOS::Accounts::Bases::Sql::objects);
 
 our $VERSION = (q$Rev$ =~ /^Rev: (\d+) /)[0];
@@ -39 +39 @@
 sub object_table { 'group' }
 
+sub key_field { 'groupname' }
+
 1;
 

LATMOS-Accounts/lib/LATMOS/Accounts/Bases/Sql/User.pm

@@ -1 @@
-package LATMOS::Accounts::Bases::SQL::User;
+package LATMOS::Accounts::Bases::Sql::User;
 
 use 5.010000;
@@ -5 +5 @@
 use warnings;
 
-use base qw(LATMOS::Accounts::Bases::SQL::objects);
+use base qw(LATMOS::Accounts::Bases::Sql::objects);
 
 our $VERSION = (q$Rev$ =~ /^Rev: (\d+) /)[0];
@@ -39 +39 @@
 sub object_table { 'person' }
 
+sub key_field { 'login' }
+
 1;
 

LATMOS-Accounts/lib/LATMOS/Accounts/Bases/Sql/objects.pm

@@ -1 @@
-package LATMOS::Accounts::Bases::SQL::object;
+package LATMOS::Accounts::Bases::Sql::objects;
 
 use 5.010000;
@@ -37 +37 @@
 =cut
 
+sub list {
+    my ($class, $base) = @_;
+
+    my $sth = $base->db->prepare_cached(
+        sprintf(
+            q{select %s as k from %s order by %s},
+            $base->db->quote_identifier($class->key_field),
+            $base->db->quote_identifier($class->object_table),
+            $base->db->quote_identifier($class->key_field),
+        )
+    );
+    $sth->execute;
+    my @keys;
+    while(my $res = $sth->fetchrow_hashref) {
+        push(@keys, $res->{k});
+    }
+    @keys
+}
+
 sub new {
     my ($class, $base, $id) = @_;
@@ -51 +70 @@
     $self->db->quote_identifier($table);
 }
+sub quote_key_field { 
+    my ($self) = @_;
+    my $key_field = $self->key_field or return;
+    $self->db->quote_identifier($key_field);
+}
 
 sub get_field {
@@ -56 +80 @@
     my $sth = $self->db->prepare_cached(
         sprintf(
-            q{select %s from %s where login = ?},
+            q{select %s from %s where %s = ?},
             $self->db->quote_identifier($field),
             $self->quote_object_table,
+            $self->quote_key_field,
         )
     );
@@ -79 +104 @@
         sprintf(
             q{update %s set %s where login = ?},
-            $self->quote_object_table),
+            $self->quote_object_table,
             join(', ', @fields),
         )