summaryrefslogtreecommitdiffstats
path: root/backend/php-mysql
diff options
context:
space:
mode:
Diffstat (limited to 'backend/php-mysql')
-rw-r--r--backend/php-mysql/index.php228
1 files changed, 125 insertions, 103 deletions
diff --git a/backend/php-mysql/index.php b/backend/php-mysql/index.php
index 59b7e64..03bbefc 100644
--- a/backend/php-mysql/index.php
+++ b/backend/php-mysql/index.php
@@ -13,57 +13,73 @@
define("PASSWORD","");
define("DB","information_schema");
}
- function connect() {
- $conn = mysql_connect(SERVER,USER,PASSWORD);
- if (!$conn) return false;
- $res = mysql_select_db(DB);
- if (!$res) return false;
- return true;
- }
-
- function import() {
- $db = (isset($_GET["database"]) ? $_GET["database"] : "information_schema");
- $db = mysql_real_escape_string($db);
- $xml = "";
-
- $arr = array();
- @ $datatypes = file("../../db/mysql/datatypes.xml");
- $arr[] = $datatypes[0];
- $arr[] = '<sql db="mysql">';
- for ($i=1;$i<count($datatypes);$i++) {
- $arr[] = $datatypes[$i];
+ class mysqlDB {
+ var $_conn;
+ function connect() {
+ $conn = mysqli_connect(SERVER,USER,PASSWORD);
+ $this->setLink($conn);
+ if (!$this->getLink()){
+ return false;
+ }
+ $res = mysqli_select_db($this->getLink(), DB);
+ if (!$res){
+ // try to create the DataBase and table
+ if(!$this->setup_first_time()){
+ return false;
+ }
+ }
+ return true;
+ }
+ function getLink(){
+ return $this->_conn;
+ }
+ function setLink($conn){
+ $this->_conn = $conn;
}
- $result = mysql_query("SELECT * FROM TABLES WHERE TABLE_SCHEMA = '".$db."'");
- while ($row = mysql_fetch_array($result)) {
- $table = $row["TABLE_NAME"];
- $xml .= '<table name="'.$table.'">';
- $comment = (isset($row["TABLE_COMMENT"]) ? $row["TABLE_COMMENT"] : "");
- if ($comment) { $xml .= '<comment>'.htmlspecialchars($comment).'</comment>'; }
-
- $q = "SELECT * FROM COLUMNS WHERE TABLE_NAME = '".$table."' AND TABLE_SCHEMA = '".$db."'";
- $result2 = mysql_query($q);
- while ($row = mysql_fetch_array($result2)) {
- $name = $row["COLUMN_NAME"];
- $type = $row["COLUMN_TYPE"];
- $comment = (isset($row["COLUMN_COMMENT"]) ? $row["COLUMN_COMMENT"] : "");
- $null = ($row["IS_NULLABLE"] == "YES" ? "1" : "0");
-
- if (preg_match("/binary/i",$row["COLUMN_TYPE"])) {
- $def = bin2hex($row["COLUMN_DEFAULT"]);
- } else {
- $def = $row["COLUMN_DEFAULT"];
- }
+ function import() {
+ $db = (isset($_GET["database"]) ? $_GET["database"] : "information_schema");
+ $db = mysqli_real_escape_string($this->getLink(), $db);
+ $xml = "";
+
+ $arr = array();
+ @ $datatypes = file("../../db/mysql/datatypes.xml");
+ $arr[] = $datatypes[0];
+ $arr[] = '<sql db="mysql">';
+ for ($i=1;$i<count($datatypes);$i++) {
+ $arr[] = $datatypes[$i];
+ }
- $ai = (preg_match("/auto_increment/i",$row["EXTRA"]) ? "1" : "0");
- if ($def == "NULL") { $def = ""; }
- $xml .= '<row name="'.$name.'" null="'.$null.'" autoincrement="'.$ai.'">';
- $xml .= '<datatype>'.strtoupper($type).'</datatype>';
- $xml .= '<default>'.$def.'</default>';
+ $result = mysqli_query($this->getLink(), "SELECT * FROM TABLES WHERE TABLE_SCHEMA = '".$db."'");
+ while ($row = mysqli_fetch_array($result)) {
+ $table = $row["TABLE_NAME"];
+ $xml .= '<table name="'.$table.'">';
+ $comment = (isset($row["TABLE_COMMENT"]) ? $row["TABLE_COMMENT"] : "");
if ($comment) { $xml .= '<comment>'.htmlspecialchars($comment).'</comment>'; }
- /* fk constraints */
- $q = "SELECT
+ $q = "SELECT * FROM COLUMNS WHERE TABLE_NAME = '".$table."' AND TABLE_SCHEMA = '".$db."'";
+ $result2 = mysqli_query($this->getLink(), $q);
+ while ($row = mysqli_fetch_array($result2)) {
+ $name = $row["COLUMN_NAME"];
+ $type = $row["COLUMN_TYPE"];
+ $comment = (isset($row["COLUMN_COMMENT"]) ? $row["COLUMN_COMMENT"] : "");
+ $null = ($row["IS_NULLABLE"] == "YES" ? "1" : "0");
+
+ if (preg_match("/binary/i",$row["COLUMN_TYPE"])) {
+ $def = bin2hex($row["COLUMN_DEFAULT"]);
+ } else {
+ $def = $row["COLUMN_DEFAULT"];
+ }
+
+ $ai = (preg_match("/auto_increment/i",$row["EXTRA"]) ? "1" : "0");
+ if ($def == "NULL") { $def = ""; }
+ $xml .= '<row name="'.$name.'" null="'.$null.'" autoincrement="'.$ai.'">';
+ $xml .= '<datatype>'.strtoupper($type).'</datatype>';
+ $xml .= '<default>'.$def.'</default>';
+ if ($comment) { $xml .= '<comment>'.htmlspecialchars($comment).'</comment>'; }
+
+ /* fk constraints */
+ $q = "SELECT
REFERENCED_TABLE_NAME AS 'table', REFERENCED_COLUMN_NAME AS 'column'
FROM KEY_COLUMN_USAGE k
LEFT JOIN TABLE_CONSTRAINTS c
@@ -71,87 +87,91 @@
WHERE CONSTRAINT_TYPE = 'FOREIGN KEY'
AND c.TABLE_SCHEMA = '".$db."' AND c.TABLE_NAME = '".$table."'
AND k.COLUMN_NAME = '".$name."'";
- $result3 = mysql_query($q);
-
- while ($row = mysql_fetch_array($result3)) {
- $xml .= '<relation table="'.$row["table"].'" row="'.$row["column"].'" />';
- }
+ $result3 = mysqli_query($this->getLink(), $q);
- $xml .= '</row>';
- }
+ while ($row = mysqli_fetch_array($result3)) {
+ $xml .= '<relation table="'.$row["table"].'" row="'.$row["column"].'" />';
+ }
- /* keys */
- $q = "SELECT * FROM STATISTICS WHERE TABLE_NAME = '".$table."' AND TABLE_SCHEMA = '".$db."' ORDER BY SEQ_IN_INDEX ASC";
- $result2 = mysql_query($q);
- $idx = array();
-
- while ($row = mysql_fetch_array($result2)) {
- $name = $row["INDEX_NAME"];
- if (array_key_exists($name, $idx)) {
- $obj = $idx[$name];
- } else {
- $type = $row["INDEX_TYPE"];
- $t = "INDEX";
- if ($type == "FULLTEXT") { $t = $type; }
- if ($row["NON_UNIQUE"] == "0") { $t = "UNIQUE"; }
- if ($name == "PRIMARY") { $t = "PRIMARY"; }
-
- $obj = array(
- "columns" => array(),
- "type" => $t
- );
+ $xml .= '</row>';
}
- $obj["columns"][] = $row["COLUMN_NAME"];
- $idx[$name] = $obj;
- }
+ /* keys */
+ $q = "SELECT * FROM STATISTICS WHERE TABLE_NAME = '".$table."' AND TABLE_SCHEMA = '".$db."' ORDER BY SEQ_IN_INDEX ASC";
+ $result2 =mysqli_query($this->getLink(),$q);
+ $idx = array();
+
+ while ($row = mysqli_fetch_array($result2)) {
+ $name = $row["INDEX_NAME"];
+ if (array_key_exists($name, $idx)) {
+ $obj = $idx[$name];
+ } else {
+ $type = $row["INDEX_TYPE"];
+ $t = "INDEX";
+ if ($type == "FULLTEXT") { $t = $type; }
+ if ($row["NON_UNIQUE"] == "0") { $t = "UNIQUE"; }
+ if ($name == "PRIMARY") { $t = "PRIMARY"; }
+
+ $obj = array(
+ "columns" => array(),
+ "type" => $t
+ );
+ }
+
+ $obj["columns"][] = $row["COLUMN_NAME"];
+ $idx[$name] = $obj;
+ }
- foreach ($idx as $name=>$obj) {
- $xml .= '<key name="'.$name.'" type="'.$obj["type"].'">';
- for ($i=0;$i<count($obj["columns"]);$i++) {
- $col = $obj["columns"][$i];
- $xml .= '<part>'.$col.'</part>';
+ foreach ($idx as $name=>$obj) {
+ $xml .= '<key name="'.$name.'" type="'.$obj["type"].'">';
+ for ($i=0;$i<count($obj["columns"]);$i++) {
+ $col = $obj["columns"][$i];
+ $xml .= '<part>'.$col.'</part>';
+ }
+ $xml .= '</key>';
}
- $xml .= '</key>';
+ $xml .= "</table>";
}
- $xml .= "</table>";
+ $arr[] = $xml;
+ $arr[] = '</sql>';
+ return implode("\n",$arr);
}
- $arr[] = $xml;
- $arr[] = '</sql>';
- return implode("\n",$arr);
- }
+ }
+
$a = (isset($_GET["action"]) ? $_GET["action"] : false);
switch ($a) {
case "list":
setup_saveloadlist();
- if (!connect()) {
+ $DBHandler = new mysqlDB();
+ if (!$DBHandler->connect()) {
header("HTTP/1.0 503 Service Unavailable");
break;
}
- $result = mysql_query("SELECT keyword FROM ".TABLE." ORDER BY dt DESC");
- while ($row = mysql_fetch_assoc($result)) {
+ $result = mysqli_query($DBHandler->getLink(), "SELECT keyword FROM ".TABLE." ORDER BY dt DESC");
+ while ($row = mysqli_fetch_assoc($result)) {
echo $row["keyword"]."\n";
}
break;
case "save":
setup_saveloadlist();
- if (!connect()) {
+ $DBHandler = new mysqlDB();
+ if (!$DBHandler->connect()) {
header("HTTP/1.0 503 Service Unavailable");
break;
}
$keyword = (isset($_GET["keyword"]) ? $_GET["keyword"] : "");
- $keyword = mysql_real_escape_string($keyword);
+ $keyword = mysqli_real_escape_string($DBHandler->getLink(), $keyword);
$data = file_get_contents("php://input");
if (get_magic_quotes_gpc() || get_magic_quotes_runtime()) {
$data = stripslashes($data);
}
- $data = mysql_real_escape_string($data);
- $r = mysql_query("SELECT * FROM ".TABLE." WHERE keyword = '".$keyword."'");
- if (mysql_num_rows($r) > 0) {
- $res = mysql_query("UPDATE ".TABLE." SET data = '".$data."' WHERE keyword = '".$keyword."'");
+ $data = mysqli_real_escape_string($DBHandler->getLink(), $data);
+ $r = mysqli_query($DBHandler->getLink(), "SELECT * FROM ".TABLE." WHERE keyword = '".$keyword."'");
+ if (mysqli_num_rows($r) > 0) {
+ $res = mysqli_query($DBHandler->getLink(), "UPDATE ".TABLE." SET data = '".$data."' WHERE keyword = '".$keyword."'");
} else {
- $res = mysql_query("INSERT INTO ".TABLE." (keyword, data) VALUES ('".$keyword."', '".$data."')");
+ $res = mysqli_query($DBHandler->getLink(), "INSERT INTO ".TABLE." (keyword, data) VALUES ('".$keyword."', '".$data."')");
}
if (!$res) {
header("HTTP/1.0 500 Internal Server Error");
@@ -161,14 +181,15 @@
break;
case "load":
setup_saveloadlist();
- if (!connect()) {
+ $DBHandler = new mysqlDB();
+ if (!$DBHandler->connect()) {
header("HTTP/1.0 503 Service Unavailable");
break;
}
$keyword = (isset($_GET["keyword"]) ? $_GET["keyword"] : "");
- $keyword = mysql_real_escape_string($keyword);
- $result = mysql_query("SELECT `data` FROM ".TABLE." WHERE keyword = '".$keyword."'");
- $row = mysql_fetch_assoc($result);
+ $keyword = mysqli_real_escape_string($DBHandler->getLink(), $keyword);
+ $result = mysqli_query($DBHandler->getLink(), "SELECT `data` FROM ".TABLE." WHERE keyword = '".$keyword."'");
+ $row = mysqli_fetch_assoc($result);
if (!$row) {
header("HTTP/1.0 404 Not Found");
} else {
@@ -178,13 +199,14 @@
break;
case "import":
setup_import();
- if (!connect()) {
+ $DBHandler = new mysqlDB();
+ if (!$DBHandler->connect()) {
header("HTTP/1.0 503 Service Unavailable");
break;
}
header("Content-type: text/xml");
- echo import();
+ echo $DBHandler->import();
break;
default: header("HTTP/1.0 501 Not Implemented");
}
generated by cgit v1.1 at 2025-05-11 08:50:17 +0000