ECSHOP SQL语句执行类
<?php/** * ECSHOP SQL语句执行类。在调用该类方法之前，请参看相应方法的说明。 * * ============================================================================ * 版权所有 2005-2010 上海商派网络科技有限公司，并保留所有权利。 * 网站地址: http://www.ecshop.com； * ---------------------------------------- * 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和 * 使用；不允许对程序代码以任何形式任何目的的再发布。 * ============================================================================ * $Author: liuhui $ * $Id: cls_sql_executor.php 17063 2010-03-25 06:35:46Z liuhui $ */if (!defined('IN_ECS')){ die('Hacking attempt');}class sql_executor{ /** * 记录程序执行过程中最后产生的那条错误信息 * * @access public * @var string $error */ var $error = ''; /** * 存储将被忽略的错误号，这些错误不会记录在$error属性中， * 但仍然会记录在错误日志文件当中。 * * @access private * @var array $ignored_errors */ var $ignored_errors = array(); /** * MySQL对象 * * @access private * @var object $db */ var $db = ''; /** * 数据库字符编码 * * @access private * @var string $charset */ var $db_charset = ''; /** * 替换前表前缀 * * @access private * @var string $source_prefix */ var $source_prefix = ''; /** * 替换后表前缀 * * @access private * @var string $target_prefix */ var $target_prefix = ''; /** * 当发生错误时，程序将把日志记录在该指定的文件中 * * @access private * @var string $log_path */ var $log_path = ''; /** * 开启此选项后，程序将进行智能化地查询操作，即使重复运行本程序，也不会引起数据库的查询冲突。这点在浏览器 * 和服务器之间进行通讯时是非常有必要的，因为网络很有可能在您不经意间发生中断。不过，由于用到了大量的正则 * 表达式，开启该选项后将非常耗费服务器的资源。 * * @access private * @var boolean $auto_match */ var $auto_match = false; /** * 记录当前正在执行的SQL文件名 * * @access private * @var string $current_file */ var $current_file = 'Not a file, but a string.'; /** * 构造函数 * * @access public * @param mysql $db mysql类对象 * @param string $charset 字符集 * @param string $sprefix 替换前表前缀 * @param string $tprefix 替换后表前缀 * @param string $log_path 日志路径 * @param boolean $auto_match 是否进行智能化查询 * @param array $ignored_errors 忽略的错误号数组 * @return void */ function __construct($db, $charset = 'gbk', $sprefix = 'ecs_', $tprefix = 'ecs_', $log_path = '', $auto_match = false, $ignored_errors = array()) { $this->sql_executor($db, $charset, $sprefix, $tprefix, $log_path, $auto_match, $ignored_errors); } /** * 构造函数 * * @access public * @param mysql $db mysql类对象 * @param string $charset 字符集 * @param string $sprefix 替换前表前缀 * @param string $tprefix 替换后表前缀 * @param string $log_path 日志路径 * @param boolean $auto_match 是否进行智能化查询 * @param array $ignored_errors 忽略的错误号数组 * @return void */ function sql_executor($db, $charset = 'gbk', $sprefix = 'ecs_', $tprefix = 'ecs_', $log_path = '', $auto_match = false, $ignored_errors = array()) { $this->db = $db; $this->db_charset = $charset; $this->source_prefix = $sprefix; $this->target_prefix = $tprefix; $this->log_path = $log_path; $this->auto_match = $auto_match; $this->ignored_errors = $ignored_errors; } /** * 执行所有SQL文件中所有的SQL语句 * * @access public * @param array $sql_files 文件绝对路径组成的一维数组 * @return boolean 执行成功返回true，失败返回false。 */ function run_all($sql_files) { /* 如果传入参数不是数组，程序直接返回 */ if (!is_array($sql_files)) { return false; } foreach ($sql_files AS $sql_file) { $query_items = $this->parse_sql_file($sql_file); /* 如果解析失败，则跳过 */ if (!$query_items) { continue; } foreach ($query_items AS $query_item) { /* 如果查询项为空，则跳过 */ if (!$query_item) { continue; } if (!$this->query($query_item)) { return false; } } } return true; } /** * 获得分散的查询项 * * @access public * @param string $file_path 文件的绝对路径 * @return mixed 解析成功返回分散的查询项数组，失败返回false。 */ function parse_sql_file($file_path) { /* 如果SQL文件不存在则返回false */ if (!file_exists($file_path)) { return false; } /* 记录当前正在运行的SQL文件 */ $this->current_file = $file_path; /* 读取SQL文件 */ $sql = implode('', file($file_path)); /* 删除SQL注释，由于执行的是replace操作，所以不需要进行检测。下同。 */ $sql = $this->remove_comment($sql); /* 删除SQL串首尾的空白符 */ $sql = trim($sql); /* 如果SQL文件中没有查询语句则返回false */ if (!$sql) { return false; } /* 替换表前缀 */ $sql = $this->replace_prefix($sql); /* 解析查询项 */ $sql = str_replace("\r", '', $sql); $query_items = explode(";\n", $sql); return $query_items; } /** * 执行某一个查询项 * * @access public * @param string $query_item 查询项 * @return boolean 成功返回true，失败返回false。 */ function query($query_item) { /* 删除查询项首尾的空白符 */ $query_item = trim($query_item); /* 如果查询项为空则返回false */ if (!$query_item) { return false; } /* 处理建表操作 */ if (preg_match('/^\s*CREATE\s+TABLE\s*/i', $query_item)) { if (!$this->create_table($query_item)) { return false; } } /* 处理ALTER TABLE语句，此时程序将对表的结构进行修改 */ elseif ($this->auto_match && preg_match('/^\s*ALTER\s+TABLE\s*/i', $query_item)) { if (!$this->alter_table($query_item)) { return false; } } /* 处理其它修改操作，如数据添加、更新、删除等 */ else { if (!$this->do_other($query_item)) { return false; } } return true; } /** * 过滤SQL查询串中的注释。该方法只过滤SQL文件中独占一行或一块的那些注释。 * * @access public * @param string $sql SQL查询串 * @return string 返回已过滤掉注释的SQL查询串。 */ function remove_comment($sql) { /* 删除SQL行注释，行注释不匹配换行符 */ $sql = preg_replace('/^\s*(?:--|#).*/m', '', $sql); /* 删除SQL块注释，匹配换行符，且为非贪婪匹配 */ //$sql = preg_replace('/^\s*\/\*(?:.|\n)*\*\//m', '', $sql); $sql = preg_replace('/^\s*\/\*.*?\*\//ms', '', $sql); return $sql; } /** * 替换查询串中数据表的前缀。该方法只对下列查询有效：CREATE TABLE, * DROP TABLE, ALTER TABLE, UPDATE, REPLACE INTO, INSERT INTO * * @access public * @param string $sql SQL查询串 * @return string 返回已替换掉前缀的SQL查询串。 */ function replace_prefix($sql) { $keywords = 'CREATE\s+TABLE(?:\s+IF\s+NOT\s+EXISTS)?|' . 'DROP\s+TABLE(?:\s+IF\s+EXISTS)?|' . 'ALTER\s+TABLE|' . 'UPDATE|' . 'REPLACE\s+INTO|' . 'DELETE\s+FROM|' . 'INSERT\s+INTO'; $pattern = '/(' . $keywords . ')(\s*)`?' . $this->source_prefix . '(\w+)`?(\s*)/i'; $replacement = '\1\2`' . $this->target_prefix . '\3`\4'; $sql = preg_replace($pattern, $replacement, $sql); $pattern = '/(UPDATE.*?WHERE)(\s*)`?' . $this->source_prefix . '(\w+)`?(\s*\.)/i'; $replacement = '\1\2`' . $this->target_prefix . '\3`\4'; $sql = preg_replace($pattern, $replacement, $sql); return $sql; } /** * 获取表的名字。该方法只对下列查询有效：CREATE TABLE, * DROP TABLE, ALTER TABLE, UPDATE, REPLACE INTO, INSERT INTO * * @access public * @param string $query_item SQL查询项 * @param string $query_type 查询类型 * @return mixed 成功返回表的名字，失败返回false。 */ function get_table_name($query_item, $query_type = '') { $pattern = ''; $matches = array(); $table_name = ''; /* 如果没指定$query_type，则自动获取 */ if (!$query_type && preg_match('/^\s*(\w+)/', $query_item, $matches)) { $query_type = $matches[1]; } /* 获取相应的正则表达式 */ $query_type = strtoupper($query_type); switch ($query_type) { case 'ALTER' : $pattern = '/^\s*ALTER\s+TABLE\s*`?(\w+)/i'; break; case 'CREATE' : $pattern = '/^\s*CREATE\s+TABLE(?:\s+IF\s+NOT\s+EXISTS)?\s*`?(\w+)/i'; break; case 'DROP' : $pattern = '/^\s*DROP\s+TABLE(?:\s+IF\s+EXISTS)?\s*`?(\w+)/i'; break; case 'INSERT' : $pattern = '/^\s*INSERT\s+INTO\s*`?(\w+)/i'; break; case 'REPLACE' : $pattern = '/^\s*REPLACE\s+INTO\s*`?(\w+)/i'; break; case 'UPDATE' : $pattern = '/^\s*UPDATE\s*`?(\w+)/i'; break; default : return false; } if (!preg_match($pattern, $query_item, $matches)) { return false; } $table_name = $matches[1]; return $table_name; } /** * 获得SQL文件中指定的查询项 * * @access public * @param string $file_path SQL查询项 * @param int $pos 查询项的索引号 * @return mixed 成功返回该查询项，失败返回false。 */ function get_spec_query_item($file_path, $pos) { $query_items = $this->parse_sql_file($file_path); if (empty($query_items) || empty($query_items[$pos])) { return false; } return $query_items[$pos]; } /** * 概据MYSQL版本，创建数据表 * * @access public * @param string $query_item SQL查询项 * @return boolean 成功返回true，失败返回false。 */ function create_table($query_item) { /* 获取建表主体串以及表属性声明串，不区分大小写，匹配换行符，且为贪婪匹配 */ $pattern = '/^\s*(CREATE\s+TABLE[^(]+\(.*\))(.*)$/is'; if (!preg_match($pattern, $query_item, $matches)) { return false; } $main = $matches[1]; $postfix = $matches[2]; /* 从表属性声明串中查找表的类型 */ $pattern = '/.*(?:ENGINE|TYPE)\s*=\s*([a-z]+).*$/is'; $type = preg_match($pattern, $postfix, $matches) ? $matches[1] : 'MYISAM'; /* 从表属性声明串中查找自增语句 */ $pattern = '/.*(AUTO_INCREMENT\s*=\s*\d+).*$/is'; $auto_incr = preg_match($pattern, $postfix, $matches) ? $matches[1] : ''; /* 重新设置表属性声明串 */ $postfix = $this->db->version() > '4.1' ? " ENGINE=$type DEFAULT CHARACTER SET " . $this->db_charset : " TYPE=$type"; $postfix .= ' ' . $auto_incr; /* 重新构造建表语句 */ $sql = $main . $postfix; /* 开始创建表 */ if (!$this->db->query($sql, 'SILENT')) { $this->handle_error($sql); return false; } return true; } /** * 修改数据表的方法。算法设计思路： * 1. 先进行字段修改操作。CHANGE * 2. 然后进行字段移除操作。DROP [COLUMN] * 3. 接着进行字段添加操作。ADD [COLUMN] * 4. 进行索引移除操作。DROP INDEX * 5. 进行索引添加操作。ADD INDEX * 6. 最后进行其它操作。 * * @access public * @param string $query_item SQL查询项 * @return boolean 修改成功返回true，否则返回false */ function alter_table($query_item) { /* 获取表名 */ $table_name = $this->get_table_name($query_item, 'ALTER'); if (!$table_name) { return false; } /* 先把CHANGE操作提取出来执行，再过滤掉它们 */ $result = $this->parse_change_query($query_item, $table_name); if ($result[0] && !$this->db->query($result[0], 'SILENT')) { $this->handle_error($result[0]); return false; } if (!$result[1]) { return true; } /* 把DROP [COLUMN]提取出来执行，再过滤掉它们 */ $result = $this->parse_drop_column_query($result[1], $table_name); if ($result[0] && !$this->db->query($result[0], 'SILENT')) { $this->handle_error($result[0]); return false; } if (!$result[1]) { return true; } /* 把ADD [COLUMN]提取出来执行，再过滤掉它们 */ $result = $this->parse_add_column_query($result[1], $table_name); if ($result[0] && !$this->db->query($result[0], 'SILENT')) { $this->handle_error($result[0]); return false; } if (!$result[1]) { return true; } /* 把DROP INDEX提取出来执行，再过滤掉它们 */ $result = $this->parse_drop_index_query($result[1], $table_name); if ($result[0] && !$this->db->query($result[0], 'SILENT')) { $this->handle_error($result[0]); return false; } if (!$result[1]) { return true; } /* 把ADD INDEX提取出来执行，再过滤掉它们 */ $result = $this->parse_add_index_query($result[1], $table_name); if ($result[0] && !$this->db->query($result[0], 'SILENT')) { $this->handle_error($result[0]); return false; } /* 执行其它的修改操作 */ if ($result[1] && !$this->db->query($result[1], 'SILENT')) { $this->handle_error($result[1]); return false; } return true; } /** * 解析出CHANGE操作 * * @access public * @param string $query_item SQL查询项 * @param string $table_name 表名 * @return array 返回一个以CHANGE操作串和其它操作串组成的数组 */ function parse_change_query($query_item, $table_name = '') { $result = array('', $query_item); if (!$table_name) { $table_name = $this->get_table_name($query_item, 'ALTER'); } $matches = array(); /* 第1个子模式匹配old_col_name，第2个子模式匹配column_definition，第3个子模式匹配new_col_name */ $pattern = '/\s*CHANGE\s*`?(\w+)`?\s*`?(\w+)`?([^,(]+\([^,]+?(?:,[^,)]+)*\)[^,]+|[^,;]+)\s*,?/i'; if (preg_match_all($pattern, $query_item, $matches, PREG_SET_ORDER)) { $fields = $this->get_fields($table_name); $num = count($matches); $sql = ''; for ($i = 0; $i < $num; $i++) { /* 如果表中存在原列名 */ if (in_array($matches[$i][1], $fields)) { $sql .= $matches[$i][0]; } /* 如果表中存在新列名 */ elseif (in_array($matches[$i][2], $fields)) { $sql .= 'CHANGE ' . $matches[$i][2] . ' ' . $matches[$i][2] . ' ' . $matches[$i][3] . ','; } else /* 如果两个列名都不存在 */ { $sql .= 'ADD ' . $matches[$i][2] . ' ' . $matches[$i][3] . ','; $sql = preg_replace('/(\s+AUTO_INCREMENT)/i', '\1 PRIMARY KEY', $sql); } } $sql = 'ALTER TABLE ' . $table_name . ' ' . $sql; $result[0] = preg_replace('/\s*,\s*$/', '', $sql);//存储CHANGE操作，已过滤末尾的逗号 $result[0] = $this->insert_charset($result[0]);//加入字符集设置 $result[1] = preg_replace($pattern, '', $query_item);//存储其它操作 $result[1] = $this->has_other_query($result[1]) ? $result[1]: ''; } return $result; } /** * 解析出DROP COLUMN操作 * * @access public * @param string $query_item SQL查询项 * @param string $table_name 表名 * @return array 返回一个以DROP COLUMN操作和其它操作组成的数组 */ function parse_drop_column_query($query_item, $table_name = '') { $result = array('', $query_item); if (!$table_name) { $table_name = $this->get_table_name($query_item, 'ALTER'); } $matches = array(); /* 子模式存储列名 */ $pattern = '/\s*DROP(?:\s+COLUMN)?(?!\s+(?:INDEX|PRIMARY))\s*`?(\w+)`?\s*,?/i'; if (preg_match_all($pattern, $query_item, $matches, PREG_SET_ORDER)) { $fields = $this->get_fields($table_name); $num = count($matches); $sql = ''; for ($i = 0; $i < $num; $i++) { if (in_array($matches[$i][1], $fields)) { $sql .= 'DROP ' . $matches[$i][1] . ','; } } if ($sql) { $sql = 'ALTER TABLE ' . $table_name . ' ' . $sql; $result[0] = preg_replace('/\s*,\s*$/', '', $sql);//过滤末尾的逗号 } $result[1] = preg_replace($pattern, '', $query_item);//过滤DROP COLUMN操作 $result[1] = $this->has_other_query($result[1]) ? $result[1] : ''; } return $result; } /** * 解析出ADD [COLUMN]操作 * * @access public * @param string $query_item SQL查询项 * @param string $table_name 表名 * @return array 返回一个以ADD [COLUMN]操作和其它操作组成的数组 */ function parse_add_column_query($query_item, $table_name = '') { $result = array('', $query_item); if (!$table_name) { $table_name = $this->get_table_name($query_item, 'ALTER'); } $matches = array(); /* 第1个子模式存储列定义，第2个子模式存储列名 */ $pattern = '/\s*ADD(?:\s+COLUMN)?(?!\s+(?:INDEX|UNIQUE|PRIMARY))\s*(`?(\w+)`?(?:[^,(]+\([^,]+?(?:,[^,)]+)*\)[^,]+|[^,;]+))\s*,?/i'; if (preg_match_all($pattern, $query_item, $matches, PREG_SET_ORDER)) { $fields = $this->get_fields($table_name); $mysql_ver = $this->db->version(); $num = count($matches); $sql = ''; for ($i = 0; $i < $num; $i++) { if (in_array($matches[$i][2], $fields)) { /* 如果为低版本MYSQL，则把非法关键字过滤掉 */ if ($mysql_ver < '4.0.1' ) { $matches[$i][1] = preg_replace('/\s*(?:AFTER|FIRST)\s*.*$/i', '', $matches[$i][1]); } $sql .= 'CHANGE ' . $matches[$i][2] . ' ' . $matches[$i][1] . ','; } else { $sql .= 'ADD ' . $matches[$i][1] . ','; } } $sql = 'ALTER TABLE ' . $table_name . ' ' . $sql; $result[0] = preg_replace('/\s*,\s*$/', '', $sql);//过滤末尾的逗号 $result[0] = $this->insert_charset($result[0]);//加入字符集设置 $result[1] = preg_replace($pattern, '', $query_item);//过滤ADD COLUMN操作 $result[1] = $this->has_other_query($result[1]) ? $result[1] : ''; } return $result; } /** * 解析出DROP INDEX操作 * * @access public * @param string $query_item SQL查询项 * @param string $table_name 表名 * @return array 返回一个以DROP INDEX操作和其它操作组成的数组 */ function parse_drop_index_query($query_item, $table_name = '') { $result = array('', $query_item); if (!$table_name) { $table_name = $this->get_table_name($query_item, 'ALTER'); } /* 子模式存储键名 */ $pattern = '/\s*DROP\s+(?:PRIMARY\s+KEY|INDEX\s*`?(\w+)`?)\s*,?/i'; if (preg_match_all($pattern, $query_item, $matches, PREG_SET_ORDER)) { $indexes = $this->get_indexes($table_name); $num = count($matches); $sql = ''; for ($i = 0; $i < $num; $i++) { /* 如果子模式为空，删除主键 */ if (empty($matches[$i][1])) { $sql .= 'DROP PRIMARY KEY,'; } /* 否则删除索引 */ elseif (in_array($matches[$i][1], $indexes)) { $sql .= 'DROP INDEX ' . $matches[$i][1] . ','; } } if ($sql) { $sql = 'ALTER TABLE ' . $table_name . ' ' . $sql; $result[0] = preg_replace('/\s*,\s*$/', '', $sql);//存储DROP INDEX操作，已过滤末尾的逗号 } $result[1] = preg_replace($pattern, '', $query_item);//存储其它操作 $result[1] = $this->has_other_query($result[1]) ? $result[1] : ''; } return $result; } /** * 解析出ADD INDEX操作 * * @access public * @param string $query_item SQL查询项 * @param string $table_name 表名 * @return array 返回一个以ADD INDEX操作和其它操作组成的数组 */ function parse_add_index_query($query_item, $table_name = '') { $result = array('', $query_item); if (!$table_name) { $table_name = $this->get_table_name($query_item, 'ALTER'); } /* 第1个子模式存储索引定义，第2个子模式存储"PRIMARY KEY"，第3个子模式存储键名，第4个子模式存储列名 */ $pattern = '/\s*ADD\s+((?:INDEX|UNIQUE|(PRIMARY\s+KEY))\s*(?:`?(\w+)`?)?\s*\(\s*`?(\w+)`?\s*(?:,[^,)]+)*\))\s*,?/i'; if (preg_match_all($pattern, $query_item, $matches, PREG_SET_ORDER)) { $indexes = $this->get_indexes($table_name); $num = count($matches); $sql = ''; for ($i = 0; $i < $num; $i++) { $index = !empty($matches[$i][3]) ? $matches[$i][3] : $matches[$i][4]; if (!empty($matches[$i][2]) && in_array('PRIMARY', $indexes)) { $sql .= 'DROP PRIMARY KEY,'; } elseif (in_array($index, $indexes)) { $sql .= 'DROP INDEX ' . $index . ','; } $sql .= 'ADD ' . $matches[$i][1] . ','; } $sql = 'ALTER TABLE ' . $table_name . ' ' . $sql; $result[0] = preg_replace('/\s*,\s*$/', '', $sql);//存储ADD INDEX操作，已过滤末尾的逗号 $result[1] = preg_replace($pattern, '', $query_item);//存储其它的操作 $result[1] = $this->has_other_query($result[1]) ? $result[1] : ''; } return $result; } /** * 获取所有的indexes * * @access public * @param string $table_name 数据表名 * @return array */ function get_indexes($table_name) { $indexes = array(); $result = $this->db->query("SHOW INDEX FROM $table_name", 'SILENT'); if ($result) { while ($row = $this->db->fetchRow($result)) { $indexes[] = $row['Key_name']; } } return $indexes; } /** * 获取所有的fields * * @access public * @param string $table_name 数据表名 * @return array */ function get_fields($table_name) { $fields = array(); $result = $this->db->query("SHOW FIELDS FROM $table_name", 'SILENT'); if ($result) { while ($row = $this->db->fetchRow($result)) { $fields[] = $row['Field']; } } return $fields; } /** * 判断是否还有其它的查询 * * @access private * @param string $sql_string SQL查询串 * @return boolean 有返回true，否则返回false */ function has_other_query($sql_string) { return preg_match('/^\s*ALTER\s+TABLE\s*`\w+`\s*\w+/i', $sql_string); } /** * 在查询串中加入字符集设置 * * @access private * @param string $sql_string SQL查询串 * @return string 含有字符集设置的SQL查询串 */ function insert_charset($sql_string) { if ($this->db->version() > '4.1') { $sql_string = preg_replace('/(TEXT|CHAR\(.*?\)|VARCHAR\(.*?\))\s+/i', '\1 CHARACTER SET ' . $this->db_charset . ' ', $sql_string); } return $sql_string; } /** * 处理其它的数据库操作 * * @access private * @param string $query_item SQL查询项 * @return boolean 成功返回true，失败返回false。 */ function do_other($query_item) { if (!$this->db->query($query_item, 'SILENT')) { $this->handle_error($query_item); return false; } return true; } /** * 处理错误信息 * * @access private * @param string $query_item SQL查询项 * @return boolean 成功返回true，失败返回false。 */ function handle_error($query_item) { $mysql_error = 'ERROR NO: ' . $this->db->errno() . "\r\nERROR MSG: " . $this->db->error(); $error_str = "SQL Error:\r\n " . $mysql_error . "\r\n\r\n" . "Query String:\r\n ". $query_item . "\r\n\r\n" . "File Path:\r\n ". $this->current_file . "\r\n\r\n\r\n\r\n"; /* 过滤一些错误 */ if (!in_array($this->db->errno(), $this->ignored_errors)) { $this->error = $error_str; } if ($this->log_path) { $f = @fopen($this->log_path, 'ab+'); if (!$f) { return false; } if ([email protected]($f, $error_str)) { return false; } } return true; }}?>?
/** * 安装数据 * * @access public * @param array $sql_files SQL文件路径组成的数组 * @return boolean 成功返回true，失败返回false */function install_data($sql_files){ global $err; include(ROOT_PATH . 'data/config.php'); include_once(ROOT_PATH . 'includes/cls_mysql.php'); include_once(ROOT_PATH . 'includes/cls_sql_executor.php'); $db = new cls_mysql($db_host, $db_user, $db_pass, $db_name); $se = new sql_executor($db, EC_DB_CHARSET, 'ecs_', $prefix); $result = $se->run_all($sql_files); if ($result === false) { $err->add($se->error); return false; } return true;}function rollback($next_ver){ global $db, $prefix, $err; $structure_path[] = ROOT_PATH . 'data/sqldata/' . $next_ver . '.sql'; if(!file_exists($structure_path[0])) { return false; } $db_charset = strtolower((str_replace('-', '', EC_CHARSET))); $se = new sql_executor($db, $db_charset, 'ecs_', $prefix); $result = $se->run_all($structure_path); if ($result === false) { $err->add($se->error); return false; } return true;}