phpsql文件导入类(示例)

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

2，调用方法：

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