@ISA = qw(Exporter);
@EXPORT = qw(conv_i conv_date conv_dateq do_query selectrow_query do_statement
- dump_query quote_db_date selectall_hashref_query
- selectfirst_hashref_query selectfirst_array_query
- prepare_execute_query);
+ dump_query quote_db_date
+ selectfirst_hashref_query selectfirst_array_query
+ selectall_hashref_query selectall_array_query
+ prepare_execute_query prepare_query);
sub conv_i {
my ($value, $default) = @_;
sub do_query {
my ($form, $dbh, $query) = splice(@_, 0, 3);
- dump_query(LXDebug::QUERY, '', $query . " (" . join(", ", @_) . ")", @_);
+ dump_query(LXDebug::QUERY, '', $query, @_);
if (0 == scalar(@_)) {
$dbh->do($query) || $form->dberror($query);
sub do_statement {
my ($form, $sth, $query) = splice(@_, 0, 3);
- dump_query(LXDebug::QUERY, '', $query . " (" . join(", ", @_) . ")", @_);
+ dump_query(LXDebug::QUERY, '', $query, @_);
if (0 == scalar(@_)) {
$sth->execute() || $form->dberror($query);
return "'$str'";
}
+sub prepare_query {
+ my ($form, $dbh, $query) = splice(@_, 0, 3);
+
+ dump_query(LXDebug::QUERY, '', $query, @_);
+
+ my $sth = $dbh->prepare($query) || $form->dberror($query);
+ return $sth;
+}
+
sub prepare_execute_query {
my ($form, $dbh, $query) = splice(@_, 0, 3);
- dump_query(LXDebug::QUERY, '', $query . " (" . join(", ", @_) . ")", @_);
+ dump_query(LXDebug::QUERY, '', $query, @_);
my $sth = $dbh->prepare($query) || $form->dberror($query);
if (scalar(@_) != 0) {
return $result;
}
+sub selectall_array_query {
+ my ($form, $dbh, $query) = splice(@_, 0, 3);
+
+ my $sth = prepare_execute_query($form, $dbh, $query, @_);
+ my @result;
+ while (my ($value) = $sth->fetchrow_array()) {
+ push(@result, $value);
+ }
+ $sth->finish();
+
+ return @result;
+}
+
sub selectfirst_hashref_query {
my ($form, $dbh, $query) = splice(@_, 0, 3);