Changeset 304

Timestamp:

05/20/06 11:07:13 (6 years ago)

Author:

dom

Message:

Check for the schema version before trying to use the database (closes #5)

Location:

wiki-toolkit/trunk

Files:

• Changes (modified) (1 diff)
• MANIFEST (modified) (1 diff)
• lib/Wiki/Toolkit/Store/Database.pm (modified) (3 diffs)
• t/026_schema_current.t (added)

wiki-toolkit/trunk/Changes

@@ -1 +1 @@
 0.69_04
         Feed code being refactored.
+        Check that the database schema is up-to-date when initializing the
+        store and abort otherwise.
 
 0.69_03 13 May 2006

wiki-toolkit/trunk/MANIFEST

@@ -57 +57 @@
 t/022_list_unmoderated.t
 t/025_list_node_all_versions.t
+t/026_schema_current.t
 t/040_rename.t
 t/050_mysql_store.t

wiki-toolkit/trunk/lib/Wiki/Toolkit/Store/Database.pm

@@ -13 +13 @@
 
 $VERSION = '0.27';
+my $SCHEMA_VER = 9;
 
 # first, detect if Encode is available - it's not under 5.6. If we _are_
@@ -113 +114 @@
           or croak "Can't connect to database $dbname using $dsn: "
                    . DBI->errstr;
+    }
+
+    my ($cur_ver, $db_ver) = $self->schema_current;
+    if ($db_ver < $cur_ver) {
+        croak "Database schema version $db_ver is too old (need $cur_ver)";
+    } elsif ($db_ver > $cur_ver) {
+        croak "Database schema version $db_ver is too new (need $cur_ver)";
     }
 
@@ -1648 +1656 @@
 }
 
+=item B<schema_current>
+
+  my ($code_version, $db_version) = $store->schema_current;
+  if ($code_version == $db_version)
+      # Do stuff
+  } else {
+      # Bail
+  }
+
+=cut
+
+sub schema_current {
+    my $self = shift;
+    my $dbh = $self->dbh;
+    my $sth;
+    eval { $sth = $dbh->prepare("SELECT version FROM schema_info") };
+    if ($@) {
+        return ($SCHEMA_VER, 0);
+    }
+    eval { $sth->execute };
+    if ($@) {
+        return ($SCHEMA_VER, 0);
+    }
+    my $version;
+    eval { $version = $sth->fetchrow_array };
+    if ($@) {
+        return ($SCHEMA_VER, 0);
+    } else {
+        return ($SCHEMA_VER, $version);
+    }
+}
+
+
 =item B<dbh>