当前位置:首页 > PHP教程 > php类库 > 列表

php实现可用于mysql,mssql,pg数据库操作类

发布:smiling 来源: PHP粉丝网  添加日期:2021-05-03 16:08:13 浏览: 评论:0 

这篇文章主要介绍了php实现可用于mysql,mssql,pg数据库操作类,以类的形式封装了对mysql,mssql,pg三种数据库的操作,非常具有实用价值,需要的朋友可以参考下

本文实例讲述了可用mysql,mssql,pg三种数据库的数据库操作类,你只要作任何修改就可以方便的改变你数据库的类型.分享给大家供大家参考。具体分析如下:

函数清单,索引:

Open:打开数据库连接 Line:71

Close:关闭数据库连接 Line:107

SelectDB:选择数据库 Line:129

Query:创建查询 Line:151

DataSeek:移动记录指针 Line:175

FieldName:获取字段名称 Line:198

FieldType:获取字段类型 Line:220

FieldLenght:获取字段长度 Line:242

FetchRow:获取数据并保存到数组(数字索引) Line:264

FetchArray:获取数据并保存进数组(数字和关联) Line:289

FetchObject:获取数据并保存到对象(对象方式) Line:315

Result:获取结果数据 Line:341

FreeResult:刷新记录集 Line:363

RowsNumber:获取记录数量 Line:385

FieldsNumber:获取字段数量 Line:407

CurRecNumber:获取当前记录号(从0开始) Line:429

RecordNumber:获取当前行号(从1开始) Line:438

MoveFirstRec:移动到第一条记录 Line:447

MoveLastRec:移动到最后一条记录 Line:469

MovePreviousRec:移动到前一条记录 Line:495

MoveNextRec:移动到下一条记录 Line:521

MoveToRec:移动到一个特定的记录(从1开始) Line:548

php数据库操作类代码如下:

  1. <?PHP 
  2. /********************************************************************************** 
  3. 此类将数据库操作封装,具有良好的可移植性,针对数据库:mysql,mssql,pg 
  4. ************************************************************************************ 
  5. // -函数清单 索引: 
  6. // - Open: 打开数据库连接 Line:71 
  7. // - Close: 关闭数据库连接 Line:107 
  8. // - SelectDB: 选择数据库 Line:129 
  9. // - Query: 创建查询 Line:151 
  10. // - DataSeek: 移动记录指针 Line:175 
  11. // - FieldName: 获取字段名称 Line:198 
  12. // - FieldType: 获取字段类型 Line:220 
  13. // - FieldLenght: 获取字段长度 Line:242 
  14. // - FetchRow: 获取数据并保存到数组(数字索引) Line:264 
  15. // - FetchArray: 获取数据并保存进数组(数字和关联) Line:289 
  16. // - FetchObject: 获取数据并保存到对象(对象方式) Line:315 
  17. // - Result: 获取结果数据 Line:341 
  18. // - FreeResult: 刷新记录集 Line:363 
  19. // - RowsNumber: 获取记录数量 Line:385 
  20. // - FieldsNumber: 获取字段数量 Line:407 
  21. // - CurRecNumber: 获取当前记录号(从0开始) Line:429 
  22. // - RecordNumber: 获取当前行号(从1开始) Line:438 
  23. // - MoveFirstRec: 移动到第一条记录 Line:447 
  24. // - MoveLastRec: 移动到最后一条记录 Line:469 
  25. // - MovePreviousRec: 移动到前一条记录 Line:495 
  26. // - MoveNextRec: 移动到下一条记录 Line:521 
  27. // - MoveToRec: 移动到一个特定的记录(从1开始) Line:548 
  28. ************************************************************************************ 
  29. //Inputs: 
  30. // - dbType: databases type: mssql, mysql, pg 
  31. // - connectType: connection type: c - common connection, 
  32. // p - open persistent connection 
  33. // - connect: for MS SQL Server - server name, 
  34. // for MySQL - hostname [:port] [:/path/to/socket] , 
  35. // for PostgreSQL - host, port, tty, options, 
  36. // dbname (without username and password) 
  37. // - username 
  38. // - password 
  39. // - dbName: database name 
  40. // - query: SQL query 
  41. // - result: result set identifier 
  42. // - RowNumber: 
  43. // - offset: field identifier 
  44. // - ResultType: a constant and can take the following values: PGSQL_ASSOC, PGSQL_NUM, and PGSQL_BOTH 
  45. // - FieldName 
  46. // 
  47. //Returns: 
  48. // - result: result set identifier 
  49. // - connect link identifier 
  50. // - record number (starting at 0: CurrRecNumber or starting at 1: RecordNumber) 
  51. // - number of fields in the specified result set 
  52. // - number of rows in the specified result set 
  53. *************************************************************************************/ 
  54. Class mDatabase 
  55. /***********************************成员变量定义***************************************/ 
  56. var $dbType// 数据库类型: mssql, mysql, pg 
  57. var $connectType// 连接类型: c - common connection, p - open persistent connection 
  58. var $idCon// 连接号 
  59. var $curRow// current row number of data from the result 
  60. // associated with the specified result identifier array 
  61. var $seek// current row number of data from DataSeek function array 
  62.  
  63. /***********************************成员方法实现***************************************/ 
  64. /************************************************************************************ 
  65. *连接数据库的函数 
  66. *************************************************************************************/ 
  67. Function Open($dbType$c$connect$username = ""$password = ""
  68. $this->dbType = $dbType
  69. Switch ($dbType) { 
  70. Case "mssql"
  71. If ($connectType == "c") { 
  72. $idCon = mssql_connect($connect$username$password); 
  73. } Else { 
  74. $idCon = mssql_pconnect($connect$username$password); 
  75. Break; 
  76. Case "mysql"
  77. If ($connectType == "c") { 
  78. $idCon = mysql_connect($connect$username$password); 
  79. } Else { 
  80. $idCon = mysql_pconnect($connect$username$password); 
  81. Break; 
  82. Case "pg"
  83. If ($connectType == "c") { 
  84. $idCon = pg_connect($connect . " user=" . $username . " password=" . $password); 
  85. } Else { 
  86. $idCon = pg_pconnect($connect . " user=" . $username . " password=" . $password); 
  87. Break; 
  88. Default: 
  89. $idCon = 0; 
  90. Break; 
  91. $this->idCon = $idCon
  92. Return $idCon
  93. /************************************************************************************ 
  94. *关闭数据库连接 
  95. *************************************************************************************/ 
  96. Function Close() 
  97. Switch ($this->dbType) { 
  98. Case "mssql"
  99. $r = mssql_close($this->idCon); 
  100. Break; 
  101. Case "mysql"
  102. $r = mysql_close($this->idCon); 
  103. Break; 
  104. Case "pg"
  105. $r = pg_close($this->idCon); 
  106. Break; 
  107. Default: 
  108. $r = False; 
  109. Break; 
  110. Return $r
  111. /************************************************************************************ 
  112. *选择数据库 
  113. *************************************************************************************/ 
  114. Function SelectDb($dbName
  115. Switch ($this->dbType) { 
  116. Case "mssql"
  117. $r = mssql_select_db($dbName); 
  118. Break; 
  119. Case "mysql"
  120. $r = mysql_select_db($dbName); 
  121. Break; 
  122. Case "pg"
  123. $r = False; 
  124. Break; 
  125. Default: 
  126. $r = False; 
  127. Break; 
  128. Return $r
  129. /************************************************************************************ 
  130. *创建查询 
  131. *************************************************************************************/ 
  132. Function Query($query
  133. Switch ($this->dbType) { 
  134. Case "mssql"
  135. $r = mssql_query($query$this->idCon); 
  136. Break; 
  137. Case "mysql"
  138. $r = mysql_query($query$this->idCon); 
  139. Break; 
  140. Case "pg"
  141. $r = pg_exec($this->idCon, $query); 
  142. Break; 
  143. Default: 
  144. $r = False; 
  145. Break; 
  146. $this->curRow[$r] = 0; 
  147. $this->seek[$r] = 0; 
  148. Return $r
  149. /************************************************************************************ 
  150. *移动记录指针 
  151. *************************************************************************************/ 
  152. Function DataSeek($result$RowNumber
  153. Switch ($this->dbType) { 
  154. Case "mssql"
  155. $r = mssql_data_seek($result$RowNumber); 
  156. Break; 
  157. Case "mysql"
  158. $r = mysql_data_seek($result$RowNumber); 
  159. Break; 
  160. Case "pg"
  161. $r = False; 
  162. Break; 
  163. Default: 
  164. $r = False; 
  165. Break; 
  166. $this->seek[$result] = (int) $RowNumber
  167. Return $r
  168. /************************************************************************************ 
  169. *获取字段名 
  170. *************************************************************************************/ 
  171. Function FieldName($result$offset
  172. Switch ($this->dbType) { 
  173. Case "mssql"
  174. $r = mssql_field_name($result$offset); 
  175. Break; 
  176. Case "mysql"
  177. $r = mysql_field_name($result$offset); 
  178. Break; 
  179. Case "pg"
  180. $r = pg_fieldname($result$offset); 
  181. Break; 
  182. Default: 
  183. $r = False; 
  184. Break; 
  185. Return $r
  186. /************************************************************************************ 
  187. *获取字段类型 
  188. *************************************************************************************/ 
  189. Function FieldType($result$offset
  190. Switch ($this->dbType) { 
  191. Case "mssql"
  192. $r = mssql_field_type($result$offset); 
  193. Break; 
  194. Case "mysql"
  195. $r = mysql_field_type($result$offset); 
  196. Break; 
  197. Case "pg"
  198. $r = pg_fieldtype($result$offset); 
  199. Break; 
  200. Default: 
  201. $r = False; 
  202. Break; 
  203. Return $r
  204. /************************************************************************************ 
  205. *获取字段长度 
  206. *************************************************************************************/ 
  207. Function FieldLength($result$offset
  208. Switch ($this->dbType) { 
  209. Case "mssql"
  210. $r = mssql_field_length($result$offset); 
  211. Break; 
  212. Case "mysql"
  213. $r = mysql_field_len($result$offset); 
  214. Break; 
  215. Case "pg"
  216. $r = pg_fieldsize($result$offset); 
  217. Break; 
  218. Default: 
  219. $r = False; 
  220. Break; 
  221. Return $r
  222. /************************************************************************************ 
  223. *获取数据并保存到数组,可以用数字索引方式访问数组 
  224. *************************************************************************************/ 
  225. Function FetchRow($result$RowNumber = 0) 
  226. Switch ($this->dbType) { 
  227. Case "mssql"
  228. $r = mssql_fetch_row($result); 
  229. Break; 
  230. Case "mysql"
  231. $r = mysql_fetch_row($result); 
  232. Break; 
  233. Case "pg"
  234. $r = pg_fetch_row($result$RowNumber); 
  235. If ($r) { 
  236. $this->curRow[$result] = $RowNumber
  237. $this->seek[$result] = $RowNumber
  238. Break; 
  239. Default: 
  240. $r = False; 
  241. Break; 
  242. Return $r
  243.  
  244. /************************************************************************************ 
  245. *获取数据并保存到数组,可以用数字索引和关联索引的方式访问 
  246. *************************************************************************************/ 
  247. Function FetchArray($result$RowNumber = 0, $ResultType = 2) 
  248. Switch ($this->dbType) { 
  249. Case "mssql"
  250. $r = mssql_fetch_array($result); 
  251. Break; 
  252. Case "mysql"
  253. $r = mysql_fetch_array($result); 
  254. Break; 
  255. Case "pg"
  256. $r = pg_fetch_array($result$RowNumber$ResultType); 
  257. If ($r) { 
  258. $this->curRow[$result] = $RowNumber
  259. $this->seek[$result] = $RowNumber
  260. Break; 
  261. Default: 
  262. $r = False; 
  263. Break; 
  264. Return $r
  265. /************************************************************************************ 
  266. *获取数据并保存到对象 
  267. *************************************************************************************/ 
  268. Function FetchObject($result$RowNumber = 0, $ResultType = 2) 
  269. Switch ($this->dbType) { 
  270. Case "mssql"
  271. $r = mssql_fetch_object($result); 
  272. Break; 
  273. Case "mysql"
  274. $r = mysql_fetch_object($result); 
  275. Break; 
  276. Case "pg"
  277. $r = pg_fetch_object($result$RowNumber$ResultType); 
  278. If ($r) { 
  279. $this->curRow[$result] = $RowNumber
  280. $this->seek[$result] = $RowNumber
  281. Break; 
  282. Default: 
  283. $r = False; 
  284. Break; 
  285. Return $r
  286. /************************************************************************************ 
  287. *获取结果数据 
  288. *************************************************************************************/ 
  289. Function Result($result$RowNumber$FieldName
  290. Switch ($this->dbType) { 
  291. Case "mssql"
  292. $r = mssql_result($result$RowNumber$FieldName); 
  293. Break; 
  294. Case "mysql"
  295. $r = mysql_result($result$RowNumber$FieldName); 
  296. Break; 
  297. Case "pg"
  298. $r = pg_result($result$RowNumber$FieldName); 
  299. Break; 
  300. Default: 
  301. $r = False; 
  302. Break; 
  303. Return $r
  304. /************************************************************************************ 
  305. *释放结果数据 
  306. *************************************************************************************/ 
  307. Function FreeResult($result
  308. Switch ($this->dbType) { 
  309. Case "mssql"
  310. $r = mssql_free_result($result); 
  311. Break; 
  312. Case "mysql"
  313. $r = mysql_free_result($result); 
  314. Break; 
  315. Case "pg"
  316. $r = pg_freeresult($result); 
  317. Break; 
  318. Default: 
  319. $r = False; 
  320. Break; 
  321. Return $r
  322. /************************************************************************************ 
  323. *获取记录数量 
  324. *************************************************************************************/ 
  325. Function RowsNumber($result
  326. Switch ($this->dbType) { 
  327. Case "mssql"
  328. $r = mssql_num_rows($result); 
  329. Break; 
  330. Case "mysql"
  331. $r = mysql_num_rows($result); 
  332. Break; 
  333. Case "pg"
  334. $r = pg_numrows($result); 
  335. Break; 
  336. Default: 
  337. $r = False; 
  338. Break; 
  339. Return $r
  340. /************************************************************************************ 
  341. *获取字段数量 
  342. *************************************************************************************/ 
  343. Function FieldsNumber($result
  344. Switch ($this->dbType) { 
  345. Case "mssql"
  346. $r = mssql_num_fields($result); 
  347. Break; 
  348. Case "mysql"
  349. $r = mysql_num_fields($result); 
  350. Break; 
  351. Case "pg"
  352. $r = pg_numfields($result); 
  353. Break; 
  354. Default: 
  355. $r = False; 
  356. Break; 
  357. Return $r
  358. /************************************************************************************ 
  359. *获取当前记录号(从0开始) 
  360. *************************************************************************************/ 
  361. Function CurRecNumber($result
  362. $r = $this->curRow[$result]; 
  363. Return $r
  364. /************************************************************************************ 
  365. *获取当前行号(从1开始) 
  366. *************************************************************************************/ 
  367. Function RecordNumber($result
  368. $cr = $this->CurRecNumber($result) + 1; 
  369. Return $cr
  370. /************************************************************************************ 
  371. *移动到第一条记录 
  372. *************************************************************************************/ 
  373. Function MoveFirstRec($result
  374. Switch ($this->dbType) { 
  375. Case "pg"
  376. $r = $this->FetchRow($result, 0); 
  377. Break; 
  378. Default: 
  379. $rn = $this->DataSeek($result, 0); 
  380. If ($rn) { 
  381. $r = $this->FetchRow($result); 
  382. If ($r$this->curRow[$result] = $this->seek[$result]; 
  383. } Else { 
  384. $r = False; 
  385. Break; 
  386. Return $r
  387. /************************************************************************************ 
  388. *移动到最后一条记录 
  389. *************************************************************************************/ 
  390. Function MoveLastRec($result
  391. $rs = $this->RowsNumber($result); 
  392. If ($rs) { 
  393. $rs--; 
  394. Switch ($this->dbType) { 
  395. Case "pg"
  396. $r = $this->FetchRow($result$rs); 
  397. Break; 
  398. Default: 
  399. $rn = $this->DataSeek($result$rs); 
  400. If ($rn) { 
  401. $r = $this->FetchRow($result); 
  402. If ($r$this->curRow[$result] = $this->seek[$result]; 
  403. } Else { 
  404. $r = False; 
  405. Break; 
  406. Return $r
  407. /************************************************************************************ 
  408. *移动到前一条记录 
  409. *************************************************************************************/ 
  410. Function MovePreviousRec($result
  411. $rs = $this->CurRecNumber($result); 
  412. If ($rs) { 
  413. $rs--; 
  414. Switch ($this->dbType) { 
  415. Case "pg"
  416. $r = $this->FetchRow($result$rs); 
  417. Break; 
  418. Default: 
  419. $rn = $this->DataSeek($result$rs); 
  420. If ($rn) { 
  421. $r = $this->FetchRow($result); 
  422. If ($r$this->curRow[$result] = $this->seek[$result]; 
  423. } Else { 
  424. $r = False; 
  425. Break; 
  426. Return $r
  427. /************************************************************************************ 
  428. *移动到下一条记录 
  429. *************************************************************************************/ 
  430. Function MoveNextRec($result
  431. $rs = $this->CurRecNumber($result); 
  432. $rn = $this->RowsNumber($result); 
  433. $rs++; 
  434. If ($rs != $rn) { 
  435. Switch ($this->dbType) { 
  436. Case "pg"
  437. $r = $this->FetchRow($result$rs); 
  438. Break; 
  439. Default: 
  440. $re = $this->FetchRow($result); 
  441. If ($re) { 
  442. $r = $re
  443. $this->curRow[$result]++; 
  444. $this->seek[$result] = $this->curRow[$result]; 
  445. } Else { 
  446. $r = False; 
  447. Break; 
  448. Return $r
  449. /************************************************************************************ 
  450. *移动到指定记录(编号从0开始) 
  451. *************************************************************************************/ 
  452. Function MoveToRec($result$RowNumber
  453. $rn = $this->RowsNumber($result); 
  454. If ($RowNumber > 0 And $RowNumber < $rn) { 
  455. $RowNumber--; 
  456. Switch ($this->dbType) { 
  457. Case "pg"
  458. $r = $this->FetchRow($result$RowNumber); 
  459. Break; 
  460. Default: 
  461. $rn = $this->DataSeek($result$RowNumber); 
  462. If ($rn) { 
  463. $r = $this->FetchRow($result); 
  464. If ($r$this->curRow[$result] = $this->seek[$result]; 
  465. } Else { 
  466. $r = False; 
  467. Break; 
  468. Return $r
  469. //********************************方法实现完毕****************************************// 
  470. ?> 

希望本文所述对大家的PHP数据库程序设计有所帮助。

Tags: mysql mssql pg数据库操作类

分享到: