1 files changed, 39 insertions, 694 deletions
diff --git a/phpBB/develop/create_schema_files.php b/phpBB/develop/create_schema_files.php
index 5ef278d493..09bc4c4085 100644
--- a/phpBB/develop/create_schema_files.php
+++ b/phpBB/develop/create_schema_files.php
@@ -1,10 +1,17 @@
 <?php
 /**
 *
-* @package phpBB3
-* @copyright (c) 2006 phpBB Group
-* @license http://opensource.org/licenses/gpl-2.0.php GNU General Public License v2
+* This file is part of the phpBB Forum Software package.
 *
+* @copyright (c) phpBB Limited <https://www.phpbb.com>
+* @license GNU General Public License, version 2 (GPL-2.0)
+*
+* For full copyright and license information, please see
+* the docs/CREDITS.txt file.
+*
+*/
+
+/**
 * This file creates new schema files for every database.
 * The filenames will be prefixed with an underscore to not overwrite the current schema files.
 *
@@ -12,6 +19,15 @@
 */
 
 $schema_path = dirname(__FILE__) . '/../install/schemas/';
+$supported_dbms = array(
+	'mssql',
+	'mysql_40',
+	'mysql_41',
+	'oracle',
+	'postgres',
+	'sqlite',
+);
+$table_prefix = 'phpbb_';
 
 if (!is_writable($schema_path))
 {
@@ -19,700 +35,29 @@ if (!is_writable($schema_path))
 }
 
 define('IN_PHPBB', true);
+$phpbb_root_path = dirname(__FILE__) . '/../';
+$phpEx = substr(strrchr(__FILE__, '.'), 1);
 
-require(dirname(__FILE__) . '/../includes/db/schema_data.php');
-require(dirname(__FILE__) . '/../phpbb/db/tools.php');
-
-$dbms_type_map = phpbb\db\tools::get_dbms_type_map();
-
-// A list of types being unsigned for better reference in some db's
-$unsigned_types = array('UINT', 'UINT:', 'USINT', 'BOOL', 'TIMESTAMP');
-$supported_dbms = array('firebird', 'mssql', 'mysql_40', 'mysql_41', 'oracle', 'postgres', 'sqlite');
-
-foreach ($supported_dbms as $dbms)
-{
-	$fp = fopen($schema_path . $dbms . '_schema.sql', 'wb');
-
-	$line = '';
-
-	// Write Header
-	switch ($dbms)
-	{
-		case 'mysql_40':
-		case 'mysql_41':
-		case 'firebird':
-		case 'sqlite':
-			fwrite($fp, "# DO NOT EDIT THIS FILE, IT IS GENERATED\n");
-			fwrite($fp, "#\n");
-			fwrite($fp, "# To change the contents of this file, edit\n");
-			fwrite($fp, "# phpBB/develop/create_schema_files.php and\n");
-			fwrite($fp, "# run it.\n");
-		break;
-
-		case 'mssql':
-		case 'oracle':
-		case 'postgres':
-			fwrite($fp, "/*\n");
-			fwrite($fp, " * DO NOT EDIT THIS FILE, IT IS GENERATED\n");
-			fwrite($fp, " *\n");
-			fwrite($fp, " * To change the contents of this file, edit\n");
-			fwrite($fp, " * phpBB/develop/create_schema_files.php and\n");
-			fwrite($fp, " * run it.\n");
-			fwrite($fp, " */\n\n");
-		break;
-	}
-
-	switch ($dbms)
-	{
-		case 'firebird':
-			$line .= custom_data('firebird') . "\n";
-		break;
-
-		case 'sqlite':
-			$line .= "BEGIN TRANSACTION;\n\n";
-		break;
-
-		case 'oracle':
-			$line .= custom_data('oracle') . "\n";
-		break;
-
-		case 'postgres':
-			$line .= "BEGIN;\n\n";
-			$line .= custom_data('postgres') . "\n";
-		break;
-	}
-
-	fwrite($fp, $line);
-
-	foreach ($schema_data as $table_name => $table_data)
-	{
-		// Write comment about table
-		switch ($dbms)
-		{
-			case 'mysql_40':
-			case 'mysql_41':
-			case 'firebird':
-			case 'sqlite':
-				fwrite($fp, "# Table: '{$table_name}'\n");
-			break;
-
-			case 'mssql':
-			case 'oracle':
-			case 'postgres':
-				fwrite($fp, "/*\n\tTable: '{$table_name}'\n*/\n");
-			break;
-		}
-
-		// Create Table statement
-		$generator = $textimage = false;
-		$line = '';
-
-		switch ($dbms)
-		{
-			case 'mysql_40':
-			case 'mysql_41':
-			case 'firebird':
-			case 'oracle':
-			case 'sqlite':
-			case 'postgres':
-				$line = "CREATE TABLE {$table_name} (\n";
-			break;
-
-			case 'mssql':
-				$line = "CREATE TABLE [{$table_name}] (\n";
-			break;
-		}
-
-		// Table specific so we don't get overlap
-		$modded_array = array();
-
-		// Write columns one by one...
-		foreach ($table_data['COLUMNS'] as $column_name => $column_data)
-		{
-			if (strlen($column_name) > 30)
-			{
-				trigger_error("Column name '$column_name' on table '$table_name' is too long. The maximum is 30 characters.", E_USER_ERROR);
-			}
-			if (isset($column_data[2]) && $column_data[2] == 'auto_increment' && strlen($column_name) > 26) // "${column_name}_gen"
-			{
-				trigger_error("Index name '${column_name}_gen' on table '$table_name' is too long. The maximum is 30 characters.", E_USER_ERROR);
-			}
-
-			// Get type
-			if (strpos($column_data[0], ':') !== false)
-			{
-				list($orig_column_type, $column_length) = explode(':', $column_data[0]);
-				if (!is_array($dbms_type_map[$dbms][$orig_column_type . ':']))
-				{
-					$column_type = sprintf($dbms_type_map[$dbms][$orig_column_type . ':'], $column_length);
-				}
-				else
-				{
-					if (isset($dbms_type_map[$dbms][$orig_column_type . ':']['rule']))
-					{
-						switch ($dbms_type_map[$dbms][$orig_column_type . ':']['rule'][0])
-						{
-							case 'div':
-								$column_length /= $dbms_type_map[$dbms][$orig_column_type . ':']['rule'][1];
-								$column_length = ceil($column_length);
-								$column_type = sprintf($dbms_type_map[$dbms][$orig_column_type . ':'][0], $column_length);
-							break;
-						}
-					}
-
-					if (isset($dbms_type_map[$dbms][$orig_column_type . ':']['limit']))
-					{
-						switch ($dbms_type_map[$dbms][$orig_column_type . ':']['limit'][0])
-						{
-							case 'mult':
-								$column_length *= $dbms_type_map[$dbms][$orig_column_type . ':']['limit'][1];
-								if ($column_length > $dbms_type_map[$dbms][$orig_column_type . ':']['limit'][2])
-								{
-									$column_type = $dbms_type_map[$dbms][$orig_column_type . ':']['limit'][3];
-									$modded_array[$column_name] = $column_type;
-								}
-								else
-								{
-									$column_type = sprintf($dbms_type_map[$dbms][$orig_column_type . ':'][0], $column_length);
-								}
-							break;
-						}
-					}
-				}
-				$orig_column_type .= ':';
-			}
-			else
-			{
-				$orig_column_type = $column_data[0];
-				$column_type = $dbms_type_map[$dbms][$column_data[0]];
-				if ($column_type == 'text' || $column_type == 'blob')
-				{
-					$modded_array[$column_name] = $column_type;
-				}
-			}
-
-			// Adjust default value if db-dependent specified
-			if (is_array($column_data[1]))
-			{
-				$column_data[1] = (isset($column_data[1][$dbms])) ? $column_data[1][$dbms] : $column_data[1]['default'];
-			}
-
-			switch ($dbms)
-			{
-				case 'mysql_40':
-				case 'mysql_41':
-					$line .= "\t{$column_name} {$column_type} ";
-
-					// For hexadecimal values do not use single quotes
-					if (!is_null($column_data[1]) && substr($column_type, -4) !== 'text' && substr($column_type, -4) !== 'blob')
-					{
-						$line .= (strpos($column_data[1], '0x') === 0) ? "DEFAULT {$column_data[1]} " : "DEFAULT '{$column_data[1]}' ";
-					}
-					$line .= 'NOT NULL';
-
-					if (isset($column_data[2]))
-					{
-						if ($column_data[2] == 'auto_increment')
-						{
-							$line .= ' auto_increment';
-						}
-						else if ($dbms === 'mysql_41' && $column_data[2] == 'true_sort')
-						{
-							$line .= ' COLLATE utf8_unicode_ci';
-						}
-					}
-
-					$line .= ",\n";
-				break;
-
-				case 'sqlite':
-					if (isset($column_data[2]) && $column_data[2] == 'auto_increment')
-					{
-						$line .= "\t{$column_name} INTEGER PRIMARY KEY ";
-						$generator = $column_name;
-					}
-					else
-					{
-						$line .= "\t{$column_name} {$column_type} ";
-					}
-
-					$line .= 'NOT NULL ';
-					$line .= (!is_null($column_data[1])) ? "DEFAULT '{$column_data[1]}'" : '';
-					$line .= ",\n";
-				break;
-
-				case 'firebird':
-					$line .= "\t{$column_name} {$column_type} ";
-
-					if (!is_null($column_data[1]))
-					{
-						$line .= 'DEFAULT ' . ((is_numeric($column_data[1])) ? $column_data[1] : "'{$column_data[1]}'") . ' ';
-					}
-
-					$line .= 'NOT NULL';
-
-					// This is a UNICODE column and thus should be given it's fair share
-					if (preg_match('/^X?STEXT_UNI|VCHAR_(CI|UNI:?)/', $column_data[0]))
-					{
-						$line .= ' COLLATE UNICODE';
-					}
-
-					$line .= ",\n";
-
-					if (isset($column_data[2]) && $column_data[2] == 'auto_increment')
-					{
-						$generator = $column_name;
-					}
-				break;
-
-				case 'mssql':
-					if ($column_type == '[text]')
-					{
-						$textimage = true;
-					}
-
-					$line .= "\t[{$column_name}] {$column_type} ";
-
-					if (!is_null($column_data[1]))
-					{
-						// For hexadecimal values do not use single quotes
-						if (strpos($column_data[1], '0x') === 0)
-						{
-							$line .= 'DEFAULT (' . $column_data[1] . ') ';
-						}
-						else
-						{
-							$line .= 'DEFAULT (' . ((is_numeric($column_data[1])) ? $column_data[1] : "'{$column_data[1]}'") . ') ';
-						}
-					}
-
-					if (isset($column_data[2]) && $column_data[2] == 'auto_increment')
-					{
-						$line .= 'IDENTITY (1, 1) ';
-					}
-
-					$line .= 'NOT NULL';
-					$line .= " ,\n";
-				break;
-
-				case 'oracle':
-					$line .= "\t{$column_name} {$column_type} ";
-					$line .= (!is_null($column_data[1])) ? "DEFAULT '{$column_data[1]}' " : '';
-
-					// In Oracle empty strings ('') are treated as NULL.
-					// Therefore in oracle we allow NULL's for all DEFAULT '' entries
-					$line .= ($column_data[1] === '') ? ",\n" : "NOT NULL,\n";
-
-					if (isset($column_data[2]) && $column_data[2] == 'auto_increment')
-					{
-						$generator = $column_name;
-					}
-				break;
-
-				case 'postgres':
-					$line .= "\t{$column_name} {$column_type} ";
-
-					if (isset($column_data[2]) && $column_data[2] == 'auto_increment')
-					{
-						$line .= "DEFAULT nextval('{$table_name}_seq'),\n";
-
-						// Make sure the sequence will be created before creating the table
-						$line = "CREATE SEQUENCE {$table_name}_seq;\n\n" . $line;
-					}
-					else
-					{
-						$line .= (!is_null($column_data[1])) ? "DEFAULT '{$column_data[1]}' " : '';
-						$line .= "NOT NULL";
-
-						// Unsigned? Then add a CHECK contraint
-						if (in_array($orig_column_type, $unsigned_types))
-						{
-							$line .= " CHECK ({$column_name} >= 0)";
-						}
-
-						$line .= ",\n";
-					}
-				break;
-			}
-		}
-
-		switch ($dbms)
-		{
-			case 'firebird':
-				// Remove last line delimiter...
-				$line = substr($line, 0, -2);
-				$line .= "\n);;\n\n";
-			break;
-
-			case 'mssql':
-				$line = substr($line, 0, -2);
-				$line .= "\n) ON [PRIMARY]" . (($textimage) ? ' TEXTIMAGE_ON [PRIMARY]' : '') . "\n";
-				$line .= "GO\n\n";
-			break;
-		}
-
-		// Write primary key
-		if (isset($table_data['PRIMARY_KEY']))
-		{
-			if (!is_array($table_data['PRIMARY_KEY']))
-			{
-				$table_data['PRIMARY_KEY'] = array($table_data['PRIMARY_KEY']);
-			}
-
-			switch ($dbms)
-			{
-				case 'mysql_40':
-				case 'mysql_41':
-				case 'postgres':
-					$line .= "\tPRIMARY KEY (" . implode(', ', $table_data['PRIMARY_KEY']) . "),\n";
-				break;
-
-				case 'firebird':
-					$line .= "ALTER TABLE {$table_name} ADD PRIMARY KEY (" . implode(', ', $table_data['PRIMARY_KEY']) . ");;\n\n";
-				break;
+include($phpbb_root_path . 'vendor/autoload.php');
+include($phpbb_root_path . 'includes/constants.' . $phpEx);
+require($phpbb_root_path . 'phpbb/class_loader.' . $phpEx);
+$phpbb_class_loader = new \phpbb\class_loader('phpbb\\', "{$phpbb_root_path}phpbb/", $phpEx);
+$phpbb_class_loader->register();
 
-				case 'sqlite':
-					if ($generator === false || !in_array($generator, $table_data['PRIMARY_KEY']))
-					{
-						$line .= "\tPRIMARY KEY (" . implode(', ', $table_data['PRIMARY_KEY']) . "),\n";
-					}
-				break;
+$finder = new \phpbb\finder(new \phpbb\filesystem\filesystem(), $phpbb_root_path);
+$classes = $finder->core_path('phpbb/')
+	->directory('/db/migration/data')
+	->get_classes();
 
-				case 'mssql':
-					$line .= "ALTER TABLE [{$table_name}] WITH NOCHECK ADD \n";
-					$line .= "\tCONSTRAINT [PK_{$table_name}] PRIMARY KEY  CLUSTERED \n";
-					$line .= "\t(\n";
-					$line .= "\t\t[" . implode("],\n\t\t[", $table_data['PRIMARY_KEY']) . "]\n";
-					$line .= "\t)  ON [PRIMARY] \n";
-					$line .= "GO\n\n";
-				break;
+$db = new \phpbb\db\driver\sqlite();
+$factory = new \phpbb\db\tools\factory();
+$db_tools = $factory->get($db, true);
 
-				case 'oracle':
-					$line .= "\tCONSTRAINT pk_{$table_name} PRIMARY KEY (" . implode(', ', $table_data['PRIMARY_KEY']) . "),\n";
-				break;
-			}
-		}
+$schema_generator = new \phpbb\db\migration\schema_generator($classes, new \phpbb\config\config(array()), $db, $db_tools, $phpbb_root_path, $phpEx, $table_prefix);
+$schema_data = $schema_generator->get_schema();
 
-		switch ($dbms)
-		{
-			case 'oracle':
-				// UNIQUE contrains to be added?
-				if (isset($table_data['KEYS']))
-				{
-					foreach ($table_data['KEYS'] as $key_name => $key_data)
-					{
-						if (!is_array($key_data[1]))
-						{
-							$key_data[1] = array($key_data[1]);
-						}
-
-						if ($key_data[0] == 'UNIQUE')
-						{
-							$line .= "\tCONSTRAINT u_phpbb_{$key_name} UNIQUE (" . implode(', ', $key_data[1]) . "),\n";
-						}
-					}
-				}
-
-				// Remove last line delimiter...
-				$line = substr($line, 0, -2);
-				$line .= "\n)\n/\n\n";
-			break;
-
-			case 'postgres':
-				// Remove last line delimiter...
-				$line = substr($line, 0, -2);
-				$line .= "\n);\n\n";
-			break;
-
-			case 'sqlite':
-				// Remove last line delimiter...
-				$line = substr($line, 0, -2);
-				$line .= "\n);\n\n";
-			break;
-		}
-
-		// Write Keys
-		if (isset($table_data['KEYS']))
-		{
-			foreach ($table_data['KEYS'] as $key_name => $key_data)
-			{
-				if (!is_array($key_data[1]))
-				{
-					$key_data[1] = array($key_data[1]);
-				}
-
-				if (strlen($table_name . $key_name) > 30)
-				{
-					trigger_error("Index name '${table_name}_$key_name' on table '$table_name' is too long. The maximum is 30 characters.", E_USER_ERROR);
-				}
-
-				switch ($dbms)
-				{
-					case 'mysql_40':
-					case 'mysql_41':
-						$line .= ($key_data[0] == 'INDEX') ? "\tKEY" : '';
-						$line .= ($key_data[0] == 'UNIQUE') ? "\tUNIQUE" : '';
-						foreach ($key_data[1] as $key => $col_name)
-						{
-							if (isset($modded_array[$col_name]))
-							{
-								switch ($modded_array[$col_name])
-								{
-									case 'text':
-									case 'blob':
-										$key_data[1][$key] = $col_name . '(255)';
-									break;
-								}
-							}
-						}
-						$line .= ' ' . $key_name . ' (' . implode(', ', $key_data[1]) . "),\n";
-					break;
-
-					case 'firebird':
-						$line .= ($key_data[0] == 'INDEX') ? 'CREATE INDEX' : '';
-						$line .= ($key_data[0] == 'UNIQUE') ? 'CREATE UNIQUE INDEX' : '';
-
-						$line .= ' ' . $table_name . '_' . $key_name . ' ON ' . $table_name . '(' . implode(', ', $key_data[1]) . ");;\n";
-					break;
-
-					case 'mssql':
-						$line .= ($key_data[0] == 'INDEX') ? 'CREATE  INDEX' : '';
-						$line .= ($key_data[0] == 'UNIQUE') ? 'CREATE  UNIQUE  INDEX' : '';
-						$line .= " [{$key_name}] ON [{$table_name}]([" . implode('], [', $key_data[1]) . "]) ON [PRIMARY]\n";
-						$line .= "GO\n\n";
-					break;
-
-					case 'oracle':
-						if ($key_data[0] == 'UNIQUE')
-						{
-							continue;
-						}
-
-						$line .= ($key_data[0] == 'INDEX') ? 'CREATE INDEX' : '';
-
-						$line .= " {$table_name}_{$key_name} ON {$table_name} (" . implode(', ', $key_data[1]) . ")\n";
-						$line .= "/\n";
-					break;
-
-					case 'sqlite':
-						$line .= ($key_data[0] == 'INDEX') ? 'CREATE INDEX' : '';
-						$line .= ($key_data[0] == 'UNIQUE') ? 'CREATE UNIQUE INDEX' : '';
-
-						$line .= " {$table_name}_{$key_name} ON {$table_name} (" . implode(', ', $key_data[1]) . ");\n";
-					break;
-
-					case 'postgres':
-						$line .= ($key_data[0] == 'INDEX') ? 'CREATE INDEX' : '';
-						$line .= ($key_data[0] == 'UNIQUE') ? 'CREATE UNIQUE INDEX' : '';
-
-						$line .= " {$table_name}_{$key_name} ON {$table_name} (" . implode(', ', $key_data[1]) . ");\n";
-					break;
-				}
-			}
-		}
-
-		switch ($dbms)
-		{
-			case 'mysql_40':
-				// Remove last line delimiter...
-				$line = substr($line, 0, -2);
-				$line .= "\n);\n\n";
-			break;
-
-			case 'mysql_41':
-				// Remove last line delimiter...
-				$line = substr($line, 0, -2);
-				$line .= "\n) CHARACTER SET `utf8` COLLATE `utf8_bin`;\n\n";
-			break;
-
-			// Create Generator
-			case 'firebird':
-				if ($generator !== false)
-				{
-					$line .= "\nCREATE GENERATOR {$table_name}_gen;;\n";
-					$line .= 'SET GENERATOR ' . $table_name . "_gen TO 0;;\n\n";
-
-					$line .= 'CREATE TRIGGER t_' . $table_name . ' FOR ' . $table_name . "\n";
-					$line .= "BEFORE INSERT\nAS\nBEGIN\n";
-					$line .= "\tNEW.{$generator} = GEN_ID({$table_name}_gen, 1);\nEND;;\n\n";
-				}
-			break;
-
-			case 'oracle':
-				if ($generator !== false)
-				{
-					$line .= "\nCREATE SEQUENCE {$table_name}_seq\n/\n\n";
-
-					$line .= "CREATE OR REPLACE TRIGGER t_{$table_name}\n";
-					$line .= "BEFORE INSERT ON {$table_name}\n";
-					$line .= "FOR EACH ROW WHEN (\n";
-					$line .= "\tnew.{$generator} IS NULL OR new.{$generator} = 0\n";
-					$line .= ")\nBEGIN\n";
-					$line .= "\tSELECT {$table_name}_seq.nextval\n";
-					$line .= "\tINTO :new.{$generator}\n";
-					$line .= "\tFROM dual;\nEND;\n/\n\n";
-				}
-			break;
-		}
-
-		fwrite($fp, $line . "\n");
-	}
-
-	$line = '';
-
-	// Write custom function at the end for some db's
-	switch ($dbms)
-	{
-		case 'mssql':
-			// No need to do this, no transaction support for schema changes
-			//$line = "\nCOMMIT\nGO\n\n";
-		break;
-
-		case 'sqlite':
-			$line = "\nCOMMIT;";
-		break;
-
-		case 'postgres':
-			$line = "\nCOMMIT;";
-		break;
-	}
-
-	fwrite($fp, $line);
-	fclose($fp);
-}
-
-/**
-* Data put into the header for various dbms
-*/
-function custom_data($dbms)
-{
-	switch ($dbms)
-	{
-		case 'oracle':
-			return <<<EOF
-/*
-  This first section is optional, however its probably the best method
-  of running phpBB on Oracle. If you already have a tablespace and user created
-  for phpBB you can leave this section commented out!
-
-  The first set of statements create a phpBB tablespace and a phpBB user,
-  make sure you change the password of the phpBB user before you run this script!!
-*/
-
-/*
-CREATE TABLESPACE "PHPBB"
-	LOGGING
-	DATAFILE 'E:\ORACLE\ORADATA\LOCAL\PHPBB.ora'
-	SIZE 10M
-	AUTOEXTEND ON NEXT 10M
-	MAXSIZE 100M;
-
-CREATE USER "PHPBB"
-	PROFILE "DEFAULT"
-	IDENTIFIED BY "phpbb_password"
-	DEFAULT TABLESPACE "PHPBB"
-	QUOTA UNLIMITED ON "PHPBB"
-	ACCOUNT UNLOCK;
-
-GRANT ANALYZE ANY TO "PHPBB";
-GRANT CREATE SEQUENCE TO "PHPBB";
-GRANT CREATE SESSION TO "PHPBB";
-GRANT CREATE TABLE TO "PHPBB";
-GRANT CREATE TRIGGER TO "PHPBB";
-GRANT CREATE VIEW TO "PHPBB";
-GRANT "CONNECT" TO "PHPBB";
-
-COMMIT;
-DISCONNECT;
-
-CONNECT phpbb/phpbb_password;
-*/
-EOF;
-
-		break;
-
-		case 'postgres':
-			return <<<EOF
-/*
-	Domain definition
-*/
-CREATE DOMAIN varchar_ci AS varchar(255) NOT NULL DEFAULT ''::character varying;
-
-/*
-	Operation Functions
-*/
-CREATE FUNCTION _varchar_ci_equal(varchar_ci, varchar_ci) RETURNS boolean AS 'SELECT LOWER($1) = LOWER($2)' LANGUAGE SQL STRICT;
-CREATE FUNCTION _varchar_ci_not_equal(varchar_ci, varchar_ci) RETURNS boolean AS 'SELECT LOWER($1) != LOWER($2)' LANGUAGE SQL STRICT;
-CREATE FUNCTION _varchar_ci_less_than(varchar_ci, varchar_ci) RETURNS boolean AS 'SELECT LOWER($1) < LOWER($2)' LANGUAGE SQL STRICT;
-CREATE FUNCTION _varchar_ci_less_equal(varchar_ci, varchar_ci) RETURNS boolean AS 'SELECT LOWER($1) <= LOWER($2)' LANGUAGE SQL STRICT;
-CREATE FUNCTION _varchar_ci_greater_than(varchar_ci, varchar_ci) RETURNS boolean AS 'SELECT LOWER($1) > LOWER($2)' LANGUAGE SQL STRICT;
-CREATE FUNCTION _varchar_ci_greater_equals(varchar_ci, varchar_ci) RETURNS boolean AS 'SELECT LOWER($1) >= LOWER($2)' LANGUAGE SQL STRICT;
-
-/*
-	Operators
-*/
-CREATE OPERATOR <(
-  PROCEDURE = _varchar_ci_less_than,
-  LEFTARG = varchar_ci,
-  RIGHTARG = varchar_ci,
-  COMMUTATOR = >,
-  NEGATOR = >=,
-  RESTRICT = scalarltsel,
-  JOIN = scalarltjoinsel);
-
-CREATE OPERATOR <=(
-  PROCEDURE = _varchar_ci_less_equal,
-  LEFTARG = varchar_ci,
-  RIGHTARG = varchar_ci,
-  COMMUTATOR = >=,
-  NEGATOR = >,
-  RESTRICT = scalarltsel,
-  JOIN = scalarltjoinsel);
-
-CREATE OPERATOR >(
-  PROCEDURE = _varchar_ci_greater_than,
-  LEFTARG = varchar_ci,
-  RIGHTARG = varchar_ci,
-  COMMUTATOR = <,
-  NEGATOR = <=,
-  RESTRICT = scalargtsel,
-  JOIN = scalargtjoinsel);
-
-CREATE OPERATOR >=(
-  PROCEDURE = _varchar_ci_greater_equals,
-  LEFTARG = varchar_ci,
-  RIGHTARG = varchar_ci,
-  COMMUTATOR = <=,
-  NEGATOR = <,
-  RESTRICT = scalargtsel,
-  JOIN = scalargtjoinsel);
-
-CREATE OPERATOR <>(
-  PROCEDURE = _varchar_ci_not_equal,
-  LEFTARG = varchar_ci,
-  RIGHTARG = varchar_ci,
-  COMMUTATOR = <>,
-  NEGATOR = =,
-  RESTRICT = neqsel,
-  JOIN = neqjoinsel);
-
-CREATE OPERATOR =(
-  PROCEDURE = _varchar_ci_equal,
-  LEFTARG = varchar_ci,
-  RIGHTARG = varchar_ci,
-  COMMUTATOR = =,
-  NEGATOR = <>,
-  RESTRICT = eqsel,
-  JOIN = eqjoinsel,
-  HASHES,
-  MERGES,
-  SORT1= <);
-
-EOF;
-		break;
-	}
-
-	return '';
-}
+$fp = fopen($schema_path . 'schema.json', 'wb');
+fwrite($fp, json_encode($schema_data, JSON_PRETTY_PRINT));
+fclose($fp);
 
-echo 'done';
+echo 'Successfully created schema file';