sub execute_sql {
# --------------------------------------------------------
# Execute an SQL statement.
#
my ($in, $db) = @_;
my $query = $in->param('command') || return "No query entered!";
my $file = $in->param('command-file');

$file and (-w $file or return "Unable to write to file '$file'. Reason: $!");
my ($sth, $rv, $output);

eval { $sth = $db->prepare ($query); };
($@ or !defined $sth) and return "Query Error: $Links::DBSQL::error";

eval { $rv = $sth->execute(); };
($@ or !defined $rv) and return "Query Error: $DBI::errstr";

my $rows = $sth->rows || 0;
$file and (open (FILE, ">$file") or return "Unable to open file: '$file'. Reason: $!");
if ($query =~ /SELECT|DESCRIBE|SHOW/i) {
$output = "<pre>Your query returned $rows rows. \n\n";
while (my $arr = $sth->fetchrow_arrayref) {
$file ? (print FILE join ("\t", @$arr), "\n") : ($output .= join ("\t", @$arr) . "\n");
}
$output .= "</pre>";
}
else {
$output = "Rows affected: $rows";
}
return $output;
}