php导入sql文件

sql php

php导入sql文件

基本思路

1.打开sql文件，放入一个变量（字符串类型）其中

2.使用正则替换掉其中的凝视（“--”与“/**/”）

3.使用explode切割成为一个数组并去除每行的空格

4.链接数据库之后使用my_query()运行sql

代码

1. <?php
3. // +------------------------------------------------------------------------------------------
4. // | Author: longDD <longdd_love@163.com>
5. // +------------------------------------------------------------------------------------------
6. // | There is no true,no evil,no light,there is only power.
7. // +------------------------------------------------------------------------------------------
8. // | Description: import sql Dates: 2014-08-07
9. // +------------------------------------------------------------------------------------------
12. class ImportSql
13. {
15. /** @var $content 数据库连接 */
16. protected $connect = null;
17. /** @var $db 数据库对象 */
18. protected $db = null;
19. /** @var $sqlFile sql文件 */
20. public $sqlFile = "";
21. /** @array @sqlArr sql语句数组 */
22. public $sqlArr = array();
24. /**
25. * 构造函数
26. *
27. * @param string $host 主机地址
28. * @param string $user username
29. * @param string $pw password
30. * @param $db_name 数据库名称
31. * @return void
32. */
33. public function __construct($host, $user, $pw, $db_name)
34. {
35. /** 连接数据库 */
36. $this->connect = mysql_connect($host, $user, $pw) or die("Could not connect: " . mysql_error());
37. /** 选中数据库 */
38. $this->db = mysql_select_db($db_name, $this->connect) or die("Yon can not select the table:" . mysql_error());
39. }
41. /**
42. * 导入sql文件
43. *
44. * @param string $url 文件路径
45. * @return true 导入成返回true
46. */
47. public function Import($url)
48. {
49. if(!file_exists($url))
50. {
51. exit("文件不存在！");
52. }
54. $this->sqlFile = file_get_contents($url);
56. if (!$this->sqlFile)
57. {
58. exit("打开文件错误！");
59. }
60. else
61. {
62. $this->GetSqlArr();
64. if ($this->Runsql())
65. {
66. return true;
67. }
68. }
69. }
71. /**
72. * 获取sql语句数组
73. *
74. * @return void
75. */
76. public function GetSqlArr()
77. {
78. /** 去除凝视 */
79. $str = $this->sqlFile;
80. $str = preg_replace('/--.*/i', '', $str);
81. $str = preg_replace('/\/\*.*\*\/(\;)?/i', '', $str);
83. /** 去除空格 创建数组 */
84. $str = explode(";\n", $str);
86. foreach ($str as $v)
87. {
88. $v = trim($v);
90. if (empty($v))
91. {
92. continue;
93. }
94. else
95. {
96. $this->sqlArr[] = $v;
97. }
98. }
99. }
101. /**
102. * 运行sql文件
103. *
104. * @return true 运行成功返回true
105. */
106. public function RunSql()
107. {
108. /** 开启事务 */
109. if (mysql_query('BEGIN'))
110. {
111. foreach ($this->sqlArr as $k => $v)
112. {
113. if (!mysql_query($v))
114. {
115. /** 回滚 */
116. mysql_query('ROLLBACK');
118. exit("sql语句错误：第" . $k . "行" . mysql_error());
119. }
120. }
122. /** 提交事务 */
123. mysql_query('COMMIT');
124. return true;
125. }
126. else
127. {
128. exit('无法开启事务！');
129. }
130. }
132. }
134. // +------------------------------------------------------------------------------------------
135. // | End of ImportSql class
136. // +------------------------------------------------------------------------------------------
139. /**
140. * This is a example.
141. */
143. header("Content-type:text/html;charset=utf-8");
145. $sql = new ReadSql("localhost", "root", "", "log_db");
147. $rst = $sql->Import("./log_db.sql");
149. if ($rst)
150. {
151. echo "Success。";
152. }
154. // +------------------------------------------------------------------------------------------
155. // | End of file ImportSql.php
156. // +------------------------------------------------------------------------------------------
157. // | Location: ./ImportSql.php
158. // +------------------------------------------------------------------------------------------