X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~yarrgweb/git?p=ypp-sc-tools.db-live.git;a=blobdiff_plain;f=yarrg%2FCommodsDatabase.pm;h=79744cede7254daabbb07cd0db1941d2e0b7eae2;hp=2ea674d6963e489647b779fb880b464931fc1684;hb=a86f9a86ac468875dd428c068315a2617e8e12ac;hpb=a9583fa8a29e889f435ee4d6cf3dc6a5979a6bd5

diff --git a/yarrg/CommodsDatabase.pm b/yarrg/CommodsDatabase.pm
index 2ea674d..79744ce 100644
--- a/yarrg/CommodsDatabase.pm
+++ b/yarrg/CommodsDatabase.pm
@@ -44,22 +44,39 @@ BEGIN {
     $VERSION     = 1.00;
     @ISA         = qw(Exporter);
     @EXPORT      = qw(&db_setocean &db_writer &db_connect $dbh
-		      &db_filename &db_doall &db_onconflict &db_setdatadir);
+		      &db_filename &db_doall &db_onconflict
+		      &dbr_filename &dbr_connect);
     %EXPORT_TAGS = ( );
 
     @EXPORT_OK   = qw();
 }
 
+sub dbr_filename ($$) {
+    my ($datadir,$oceanname) = @_;
+    return "$datadir/OCEAN-$oceanname.db";
+}
+sub dbr_connect ($$) {
+    my ($datadir,$ocean) = @_;
+    return connect_core(dbr_filename($datadir,$ocean));
+}
+
+sub connect_core ($) {
+    my ($fn)= @_;
+    my $h= DBI->connect("dbi:SQLite:$fn",'','',
+		       { AutoCommit=>0,
+			 RaiseError=>1, ShowErrorStatement=>1,
+			 unicode=>1 })
+	or die "$fn $DBI::errstr ?";
+    return $h;
+    # default timeout is 30s which is plenty
+}
+
 our $dbfn;
 our $dbh;
-our $datadir= '.';
 
-sub db_setdatadir ($) {
-    $datadir= $_[0];
-}
 sub db_setocean ($) {
     my ($oceanname) = @_;
-    $dbfn= "$datadir/OCEAN-$oceanname.db";
+    $dbfn= dbr_filename('.',$oceanname);
 }
 sub db_filename () {
     return $dbfn;
@@ -93,13 +110,7 @@ sub db_writer () {
 }
 
 sub db_connect () {
-    return if $dbh;
-    $dbh= DBI->connect("dbi:SQLite:$dbfn",'','',
-		       { AutoCommit=>0,
-			 RaiseError=>1, ShowErrorStatement=>1,
-			 unicode=>1 })
-	or die "$dbfn $DBI::errstr ?";
-    # default timeout is 30s which is plenty
+    $dbh= connect_core($dbfn);
 }
 
 sub db_doall ($) {