$time = time();

$filename = 'backup_' . $time . '_' . unique_id();

{

case 'mysql':

$extractor = new mysql_extractor($download, $store, $format, $filename, $time);

else

{

// We might wanna empty out all that junk :D

{

case 'sqlite':

case 'firebird':

break;

}

{

case 'mysql':

case 'sqlite':

case 'db2':

while (($sql = $fgetd($fp, ";\n", $read, $seek, $eof)) !== false)

{

}

break;

$delim = $query[9] . "\n";

continue;

}

}

break;

$sql = "SELECT domain_name

FROM information_schema.domains

WHERE domain_name = '$domain';";

{

}

}

else

{

}

if (substr($query, 0, 4) == 'COPY')

{

trigger_error(phpbb::$user->lang['RESTORE_FAILURE'] . adm_back_link($this->u_action), E_USER_WARNING);

}

}

}

}

break;

case 'oracle':

while (($sql = $fgetd($fp, "/\n", $read, $seek, $eof)) !== false)

{

}

break;

case 'mssql':

while (($sql = $fgetd($fp, "GO\n", $read, $seek, $eof)) !== false)

{

}

break;

}

function write_table($table_name)

{

$sql = 'SHOW CREATE TABLE ' . $table_name;

$sql_data = '# Table: ' . $table_name . "\n";

$sql_data .= "DROP TABLE IF EXISTS $table_name;\n";

$this->flush($sql_data . $row['Create Table'] . ";\n\n");

}

function write_data($table_name)

{

{

$this->write_data_mysqli($table_name);

}

{

$sql = "SELECT *

FROM $table_name";

if ($result != false)

{

$fields_cnt = mysqli_num_fields($result);

{

$sql = "SELECT *

FROM $table_name";

if ($result != false)

{

$sql = "SELECT sql

FROM sqlite_master

WHERE type = 'table'

ORDER BY type DESC, name;";

// Create Table

$sql_data .= $row['sql'] . ";\n";

$ar = array();

{

$ar[] = $row;

}

foreach ($ar as $value)

{

continue;

}

$fields = array();

{

$fields[] = $row['name'];

}

$sql_data .= 'CREATE ' . ($value['unique'] ? 'UNIQUE ' : '') . 'INDEX ' . $value['name'] . ' on ' . $table_name . ' (' . implode(', ', $fields) . ");\n";

}

if ($proper)

{

}

else

{

FROM sqlite_master

WHERE type = 'table'

AND name = '" . $table_name . "'";

$table_data = preg_replace('#CREATE\s+TABLE\s+"?' . $table_name . '"?#i', '', $table_data);

$table_data = trim($table_data);

$sql = "SELECT *

FROM $table_name";

$rows = sqlite_fetch_all($result, SQLITE_ASSOC);

$sql_insert = 'INSERT INTO ' . $table_name . ' (' . implode(', ', array_keys($col_types)) . ') VALUES (';

foreach ($rows as $row)

FROM INFORMATION_SCHEMA.domains a, INFORMATION_SCHEMA.column_domain_usage b

WHERE a.domain_name = b.domain_name

AND b.table_name = '{$table_name}'";

{

if (empty($domains_created[$row['domain_name']]))

{

FROM pg_class

WHERE relkind = 'S'

AND relname = '{$table_name}_seq'";

// We don't even care about storing the results. We already know the answer if we get rows back.

{

$sql_data .= "DROP SEQUENCE {$table_name}_seq;\n";

$sql_data .= "CREATE SEQUENCE {$table_name}_seq;\n";

}

$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

AND a.attnum > 0

AND a.attrelid = c.oid

AND a.atttypid = t.oid

ORDER BY a.attnum";

$sql_data .= "CREATE TABLE $table_name(\n";

$lines = array();

{

// Get the data from the table

$sql_get_default = "SELECT pg_get_expr(d.adbin, d.adrelid) as rowdefault

FROM pg_attrdef d, pg_class c

AND (c.oid = d.adrelid)

AND d.adnum = " . $row['attnum'];

if (!$def_res)

{

}

else

{

}

if ($row['type'] == 'bpchar')

{

$lines[] = $line;

}

// Get the listing of primary keys.

AND (ic.oid = i.indexrelid)

AND (ia.attrelid = i.indexrelid)

AND (ta.attrelid = bc.oid)

AND (ta.attrelid = i.indrelid)

AND (ta.attnum = i.indkey[ia.attnum-1])

ORDER BY index_name, tab_name, column_name";

$index_create = $index_rows = $primary_key = array();

// We do this in two steps. It makes placing the comma easier

{

if ($row['primary_key'] == 't')

{

$index_rows[$row['index_name']]['column_names'][] = $row['column_name'];

}

}

if (!empty($index_rows))

{

$sql_checks = "SELECT conname as index_name, consrc

FROM pg_constraint, pg_class bc

WHERE conrelid = bc.oid

AND NOT EXISTS (

SELECT *

FROM pg_constraint as c, pg_inherits as i

AND c.consrc = pg_constraint.consrc

AND c.conrelid = i.inhparent

)";

// Add the constraints to the sql file.

{

if (!is_null($row['consrc']))

{

$lines[] = ' CONSTRAINT ' . $row['index_name'] . ' CHECK ' . $row['consrc'];

}

}

$sql_data .= implode(", \n", $lines);

$sql_data .= "\n);\n";

// Grab all of the data from current table.

$sql = "SELECT *

FROM $table_name";

$i_num_fields = pg_num_fields($result);

$seq = '';

WHERE (c.relname = '{$table_name}')

AND (c.oid = d.adrelid)

AND d.adnum = " . strval($i + 1);

{

// Determine if we must reset the sequences

if (strpos($row['rowdefault'], "nextval('") === 0)

}

$this->flush("COPY $table_name (" . implode(', ', $ary_name) . ') FROM stdin;' . "\n");

{

$schema_vals = array();

// into a valid sql statement to recreate that field in the data.

$this->flush(implode("\t", $schema_vals) . "\n");

}

$this->flush("\\.\n");

// Write out the sequence statements

$sql = "SELECT COLUMN_NAME, COLUMN_DEFAULT, IS_NULLABLE, DATA_TYPE, CHARACTER_MAXIMUM_LENGTH, COLUMNPROPERTY(object_id(TABLE_NAME), COLUMN_NAME, 'IsIdentity') as IS_IDENTITY

FROM INFORMATION_SCHEMA.COLUMNS

WHERE TABLE_NAME = '$table_name'";

{

$line = "\t[{$row['COLUMN_NAME']}] [{$row['DATA_TYPE']}]";

$rows[] = $line;

}

$sql_data .= implode(",\n", $rows);

$sql_data .= "\n) ON [PRIMARY]";

$sql = "SELECT CONSTRAINT_NAME, COLUMN_NAME

FROM INFORMATION_SCHEMA.KEY_COLUMN_USAGE

WHERE TABLE_NAME = '$table_name'";

{

if (!sizeof($rows))

{

$sql_data .= implode(",\n", $rows);

$sql_data .= "\n\t) ON [PRIMARY] \nGO\n";

}

$index = array();

$sql = "EXEC sp_statistics '$table_name'";

{

if ($row['TYPE'] == 3)

{

$index[$row['INDEX_NAME']][] = '[' . $row['COLUMN_NAME'] . ']';

}

}

foreach ($index as $index_name => $column_name)

{

function write_data($table_name)

{

{

$this->write_data_mssql($table_name);

}

{

$this->write_data_odbc($table_name);

}

// Grab all of the data from current table.

$sql = "SELECT *

FROM $table_name";

$retrieved_data = mssql_num_rows($result);

$sql = "SELECT 1 as has_identity

FROM INFORMATION_SCHEMA.COLUMNS

WHERE COLUMNPROPERTY(object_id('$table_name'), COLUMN_NAME, 'IsIdentity') = 1";

if (!empty($row2['has_identity']))

{

$sql_data .= "\nSET IDENTITY_INSERT $table_name ON\nGO\n";

$ident_set = true;

}

}

{

$schema_vals = $schema_fields = array();

$this->flush($sql_data);

$sql_data = '';

}

if ($retrieved_data && $ident_set)

{

// Grab all of the data from current table.

$sql = "SELECT *

FROM $table_name";

$retrieved_data = odbc_num_rows($result);

$sql = "SELECT 1 as has_identity

FROM INFORMATION_SCHEMA.COLUMNS

WHERE COLUMNPROPERTY(object_id('$table_name'), COLUMN_NAME, 'IsIdentity') = 1";

if (!empty($row2['has_identity']))

{

$sql_data .= "\nSET IDENTITY_INSERT $table_name ON\nGO\n";

$ident_set = true;

}

}

$i_num_fields = odbc_num_fields($result);

$ary_name[$i] = odbc_field_name($result, $i + 1);

}

{

$schema_vals = $schema_fields = array();

$sql_data = '';

}

if ($retrieved_data && $ident_set)

{

$sql = "SELECT colname, typename, length, default, identity, nulls

FROM syscat.columns

WHERE tabname = '$table_name'";

{

$line = "\t{$row['colname']} {$row['typename']}";

$rows[] = $line;

}

// switch to db2_columns()?

$sql = "SELECT colname

FROM SYSCAT.KEYCOLUSE

WHERE tabname = '$table_name'";

$prim_cols = array();

{

$prim_cols[] = $row['colname'];

}

if (sizeof($prim_cols))

{

$rows[] = "\tPRIMARY KEY (" . implode($prim_cols) . ')';

FROM SYSCAT.INDEXES

WHERE TABNAME = '$table_name'

AND UNIQUERULE <> 'P'";

$index = array();

{

$inds = explode('+', $row['colnames']);

unset($inds[0]);

$sql_data .= 'CREATE INDEX ' . $row['indname'] . ' ON ' . $table_name . ' (' . implode(', ', $inds) . ") PCTFREE 10 MINPCTUSED 10 ALLOW REVERSE SCANS PAGE SPLIT SYMMETRIC COLLECT SAMPLED DETAILED STATISTICS;\n";

}

$this->flush($sql_data);

}

function write_data($table_name)

{

$ary_type = $ary_name = array();

$i = 0;

{

$ary_type[$i] = $row['type_name'];

$ary_name[$i++] = strtolower($row['column_name']);

}

// Grab all of the data from current table.

$sql = "SELECT *

FROM $table_name";

$sql_data = '';

$i_num_fields = $i;

{

$schema_vals = $schema_fields = array();

$this->flush($sql_data);

}

}

}

$sql = "SELECT COLUMN_NAME, DATA_TYPE, DATA_PRECISION, DATA_LENGTH, NULLABLE, DATA_DEFAULT

FROM ALL_TAB_COLS

WHERE table_name = '{$table_name}'";

$rows = array();

{

$line = ' "' . $row['column_name'] . '" ' . $row['data_type'];

}

$rows[] = $line;

}

$sql = "SELECT A.CONSTRAINT_NAME, A.COLUMN_NAME

FROM USER_CONS_COLUMNS A, USER_CONSTRAINTS B

WHERE A.CONSTRAINT_NAME = B.CONSTRAINT_NAME

AND B.CONSTRAINT_TYPE = 'P'

AND A.TABLE_NAME = '{$table_name}'";

{

$rows[] = " CONSTRAINT {$row['constraint_name']} PRIMARY KEY ({$row['column_name']})";

}

$sql = "SELECT A.CONSTRAINT_NAME, A.COLUMN_NAME

FROM USER_CONS_COLUMNS A, USER_CONSTRAINTS B

WHERE A.CONSTRAINT_NAME = B.CONSTRAINT_NAME

AND B.CONSTRAINT_TYPE = 'U'

AND A.TABLE_NAME = '{$table_name}'";

{

$rows[] = " CONSTRAINT {$row['constraint_name']} UNIQUE ({$row['column_name']})";

}

$sql_data .= implode(",\n", $rows);

$sql_data .= "\n)\n\\";

WHERE A.REFERENCED_TYPE = 'SEQUENCE'

AND A.NAME = B.TRIGGER_NAME

AND B.TABLE_NAME = '{$table_name}'";

{

$sql_data .= "\nCREATE SEQUENCE {$row['referenced_name']}\\\n";

}

$sql = "SELECT DESCRIPTION, WHEN_CLAUSE, TRIGGER_BODY

FROM USER_TRIGGERS

WHERE TABLE_NAME = '{$table_name}'";

{

$sql_data .= "\nCREATE OR REPLACE TRIGGER {$row['description']}WHEN ({$row['when_clause']})\n{$row['trigger_body']}\\";

}

$sql = "SELECT A.INDEX_NAME, B.COLUMN_NAME

FROM USER_INDEXES A, USER_IND_COLUMNS B

WHERE A.UNIQUENESS = 'NONUNIQUE'

AND A.INDEX_NAME = B.INDEX_NAME

AND B.TABLE_NAME = '{$table_name}'";

$index = array();

{

$index[$row['index_name']][] = $row['column_name'];

}

{

$sql_data .= "\nCREATE INDEX $index_name ON $table_name(" . implode(', ', $column_names) . ")\n\\";

}

$this->flush($sql_data);

}

// Grab all of the data from current table.

$sql = "SELECT *

FROM $table_name";

$i_num_fields = ocinumcols($result);

$sql_data = '';

{

$schema_vals = $schema_fields = array();

$this->flush($sql_data);

}

}

function write_start($prefix)

// Grab all of the data from current table.

$sql = "SELECT *

FROM $table_name";

$i_num_fields = ibase_num_fields($result);

$ary_name[$i] = $info['name'];

}

{

$schema_vals = $schema_fields = array();

$this->flush($sql_data);

}

}

function write_table($table_name)

WHERE F.RDB$SYSTEM_FLAG = 0

AND R.RDB$RELATION_NAME = \''. $table_name . '\'

ORDER BY R.RDB$FIELD_POSITION';

$rows = array();

{

$line = "\t" . '"' . $row['fname'] . '" ' . $data_types[$row['ftype']];

}

$rows[] = $line;

}

$sql_data .= implode(",\n", $rows);

$sql_data .= "\n);\n";

AND (IDX.RDB$INDEX_NAME = RC.RDB$INDEX_NAME)

AND (RC.RDB$RELATION_NAME = \''. $table_name . '\')

ORDER BY I.RDB$FIELD_POSITION';

{

$keys[] = $row['name'];

}

$sql_data .= "\nALTER TABLE $table_name ADD PRIMARY KEY (" . implode(', ', $keys) . ');';

}

$sql = 'SELECT I.RDB$INDEX_NAME as INAME, I.RDB$UNIQUE_FLAG as UFLAG, S.RDB$FIELD_NAME as FNAME

FROM RDB$INDICES I JOIN RDB$INDEX_SEGMENTS S ON S.RDB$INDEX_NAME=I.RDB$INDEX_NAME

AND I.RDB$RELATION_NAME = \''. $table_name . '\'

AND I.RDB$INDEX_NAME NOT STARTING WITH \'RDB$\'

ORDER BY S.RDB$FIELD_POSITION';

$index = array();

{

$index[$row['iname']]['unique'] = !empty($row['uflag']);

$index[$row['iname']]['values'][] = $row['fname'];

}

$sql_data .= "\n";

$sql = 'SELECT D1.RDB$DEPENDENT_NAME as DNAME, D1.RDB$FIELD_NAME as FNAME, D1.RDB$DEPENDENT_TYPE, R1.RDB$RELATION_NAME

FROM RDB$DEPENDENCIES D1

AND (D2.RDB$DEPENDENT_NAME = F2.RDB$FIELD_SOURCE)

AND (D2.RDB$DEPENDED_ON_NAME = \'' . $table_name . '\')

ORDER BY 1, 2';

{

$sql = 'SELECT T1.RDB$DEPENDED_ON_NAME as GEN, T1.RDB$FIELD_NAME, T1.RDB$DEPENDED_ON_TYPE

FROM RDB$DEPENDENCIES T1

AND (D.RDB$DEPENDENT_NAME = F.RDB$FIELD_SOURCE)

AND (F.RDB$RELATION_NAME = \'' . $row['dname'] . '\')

ORDER BY 1,2';

$gen_name = $row2['gen'];

$sql_data .= "\nDROP GENERATOR " . $gen_name . ";";

$this->flush($sql_data);

}

}