pronto/bin/load_schemas.php

Go to the documentation of this file.

<?php
if(!file_exists('profiles/cmdline.php')) {
        die("Run this script from your top-level app directory (eg, /var/www/html/app)\n");
}
require_once('profiles/cmdline.php');
$GLOBALS['db'] = Registry::get('pronto:db:main');

$args = $_SERVER['argv'];
array_shift($args);

$opts = getopt("t:m:ca");
for($i = 0; $i < count($opts); $i++) array_shift($args);

if(empty($opts)) {
        echo "usage: php load_schemas.php [-t <table>] [-m <module>] [-c] [-a]\n\n";
        echo "This script will scan for .sql schema files and execute them within your RDBMS.\n\n";
        echo "Options (use one):\n";
        echo "  -t <table>   Scan all enabled modules (as set in config/config.php) and\n";
        echo "               config/sql for schema file named <table>.sql\n";
        echo "  -m <module>  Scan <module>/config/sql for schema files\n";
        echo "  -c           Scan config/sql for schema files\n";
        echo "  -a           Scan all enabled modules (as set in config/config.php) and\n";
        echo "               config/sql for schema files\n\n";
        exit(0);
}

$files = array();
if(isset($opts['t'])) {
        if(isset($opts['m'])) {
                $dirs = array(DIR_FS_APP.DS.'modules'.DS.$opts['m'].DS.'config'.DS.'sql');
        } else {
                // Scan all directories for the specified table file
                $dirs = array(DIR_FS_APP.DS.'config'.DS.'sql');
                foreach(explode(' ', MODULES) as $mod) {
                        $dirs[] = DIR_FS_APP.DS.'modules'.DS.$mod.DS.'config'.DS.'sql';
                }
        }
        foreach($dirs as $dir) {
                $fn = $dir.DS.$opts['t'].'.sql';
                if(file_exists($fn)) {
                        $files = array($fn);
                        break;
                }
        }
} else if(isset($opts['c'])) {
        $files = glob(DIR_FS_APP.DS.'config'.DS.'sql'.DS.'*.sql');
} else if(isset($opts['m'])) {
        $files = glob(DIR_FS_APP.DS.'modules'.DS.$opts['m'].DS.'config'.DS.'sql'.DS.'*.sql');
} else if(isset($opts['a'])) {
        $files = glob(DIR_FS_APP.DS.'config'.DS.'sql'.DS.'*.sql');
        foreach(explode(' ', MODULES) as $mod) {
                $files = array_merge($files, glob(DIR_FS_APP.DS.'modules'.DS.$mod.DS.'config'.DS.'sql'.DS.'*.sql'));
        }
}

if(empty($files)) {
        echo "No files found.\n";
        exit(1);
}

$db =& Registry::get('pronto:db:main');

foreach($files as $f) {
        unset($GLOBALS['insql_done'], $GLOBALS['LFILE']);
        echo "Loading $f...\n";
        if(!do_multi_sql('', $f)) {
                echo "Error: An error occurred while trying to run this SQL chunk.\n";
        }
}

function do_sql($sql) {
        global $db;

        $sql = trim($sql);
        if(empty($sql)) return true;

        return !!$db->execute($sql);
}


function do_multi_sql($insql, $fname) {
        $sql = '';
        $ochar = '';
        $is_cmt = '';
        $GLOBALS['insql_done'] = 0;
        while($str = get_next_chunk($insql, $fname)) {
                $opos =- strlen($ochar);
                $cur_pos = 0;
                $i = strlen($str);
                while($i--) {
                        if($ochar) {
                                list($clchar, $clpos) = get_close_char($str, $opos+strlen($ochar), $ochar);
                                if($clchar) {
                                        if($ochar == '--' || $ochar == '#' || $is_cmt) {
                                                $sql .= substr($str, $cur_pos, $opos-$cur_pos);
                                        } else {
                                                $sql .= substr($str, $cur_pos, $clpos+strlen($clchar)-$cur_pos);
                                        }
                                        $cur_pos = $clpos + strlen($clchar);
                                        $ochar = '';
                                        $opos = 0;
                                } else {
                                        $sql .= substr($str, $cur_pos);
                                        break;
                                }
                        } else {
                                list($ochar, $opos) = get_open_char($str, $cur_pos);
                                if($ochar == ';') {
                                        $sql .= substr($str, $cur_pos, $opos-$cur_pos+1);
                                        if(!do_sql($sql)) return 0;
                                        $sql='';
                                        $cur_pos = $opos + strlen($ochar);
                                        $ochar = '';
                                        $opos = 0;
                                } else if (!$ochar) {
                                        $sql .= substr($str, $cur_pos);
                                        break;
                                } else {
                                        $is_cmt = 0;
                                        if($ochar == '/*' && substr($str, $opos, 3) != '

---