expr)) || (empty($statement->from)) ) { return array(); } $retval = array(); $tables = array(); /** * Expressions that may contain aliases. * These are extracted from `FROM` and `JOIN` keywords. * * @var Expression[] */ $expressions = $statement->from; // Adding expressions from JOIN. if (!empty($statement->join)) { foreach ($statement->join as $join) { $expressions[] = $join->expr; } } foreach ($expressions as $expr) { if ((!isset($expr->table)) || ($expr->table === '')) { continue; } $thisDb = ((isset($expr->database)) && ($expr->database !== '')) ? $expr->database : $database; if (!isset($retval[$thisDb])) { $retval[$thisDb] = array( 'alias' => null, 'tables' => array(), ); } if (!isset($retval[$thisDb]['tables'][$expr->table])) { $retval[$thisDb]['tables'][$expr->table] = array( 'alias' => ((isset($expr->alias)) && ($expr->alias !== '')) ? $expr->alias : null, 'columns' => array(), ); } if (!isset($tables[$thisDb])) { $tables[$thisDb] = array(); } $tables[$thisDb][$expr->alias] = $expr->table; } foreach ($statement->expr as $expr) { if ((!isset($expr->column)) || ($expr->column === '') || (!isset($expr->alias)) || ($expr->alias === '') ) { continue; } $thisDb = ((isset($expr->database)) && ($expr->database !== '')) ? $expr->database : $database; if ((isset($expr->table)) && ($expr->table !== '')) { $thisTable = isset($tables[$thisDb][$expr->table]) ? $tables[$thisDb][$expr->table] : $expr->table; $retval[$thisDb]['tables'][$thisTable]['columns'][$expr->column] = $expr->alias; } else { foreach ($retval[$thisDb]['tables'] as &$table) { $table['columns'][$expr->column] = $expr->alias; } } } return $retval; } }