dbxe/fusionpbx
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add ability to rename tables.

Browse Source
This commit is contained in:
Mark Crane
2013-03-26 06:17:35 +00:00
parent f2a159b735
commit 307d82bb1f
1 changed files with 43 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
includes/lib_schema.php
+43 -7
View File
@@ -309,7 +309,12 @@ function db_upgrade_schema ($db, $db_type, $db_name, $display_results) {
$sql = ''; $sql = '';
foreach ($apps as $x => &$app) { foreach ($apps as $x => &$app) {
foreach ($app['db'] as $y => &$row) { foreach ($app['db'] as $y => &$row) {
$table_name = $row['table']; if (is_array($row['table'])) {
$table_name = $row['table']['text'];
}
else {
$table_name = $row['table'];
}
if (strlen($table_name) > 0) { if (strlen($table_name) > 0) {
//check if the table exists //check if the table exists
if (db_table_exists($db, $db_type, $db_name, $table_name)) { if (db_table_exists($db, $db_type, $db_name, $table_name)) {
@@ -355,7 +360,26 @@ function db_upgrade_schema ($db, $db_type, $db_name, $display_results) {
//add missing tables and fields //add missing tables and fields
foreach ($apps as $x => &$app) { foreach ($apps as $x => &$app) {
foreach ($app['db'] as $y => &$row) { foreach ($app['db'] as $y => &$row) {
$table_name = $row['table']; if (is_array($row['table'])) {
$table_name = $row['table']['text'];
if (!db_table_exists($db, $db_type, $db_name, $row['table']['text'])) {
$row['exists'] = "true"; //testing
//if (db_table_exists($db, $db_type, $db_name, $row['table']['deprecated'])) {
if ($db_type == "pgsql") {
$sql_update .= "ALTER TABLE ".$row['table']['deprecated']." RENAME TO ".$row['table']['text'].";\n";
}
if ($db_type == "mysql") {
$sql_update .= "RENAME TABLE ".$row['table']['deprecated']." TO ".$row['table']['text'].";\n";
}
if ($db_type == "sqlite") {
$sql_update .= "ALTER TABLE ".$row['table']['deprecated']." RENAME TO ".$row['table']['text'].";\n";
}
//}
}
}
else {
$table_name = $row['table'];
}
//check if the table exists //check if the table exists
if ($row['exists'] == "true") { if ($row['exists'] == "true") {
if (count($row['fields']) > 0) { if (count($row['fields']) > 0) {
@@ -424,7 +448,7 @@ function db_upgrade_schema ($db, $db_type, $db_name, $display_results) {
//field type has not changed //field type has not changed
} }
else { else {
$sql_update .= "-- $db_type, $db_name, $table_name, $field_name ".db_column_data_type ($db, $db_type, $db_name, $table_name, $field_name)."<br>"; //$sql_update .= "-- $db_type, $db_name, $table_name, $field_name ".db_column_data_type ($db, $db_type, $db_name, $table_name, $field_name)."<br>";
$sql_update .= "ALTER TABLE ".$table_name." ALTER COLUMN ".$field_name." TYPE ".$field_type.";\n"; $sql_update .= "ALTER TABLE ".$table_name." ALTER COLUMN ".$field_name." TYPE ".$field_type.";\n";
} }
} }
@@ -454,14 +478,21 @@ function db_upgrade_schema ($db, $db_type, $db_name, $display_results) {
} }
else { else {
//create table //create table
$sql_update .= db_create_table($apps, $db_type, $row['table']); if (!is_array($row['table'])) {
$sql_update .= db_create_table($apps, $db_type, $row['table']);
}
} }
} }
} }
//rebuild and populate the table //rebuild and populate the table
foreach ($apps as $x => &$app) { foreach ($apps as $x => &$app) {
foreach ($app['db'] as $y => &$row) { foreach ($app['db'] as $y => &$row) {
$table_name = $row['table']; if (is_array($row['table'])) {
$table_name = $row['table']['text'];
}
else {
$table_name = $row['table'];
}
if ($row['rebuild'] == "true") { if ($row['rebuild'] == "true") {
if ($db_type == "sqlite") { if ($db_type == "sqlite") {
//start the transaction //start the transaction
@@ -509,7 +540,12 @@ function db_upgrade_schema ($db, $db_type, $db_name, $display_results) {
$sql = ''; $sql = '';
foreach ($apps as &$app) { foreach ($apps as &$app) {
foreach ($app['db'] as $row) { foreach ($app['db'] as $row) {
$table_name = $row['table']; if (is_array($row['table'])) {
$table_name = $row['table']['text'];
}
else {
$table_name = $row['table'];
}
echo "<tr>\n"; echo "<tr>\n";
//check if the table exists //check if the table exists
@@ -592,7 +628,7 @@ function db_upgrade_schema ($db, $db_type, $db_name, $display_results) {
try { try {
$db->query(trim($sql)); $db->query(trim($sql));
if ($display_type == "text") { if ($display_type == "text") {
echo " $sql\n"; echo " $sql\n";
} }
} }
catch (PDOException $error) { catch (PDOException $error) {