>  기사  >  백엔드 개발  >  PHP는 SQL 파일을 읽고 데이터베이스로 가져옵니다(예)

PHP는 SQL 파일을 읽고 데이터베이스로 가져옵니다(예)

WBOY
WBOY원래의
2016-07-25 08:55:001457검색
  1. /**

  2. * SQL 파일 읽기 및 데이터베이스에 쓰기
  3. * @version 1.01 데모.php
  4. * @author xingshaocheng
  5. * @edit: bbs.it-home.org
  6. */
  7. class DBManager
  8. {
  9. var $dbHost = '';
  10. var $dbUser = '';
  11. var $dbPassword = '';
  12. var $dbSchema = '';
  13. 함수 __construct($host,$user ,$password,$schema)
  14. {
  15. $this->dbHost = $host;
  16. $this->dbUser = $user;
  17. $this->dbPassword = $password;
  18. $this->dbSchema = $schema;
  19. }
  20. function createFromFile($sqlPath,$delimiter = '(;n)|((;rn))|(;r)' ,$prefix = '',$commenter = array('#','--'))
  21. {
  22. //파일 존재 여부 확인
  23. if(!file_exists($sqlPath))
  24. false 반환;
  25. $handle = fopen($sqlPath,'rb');
  26. $sqlStr = fread($handle,filesize($sqlPath));
  27. / / SQL 구문의 문 구분 기호를 통해 분할
  28. $segment =explore(";",trim($sqlStr))
  29. //var_dump($segment);
  30. / /주석 및 추가 빈 줄 제거
  31. foreach($segment as & $statement)
  32. {
  33. $sentence =Explode("n",$statement);
  34. $newStatement = array ( );
  35. foreach($sentence as $subSentence)
  36. {
  37. if('' != Trim($subSentence))
  38. {
  39. //예 또는 아니오 여부를 판단합니다.
  40. $isComment = false;
  41. foreach($commenter as $comer)
  42. {
  43. if(eregi("^(".$comer.")",trim($subSentence)))
  44. {
  45. $isComment = true;
  46. break;
  47. }
  48. }
  49. //주석이 아니면 SQL 문으로 간주
  50. if(! $isComment)
  51. $newStatement[] = $subSentence;
  52. }
  53. }
  54. $statement = $newStatement;
  55. }
  56. //테이블 이름 접두사
  57. if('' != $prefix)
  58. {
  59. //테이블 이름이 첫 번째 행에 나타날 때만 유효합니다. 예를 들어 CREATE TABLE talbeName
  60. $regxTable. = "^[`'" ]{0,1}[_a-zA-Z] [_a-zA-Z0-9]*[`'"]{0,1}$";//테이블 처리를 위한 정규식 names
  61. $regxLeftWall = "^[`'"]개발됨";
  62. $sqlFlagTree = array(
  63. "CREATE" => array(
  64. "TABLE" => array(
  65. "$regxTable " => 0
  66. )
  67. ),
  68. "INSERT" => array(
  69. "INTO" => array(
  70. "$regxTable" => ; 0
  71. )
  72. )
  73. );
  74. foreach($segment as & $statement)
  75. {
  76. $tokens = Split(" ",$statement [0]);
  77. $tableName = array();
  78. $this->findTableName($sqlFlagTree,$tokens,0,$tableName);
  79. if(empty( $tableName['leftWall ']))
  80. {
  81. $newTableName = $prefix.$tableName['name'];
  82. }
  83. else{
  84. $newTableName = $tableName['leftWall '].$prefix .substr($tableName['name'],1);
  85. }
  86. $statement[0] = str_replace($tableName['name'],$newTableName,$statement [0]);
  87. }
  88. }
  89. //결합된 SQL 문
  90. foreach($segment as & $statement)
  91. {
  92. $newStmt = '';
  93. foreach($ 문장을 $문장으로)
  94. {
  95. $newStmt = $newStmt.trim($sentence)."n";
  96. }
  97. $statement = $newStmt;
  98. }
  99. //테스트용---------
  100. //var_dump($segment);
  101. // writeArrayToFile('data.txt',$segment);
  102. //--------------------------------- -
  103. self::saveByQuery($segment);
  104. return true;
  105. }
  106. 비공개 함수 saveByQuery($sqlArray)
  107. {
  108. $conn = mysql_connect($this->dbHost,$this->dbUser,$this->dbPassword);
  109. mysql_select_db($this->dbSchema);
  110. foreach($sqlArray as $sql)
  111. {
  112. mysql_query($sql);
  113. }
  114. mysql_close($ conn);
  115. }
  116. 비공개 함수 findTableName($sqlFlagTree,$tokens,$tokensKey=0,& $tableName = array())
  117. {
  118. $regxLeftWall = "^[` '"]发达";
  119. if(count($tokens)<=$tokensKey)
  120. return false
  121. if('' == Trim($tokens[$tokensKey) ]))
  122. {
  123. return self::findTableName($sqlFlagTree,$tokens,$tokensKey 1,$tableName);
  124. }
  125. else
  126. {
  127. foreach($sqlFlagTree as $flag => $v)
  128. {
  129. if(eregi($flag,$tokens[$tokensKey]))
  130. {
  131. if(0==$v)
  132. {
  133. $tableName['name'] = $tokens[$tokensKey];
  134. if(eregi($regxLeftWall,$tableName['name']))
  135. {
  136. $tableName[' leftWall'] = $tableName['name']{0};
  137. }
  138. return true;
  139. }
  140. else{
  141. return self::findTableName($v,$ tokens,$tokensKey 1,& $tableName);
  142. }
  143. }
  144. }
  145. }
  146. return false;
  147. }
  148. }

  149. function writeArrayToFile($fileName,$dataArray,$delimiter="rn")

  150. {
  151. $handle=fopen($fileName, "wb");
  152. $text = '';
  153. foreach($dataArray as $data)
  154. {
  155. $text = $text.$data.$delimiter;
  156. }
  157. fwrite($handle,$ text);
  158. }

  159. //测试

  160. $dbM = new DBManager('localhost','w01f','123456','test');
  161. $dbM->createFromFile('data.sql',null,'fff_');
  162. ?>

复代码


성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.