Changeset 2905
- Timestamp:
- Jan 4, 2005, 6:31:59 PM (22 years ago)
- Location:
- trunk
- Files:
-
- 2 edited
-
Nebulous-Server/lib/Nebulous/Server.pm (modified) (14 diffs)
-
Nebulous/lib/Nebulous/Server.pm (modified) (14 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/Nebulous-Server/lib/Nebulous/Server.pm
r2904 r2905 1 1 # Copyright (c) 2004 Joshua Hoblitt 2 2 # 3 # $Id: Server.pm,v 1. 7 2005-01-05 04:04:45jhoblitt Exp $3 # $Id: Server.pm,v 1.8 2005-01-05 04:31:59 jhoblitt Exp $ 4 4 5 5 package PS::IPP::IData::Server; … … 128 128 $query->execute; 129 129 ( $ins_id ) = $query->fetchrow_array; 130 131 $query->finish; 130 132 } 131 133 }; … … 194 196 195 197 unless ( $rows > 0 ) { 198 $query->finish; 196 199 $db->rollback; 197 200 $log->logdie( "storage object does not exist" ); … … 199 202 200 203 $so_id = $query->fetchrow_hashref->{ 'so_id' }; 204 $query->finish; 201 205 } 202 206 … … 211 215 212 216 ( $ins_id ) = $query->fetchrow_array; 217 218 $query->finish; 213 219 } 214 220 … … 263 269 my $read_lock; 264 270 my $write_lock; 271 my $query; 265 272 266 273 eval { 267 274 # this will set update locks 268 my$query = $db->prepare_cached( $sql->get_object_locks );275 $query = $db->prepare_cached( $sql->get_object_locks ); 269 276 my $rows = $query->execute( $key ); 270 277 unless ( $rows == 1 ) { … … 273 280 274 281 my $row = $query->fetchrow_hashref; 282 $query->finish; 275 283 276 284 $so_id = $row->{ 'so_id' }; … … 279 287 }; 280 288 if ( $@ ) { 289 $query->finish; 281 290 $db->rollback; 282 291 $log->logdie( "database error: $@" ); … … 375 384 my $read_lock; 376 385 my $write_lock; 386 my $query; 377 387 378 388 eval { 379 389 # this will set update locks 380 my$query = $db->prepare_cached( $sql->get_object_locks );390 $query = $db->prepare_cached( $sql->get_object_locks ); 381 391 my $rows = $query->execute( $key ); 382 392 unless ( $rows == 1 ) { … … 385 395 386 396 my $row = $query->fetchrow_hashref; 397 $query->finish; 387 398 388 399 $so_id = $row->{ 'so_id' }; … … 391 402 }; 392 403 if ( $@ ) { 404 $query->finish; 393 405 $db->rollback; 394 406 $log->logdie( "database error: $@" ); … … 538 550 539 551 $so_id = $query->fetchrow_hashref->{ 'so_id' }; 552 $query->finish; 540 553 } 541 554 … … 545 558 546 559 $instances = $query->fetchrow_hashref->{ 'count(ins_id)' }; 560 $query->finish; 547 561 } 548 562 … … 604 618 605 619 $stat = $query->fetchrow_arrayref; 620 $query->finish; 606 621 607 622 $db->commit; -
trunk/Nebulous/lib/Nebulous/Server.pm
r2904 r2905 1 1 # Copyright (c) 2004 Joshua Hoblitt 2 2 # 3 # $Id: Server.pm,v 1. 7 2005-01-05 04:04:45jhoblitt Exp $3 # $Id: Server.pm,v 1.8 2005-01-05 04:31:59 jhoblitt Exp $ 4 4 5 5 package PS::IPP::IData::Server; … … 128 128 $query->execute; 129 129 ( $ins_id ) = $query->fetchrow_array; 130 131 $query->finish; 130 132 } 131 133 }; … … 194 196 195 197 unless ( $rows > 0 ) { 198 $query->finish; 196 199 $db->rollback; 197 200 $log->logdie( "storage object does not exist" ); … … 199 202 200 203 $so_id = $query->fetchrow_hashref->{ 'so_id' }; 204 $query->finish; 201 205 } 202 206 … … 211 215 212 216 ( $ins_id ) = $query->fetchrow_array; 217 218 $query->finish; 213 219 } 214 220 … … 263 269 my $read_lock; 264 270 my $write_lock; 271 my $query; 265 272 266 273 eval { 267 274 # this will set update locks 268 my$query = $db->prepare_cached( $sql->get_object_locks );275 $query = $db->prepare_cached( $sql->get_object_locks ); 269 276 my $rows = $query->execute( $key ); 270 277 unless ( $rows == 1 ) { … … 273 280 274 281 my $row = $query->fetchrow_hashref; 282 $query->finish; 275 283 276 284 $so_id = $row->{ 'so_id' }; … … 279 287 }; 280 288 if ( $@ ) { 289 $query->finish; 281 290 $db->rollback; 282 291 $log->logdie( "database error: $@" ); … … 375 384 my $read_lock; 376 385 my $write_lock; 386 my $query; 377 387 378 388 eval { 379 389 # this will set update locks 380 my$query = $db->prepare_cached( $sql->get_object_locks );390 $query = $db->prepare_cached( $sql->get_object_locks ); 381 391 my $rows = $query->execute( $key ); 382 392 unless ( $rows == 1 ) { … … 385 395 386 396 my $row = $query->fetchrow_hashref; 397 $query->finish; 387 398 388 399 $so_id = $row->{ 'so_id' }; … … 391 402 }; 392 403 if ( $@ ) { 404 $query->finish; 393 405 $db->rollback; 394 406 $log->logdie( "database error: $@" ); … … 538 550 539 551 $so_id = $query->fetchrow_hashref->{ 'so_id' }; 552 $query->finish; 540 553 } 541 554 … … 545 558 546 559 $instances = $query->fetchrow_hashref->{ 'count(ins_id)' }; 560 $query->finish; 547 561 } 548 562 … … 604 618 605 619 $stat = $query->fetchrow_arrayref; 620 $query->finish; 606 621 607 622 $db->commit;
Note:
See TracChangeset
for help on using the changeset viewer.
