/[fuse_dbi]/trunk/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

Contents of /trunk/t/02sqlite.t

Parent Directory Parent Directory | Revision Log Revision Log


Revision 59 - (show annotations)
Mon Jun 20 21:15:05 2005 UTC (16 years, 4 months ago) by dpavlin
File MIME type: application/x-troff
File size: 2604 byte(s)
added tests for write to file (update database)

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

Properties

Name Value
svn:executable *

  ViewVC Help
Powered by ViewVC 1.1.26