Changeset 13071

Timestamp:

Apr 27, 2007, 2:44:58 PM (19 years ago)

Author:

jhoblitt

Message:

add Nebulous::Server->rename_object()

Location:

trunk

Files:

• Nebulous-Server/Changes (modified) (1 diff)
• Nebulous-Server/MANIFEST (modified) (1 diff)
• Nebulous-Server/lib/Nebulous/Server.pm (modified) (2 diffs)
• Nebulous-Server/lib/Nebulous/Server/SQL.pm (modified) (2 diffs)
• Nebulous-Server/t/13_server_rename_object.t (added)
• Nebulous/Changes (modified) (1 diff)
• Nebulous/MANIFEST (modified) (1 diff)
• Nebulous/lib/Nebulous/Server.pm (modified) (2 diffs)
• Nebulous/lib/Nebulous/Server/SQL.pm (modified) (2 diffs)
• Nebulous/t/13_server_rename_object.t (added)

trunk/Nebulous-Server/Changes

@@ -2 +2 @@
 
 0.05
+    - add Nebulous::Server->rename_object()
     - add neb-rm
     - add neb-cp

trunk/Nebulous-Server/MANIFEST

@@ -88 +88 @@
 t/11_server_is_valid_class_id.t
 t/12_server_find_objects.t
+t/13_server_rename_object.t
 t/50_client_new.t
 t/51_client_create.t

trunk/Nebulous-Server/lib/Nebulous/Server.pm

@@ -1 +1 @@
 # Copyright (c) 2004  Joshua Hoblitt
 #
-# $Id: Server.pm,v 1.25 2007-04-26 23:45:03 jhoblitt Exp $
+# $Id: Server.pm,v 1.26 2007-04-28 00:44:38 jhoblitt Exp $
 
 package Nebulous::Server;
@@ -236 +236 @@
 }
 
+sub rename_object {
+    my $self = shift;
+
+    my ( $key, $newkey ) = validate_pos( @_,
+        {
+            type        => SCALAR,
+        },
+        {
+            type        => SCALAR,
+        },
+    );
+
+    my $log = $self->log;
+    my $sql = $self->sql;
+    my $db  =$self->db;
+
+    $log->debug( "entered - @_" );
+
+    eval {
+        # rename storage_object
+        my $query = $db->prepare_cached($sql->rename_object); 
+        # this SQL statment takes the new key name as the first param
+        my $rows = $query->execute($newkey, $key);
+
+        # if we affected more then one row something very bad has happened.
+        unless ( $rows == 1 ) {
+            $log->logdie( "affected row count is $rows instead of 1" );
+        }
+    };
+    if ($@) {
+        $db->rollback;
+        $log->logdie( "database error: $@" );
+    }
+
+    eval { 
+        $db->commit;
+    };
+    if ( $@ ) {
+        $db->rollback;
+        $log->logdie( "database error: $@" );
+    }
+
+    $log->debug( "leaving" );
+
+    return $newkey;
+}
+
 sub replicate_object {
     my $self = shift;

trunk/Nebulous-Server/lib/Nebulous/Server/SQL.pm

@@ -1 +1 @@
 # Copyright (c) 2004  Joshua Hoblitt
 #
-# $Id: SQL.pm,v 1.27 2007-04-26 23:45:03 jhoblitt Exp $
+# $Id: SQL.pm,v 1.28 2007-04-28 00:44:38 jhoblitt Exp $
 
 package Nebulous::Server::SQL;
@@ -153 +153 @@
         FROM storage_object
         WHERE ext_id REGEXP ?
+    },
+    rename_object => qq{
+        UPDATE storage_object
+        SET ext_id = ?
+        WHERE ext_id = ?
     },
 );

trunk/Nebulous/Changes

@@ -2 +2 @@
 
 0.05
+    - add Nebulous::Server->rename_object()
     - add neb-rm
     - add neb-cp

trunk/Nebulous/MANIFEST

@@ -88 +88 @@
 t/11_server_is_valid_class_id.t
 t/12_server_find_objects.t
+t/13_server_rename_object.t
 t/50_client_new.t
 t/51_client_create.t

trunk/Nebulous/lib/Nebulous/Server.pm

@@ -1 +1 @@
 # Copyright (c) 2004  Joshua Hoblitt
 #
-# $Id: Server.pm,v 1.25 2007-04-26 23:45:03 jhoblitt Exp $
+# $Id: Server.pm,v 1.26 2007-04-28 00:44:38 jhoblitt Exp $
 
 package Nebulous::Server;
@@ -236 +236 @@
 }
 
+sub rename_object {
+    my $self = shift;
+
+    my ( $key, $newkey ) = validate_pos( @_,
+        {
+            type        => SCALAR,
+        },
+        {
+            type        => SCALAR,
+        },
+    );
+
+    my $log = $self->log;
+    my $sql = $self->sql;
+    my $db  =$self->db;
+
+    $log->debug( "entered - @_" );
+
+    eval {
+        # rename storage_object
+        my $query = $db->prepare_cached($sql->rename_object); 
+        # this SQL statment takes the new key name as the first param
+        my $rows = $query->execute($newkey, $key);
+
+        # if we affected more then one row something very bad has happened.
+        unless ( $rows == 1 ) {
+            $log->logdie( "affected row count is $rows instead of 1" );
+        }
+    };
+    if ($@) {
+        $db->rollback;
+        $log->logdie( "database error: $@" );
+    }
+
+    eval { 
+        $db->commit;
+    };
+    if ( $@ ) {
+        $db->rollback;
+        $log->logdie( "database error: $@" );
+    }
+
+    $log->debug( "leaving" );
+
+    return $newkey;
+}
+
 sub replicate_object {
     my $self = shift;

trunk/Nebulous/lib/Nebulous/Server/SQL.pm

@@ -1 +1 @@
 # Copyright (c) 2004  Joshua Hoblitt
 #
-# $Id: SQL.pm,v 1.27 2007-04-26 23:45:03 jhoblitt Exp $
+# $Id: SQL.pm,v 1.28 2007-04-28 00:44:38 jhoblitt Exp $
 
 package Nebulous::Server::SQL;
@@ -153 +153 @@
         FROM storage_object
         WHERE ext_id REGEXP ?
+    },
+    rename_object => qq{
+        UPDATE storage_object
+        SET ext_id = ?
+        WHERE ext_id = ?
     },
 );