git.rot13.org Git - Fuse-DBI/blob - t/02sqlite.t

   1 #!/usr/bin/perl -w
   2
   3 use strict;
   4 use warnings;
   5
   6 use Test::More;
   7 use File::Find;
   8 use blib;
   9
  10 eval "use DBD::SQLite";
  11 plan skip_all => "DBD::SQLite required for testing" if $@;
  12 plan tests => 50;
  13
  14 use_ok('DBI');
  15 use_ok('Fuse::DBI');
  16
  17 my $test_db = 'fusedbi.db';
  18 my $dsn = "DBI:SQLite:dbname=$test_db";
  19 my $mount = '/tmp/fuse_dbi_mnt';
  20
  21 ok((! -e $test_db || unlink $test_db), "test db: $test_db");
  22
  23 ok((! -e $mount || rmdir $mount), "mount point $mount");
  24
  25 mkdir $mount || die "mkdir $mount: $!";
  26 ok(-d $mount, "mkdir $mount");
  27
  28 ok(my $dbh = DBI->connect($dsn, , '', '', { RaiseError => 1 }),
  29         "connect fusedbi test database");
  30
  31 ok($dbh->do(qq{
  32         create table files (
  33                 name text primary key,
  34                 data text
  35         )
  36 }), "create table files");
  37
  38 ok(my $sth_insert = $dbh->prepare(qq{
  39         insert into files (name,data) values (?,?)
  40 }), "prepare insert");
  41
  42 ok(my $sth_select = $dbh->prepare(qq{
  43         select data from files where name = ?
  44 }), "prepare select");
  45
  46 my @files = qw(file dir/file dir/subdir/file);
  47 my %file_data;
  48
  49 foreach my $file (@files) {
  50         $file_data{$file} = ("this is test data on ".localtime()."\n") x length($file);
  51         ok($sth_insert->execute($file,$file_data{$file}), "insert $file");
  52 }
  53
  54 my $sql_filenames = qq{
  55         select
  56                 name as id,
  57                 name as filename,
  58                 length(data) as size,
  59                 1 as writable
  60         from files
  61 };
  62
  63 my $sql_read = qq{
  64         select data
  65                 from files
  66                 where name = ?;
  67 };
  68
  69 my $sql_update = qq{
  70         update files
  71                 set data = ?
  72                 where name = ?;
  73 };
  74
  75 system "fusermount -q -u $mount" || diag "nothing mounted at $mount, ok";
  76
  77 my $mnt = Fuse::DBI->mount({
  78         filenames => $sql_filenames,
  79         read => $sql_read,
  80         update => $sql_update,
  81         dsn => $dsn,
  82         mount => $mount,
  83         fork => 1,
  84 });
  85
  86 ok($mnt, "mount");
  87
  88 sub test_file {
  89         my $f = $File::Find::name;
  90
  91         ok($f, "file $f");
  92
  93         return unless (-f $f);
  94
  95         ok(open(F, $f), "open read $f");
  96         my $tmp = '';
  97         while(<F>) {
  98                 $tmp .= $_;
  99         }
 100         ok(close(F), "close");
 101
 102         # strip mountpoint
 103         $f =~ s#^\Q$mount\E/##;
 104
 105         ok($file_data{$f}, "$f exists");
 106
 107         cmp_ok(length($file_data{$f}), '==', length($tmp), "size");
 108         cmp_ok($file_data{$f}, 'eq', $tmp, "content");
 109
 110         $tmp =~ tr/a-z/A-Z/;
 111         $tmp .= $f;
 112
 113         ok(open(F, "> $mount/$f"), "open write $mount/$f");
 114         print F $tmp;
 115         ok(close(F), "close");
 116
 117         ok($sth_select->execute($f), "select $f");
 118         cmp_ok($sth_select->fetchrow_array(), 'eq', $tmp, "updated content");
 119 }
 120
 121 # small delay so that filesystem could mount
 122 sleep(1);
 123
 124 find({ wanted => \&test_file, no_chdir => 1 }, $mount);
 125
 126 ok($mnt->umount,"umount");
 127
 128 undef $sth_select;
 129 undef $sth_insert;
 130
 131 ok($dbh->disconnect, "disconnect");
 132
 133 ok(unlink $test_db,"rm $test_db");
 134
 135 ok(!-e $test_db,"cleanup");
 136