文本文件操作的php类

2. var $file;
3. var $index;
4. //建立一个文件并写入输入
5. function null_write($new) {
6. $f=fopen($this->file,"w");
7. flock($f,LOCK_EX);
8. fputs($f,$new);
9. fclose($f);
10. }
11. // 添加数据记录到文件末端
12. function add_write($new) {
13. $f=fopen($this->file,"a");
14. flock($f,LOCK_EX);
15. fputs($f,$new);
16. fclose($f);
17. }
18. // 配合readfile()的返回一起使用,把一行数据转换为一维数组
19. function make_array($line) {
20. $array = explode("\\x0E",$line);
21. return $array;
22. }
23. //把为一维数组转换一行数据
24. function join_array($line) {
25. $array = join("\\x0E",$line); return $array;
26. }
27. // 返回数据文件的总行数
28. function getlines() {
29. $f=file($this->file);
30. return count($f);
31. }
32. // 返回下一行的数据记录(备用)
33. function next_line() {
34. $this->index=$this->index++;
35. return $this->get();
36. }
37. // 返回上一行的数据记录(备用)
38. function prev_line() {
39. $this->index=$this->index--;
40. return $this->get();
41. }
42. // 返回当前行的数据记录数据较小
43. function get() {
44. $f=fopen($this->file,"r");
45. flock($f,LOCK_SH);
46. for($i=0;$iindex;$i++) {
47. $rec=fgets($f,1024);
48. }
49. $line=explode("\\x0E",$rec);
50. fclose($f);
51. return $line;
52. }
53. // 返回当前行的数据记录数据较大
54. function get_big_file() {
55. $f=fopen($this->file,"r");
56. flock($f,LOCK_SH);
57. for($i=0;$iindex;$i++) {
58. $rec=fgets($f,1024*5);
59. }
60. $line=explode("\\x0E",$rec);
61. fclose($f);
62. return $line;
63. }
64. // 打开数据文件---以一维数组返回文件内容
65. function read_file() {
66. if (file_exists($this->file)) {
67. $line =file($this->file);
68. }
69. return $line;
70. }
71. // 打开数据文件---以二维数组返回文件内容
72. function openFile() {
73. if (file_exists($this->file)) {
74. $f =file($this->file);
75. $lines = array();
76. foreach ($f as $rawline) {
77. $tmpline = explode("\\x0E",$rawline);
78. array_push($lines, $tmpline);
79. }
80. }
81. return $lines;
82. }
83. // 传入一个数组,合并成一行数据,重写整个文件
84. function overwrite($array){
85. $newline = implode("\\x0E",$array);
86. $f = fopen($this->file,"w");
87. flock($f,LOCK_EX);
88. fputs($f,$newline);
89. fclose($f);
90. }
91. // 添加一行数据记录到文件末端
92. function add_line($array,$check_n=1) {
93. $s=implode("\\x0E",$array);
94. $f=fopen($this->file,"a");
95. flock($f,LOCK_EX);
96. fputs($f,$s);
97. if ($check_n==1)
98. fputs($f,"\\n");
99. fclose($f);
100. }
101. // 插入一行数据记录到文件最前面
102. function insert_line($array) {
103. $newfile = implode("\\x0E",$array);
104. $f = fopen($this->file,"r");
105. flock($f,LOCK_SH);
106. while ($line = fgets($f,1024)) {
107. $newfile .= $line;
108. }
109. fclose($f);
110. $f = fopen($this->file,"w");
111. flock($f,LOCK_EX);
112. fputs($f,$newfile);
113. fclose($f);
114. }
115. // 更新所有符合条件的数据记录,适用于每行字节数据较大的情况
116. function update($column,$query_string,$update_array) {
117. $update_string = implode("\\x0E",$update_array);
118. $newfile = "";
119. $fc=file($this->file);
120. $f=fopen($this->file,"r");
121. flock($f,LOCK_SH);
122. for ($i=0;$i $list = explode("\\x0E",$fc[$i]);
123. if ($list[$column] != $query_string) {
124. $newfile = $newfile.chop($fc[$i])."\\n";
125. } else {
126. $newfile = $newfile.$update_string;
127. }
128. }
129. fclose($f);
130. $f=fopen($this->file,"w");
131. flock($f,LOCK_EX);
132. fputs($f,$newfile);
133. fclose($f);
134. }
135. // 更新所有符合条件的数据记录,适用于每行字节数据较小的情况
136. function update2($column,$query_string,$update_array) {
137. $newline = implode("\\x0E",$update_array);
138. $newfile = "";
139. $f = fopen($this->file,"r");
140. flock($f,LOCK_SH);
141. while ($line = fgets($f,1024)) {
142. $tmpLine = explode("\\x0E",$line);
143. if ($tmpLine[$column] == $query_string) {
144. $newfile .= $newline;
145. } else {
146. $newfile .= $line;
147. }
148. }
149. fclose($f);
150. $f = fopen($this->file,"w");
151. flock($f,LOCK_EX);
152. fputs($f,$newfile);
153. fclose($f);
154. }
155. // 删除所有符合条件的数据记录,适用于每行字节数据较大的情况
156. function delete($column,$query_string) {
157. $newfile = "";
158. $fc=file($this->file);
159. $f=fopen($this->file,"r");
160. flock($f,LOCK_SH);
161. for ($i=0;$i $list = explode("\\x0E",$fc[$i]);
162. if ($list[$column] != $query_string) {
163. $newfile = $newfile.chop($fc[$i])."\\n";
164. }
165. }
166. fclose($f);
167. $f=fopen($this->file,"w");
168. flock($f,LOCK_EX);
169. fputs($f,$newfile);
170. fclose($f);
171. }
172. // 删除所有符合条件的数据记录,适用于每行字节数据较小的情况
173. function delete2($column,$query_string){
174. $newfile = "";
175. $f = fopen($this->file,"r");
176. flock($f,LOCK_SH);
177. while ($line = fgets($f,1024)) {
178. $tmpLine = explode("\\x0E",$line);
179. if ($tmpLine[$column] != $query_string) {
180. $newfile .= $line;
181. }
182. }
183. fclose($f);
184. $f = fopen($this->file,"w");
185. flock($f,LOCK_EX);
186. fputs($f,$newfile);
187. fclose($f);
188. }
189. //取得一个文件里某个字段的最大值
190. function get_max_value($column) {
191. $tlines = file($this->file);
192. for ($i=0;$i $line=explode("\\x0E",$tlines[$i]);
193. $get_value[]=$line[$column];
194. }
195. $get_max_value = max($get_value);
196. return $get_max_value;
197. }
198. // 根据数据文件的某个字段是否包含$query_string进行查询,以二维数组返回所有符合条件的数据
199. function select($column, $query_string) {
200. $tline = $this->openfile();
201. $lines = array();
202. foreach ($tline as $line) {
203. if ($line[$column] == $query_string) {
204. array_push($lines, $line);
205. }
206. }
207. return $lines;
208. }
209. // 功能与function select()一样,速度可能略有提升
210. function select2($column, $query_string) {
211. if (file_exists($this->file)) {
212. $tline = $this->read_file();
213. foreach ($tline as $tmpLine) {
214. $line = $this->make_array($tmpLine);
215. if ($line[$column] == $query_string) {
216. $lines[]=$tmpLine;
217. }
218. }
219. }
220. return $lines;
221. }
222. // 根据数据文件的某个字段是否包含$query_string进行查询,以一维数组返回第一个符合条件的数据
223. function select_line($column, $query_string) {
224. $tline = $this->read_file();
225. foreach ($tline as $tmpLine) {
226. $line = $this->make_array($tmpLine);
227. if ($line[$column] == $query_string) {
228. return $line;
229. break;
230. }
231. }
232. }
233. // select next/prev line(next_prev ==> 1/next, 2/prev) by cx
234. function select_next_prev_line($column, $query_string, $next_prev) {
235. $tline = $this->read_file();
236. $line_key_end = count($tline) - 1;
237. $line_key = -1;
238. foreach ($tline as $tmpLine) {
239. $line_key++;
240. $line = $this->make_array($tmpLine);
241. if ($next_prev == 1) {
242. // next?
243. if ($line[$column] == $query_string) {
244. if ($line_key == 0) {
245. return 0;
246. } else {
247. $line_key_up = $line_key - 1;
248. return $up_line;
249. }
250. } else {
251. $up_line = $line;
252. }
253. } elseif ($next_prev == 2) {
254. // prev?
255. if ($line[$column] == $query_string) {
256. if ($line_key == $line_key_end) {
257. return 0;
258. } else {
259. $line_key_down = $line_key + 1;
260. break;
261. }
262. }
263. } else {
264. return 0;
265. }
266. }
267. $down_line = $this->make_array($tline[$line_key_down]);
268. return $down_line;
269. }
270. ?>

复制代码

文本文件, php