summaryrefslogtreecommitdiff
path: root/regress/mysql/rollback.pl
blob: 35db21fd119c9efc2febd8887e5ae359b79d1beb (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
#!/usr/pkg/bin/perl
#
# $FML: getline.pl,v 1.9 2001/06/17 09:00:31 fukachan Exp $
#

use strict;
use Carp;
use IO::Adapter;

my $map = 'mysql:toymodel';


my $map_params = {
    $map => {
	sql_server    => 'mysql.home.fml.org',
	user          => 'fukachan',
	user_password => 'uja',
	database      => 'ML',
	table         => 'ml',
	params        => {
	    ml_name   => 'elena',
	    file      => 'members',
	},
    },
};


my $obj = new IO::Adapter ($map, $map_params);

unless (defined $obj) {
   croak "cannot set up $map\n";
}

print STDERR "* current table\n";
_dump($obj); print "\n";

print STDERR "* add ...\n";
$obj->open();

for (1 .. 10) {
    $obj->add( "add\-${_}\-ress\@nuinui.net" );
}
$obj->close();

_dump($obj); print "\n";


print STDERR "* rollback test ...\n";
_rollback($obj); print "\n";

print STDERR "* regexp test ...\n";
$obj->close();
$obj->open();
$obj->replace('7', 7); print "\n";
$obj->close();

print STDERR "* delete ...\n";
$obj->open();

for (1 .. 10) {
    $obj->delete( "add\-${_}\-ress\@nuinui.net" );
}

$obj->close();

_dump($obj); print "\n";

exit 0;


sub _dump
{
    my ($obj) = @_;

    if (defined $obj) {
	if (defined $obj->open()) {
	    while ($_ = $obj->getline()) {
		my $y = $obj->eof ? "y" : "n";
		print "<", $obj->getpos, "(eof=$y)> ";
		print $_, "\n";
	    }
	    $obj->close;
	}
	else {
	    croak("cannot open()");
	}
    }
    else {
	croak("cannot make object");
    }
}


sub _rollback
{
    my ($obj) = @_;
    my $done  = 0;

    if (defined $obj) {
	if (defined $obj->open()) {
	    while ($_ = $obj->getline()) {
		my $y = $obj->eof ? "y" : "n";
		print "<", $obj->getpos, "(eof=$y)> ";
		print $_, "\n";

		unless ($done) {
		    if ($obj->getpos == 4) {
			print STDERR "   skip to 6 \n";
			$obj->setpos(6);
			next;
		    }

		    if ($obj->getpos == 7) {
			print STDERR "   back to 3 \n";
			$obj->setpos(3);
			$done = 1;
		    }
		}
	    }
	    $obj->close;
	}
	else {
	    croak("cannot open()");
	}
    }
    else {
	croak("cannot make object");
    }
}