nupplaPhil/friendica
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Create database.sql from include\dbstructure.php

Browse source 
add two commands to `dbstructure.php` when called from cli:
'update' updates the database schema
'dumpsql' dump database sql to stdout
This commit is contained in:
fabrixxm 2015-03-25 09:47:59 +01:00
parent f1c6d6f1ba
commit b2b1de5a01
2 changed files with 879 additions and 1057 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1862
database.sql
View file

File diff suppressed because it is too large Load diff

74
include/dbstructure.php
View file

@ -106,29 +106,17 @@ function table_structure($table) {
} }
function print_structure($database) { function print_structure($database) {
echo "-- ------------------------------------------\n";
echo "-- ".FRIENDICA_PLATFORM." ".FRIENDICA_VERSION." (".FRIENDICA_CODENAME,")\n";
echo "-- DB_UPDATE_VERSION ".DB_UPDATE_VERSION."\n";
echo "-- ------------------------------------------\n\n\n";
foreach ($database AS $name => $structure) { foreach ($database AS $name => $structure) {
echo "\t".'$database["'.$name."\"] = array(\n"; echo "--\n";
echo "-- TABLE $name\n";
echo "--\n";
db_create_table($name, $structure['fields'], true, false, $structure["indexes"]);
echo "\t\t\t".'"fields" => array('."\n"; echo "\n";
foreach ($structure["fields"] AS $fieldname => $parameters) {
echo "\t\t\t\t\t".'"'.$fieldname.'" => array(';
$data = "";
foreach ($parameters AS $name => $value) {
if ($data != "")
$data .= ", ";
$data .= '"'.$name.'" => "'.$value.'"';
}
echo $data."),\n";
}
echo "\t\t\t\t\t),\n";
echo "\t\t\t".'"indexes" => array('."\n";
foreach ($structure["indexes"] AS $indexname => $fieldnames) {
echo "\t\t\t\t\t".'"'.$indexname.'" => array("'.implode($fieldnames, '","').'"'."),\n";
}
echo "\t\t\t\t\t)\n";
echo "\t\t\t);\n";
} }
} }
@ -243,7 +231,7 @@ function db_field_command($parameters, $create = true) {
return($fieldstruct); return($fieldstruct);
} }
function db_create_table($name, $fields, $verbose, $action) { function db_create_table($name, $fields, $verbose, $action, $indexes=null) {
global $a, $db; global $a, $db;
$r = true; $r = true;
@ -253,7 +241,13 @@ function db_create_table($name, $fields, $verbose, $action) {
if ($sql != "") if ($sql != "")
$sql .= ",\n"; $sql .= ",\n";
$sql .= "`".dbesc($fieldname)."` ".db_field_command($field); $sql .= "\t`".dbesc($fieldname)."` ".db_field_command($field);
}
if (!is_null($indexes)) {
foreach ($indexes AS $indexname => $fieldnames) {
$sql .= "\t".db_create_index($indexname, $fieldnames, "")."\n";
}
} }
$sql = sprintf("CREATE TABLE IF NOT EXISTS `%s` (\n", dbesc($name)).$sql."\n) DEFAULT CHARSET=utf8"; $sql = sprintf("CREATE TABLE IF NOT EXISTS `%s` (\n", dbesc($name)).$sql."\n) DEFAULT CHARSET=utf8";
@ -282,7 +276,7 @@ function db_drop_index($indexname) {
return($sql); return($sql);
} }
function db_create_index($indexname, $fieldnames) { function db_create_index($indexname, $fieldnames, $method="ADD") {
if ($indexname == "PRIMARY") if ($indexname == "PRIMARY")
return; return;
@ -298,7 +292,13 @@ function db_create_index($indexname, $fieldnames) {
$names .= "`".dbesc($fieldname)."`"; $names .= "`".dbesc($fieldname)."`";
} }
$sql = sprintf("ADD INDEX `%s` (%s)", dbesc($indexname), $names); $method = strtoupper(trim($method));
if ($method!="" && $method!="ADD") {
throw new Exception("Invalid parameter 'method' in db_create_index(): '$method'");
killme();
}
$sql = sprintf("%s INDEX `%s` (%s)", $method, dbesc($indexname), $names);
return($sql); return($sql);
} }
@ -1357,7 +1357,29 @@ function dbstructure_run(&$argv, &$argc) {
unset($db_host, $db_user, $db_pass, $db_data); unset($db_host, $db_user, $db_pass, $db_data);
} }
update_structure(true, true); if ($argc==2) {
switch ($argv[1]) {
case "update":
update_structure(true, true);
return;
case "dumpsql":
print_structure(db_definition());
return;
}
}
// print help
echo $argv[0]." <command>\n";
echo "\n";
echo "commands:\n";
echo "update update database schema\n";
echo "dumpsql dump database schema\n";
return;
} }
if (array_search(__file__,get_included_files())===0){ if (array_search(__file__,get_included_files())===0){