From 94a6784508637823f6a1a2aa7f8bb34f0d5982b6 Mon Sep 17 00:00:00 2001
From: erickson <erickson@dcc99617-32d9-48b4-a31d-7c20da2025e4>
Date: Mon, 10 May 2010 22:26:20 +0000
Subject: [PATCH] pcrud requires transaction begin/commit for writes...

git-svn-id: svn://svn.open-ils.org/ILS/trunk@16415 dcc99617-32d9-48b4-a31d-7c20da2025e4
---
 Open-ILS/src/support-scripts/marc_stream_importer.pl | 16 +++++++++++-----
 1 file changed, 11 insertions(+), 5 deletions(-)

diff --git a/Open-ILS/src/support-scripts/marc_stream_importer.pl b/Open-ILS/src/support-scripts/marc_stream_importer.pl
index ad8d408e8d..d7a0687a9e 100755
--- a/Open-ILS/src/support-scripts/marc_stream_importer.pl
+++ b/Open-ILS/src/support-scripts/marc_stream_importer.pl
@@ -272,19 +272,25 @@ sub bib_queue_import {
     }
 
     # clean up the successfully imported vandelay records to prevent queue bloat
+    my $pcrud = OpenSRF::AppSession->create('open-ils.pcrud');
+    $pcrud->connect;
+    $pcrud->request('open-ils.pcrud.transaction.begin', $authtoken);
+    my $err;
+
     foreach (@cleanup_recs) {
 
         try { 
-            $apputils->simplereq(
-                'open-ils.pcrud',
-                'open-ils.pcrud.delete.vqbr',
-                $authtoken, $_);
+
+            $pcrud->request('open-ils.pcrud.delete.vqbr', $authtoken, $_);
 
         } catch Error with {
-            my $err = shift;
+            $err = shift;
             $logger->error("Error deleteing queued bib record $_: $err");
         };
     }
+
+    $pcrud->request('open-ils.pcrud.transaction.commit', $authtoken) unless $err;
+    $pcrud->disconnect;
 }
 
 sub process_batch_data {
-- 
2.11.0