mirror of
https://github.com/phpbb/phpbb.git
synced 2025-06-26 13:18:54 +00:00
- ok, we should try to write the sql data as early as possible (to prevent extensive memory consumption). What needs to be done now? Trying to compress in realtime if specified and it would be also nice if the filenames had a more meaningful naming. :)
git-svn-id: file:///svn/phpbb/trunk@5666 89ea8834-ac86-4346-8a33-228a782c2dd0
This commit is contained in:
Meik Sievertsen
parent
04a228ecbc
commit
fe8958258c
1 changed files with 382 additions and 361 deletions
|
|
@ -37,6 +37,7 @@ class acp_database
|
||||||
switch ($mode)
|
switch ($mode)
|
||||||
{
|
{
|
||||||
case 'backup':
|
case 'backup':
|
||||||
|
|
||||||
switch ($action)
|
switch ($action)
|
||||||
{
|
{
|
||||||
case 'download':
|
case 'download':
|
||||||
|
|
@ -48,6 +49,18 @@ class acp_database
|
||||||
@set_time_limit(1200);
|
@set_time_limit(1200);
|
||||||
|
|
||||||
$filename = time();
|
$filename = time();
|
||||||
|
$time_start = microtime(true);
|
||||||
|
|
||||||
|
// We write the file to "store" first (and then compress the file) to not use too much
|
||||||
|
// memory. The server process can be easily killed by storing too much data at once.
|
||||||
|
$file = $phpbb_root_path . 'store/' . $filename . '.sql';
|
||||||
|
|
||||||
|
$fp = fopen($file, 'a');
|
||||||
|
|
||||||
|
if (!$fp)
|
||||||
|
{
|
||||||
|
trigger_error('Unable to write temporary file to storage folder');
|
||||||
|
}
|
||||||
|
|
||||||
// All of the generated queries go here
|
// All of the generated queries go here
|
||||||
$sql_data = '';
|
$sql_data = '';
|
||||||
|
|
@ -55,7 +68,6 @@ class acp_database
|
||||||
$sql_data .= "# phpBB Backup Script\n";
|
$sql_data .= "# phpBB Backup Script\n";
|
||||||
$sql_data .= "# Dump of tables for $table_prefix\n";
|
$sql_data .= "# Dump of tables for $table_prefix\n";
|
||||||
$sql_data .= "#\n# DATE : " . gmdate("d-m-Y H:i:s", $filename) . " GMT\n";
|
$sql_data .= "#\n# DATE : " . gmdate("d-m-Y H:i:s", $filename) . " GMT\n";
|
||||||
$time_start = microtime(true);
|
|
||||||
$sql_data .= "# START : $time_start\n";
|
$sql_data .= "# START : $time_start\n";
|
||||||
$sql_data .= "#\n";
|
$sql_data .= "#\n";
|
||||||
|
|
||||||
|
|
@ -66,7 +78,9 @@ class acp_database
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Structure
|
foreach ($table as $table_name)
|
||||||
|
{
|
||||||
|
// Get the table structure
|
||||||
if ($type == 'full' || $type == 'structure')
|
if ($type == 'full' || $type == 'structure')
|
||||||
{
|
{
|
||||||
switch (SQL_LAYER)
|
switch (SQL_LAYER)
|
||||||
|
|
@ -74,337 +88,36 @@ class acp_database
|
||||||
case 'mysqli':
|
case 'mysqli':
|
||||||
case 'mysql4':
|
case 'mysql4':
|
||||||
case 'mysql':
|
case 'mysql':
|
||||||
|
case 'sqlite';
|
||||||
|
|
||||||
foreach ($table as $table_name)
|
|
||||||
{
|
|
||||||
$row = $rows = array();
|
|
||||||
$sql_data .= '# Table: ' . $table_name . "\n";
|
$sql_data .= '# Table: ' . $table_name . "\n";
|
||||||
$sql_data .= "DROP TABLE IF EXISTS $table_name;\n";
|
$sql_data .= "DROP TABLE IF EXISTS $table_name;\n";
|
||||||
$sql_data .= "CREATE TABLE $table_name(\n";
|
|
||||||
|
|
||||||
$result = $db->sql_query("SHOW FIELDS FROM $table_name");
|
|
||||||
while ($row = $db->sql_fetchrow($result))
|
|
||||||
{
|
|
||||||
$line = ' ' . $row['Field'] . ' ' . $row['Type'];
|
|
||||||
|
|
||||||
if (!is_null($row['Default']))
|
|
||||||
{
|
|
||||||
$line .= " DEFAULT '{$row['Default']}'";
|
|
||||||
}
|
|
||||||
|
|
||||||
if ($row['Null'] != 'YES')
|
|
||||||
{
|
|
||||||
$line .= ' NOT NULL';
|
|
||||||
}
|
|
||||||
|
|
||||||
if ($row['Extra'] != '')
|
|
||||||
{
|
|
||||||
$line .= ' ' . $row['Extra'];
|
|
||||||
}
|
|
||||||
|
|
||||||
$rows[] = $line;
|
|
||||||
}
|
|
||||||
$db->sql_freeresult($result);
|
|
||||||
|
|
||||||
$result = $db->sql_query("SHOW KEYS FROM $table_name");
|
|
||||||
$index = array();
|
|
||||||
|
|
||||||
while ($row = $db->sql_fetchrow($result))
|
|
||||||
{
|
|
||||||
$kname = $row['Key_name'];
|
|
||||||
|
|
||||||
if (($kname != 'PRIMARY') && ($row['Non_unique'] == 0))
|
|
||||||
{
|
|
||||||
$kname = "UNIQUE|$kname";
|
|
||||||
}
|
|
||||||
|
|
||||||
$index[$kname][] = $row['Column_name'];
|
|
||||||
}
|
|
||||||
$db->sql_freeresult($result);
|
|
||||||
|
|
||||||
$field = array();
|
|
||||||
foreach ($index as $key => $columns)
|
|
||||||
{
|
|
||||||
$line = ' ';
|
|
||||||
|
|
||||||
if ($key == 'PRIMARY')
|
|
||||||
{
|
|
||||||
$line .= 'PRIMARY KEY (' . implode(', ', $columns) . ')';
|
|
||||||
}
|
|
||||||
elseif (strpos($key, 'UNIQUE') === 0)
|
|
||||||
{
|
|
||||||
$line .= 'UNIQUE ' . substr($key, 7) . ' (' . implode(', ', $columns) . ')';
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
$line .= "KEY $key (" . implode(', ', $columns) . ')';
|
|
||||||
}
|
|
||||||
$rows[] = $line;
|
|
||||||
}
|
|
||||||
$sql_data .= implode(",\n", $rows);
|
|
||||||
$sql_data .= "\n);\n\n";
|
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
case 'sqlite':
|
|
||||||
$names = preg_replace('/\w+/', "'\\0'", implode(', ', $table));
|
|
||||||
$sql = "SELECT sql, name FROM sqlite_master WHERE type!='meta' AND name IN ($names) ORDER BY type DESC, name;";
|
|
||||||
$result = $db->sql_query($sql);
|
|
||||||
|
|
||||||
while ($row = $db->sql_fetchrow($result))
|
|
||||||
{
|
|
||||||
$sql_data .= '# Table: ' . $row['name'] . "\n" . $row['sql'] . ";\n";
|
|
||||||
$sql_data .= "DROP TABLE IF EXISTS {$row['name']};\n";
|
|
||||||
$sql2 = "PRAGMA index_list('{$row['name']}');";
|
|
||||||
$result2 = $db->sql_query($sql2);
|
|
||||||
$ar = sqlite_fetch_all($result2);
|
|
||||||
$db->sql_freeresult($result2);
|
|
||||||
|
|
||||||
foreach ($ar as $value)
|
|
||||||
{
|
|
||||||
if (strpos($value['name'], 'autoindex') !== false)
|
|
||||||
{
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
$result3 = $db->sql_query("PRAGMA index_info('{$value['name']}');");
|
|
||||||
$ars = sqlite_fetch_all($result3);
|
|
||||||
$db->sql_freeresult($result3);
|
|
||||||
|
|
||||||
$fields = array();
|
|
||||||
foreach ($ars as $va)
|
|
||||||
{
|
|
||||||
$fields[] = $va['name'];
|
|
||||||
}
|
|
||||||
|
|
||||||
$sql_data .= 'CREATE ' . ($value['unique'] ? 'UNIQUE ' : '') . 'INDEX ' . $value['name'] . ' on ' . $row['name'] . ' (' . implode(', ', $fields) . ");\n";
|
|
||||||
}
|
|
||||||
$sql_data .= "\n";
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case 'postgres':
|
case 'postgres':
|
||||||
$get_seq_sql = "SELECT * FROM pg_class WHERE NOT relname ~ 'pg_.*'
|
|
||||||
AND relkind = 'S' ORDER BY relname";
|
|
||||||
|
|
||||||
$seq = $db->sql_query($get_seq_sql);
|
|
||||||
|
|
||||||
if ($num_seq = $db->sql_numrows($seq))
|
|
||||||
{
|
|
||||||
$return_val = "\n# Sequences \n";
|
|
||||||
$i_seq = 0;
|
|
||||||
|
|
||||||
while($i_seq < $num_seq)
|
|
||||||
{
|
|
||||||
$row = $db->sql_fetchrow($seq);
|
|
||||||
$sequence = $row['relname'];
|
|
||||||
|
|
||||||
$bool = false;
|
|
||||||
foreach($table as $table_name)
|
|
||||||
{
|
|
||||||
if (strpos($sequence, $table_name) === false)
|
|
||||||
{
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
$bool = true;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Don't create a sequence for tables we don't create
|
|
||||||
if (!$bool)
|
|
||||||
{
|
|
||||||
$i_seq++;
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
$get_props_sql = "SELECT * FROM $sequence";
|
|
||||||
$seq_props = $db->sql_query($get_props_sql);
|
|
||||||
|
|
||||||
if ($db->sql_numrows($seq_props) > 0)
|
|
||||||
{
|
|
||||||
$row1 = $db->sql_fetchrow($seq_props);
|
|
||||||
$row1['last_value'] = 1;
|
|
||||||
|
|
||||||
$return_val .= "DROP SEQUENCE $sequence;\n";
|
|
||||||
$return_val .= "CREATE SEQUENCE $sequence START " . $row1['last_value'] . ' INCREMENT ' . $row1['increment_by'] . ' MAXVALUE ' . $row1['max_value'] . ' MINVALUE ' . $row1['min_value'] . ' CACHE ' . $row1['cache_value'] . ";\n";
|
|
||||||
}
|
|
||||||
|
|
||||||
$i_seq++;
|
|
||||||
|
|
||||||
}
|
|
||||||
$sql_data .= $return_val . "\n";
|
|
||||||
|
|
||||||
}
|
|
||||||
$db->sql_freeresult($seq);
|
|
||||||
|
|
||||||
foreach ($table as $table_name)
|
|
||||||
{
|
|
||||||
$field_query = "SELECT a.attnum, a.attname AS field, t.typname as type, a.attlen AS length, a.atttypmod as lengthvar, a.attnotnull as notnull
|
|
||||||
FROM pg_class c, pg_attribute a, pg_type t
|
|
||||||
WHERE c.relname = '$table_name'
|
|
||||||
AND a.attnum > 0
|
|
||||||
AND a.attrelid = c.oid
|
|
||||||
AND a.atttypid = t.oid
|
|
||||||
ORDER BY a.attnum";
|
|
||||||
$result = $db->sql_query($field_query);
|
|
||||||
|
|
||||||
$sql_data .= '# Table: ' . $table_name . "\n";
|
$sql_data .= '# Table: ' . $table_name . "\n";
|
||||||
$sql_data .= "DROP TABLE $table_name;\n";
|
$sql_data .= "DROP TABLE $table_name;\n";
|
||||||
$sql_data .= "CREATE TABLE $table_name(\n";
|
|
||||||
$lines = array();
|
|
||||||
while ($row = $db->sql_fetchrow($result))
|
|
||||||
{
|
|
||||||
//
|
|
||||||
// Get the data from the table
|
|
||||||
//
|
|
||||||
$sql_get_default = "SELECT d.adsrc AS rowdefault
|
|
||||||
FROM pg_attrdef d, pg_class c
|
|
||||||
WHERE (c.relname = '$table_name')
|
|
||||||
AND (c.oid = d.adrelid)
|
|
||||||
AND d.adnum = " . $row['attnum'];
|
|
||||||
$def_res = $db->sql_query($sql_get_default);
|
|
||||||
|
|
||||||
if (!$def_res)
|
|
||||||
{
|
|
||||||
unset($row['rowdefault']);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
$row['rowdefault'] = @pg_fetch_result($def_res, 0, 'rowdefault');
|
|
||||||
}
|
|
||||||
|
|
||||||
if ($row['type'] == 'bpchar')
|
|
||||||
{
|
|
||||||
// Internally stored as bpchar, but isn't accepted in a CREATE TABLE statement.
|
|
||||||
$row['type'] = 'char';
|
|
||||||
}
|
|
||||||
|
|
||||||
$line = ' ' . $row['field'] . ' ' . $row['type'];
|
|
||||||
|
|
||||||
if (strpos($row['type'], 'char') !== false)
|
|
||||||
{
|
|
||||||
if ($row['lengthvar'] > 0)
|
|
||||||
{
|
|
||||||
$line .= '(' . ($row['lengthvar'] - 4) . ')';
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (strpos($row['type'], 'numeric') !== false)
|
|
||||||
{
|
|
||||||
$line .= '(';
|
|
||||||
$line .= sprintf("%s,%s", (($row['lengthvar'] >> 16) & 0xffff), (($row['lengthvar'] - 4) & 0xffff));
|
|
||||||
$line .= ')';
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!empty($row['rowdefault']))
|
|
||||||
{
|
|
||||||
$line .= ' DEFAULT ' . $row['rowdefault'];
|
|
||||||
}
|
|
||||||
|
|
||||||
if ($row['notnull'] == 't')
|
|
||||||
{
|
|
||||||
$line .= ' NOT NULL';
|
|
||||||
}
|
|
||||||
$lines[] = $line;
|
|
||||||
}
|
|
||||||
$db->sql_freeresult($result2);
|
|
||||||
|
|
||||||
|
|
||||||
// Get the listing of primary keys.
|
|
||||||
$sql_pri_keys = "SELECT ic.relname AS index_name, bc.relname AS tab_name, ta.attname AS column_name, i.indisunique AS unique_key, i.indisprimary AS primary_key
|
|
||||||
FROM pg_class bc, pg_class ic, pg_index i, pg_attribute ta, pg_attribute ia
|
|
||||||
WHERE (bc.oid = i.indrelid)
|
|
||||||
AND (ic.oid = i.indexrelid)
|
|
||||||
AND (ia.attrelid = i.indexrelid)
|
|
||||||
AND (ta.attrelid = bc.oid)
|
|
||||||
AND (bc.relname = '$table_name')
|
|
||||||
AND (ta.attrelid = i.indrelid)
|
|
||||||
AND (ta.attnum = i.indkey[ia.attnum-1])
|
|
||||||
ORDER BY index_name, tab_name, column_name ";
|
|
||||||
$result = $db->sql_query($sql_pri_keys);
|
|
||||||
|
|
||||||
$index_create = $index_rows = $primary_key = array();
|
|
||||||
|
|
||||||
// We do this in two steps. It makes placing the comma easier
|
|
||||||
while ($row = $db->sql_fetchrow($result))
|
|
||||||
{
|
|
||||||
if ($row['primary_key'] == 't')
|
|
||||||
{
|
|
||||||
$primary_key[] = $row['column_name'];
|
|
||||||
$primary_key_name = $row['index_name'];
|
|
||||||
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
// We have to store this all this info because it is possible to have a multi-column key...
|
|
||||||
// we can loop through it again and build the statement
|
|
||||||
$index_rows[$row['index_name']]['table'] = $table_name;
|
|
||||||
$index_rows[$row['index_name']]['unique'] = ($row['unique_key'] == 't') ? true : false;
|
|
||||||
$index_rows[$row['index_name']]['column_names'][] = $row['column_name'];
|
|
||||||
}
|
|
||||||
}
|
|
||||||
$db->sql_freeresult($result);
|
|
||||||
|
|
||||||
if (!empty($index_rows))
|
|
||||||
{
|
|
||||||
foreach ($index_rows as $idx_name => $props)
|
|
||||||
{
|
|
||||||
$index_create[] = 'CREATE ' . ($props['unique'] ? 'UNIQUE ' : '') . "INDEX $idx_name ON $table_name (" . implode(', ', $props['column_names']) . ");";
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!empty($primary_key))
|
|
||||||
{
|
|
||||||
$lines[] = " CONSTRAINT $primary_key_name PRIMARY KEY (" . implode(', ', $primary_key) . ")";
|
|
||||||
}
|
|
||||||
|
|
||||||
// Generate constraint clauses for CHECK constraints
|
|
||||||
$sql_checks = "SELECT conname as index_name, consrc
|
|
||||||
FROM pg_constraint, pg_class bc
|
|
||||||
WHERE conrelid = bc.oid
|
|
||||||
AND bc.relname = '$table_name'
|
|
||||||
AND NOT EXISTS (
|
|
||||||
SELECT *
|
|
||||||
FROM pg_constraint as c, pg_inherits as i
|
|
||||||
WHERE i.inhrelid = pg_constraint.conrelid
|
|
||||||
AND c.conname = pg_constraint.conname
|
|
||||||
AND c.consrc = pg_constraint.consrc
|
|
||||||
AND c.conrelid = i.inhparent
|
|
||||||
)";
|
|
||||||
$result = $db->sql_query($sql_checks);
|
|
||||||
|
|
||||||
// Add the constraints to the sql file.
|
|
||||||
while ($row = $db->sql_fetchrow($result))
|
|
||||||
{
|
|
||||||
if (!is_null($row['consrc']))
|
|
||||||
{
|
|
||||||
$lines[] = ' CONSTRAINT ' . $row['index_name'] . ' CHECK ' . $row['consrc'];
|
|
||||||
}
|
|
||||||
}
|
|
||||||
$db->sql_freeresult($result);
|
|
||||||
|
|
||||||
$sql_data .= implode(", \n", $lines);
|
|
||||||
$sql_data .= "\n);\n";
|
|
||||||
|
|
||||||
if (!empty($index_create))
|
|
||||||
{
|
|
||||||
$sql_data .= implode("\n", $index_create) . "\n\n";
|
|
||||||
}
|
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
default:
|
$sql_data .= $this->get_table_structure($table_name);
|
||||||
trigger_error('KungFuDeathGrip');
|
|
||||||
}
|
// Now write the data for the first time. :)
|
||||||
}
|
fwrite($fp, $sql_data);
|
||||||
|
|
||||||
|
$sql_data = '';
|
||||||
|
|
||||||
// Data
|
// Data
|
||||||
if ($type == 'full' || $type == 'data')
|
if ($type == 'full' || $type == 'data')
|
||||||
{
|
{
|
||||||
$sql_data .= "\n";
|
$sql_data .= "\n";
|
||||||
|
|
||||||
switch (SQL_LAYER)
|
switch (SQL_LAYER)
|
||||||
{
|
{
|
||||||
case 'mysqli':
|
case 'mysqli':
|
||||||
foreach ($table as $name)
|
|
||||||
{
|
$sql = "SELECT * FROM $table_name";
|
||||||
$sql = "SELECT * FROM $name";
|
|
||||||
$result = mysqli_query($db->db_connect_id, $sql, MYSQLI_USE_RESULT);
|
$result = mysqli_query($db->db_connect_id, $sql, MYSQLI_USE_RESULT);
|
||||||
if ($result != false)
|
if ($result != false)
|
||||||
{
|
{
|
||||||
|
|
@ -413,10 +126,12 @@ class acp_database
|
||||||
// Get field information
|
// Get field information
|
||||||
$field = mysqli_fetch_fields($result);
|
$field = mysqli_fetch_fields($result);
|
||||||
$field_set = array();
|
$field_set = array();
|
||||||
|
|
||||||
for ($j = 0; $j < $fields_cnt; $j++)
|
for ($j = 0; $j < $fields_cnt; $j++)
|
||||||
{
|
{
|
||||||
$field_set[$j] = $field[$j]->name;
|
$field_set[$j] = $field[$j]->name;
|
||||||
}
|
}
|
||||||
|
|
||||||
$fields = implode(', ', $field_set);
|
$fields = implode(', ', $field_set);
|
||||||
$values = array();
|
$values = array();
|
||||||
$schema_insert = 'INSERT INTO ' . $name . ' (' . $fields . ') VALUES (';
|
$schema_insert = 'INSERT INTO ' . $name . ' (' . $fields . ') VALUES (';
|
||||||
|
|
@ -429,7 +144,7 @@ class acp_database
|
||||||
{
|
{
|
||||||
$values[] = 'NULL';
|
$values[] = 'NULL';
|
||||||
}
|
}
|
||||||
elseif (($field[$j]->flags & 32768) && !($field[$j]->flags & 1024))
|
else if (($field[$j]->flags & 32768) && !($field[$j]->flags & 1024))
|
||||||
{
|
{
|
||||||
$values[] = $row[$j];
|
$values[] = $row[$j];
|
||||||
}
|
}
|
||||||
|
|
@ -439,35 +154,41 @@ class acp_database
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
$sql_data .= $schema_insert . implode(', ', $values) . ");\n";
|
$sql_data .= $schema_insert . implode(', ', $values) . ");\n";
|
||||||
|
|
||||||
$values = array();
|
$values = array();
|
||||||
|
fwrite($fp, $sql_data);
|
||||||
|
$sql_data = '';
|
||||||
}
|
}
|
||||||
mysqli_free_result($result);
|
mysqli_free_result($result);
|
||||||
}
|
}
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case 'mysql4':
|
case 'mysql4':
|
||||||
case 'mysql':
|
case 'mysql':
|
||||||
foreach ($table as $name)
|
|
||||||
{
|
$sql = "SELECT * FROM $table_name";
|
||||||
$sql = "SELECT * FROM $name";
|
|
||||||
$result = mysql_unbuffered_query($sql, $db->db_connect_id);
|
$result = mysql_unbuffered_query($sql, $db->db_connect_id);
|
||||||
|
|
||||||
if ($result != false)
|
if ($result != false)
|
||||||
{
|
{
|
||||||
$fields_cnt = mysql_num_fields($result);
|
$fields_cnt = mysql_num_fields($result);
|
||||||
|
|
||||||
// Get field information
|
// Get field information
|
||||||
$field = array();
|
$field = array();
|
||||||
for ($i = 0; $i < $fields_cnt; $i++) {
|
for ($i = 0; $i < $fields_cnt; $i++)
|
||||||
|
{
|
||||||
$field[] = mysql_fetch_field($result, $i);
|
$field[] = mysql_fetch_field($result, $i);
|
||||||
}
|
}
|
||||||
$field_set = array();
|
$field_set = array();
|
||||||
|
|
||||||
for ($j = 0; $j < $fields_cnt; $j++)
|
for ($j = 0; $j < $fields_cnt; $j++)
|
||||||
{
|
{
|
||||||
$field_set[$j] = $field[$j]->name;
|
$field_set[$j] = $field[$j]->name;
|
||||||
}
|
}
|
||||||
|
|
||||||
$fields = implode(', ', $field_set);
|
$fields = implode(', ', $field_set);
|
||||||
$values = array();
|
$values = array();
|
||||||
$schema_insert = 'INSERT INTO ' . $name . ' (' . $fields . ') VALUES (';
|
$schema_insert = 'INSERT INTO ' . $table_name . ' (' . $fields . ') VALUES (';
|
||||||
|
|
||||||
while ($row = mysql_fetch_row($result))
|
while ($row = mysql_fetch_row($result))
|
||||||
{
|
{
|
||||||
|
|
@ -477,7 +198,7 @@ class acp_database
|
||||||
{
|
{
|
||||||
$values[] = 'NULL';
|
$values[] = 'NULL';
|
||||||
}
|
}
|
||||||
elseif ($field[$j]->numeric && ($field[$j]->type !== 'timestamp'))
|
else if ($field[$j]->numeric && ($field[$j]->type !== 'timestamp'))
|
||||||
{
|
{
|
||||||
$values[] = $row[$j];
|
$values[] = $row[$j];
|
||||||
}
|
}
|
||||||
|
|
@ -487,17 +208,19 @@ class acp_database
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
$sql_data .= $schema_insert . implode(', ', $values) . ");\n";
|
$sql_data .= $schema_insert . implode(', ', $values) . ");\n";
|
||||||
|
|
||||||
$values = array();
|
$values = array();
|
||||||
|
fwrite($fp, $sql_data);
|
||||||
|
$sql_data = '';
|
||||||
}
|
}
|
||||||
mysql_free_result($result);
|
mysql_free_result($result);
|
||||||
}
|
}
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case 'sqlite':
|
case 'sqlite':
|
||||||
foreach ($table as $name)
|
|
||||||
{
|
|
||||||
$col_types = sqlite_fetch_column_types($name, $db->db_connect_id);
|
$col_types = sqlite_fetch_column_types($name, $db->db_connect_id);
|
||||||
$sql = "SELECT * FROM $name";
|
$sql = "SELECT * FROM $table_name";
|
||||||
$result = $db->sql_query($sql);
|
$result = $db->sql_query($sql);
|
||||||
|
|
||||||
while ($row = $db->sql_fetchrow($result))
|
while ($row = $db->sql_fetchrow($result))
|
||||||
|
|
@ -524,17 +247,19 @@ class acp_database
|
||||||
$data[] = $row_data;
|
$data[] = $row_data;
|
||||||
}
|
}
|
||||||
$sql_data .= 'INSERT INTO ' . $name . ' (' . implode(', ', $names) . ') VALUES ('. implode(', ', $data) .");\n";
|
$sql_data .= 'INSERT INTO ' . $name . ' (' . implode(', ', $names) . ') VALUES ('. implode(', ', $data) .");\n";
|
||||||
|
|
||||||
|
fwrite($fp, $sql_data);
|
||||||
|
$sql_data = '';
|
||||||
}
|
}
|
||||||
$db->sql_freeresult($result);
|
$db->sql_freeresult($result);
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case 'postgres':
|
case 'postgres':
|
||||||
foreach ($table as $name)
|
|
||||||
{
|
|
||||||
$aryType = $aryName = array();
|
$aryType = $aryName = array();
|
||||||
|
|
||||||
// Grab all of the data from current table.
|
// Grab all of the data from current table.
|
||||||
$sql = "SELECT * FROM {$name}";
|
$sql = "SELECT * FROM {$table_name}";
|
||||||
$result = $db->sql_query($sql);
|
$result = $db->sql_query($sql);
|
||||||
|
|
||||||
$i_num_fields = pg_num_fields($result);
|
$i_num_fields = pg_num_fields($result);
|
||||||
|
|
@ -548,6 +273,7 @@ class acp_database
|
||||||
while ($row = $db->sql_fetchrow($result))
|
while ($row = $db->sql_fetchrow($result))
|
||||||
{
|
{
|
||||||
$schema_vals = $schema_fields = array();
|
$schema_vals = $schema_fields = array();
|
||||||
|
|
||||||
// Build the SQL statement to recreate the data.
|
// Build the SQL statement to recreate the data.
|
||||||
for ($i = 0; $i < $i_num_fields; $i++)
|
for ($i = 0; $i < $i_num_fields; $i++)
|
||||||
{
|
{
|
||||||
|
|
@ -588,15 +314,18 @@ class acp_database
|
||||||
// Take the ordered fields and their associated data and build it
|
// Take the ordered fields and their associated data and build it
|
||||||
// into a valid sql statement to recreate that field in the data.
|
// into a valid sql statement to recreate that field in the data.
|
||||||
$sql_data .= "INSERT INTO $name (" . implode(', ', $schema_fields) . ') VALUES(' . implode(', ', $schema_vals) . ");\n";
|
$sql_data .= "INSERT INTO $name (" . implode(', ', $schema_fields) . ') VALUES(' . implode(', ', $schema_vals) . ");\n";
|
||||||
|
|
||||||
|
fwrite($fp, $sql_data);
|
||||||
|
$sql_data = '';
|
||||||
}
|
}
|
||||||
$db->sql_freeresult($result);
|
$db->sql_freeresult($result);
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
|
|
||||||
default:
|
default:
|
||||||
trigger_error('KungFuDeathGrip');
|
trigger_error('KungFuDeathGrip');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
switch (SQL_LAYER)
|
switch (SQL_LAYER)
|
||||||
{
|
{
|
||||||
|
|
@ -608,6 +337,12 @@ class acp_database
|
||||||
$time_stop = microtime(true);
|
$time_stop = microtime(true);
|
||||||
$sql_data .= "# END : $time_stop\n";
|
$sql_data .= "# END : $time_stop\n";
|
||||||
$sql_data .= "# DIFF : ".($time_stop-$time_start);
|
$sql_data .= "# DIFF : ".($time_stop-$time_start);
|
||||||
|
|
||||||
|
fwrite($fp, $sql_data);
|
||||||
|
fclose($fp);
|
||||||
|
|
||||||
|
unset($sql_data);
|
||||||
|
|
||||||
// Base file name
|
// Base file name
|
||||||
$file = $phpbb_root_path . 'store/' . $filename . $format;
|
$file = $phpbb_root_path . 'store/' . $filename . $format;
|
||||||
|
|
||||||
|
|
@ -627,7 +362,7 @@ class acp_database
|
||||||
$compress = new compress_tar('w', $file, $format);
|
$compress = new compress_tar('w', $file, $format);
|
||||||
}
|
}
|
||||||
|
|
||||||
$compress->add_data($sql_data, "$filename.sql");
|
$compress->add_data(file_get_contents($phpbb_root_path . 'store/' . $filename . '.sql'), "$filename.sql");
|
||||||
$compress->close();
|
$compress->close();
|
||||||
if ($where == 'download')
|
if ($where == 'download')
|
||||||
{
|
{
|
||||||
|
|
@ -638,9 +373,6 @@ class acp_database
|
||||||
|
|
||||||
case '.sql':
|
case '.sql':
|
||||||
|
|
||||||
$handle = @fopen($file, 'a');
|
|
||||||
@fwrite($handle, $sql_data);
|
|
||||||
@fclose($handle);
|
|
||||||
if ($where == 'download')
|
if ($where == 'download')
|
||||||
{
|
{
|
||||||
$mimetype = 'text/sql';
|
$mimetype = 'text/sql';
|
||||||
|
|
@ -818,6 +550,295 @@ class acp_database
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Return table structure
|
||||||
|
*/
|
||||||
|
function get_table_structure($table_name)
|
||||||
|
{
|
||||||
|
global $db;
|
||||||
|
|
||||||
|
$sql_data = '';
|
||||||
|
|
||||||
|
switch (SQL_LAYER)
|
||||||
|
{
|
||||||
|
case 'mysqli':
|
||||||
|
case 'mysql4':
|
||||||
|
case 'mysql':
|
||||||
|
|
||||||
|
$sql_data .= "CREATE TABLE $table_name(\n";
|
||||||
|
$rows = array();
|
||||||
|
|
||||||
|
$result = $db->sql_query("SHOW FIELDS FROM $table_name");
|
||||||
|
|
||||||
|
while ($row = $db->sql_fetchrow($result))
|
||||||
|
{
|
||||||
|
$line = ' ' . $row['Field'] . ' ' . $row['Type'];
|
||||||
|
|
||||||
|
if (!is_null($row['Default']))
|
||||||
|
{
|
||||||
|
$line .= " DEFAULT '{$row['Default']}'";
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($row['Null'] != 'YES')
|
||||||
|
{
|
||||||
|
$line .= ' NOT NULL';
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($row['Extra'] != '')
|
||||||
|
{
|
||||||
|
$line .= ' ' . $row['Extra'];
|
||||||
|
}
|
||||||
|
|
||||||
|
$rows[] = $line;
|
||||||
|
}
|
||||||
|
$db->sql_freeresult($result);
|
||||||
|
|
||||||
|
$result = $db->sql_query("SHOW KEYS FROM $table_name");
|
||||||
|
|
||||||
|
$index = array();
|
||||||
|
while ($row = $db->sql_fetchrow($result))
|
||||||
|
{
|
||||||
|
$kname = $row['Key_name'];
|
||||||
|
|
||||||
|
if ($kname != 'PRIMARY' && $row['Non_unique'] == 0)
|
||||||
|
{
|
||||||
|
$kname = "UNIQUE|$kname";
|
||||||
|
}
|
||||||
|
|
||||||
|
$index[$kname][] = $row['Column_name'];
|
||||||
|
}
|
||||||
|
$db->sql_freeresult($result);
|
||||||
|
|
||||||
|
$field = array();
|
||||||
|
foreach ($index as $key => $columns)
|
||||||
|
{
|
||||||
|
$line = ' ';
|
||||||
|
|
||||||
|
if ($key == 'PRIMARY')
|
||||||
|
{
|
||||||
|
$line .= 'PRIMARY KEY (' . implode(', ', $columns) . ')';
|
||||||
|
}
|
||||||
|
else if (strpos($key, 'UNIQUE') === 0)
|
||||||
|
{
|
||||||
|
$line .= 'UNIQUE ' . substr($key, 7) . ' (' . implode(', ', $columns) . ')';
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
$line .= "KEY $key (" . implode(', ', $columns) . ')';
|
||||||
|
}
|
||||||
|
|
||||||
|
$rows[] = $line;
|
||||||
|
}
|
||||||
|
|
||||||
|
$sql_data .= implode(",\n", $rows);
|
||||||
|
$sql_data .= "\n);\n\n";
|
||||||
|
|
||||||
|
break;
|
||||||
|
|
||||||
|
case 'sqlite':
|
||||||
|
|
||||||
|
$sql = "SELECT sql
|
||||||
|
FROM sqlite_master
|
||||||
|
WHERE type = 'table'
|
||||||
|
AND name = '" . $db->sql_escape($table_name) . "'
|
||||||
|
ORDER BY type DESC, name;";
|
||||||
|
$result = $db->sql_query($sql);
|
||||||
|
$row = $db->sql_fetchrow($result);
|
||||||
|
$db->sql_freeresult($result);
|
||||||
|
|
||||||
|
// Create Table
|
||||||
|
$sql_data .= $row['sql'] . "\n";
|
||||||
|
|
||||||
|
$result = $db->sql_query("PRAGMA index_list('" . $db->sql_escape($table_name) . "');");
|
||||||
|
|
||||||
|
$ar = array();
|
||||||
|
while ($row = $db->sql_fetchrow($result))
|
||||||
|
{
|
||||||
|
$ar[] = $row;
|
||||||
|
}
|
||||||
|
$db->sql_freeresult($result);
|
||||||
|
|
||||||
|
foreach ($ar as $value)
|
||||||
|
{
|
||||||
|
if (strpos($value['name'], 'autoindex') !== false)
|
||||||
|
{
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
$result = $db->sql_query("PRAGMA index_info('" . $db->sql_escape($value['name']) . "');");
|
||||||
|
|
||||||
|
$fields = array();
|
||||||
|
while ($row = $db->sql_fetchrow($result))
|
||||||
|
{
|
||||||
|
$fields[] = $row['name'];
|
||||||
|
}
|
||||||
|
$db->sql_freeresult($result);
|
||||||
|
|
||||||
|
$sql_data .= 'CREATE ' . ($value['unique'] ? 'UNIQUE ' : '') . 'INDEX ' . $value['name'] . ' on ' . $table_name . ' (' . implode(', ', $fields) . ");\n";
|
||||||
|
}
|
||||||
|
|
||||||
|
$sql_data .= "\n";
|
||||||
|
break;
|
||||||
|
|
||||||
|
case 'postgres':
|
||||||
|
|
||||||
|
$field_query = "SELECT a.attnum, a.attname AS field, t.typname as type, a.attlen AS length, a.atttypmod as lengthvar, a.attnotnull as notnull
|
||||||
|
FROM pg_class c, pg_attribute a, pg_type t
|
||||||
|
WHERE c.relname = '" . $db->sql_escape($table_name) . "'
|
||||||
|
AND a.attnum > 0
|
||||||
|
AND a.attrelid = c.oid
|
||||||
|
AND a.atttypid = t.oid
|
||||||
|
ORDER BY a.attnum";
|
||||||
|
$result = $db->sql_query($field_query);
|
||||||
|
|
||||||
|
$sql_data .= "CREATE TABLE $table_name(\n";
|
||||||
|
$lines = array();
|
||||||
|
while ($row = $db->sql_fetchrow($result))
|
||||||
|
{
|
||||||
|
// Get the data from the table
|
||||||
|
$sql_get_default = "SELECT d.adsrc AS rowdefault
|
||||||
|
FROM pg_attrdef d, pg_class c
|
||||||
|
WHERE (c.relname = '" . $db->sql_escape($table_name) . "')
|
||||||
|
AND (c.oid = d.adrelid)
|
||||||
|
AND d.adnum = " . $row['attnum'];
|
||||||
|
$def_res = $db->sql_query($sql_get_default);
|
||||||
|
|
||||||
|
if (!$def_res)
|
||||||
|
{
|
||||||
|
unset($row['rowdefault']);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
$row['rowdefault'] = $db->sql_fetchfield('rowdefault', 0, $def_res);
|
||||||
|
}
|
||||||
|
$db->sql_freeresult($def_res);
|
||||||
|
|
||||||
|
if ($row['type'] == 'bpchar')
|
||||||
|
{
|
||||||
|
// Internally stored as bpchar, but isn't accepted in a CREATE TABLE statement.
|
||||||
|
$row['type'] = 'char';
|
||||||
|
}
|
||||||
|
|
||||||
|
$line = ' ' . $row['field'] . ' ' . $row['type'];
|
||||||
|
|
||||||
|
if (strpos($row['type'], 'char') !== false)
|
||||||
|
{
|
||||||
|
if ($row['lengthvar'] > 0)
|
||||||
|
{
|
||||||
|
$line .= '(' . ($row['lengthvar'] - 4) . ')';
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (strpos($row['type'], 'numeric') !== false)
|
||||||
|
{
|
||||||
|
$line .= '(';
|
||||||
|
$line .= sprintf("%s,%s", (($row['lengthvar'] >> 16) & 0xffff), (($row['lengthvar'] - 4) & 0xffff));
|
||||||
|
$line .= ')';
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!empty($row['rowdefault']))
|
||||||
|
{
|
||||||
|
$line .= ' DEFAULT ' . $row['rowdefault'];
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($row['notnull'] == 't')
|
||||||
|
{
|
||||||
|
$line .= ' NOT NULL';
|
||||||
|
}
|
||||||
|
|
||||||
|
$lines[] = $line;
|
||||||
|
}
|
||||||
|
$db->sql_freeresult($result);
|
||||||
|
|
||||||
|
|
||||||
|
// Get the listing of primary keys.
|
||||||
|
$sql_pri_keys = "SELECT ic.relname AS index_name, bc.relname AS tab_name, ta.attname AS column_name, i.indisunique AS unique_key, i.indisprimary AS primary_key
|
||||||
|
FROM pg_class bc, pg_class ic, pg_index i, pg_attribute ta, pg_attribute ia
|
||||||
|
WHERE (bc.oid = i.indrelid)
|
||||||
|
AND (ic.oid = i.indexrelid)
|
||||||
|
AND (ia.attrelid = i.indexrelid)
|
||||||
|
AND (ta.attrelid = bc.oid)
|
||||||
|
AND (bc.relname = '" . $db->sql_escape($table_name) . "')
|
||||||
|
AND (ta.attrelid = i.indrelid)
|
||||||
|
AND (ta.attnum = i.indkey[ia.attnum-1])
|
||||||
|
ORDER BY index_name, tab_name, column_name ";
|
||||||
|
$result = $db->sql_query($sql_pri_keys);
|
||||||
|
|
||||||
|
$index_create = $index_rows = $primary_key = array();
|
||||||
|
|
||||||
|
// We do this in two steps. It makes placing the comma easier
|
||||||
|
while ($row = $db->sql_fetchrow($result))
|
||||||
|
{
|
||||||
|
if ($row['primary_key'] == 't')
|
||||||
|
{
|
||||||
|
$primary_key[] = $row['column_name'];
|
||||||
|
$primary_key_name = $row['index_name'];
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
// We have to store this all this info because it is possible to have a multi-column key...
|
||||||
|
// we can loop through it again and build the statement
|
||||||
|
$index_rows[$row['index_name']]['table'] = $table_name;
|
||||||
|
$index_rows[$row['index_name']]['unique'] = ($row['unique_key'] == 't') ? true : false;
|
||||||
|
$index_rows[$row['index_name']]['column_names'][] = $row['column_name'];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
$db->sql_freeresult($result);
|
||||||
|
|
||||||
|
if (!empty($index_rows))
|
||||||
|
{
|
||||||
|
foreach ($index_rows as $idx_name => $props)
|
||||||
|
{
|
||||||
|
$index_create[] = 'CREATE ' . ($props['unique'] ? 'UNIQUE ' : '') . "INDEX $idx_name ON $table_name (" . implode(', ', $props['column_names']) . ");";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!empty($primary_key))
|
||||||
|
{
|
||||||
|
$lines[] = " CONSTRAINT $primary_key_name PRIMARY KEY (" . implode(', ', $primary_key) . ")";
|
||||||
|
}
|
||||||
|
|
||||||
|
// Generate constraint clauses for CHECK constraints
|
||||||
|
$sql_checks = "SELECT conname as index_name, consrc
|
||||||
|
FROM pg_constraint, pg_class bc
|
||||||
|
WHERE conrelid = bc.oid
|
||||||
|
AND bc.relname = '" . $db->sql_escape($table_name) . "'
|
||||||
|
AND NOT EXISTS (
|
||||||
|
SELECT *
|
||||||
|
FROM pg_constraint as c, pg_inherits as i
|
||||||
|
WHERE i.inhrelid = pg_constraint.conrelid
|
||||||
|
AND c.conname = pg_constraint.conname
|
||||||
|
AND c.consrc = pg_constraint.consrc
|
||||||
|
AND c.conrelid = i.inhparent
|
||||||
|
)";
|
||||||
|
$result = $db->sql_query($sql_checks);
|
||||||
|
|
||||||
|
// Add the constraints to the sql file.
|
||||||
|
while ($row = $db->sql_fetchrow($result))
|
||||||
|
{
|
||||||
|
if (!is_null($row['consrc']))
|
||||||
|
{
|
||||||
|
$lines[] = ' CONSTRAINT ' . $row['index_name'] . ' CHECK ' . $row['consrc'];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
$db->sql_freeresult($result);
|
||||||
|
|
||||||
|
$sql_data .= implode(", \n", $lines);
|
||||||
|
$sql_data .= "\n);\n";
|
||||||
|
|
||||||
|
if (!empty($index_create))
|
||||||
|
{
|
||||||
|
$sql_data .= implode("\n", $index_create) . "\n\n";
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
|
||||||
|
default:
|
||||||
|
trigger_error('KungFuDeathGrip');
|
||||||
|
}
|
||||||
|
|
||||||
|
return $sql_data;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue