Reworked to support multiple hosts and databases

multidb
Thomas Hooge 6 years ago
parent f1677cb6f9
commit 3944eabdcd
  1. 2
      plugin.info.txt
  2. 143
      syntax.php

@ -1,7 +1,7 @@
base sqlquery base sqlquery
author George Pirogov author George Pirogov
email i1557@yandex.ru email i1557@yandex.ru
date 2016-11-25 date 2018-12-10
name SQL query plugin name SQL query plugin
desc Processing query to mysql database and display results as a table. desc Processing query to mysql database and display results as a table.
url https://www.dokuwiki.org/plugin:sqlquery url https://www.dokuwiki.org/plugin:sqlquery

@ -4,29 +4,26 @@
* *
* @license GPL 2 http://www.gnu.org/licenses/gpl-2.0.html * @license GPL 2 http://www.gnu.org/licenses/gpl-2.0.html
* @author George Pirogov <i1557@yandex.ru> * @author George Pirogov <i1557@yandex.ru>
* @author Thomas Hooge <hooge@rowa-group.com>
*
*/ */
// must be run within Dokuwiki // must be run within Dokuwiki
if (!defined('DOKU_INC')) die(); if (!defined('DOKU_INC')) die();
/**
* All DokuWiki plugins to extend the parser/rendering mechanism
* need to inherit from this class
*/
class syntax_plugin_sqlquery extends DokuWiki_Syntax_Plugin { class syntax_plugin_sqlquery extends DokuWiki_Syntax_Plugin {
public function getType() { public function getType() { return 'substition'; }
return 'substition'; public function getSort() { return 666; }
} public function getPType() { return 'block'; }
public function getSort() {
return 666;
}
public function connectTo($mode) public function connectTo($mode)
{ {
$this->Lexer->addEntryPattern('<sql>', $mode, 'plugin_sqlquery'); $this->Lexer->addSpecialPattern('<sql\b(?:\s+(?:host|db)=[\w\-\.$]+?)*\s*>(?:.*?</sql>)', $mode, 'plugin_sqlquery');
}
public function postConnect()
{
$this->Lexer->addExitPattern('</sql>','plugin_sqlquery');
} }
/** /**
@ -36,29 +33,30 @@ class syntax_plugin_sqlquery extends DokuWiki_Syntax_Plugin {
* @param int $state The state of the handler * @param int $state The state of the handler
* @param int $pos The position in the document * @param int $pos The position in the document
* @param Doku_Handler $handler The handler * @param Doku_Handler $handler The handler
*
* @return array Data for the renderer * @return array Data for the renderer
*/ */
public function handle($match, $state, $pos, Doku_Handler $handler) public function handle($match, $state, $pos, Doku_Handler $handler) {
{ $data = array('state' => $state);
switch ( $state ) if ($state == DOKU_LEXER_SPECIAL) {
{ # get host
case DOKU_LEXER_ENTER: if (preg_match('/<sql\b.*host=([\w\-\.$]+)/', $match, $result)) {
$data = array(); $data['host'] = $result[1];
return $data; } else {
break; $data['host'] = $this->getConf('host');
}
case DOKU_LEXER_UNMATCHED: # get database
return array('sqlquery' => $match); if (preg_match('/<sql\b.*db=([\w\-\.$]+)/', $match, $result)) {
break; $data['db'] = $result[1];
} else {
case DOKU_LEXER_EXIT: $data['db'] = $this->getConf('db');
$data = array(); }
return $data; # get query
break; $data['match'] = $match;
if (preg_match('%<sql.*?>(.*)</sql>%s', $match, $result)) {
$data['query'] = trim($result[1]);
}
} }
$data = array();
return $data; return $data;
} }
@ -68,72 +66,67 @@ class syntax_plugin_sqlquery extends DokuWiki_Syntax_Plugin {
* @param string $mode Renderer mode (supported modes: xhtml) * @param string $mode Renderer mode (supported modes: xhtml)
* @param Doku_Renderer $renderer The renderer * @param Doku_Renderer $renderer The renderer
* @param array $data The data from the handler() function * @param array $data The data from the handler() function
*
* @return bool If rendering was successful. * @return bool If rendering was successful.
*/ */
public function render($mode, Doku_Renderer $renderer, $data) public function render($mode, Doku_Renderer $renderer, $data)
{ {
if ( $mode != 'xhtml' ) return false; if ($mode != 'xhtml') return false;
if (empty($data['query'])) return true;
if ( !empty( $data['sqlquery'] ) ) // get configuration
{
// получаем параметры конфигурации
$host = $this->getConf('Host');
$DB = $this->getConf('DB');
$user = $this->getConf('user'); $user = $this->getConf('user');
$password = $this->getConf('password'); $password = $this->getConf('password');
// получаем запрос // connect to database
$querystring = $data['sqlquery']; $link = mysqli_connect($data['host'], $user, $password, $data['db']);
if (!$link) {
// подключаемся к базе $renderer->doc .= "<pre>" . mysqli_connect_error() . "</pre>";
$link = mysqli_connect($host, $user, $password, $DB); return true;
}
mysqli_set_charset($link, "utf8"); mysqli_set_charset($link, "utf8");
// подключились // run query
if ( $link ) $result = mysqli_query($link, $data['query']);
{ if ($result) {
$result = mysqli_query($link, $querystring);
if ( $result ) // get the number of fields in the table
{
// получаем кол-во полей в таблице
$fieldcount = mysqli_num_fields($result); $fieldcount = mysqli_num_fields($result);
// строим таблицу // build a table
$renderer->doc .= "<table id=\"sqlquerytable\" class=\"inline\">"; $renderer->doc .= '<table id="sqlquerytable" class="inline">' . "\n";
// строим заголовок // build the header section of the table
$renderer->doc .= "<thead><tr>"; $renderer->doc .= "<thead><tr>";
while ($fieldinfo = mysqli_fetch_field($result)) while ($fieldinfo = mysqli_fetch_field($result)) {
{
$renderer->doc .= "<th>"; $renderer->doc .= "<th>";
$renderer->doc .= $fieldinfo->name; $renderer->doc .= $fieldinfo->name;
$renderer->doc .= "</th>"; $renderer->doc .= "</th>";
} }
$renderer->doc .= "</tr></thead>"; $renderer->doc .= "</tr></thead>\n";
// строим содержимое таблицы // build the contents of the table
$renderer->doc .= "<tbody>"; $renderer->doc .= "<tbody>\n";
while ($row = mysqli_fetch_row($result)) while ($row = mysqli_fetch_row($result)) {
{
$renderer->doc .= "<tr>"; $renderer->doc .= "<tr>";
for ( $i = 0; $i < $fieldcount; $i++ ) {
// строим строку
for ( $i = 0; $i < $fieldcount; $i++ )
{
$renderer->doc .= "<td>"; $renderer->doc .= "<td>";
$renderer->doc .= $row[$i]; $renderer->doc .= $row[$i];
$renderer->doc .= "</td>"; $renderer->doc .= "</td>";
} }
$renderer->doc .= "</tr>"; $renderer->doc .= "</tr>\n";
} // of while fetch_row }
// закрываем таблицу
$renderer->doc .= "</tbody></table>"; // finish the table
} // of mysqli_query $renderer->doc .= "</tbody></table>\n";
} else {
// error in query
$renderer->doc .= "<pre>" . mysqli_error($link) . "</pre>";
}
mysqli_close($link); mysqli_close($link);
} // of mysqli link
} // of sqlquery not empty
return true; return true;
} // of render function }
} }
// vim:ts=4:sw=4:et: