phpsql文件导入类(示例)

2. <?php
3. class DBManager
4. {
5. var $dbHost = '';
6. var $dbUser = '';
7. var $dbPassword = '';
8. var $dbSchema = '';
10. function __construct($host,$user,$password,$schema)
11. {
12. $this->dbHost = $host;
13. $this->dbUser = $user;
14. $this->dbPassword = $password;
15. $this->dbSchema = $schema;
16. }
18. function createFromFile($sqlPath,$delimiter = '(;\n)|((;\r\n))|(;\r)',$prefix = '',$commenter = array('#','--'))
19. {
20. //判断文件是否存在
21. if(!file_exists($sqlPath))
22. return false;
24. $handle = fopen($sqlPath,'rb');
26. $sqlStr = fread($handle,filesize($sqlPath));
28. //通过sql语法的语句分割符进行分割
29. $segment = explode(";",trim($sqlStr));
31. //var_dump($segment);
33. //去掉注释和多余的空行
34. foreach($segment as & $statement)
35. {
36. $sentence = explode("\n",$statement);
38. $newStatement = array();
40. foreach($sentence as $subSentence)
41. {
42. if('' != trim($subSentence))
43. {
44. //判断是会否是注释
45. $isComment = false;
46. foreach($commenter as $comer)
47. {
48. if(eregi("^(".$comer.")",trim($subSentence)))
49. {
50. $isComment = true;
51. break;
52. }
53. }
54. //如果不是注释，则认为是sql语句
55. if(!$isComment)
56. $newStatement[] = $subSentence;
57. }
58. }
60. $statement = $newStatement;
61. }
62. //对表名加前缀
63. if('' != $prefix)
64. {
67. //只有表名在第一行出现时才有效 例如 CREATE TABLE talbeName
69. $regxTable = "^[\`\'\"]{0,1}[\_a-zA-Z]+[\_a-zA-Z0-9]*[\`\'\"]{0,1}$";//处理表名的正则表达式
70. $regxLeftWall = "^[\`\'\"]一叶扁舟";
72. $sqlFlagTree = array(
73. "CREATE" => array(
74. "TABLE" => array(
75. "$regxTable" => 0
76. )
77. ),
78. "INSERT" => array(
79. "INTO" => array(
80. "$regxTable" => 0
81. )
82. )
84. );
86. foreach($segment as & $statement)
87. {
88. $tokens = split(" ",$statement[0]);
90. $tableName = array();
91. $this->findTableName($sqlFlagTree,$tokens,0,$tableName);
93. if(empty($tableName['leftWall']))
94. {
95. $newTableName = $prefix.$tableName['name'];
96. }
97. else{
98. $newTableName = $tableName['leftWall'].$prefix.substr($tableName['name'],1);
99. }
101. $statement[0] = str_replace($tableName['name'],$newTableName,$statement[0]);
102. }
104. }
105. //组合sql语句
106. foreach($segment as & $statement)
107. {
108. $newStmt = '';
109. foreach($statement as $sentence)
110. {
111. $newStmt = $newStmt.trim($sentence)."\n";
112. }
114. $statement = $newStmt;
115. }
116. self::saveByQuery($segment);
118. return true;
119. }
121. private function saveByQuery($sqlArray)
122. {
123. $conn = mysql_connect($this->dbHost,$this->dbUser,$this->dbPassword);
125. mysql_select_db($this->dbSchema);
127. foreach($sqlArray as $sql)
128. {
129. mysql_query("set names utf8"); //声明字符集
130. mysql_query($sql);
131. }
132. mysql_close($conn);
133. }
135. private function findTableName($sqlFlagTree,$tokens,$tokensKey=0,& $tableName = array())
136. {
137. $regxLeftWall = "^[\`\'\"]一叶扁舟";
139. if(count($tokens)<=$tokensKey)
140. return false;
142. if('' == trim($tokens[$tokensKey]))
143. {
144. return self::findTableName($sqlFlagTree,$tokens,$tokensKey+1,$tableName);
145. }
146. else
147. {
148. foreach($sqlFlagTree as $flag => $v)
149. {
150. if(eregi($flag,$tokens[$tokensKey]))
151. {
152. if(0==$v)
153. {
154. $tableName['name'] = $tokens[$tokensKey];
156. if(eregi($regxLeftWall,$tableName['name']))
157. {
158. $tableName['leftWall'] = $tableName['name']{0};
159. }
161. return true;
162. }
163. else{
164. return self::findTableName($v,$tokens,$tokensKey+1,& $tableName);
165. }
166. }
167. }
168. }
170. return false;
171. }
172. }
173. function writeArrayToFile($fileName,$dataArray,$delimiter="\r\n")
174. {
175. $handle=fopen($fileName, "wb");
177. $text = '';
179. foreach($dataArray as $data)
180. {
181. $text = $text.$data.$delimiter;
182. }
183. fwrite($handle,$text);
184. }

2，调用方法：

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