- $time_start = microtime(true);

- // Structure

- if ($type == 'full' || $type == 'structure')

- switch (SQL_LAYER)

- case 'mysqli':

- case 'mysql4':

- case 'mysql':

- foreach ($table as $table_name)

- {

- $row = $rows = array();

- $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;

- 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':

- $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 .= "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;

- default:

- trigger_error('KungFuDeathGrip');

- }

- }

- // Data

- if ($type == 'full' || $type == 'data')

- {

- $sql_data .= "\n";

- switch (SQL_LAYER)

- {

- case 'mysqli':

- foreach ($table as $name)

- {

- $sql = "SELECT * FROM $name";

- elseif (($field[$j]->flags & 32768) && !($field[$j]->flags & 1024))

- }

- break;

- case 'mysql4':

- case 'mysql':

- foreach ($table as $name)

- {

- $sql = "SELECT * FROM $name";

- for ($i = 0; $i < $fields_cnt; $i++) {

- $field_set[$j] = $field[$j]->name;

- $schema_insert = 'INSERT INTO ' . $name . ' (' . $fields . ') VALUES (';

- elseif ($field[$j]->numeric && ($field[$j]->type !== 'timestamp'))

- }

- break;

- case 'sqlite':

- foreach ($table as $name)

- {

- $sql = "SELECT * FROM $name";

- }

- break;

- case 'postgres':

- foreach ($table as $name)

- {

- $sql = "SELECT * FROM {$name}";

- }

- break;

- default:

- trigger_error('KungFuDeathGrip');

- $compress->add_data($sql_data, "$filename.sql");

- $handle = @fopen($file, 'a');

- @fwrite($handle, $sql_data);

- @fclose($handle);