use strict;
use DBI;

my($sql, $sth);

my $dbh = DBI->connect('dbi:AnyData(RaiseError=>1):');

$dbh->{TraceLevel} = 1;

$dbh->func( 'obs', 'CSV', [<DATA>], 'ad_import');

$sql = "delete from obs";                 
my $ret = $dbh->do($sql);
print "ret: $ret\n";

$sql = "select count(*) from obs";
$sth = $dbh->prepare($sql);
$sth->execute();
my $count = $sth->fetchrow_array();
$sth->finish();

print "$count rows in obs after delete\n";

__DATA__
"obs_id","flow_nm","event_type_nm","event_subtype_nm","event_selected"
1,nw,flow_nw_pyro,pyro_1_less,0
2,nw,flow_nw_pyro,pyro_1_2,0
3,nw,flow_nw_pyro,pyro_2_3,0
4,nw,flow_nw_pyro,pyro_3_more,1