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 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208
|
<?php
/**
* Process an arbitrary SQL query - tricky! The main problem is that
* unless we implement a full SQL parser, there's no way of knowing
* how many SQL statements have been strung together with semi-colons
* @param $query The SQL query string to execute
*
* $Id: sql.php,v 1.43 2008/01/10 20:19:27 xzilla Exp $
*/
// Prevent timeouts on large exports (non-safe mode only)
if (!ini_get('safe_mode')) set_time_limit(0);
// Include application functions
include_once('./libraries/lib.inc.php');
/**
* This is a callback function to display the result of each separate query
* @param ADORecordSet $rs The recordset returned by the script execetor
*/
function sqlCallback($query, $rs, $lineno) {
global $data, $misc, $lang, $_connection;
// Check if $rs is false, if so then there was a fatal error
if ($rs === false) {
echo htmlspecialchars($_FILES['script']['name']), ':', $lineno, ': ', nl2br(htmlspecialchars($_connection->getLastError())), "<br/>\n";
}
else {
// Print query results
switch (pg_result_status($rs)) {
case PGSQL_TUPLES_OK:
// If rows returned, then display the results
$num_fields = pg_numfields($rs);
echo "<p><table>\n<tr>";
for ($k = 0; $k < $num_fields; $k++) {
echo "<th class=\"data\">", $misc->printVal(pg_fieldname($rs, $k)), "</th>";
}
$i = 0;
$row = pg_fetch_row($rs);
while ($row !== false) {
$id = (($i % 2) == 0 ? '1' : '2');
echo "<tr>\n";
foreach ($row as $k => $v) {
echo "<td class=\"data{$id}\" style=\"white-space:nowrap;\">", $misc->printVal($v, pg_fieldtype($rs, $k), array('null' => true)), "</td>";
}
echo "</tr>\n";
$row = pg_fetch_row($rs);
$i++;
};
echo "</table><br/>\n";
echo $i, " {$lang['strrows']}</p>\n";
break;
case PGSQL_COMMAND_OK:
// If we have the command completion tag
if (version_compare(phpversion(), '4.3', '>=')) {
echo htmlspecialchars(pg_result_status($rs, PGSQL_STATUS_STRING)), "<br/>\n";
}
// Otherwise if any rows have been affected
elseif ($data->conn->Affected_Rows() > 0) {
echo $data->conn->Affected_Rows(), " {$lang['strrowsaff']}<br/>\n";
}
// Otherwise output nothing...
break;
case PGSQL_EMPTY_QUERY:
break;
default:
break;
}
}
}
// Pagination maybe set by a get link that has it as FALSE,
// if that's the case, unset the variable.
if (isset($_REQUEST['paginate']) && $_REQUEST['paginate'] == 'f') {
unset($_REQUEST['paginate']);
unset($_POST['paginate']);
unset($_GET['paginate']);
}
// Check to see if pagination has been specified. In that case, send to display
// script for pagination
/* if a file is given or the request is an explain, do not paginate */
if (isset($_REQUEST['paginate']) && !(isset($_FILES['script']) && $_FILES['script']['size'] > 0)
&& (preg_match('/^\s*explain/i', $_REQUEST['query']) == 0)) {
include('./display.php');
exit;
}
$subject = isset($_REQUEST['subject'])? $_REQUEST['subject'] : '';
$misc->printHeader($lang['strqueryresults']);
$misc->printBody();
$misc->printTrail('database');
$misc->printTitle($lang['strqueryresults']);
// Set the schema search path
if ($data->hasSchemas() && isset($_REQUEST['search_path'])) {
if ($data->setSearchPath(array_map('trim',explode(',',$_REQUEST['search_path']))) != 0) {
$misc->printFooter();
exit;
}
}
// May as well try to time the query
if (function_exists('microtime')) {
list($usec, $sec) = explode(' ', microtime());
$start_time = ((float)$usec + (float)$sec);
}
else $start_time = null;
// Execute the query. If it's a script upload, special handling is necessary
if (isset($_FILES['script']) && $_FILES['script']['size'] > 0)
$data->executeScript('script', 'sqlCallback');
else {
// Set fetch mode to NUM so that duplicate field names are properly returned
$data->conn->setFetchMode(ADODB_FETCH_NUM);
$rs = $data->conn->Execute($_REQUEST['query']);
// $rs will only be an object if there is no error
if (is_object($rs)) {
// Request was run, saving it in history
if(!isset($_REQUEST['nohistory']))
$misc->saveScriptHistory($_REQUEST['query']);
// Now, depending on what happened do various things
// First, if rows returned, then display the results
if ($rs->recordCount() > 0) {
echo "<table>\n<tr>";
foreach ($rs->fields as $k => $v) {
$finfo = $rs->fetchField($k);
echo "<th class=\"data\">", $misc->printVal($finfo->name), "</th>";
}
echo "</tr>\n";
$i = 0;
while (!$rs->EOF) {
$id = (($i % 2) == 0 ? '1' : '2');
echo "<tr>\n";
foreach ($rs->fields as $k => $v) {
$finfo = $rs->fetchField($k);
echo "<td class=\"data{$id}\" style=\"white-space:nowrap;\">", $misc->printVal($v, $finfo->type, array('null' => true)), "</td>";
}
echo "</tr>\n";
$rs->moveNext();
$i++;
}
echo "</table>\n";
echo "<p>", $rs->recordCount(), " {$lang['strrows']}</p>\n";
}
// Otherwise if any rows have been affected
elseif ($data->conn->Affected_Rows() > 0) {
echo "<p>", $data->conn->Affected_Rows(), " {$lang['strrowsaff']}</p>\n";
}
// Otherwise nodata to print
else echo '<p>', $lang['strnodata'], "</p>\n";
}
}
// May as well try to time the query
if ($start_time !== null) {
list($usec, $sec) = explode(' ', microtime());
$end_time = ((float)$usec + (float)$sec);
// Get duration in milliseconds, round to 3dp's
$duration = number_format(($end_time - $start_time) * 1000, 3);
}
else $duration = null;
// Reload the browser as we may have made schema changes
$_reload_browser = true;
// Display duration if we know it
if ($duration !== null) {
echo "<p>", sprintf($lang['strruntime'], $duration), "</p>\n";
}
echo "<p>{$lang['strsqlexecuted']}</p>\n";
echo "<ul class=\"navlink\">\n";
// Return
if (isset($_REQUEST['return_url']) && isset($_REQUEST['return_desc']))
echo "\t<li><a href=\"{$_REQUEST['return_url']}\">{$_REQUEST['return_desc']}</a></li>\n";
// Edit
echo "\t<li><a href=\"database.php?database=", urlencode($_REQUEST['database']),
"&server=", urlencode($_REQUEST['server']), "&action=sql&query=", urlencode($_REQUEST['query']), "\">{$lang['streditsql']}</a></li>\n";
// Create report
if (($subject !== 'report') && $conf['show_reports'] && isset($rs) && is_object($rs) && $rs->recordCount() > 0)
echo "\t<li><a href=\"reports.php?{$misc->href}&action=create&report_sql=",
urlencode($_REQUEST['query']), "\">{$lang['strcreatereport']}</a></li>\n";
// Create view and download
if (isset($_REQUEST['query']) && isset($rs) && is_object($rs) && $rs->recordCount() > 0) {
// Report views don't set a schema, so we need to disable create view in that case
if (isset($_REQUEST['schema']))
echo "\t<li><a href=\"views.php?action=create&formDefinition=",
urlencode($_REQUEST['query']), "&{$misc->href}\">{$lang['strcreateview']}</a></li>\n";
echo "\t<li><a href=\"dataexport.php?query=", urlencode($_REQUEST['query']);
if (isset($_REQUEST['search_path']))
echo "&search_path=", urlencode($_REQUEST['search_path']);
echo "&{$misc->href}\">{$lang['strdownload']}</a></li>\n";
}
echo "</ul>\n";
$misc->printFooter();
?>
|