php sql 파일 가져오기 클래스(예)

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;
 }

 함수 createFromFile($sqlPath,$delimiter = '(;n)|((;rn))|(;r)',$prefix = '',$commenter = array('#','- -'))
 {
 //파일 존재 여부 확인
 if(!file_exists($sqlPath))
 return false;

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

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

 //SQL 구문의 문 구분 기호를 통해 분할
 $segment =explore( ";",trim($sqlStr));

 //var_dump($segment);

 //주석 및 추가 빈 줄 제거
 foreach($segment as & $ 문 )
 {
 $sentence =Explode("n",$statement);

 $newStatement = array();

 foreach($sentence를 $subSentence로)
 {
 if('' != Trim($subSentence))
 {
 //댓글인지 판단
 $isComment = false;
 foreach($commenter as $ Comer )
 {
 if(eregi("^(".$comer.")",trim($subSentence)))
 {
 $isComment = true;
 break;
 }
 }
 //주석이 아니면 SQL 문으로 간주합니다.
 if(!$isComment)
 $newStatement[] = $subSentence
 }
 }

 $statement = $newStatement;
 }
 //테이블 이름에 접두사 추가
 if('' != $prefix)
 {


 //테이블 이름이 첫 번째 행에 나타날 때만 유효합니다. 예: CREATE TABLE talbeName

 $regxTable = "^[`'"]{0,1}[_a-zA -Z] [_a-zA- Z0-9]*[`'"]{0,1}$";//테이블 이름 처리를 위한 정규식
 $regxLeftWall = "^[`'"]다음을 포함하는 보트 Leaves";

 $sqlFlagTree = array(
 "CREATE" => array(
 "TABLE" => array(
 "$regxTable" => 0
 )
 ),
 "INSERT" => array(
 "INTO" => array(
 "$regxTable" => 0
 )
 )

 );

 foreach($segment as & $statement)
 {
 $tokens = Split(" ",$statement[0]);

 $tableName = array();
 $this->findTableName($sqlFlagTree,$tokens,0,$tableName);

 if(empty($tableName['leftWall']))
 {
 $newTableName = $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;
 }
 self::saveByQuery($segment );

 true를 반환합니다.
 }

 개인 함수 saveByQuery($sqlArray)
 {
 $conn = mysql_connect($this->dbHost,$this- >dbUser,$this-> ;dbPassword);

 mysql_select_db($this->dbSchema);

 foreach($sqlArray as $sql)
 {
 mysql_query ("set names utf8"); //문자 집합 선언
 mysql_query($sql);
 }
 mysql_close($conn);
 }

 비공개 함수 findTableName($sqlFlagTree,$tokens,$tokensKey=0,& $tableName = array())
 {
 $regxLeftWall = "^[`'"]一叶扁舟" ;

 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="rn")
{
 $handle=fopen($fileName, "wb");

 $text = '';

 foreach($dataArray $data로)
 {
 $text = $text.$data.$delimiter;
 }
 fwrite($handle,$text);
}

2，调사용방법：

$dbM = new DBManager('localhost','root','root','6639');
$dbM->createFromFile ('data.sql',null,'');