/[fuse_dbi]/fuse-couchdb/t/02sqlite.t
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /fuse-couchdb/t/02sqlite.t

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

trunk/t/02database.t revision 12 by dpavlin, Sun Aug 29 19:16:01 2004 UTC fuse-couchdb/t/02sqlite.t revision 68 by dpavlin, Fri Apr 24 23:43:18 2009 UTC
# Line 3  Line 3 
3  use strict;  use strict;
4  use warnings;  use warnings;
5    
6  use Test::More tests => 3;  use Test::More;
7    use File::Find;
8  use blib;  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');  use_ok('Fuse::DBI');
16    
17  my $sql_filenames = q{  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          select
56                  oid as id,                  name as id,
57                  namespace||'/'||name||' ['||oid||']' as filename,                  name as filename,
58                  length(template) as size,                  length(data) as size,
59                  iseditable as writable                  1 as writable
60          from template ;          from files
61  };  };
62    
63  my $sql_read = q{  my $sql_read = qq{
64          select template          select data
65                  from template                  from files
66                  where oid = ?;                  where name = ?;
67  };  };
68    
69  my $sql_update = q{  my $sql_update = qq{
70          update template          update files
71                  set template = ?                          set data = ?    
72                  where oid = ?;                  where name = ?;
73  };  };
74    
75    system "fusermount -q -u $mount" || diag "nothing mounted at $mount, ok";
76    
77  my $mnt = Fuse::DBI->mount({  my $mnt = Fuse::DBI->mount({
78          filenames => $sql_filenames,          filenames => $sql_filenames,
79          read => $sql_read,          read => $sql_read,
80          update => $sql_update,          update => $sql_update,
81          dsn => 'DBI:Pg:dbname=webgui',          dsn => $dsn,
82          mount => '/mnt2',          mount => $mount,
83            fork => 1,
84  });  });
85    
86  ok($mnt, "mount");  ok($mnt, "mount");
87    
88  diag "press enter to continue";  sub test_file {
89  my $foo = <STDIN>;          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");  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    
Legend:
Removed from v.12  
changed lines
  Added in v.68
  ViewVC Help
Powered by ViewVC 1.1.26