6 use OpenSRF::EX qw/:try/;
7 use OpenSRF::AppSession;
8 use OpenSRF::Application;
9 use OpenSRF::MultiSession;
10 use OpenSRF::Utils::SettingsClient;
11 use OpenILS::Application::Storage;
12 use OpenILS::Application::AppUtils;
13 use OpenILS::Utils::Fieldmapper;
14 use Digest::MD5 qw/md5_hex/;
15 use OpenSRF::Utils::JSON;
19 use Time::HiRes qw/time/;
22 use MARC::File::XML (BinaryEncoding => 'UTF-8');
25 MARC::Charset->ignore_errors(1);
28 my ($type, $config, $autoprimary) =
29 ('biblio.record_entry', '/openils/conf/opensrf_core.xml', 0);
33 'config=s' => \$config,
34 'autoprimary' => \$config,
38 OpenSRF::System->bootstrap_client( config_file => $config );
39 Fieldmapper->import(IDL => OpenSRF::Utils::SettingsClient->new->config_value("IDL"));
41 OpenILS::Application::Storage->use;
42 OpenILS::Application::Storage->initialize;
43 OpenILS::Application::Storage->child_init || die;
46 OpenILS::Application::Storage->autoprimary(1);
49 my $base = "open-ils.storage.direct.$type.batch.create";
51 OpenSRF::Application->method_lookup( "$base.start" )->run;
55 while ( my $rec = <> ) {
58 my $row = OpenSRF::Utils::JSON->JSON2perl($rec);
60 OpenSRF::Application->method_lookup( "$base.push" )->run($row);
64 print STDERR "\r$count\t". $count / (time - $starttime);
69 last if ($count > 10000);
72 #OpenSRF::Application->method_lookup( "$base.finish" )->run;