/[fuse_dbi]/trunk/t/03pgsql.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

Annotation of /trunk/t/03pgsql.t

Parent Directory Parent Directory | Revision Log Revision Log


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

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

Properties

Name Value
svn:executable *

  ViewVC Help
Powered by ViewVC 1.1.26