How to use PHP to execute .SQL files_PHP Tutorial

/**
* Read sql file and write to database
* @version 1.01 demo.php
*/
class DBManager
{
var $dbHost = '';
var $dbUser = '';
var $dbPassword = '';
var $dbSchema = '';

function __construct($host,$user,$password,$schema)
{
$this ->dbHost = $host;
$this->dbUser = $user;
$this->dbPassword = $password;
$this->dbSchema = $schema;
}

function createFromFile($sqlPath,$delimiter = '(;/n)|((;/r/n))|(;/r)',$prefix = '',$commenter = array ('#','--'))
{
//Determine whether the file exists
if(!file_exists($sqlPath))
return false;

$handle = fopen($sqlPath,'rb');

$sqlStr = fread($handle,filesize($sqlPath));

//Split by the statement separator of sql syntax
       $segment = explode(";",trim($sqlStr));

             //var_dump($segment);                                                                                                                                               foreach($segment as & $statement)
                                          $sentence =                                                 ($ Sentence as $ Subsentence)
{
if (''! = Trim ($ Subsentence))
{
// Determine whether it will be notes
$ isComment = false;
foreach($commenter as $comer)
{
🎜>                                                                                                                             true;
break;
}
}
//If not Comment, it is considered to be a sql statement
                                                                                                                                                                                          🎜>                                                                                                                                   
                                                                                                   TABLE talbeName

                           $regxTable = "^[/`/'/"]{0,1}[/_a-zA-Z]+[/_a-zA-Z0-9]*[/`/ '/"]{0,1}$";//Regular expression for processing table names
                                                                                           $regxLeftWall =                                               = array(
“CREATE” => array(
“TABLE” => array(
) "$regxTable" => 0
                                                                                                              " => array(
"INTO" "INTO" "$regxTable" => array(
"$regxTable" => 0
)
)
)

);

foreach($segment as & $statement)
                                                                                       $this- >findTableName($sqlFlagTree,$tokens,0,$tableName);

                                                                 Name = $prefix.$tableName ['name'];
}
else{
$newTableName = $tableName['leftWall'].$prefix.substr($tableName['name'],1);
          }

$statement[0] = str_replace($tableName['name'],$newTableName,$statement[0]);
      
        //组合sql语句
        foreach($segment as & $statement)
        {
            $newStmt = '';
            foreach($statement as $sentence)
            {
                $newStmt = $newStmt.trim($sentence)."/n";
            }

            $statement = $newStmt;
        }

        //用于测试------------------------      
        //var_dump($segment);
        //writeArrayToFile('data.txt',$segment);
        //-------------------------------

        self::saveByQuery($segment);

        return true;
    }

    private function saveByQuery($sqlArray)
    {
        $conn = mysql_connect($this->dbHost,$this->dbUser,$this->dbPassword);

        mysql_select_db($this->dbSchema);

        foreach($sqlArray as $sql)
        {
            mysql_query($sql);
        }      
        mysql_close($conn);
    }

    private function findTableName($sqlFlagTree,$tokens,$tokensKey=0,& $tableName = array())
    {
        $regxLeftWall = "^[/`/'/"]{1}";

        if(count($tokens)<=$tokensKey)
            return false;      

        if('' == trim($tokens[$tokensKey]))
        {
            return self::findTableName($sqlFlagTree,$tokens,$tokensKey+1,$tableName);
        }
        else
        {
            foreach($sqlFlagTree as $flag => $v)
            {  
                if(eregi($flag,$tokens[$tokensKey]))
                {
                    if(0==$v)
                    {
                        $tableName['name'] = $tokens[$tokensKey];

                        if(eregi($regxLeftWall,$tableName['name']))
                        {
                            $tableName['leftWall'] = $tableName['name']{0};
                        }

                        return true;
                    }
                    else{
                        return self::findTableName($v,$tokens,$tokensKey+1,& $tableName);
                    }
                }
            }
        }

        return false;
    }
}
function writeArrayToFile($fileName,$dataArray,$delimiter="/r/n")
{
    $handle=fopen($fileName, "wb");

    $text = '';

    foreach($dataArray as $data)
    {
        $text = $text.$data.$delimiter;
    }
    fwrite($handle,$text);
}
//测试
$dbM = new DBManager('localhost','w01f','123456','test');
$dbM->createFromFile('data.sql',null,'fff_');
?>