一个php pdo mysql操作类

3. /**

4. * PDO 操作
5. * Created by PhpStorm.
6. * User: sumiaowen
7. * Date: 13-11-28
8. * Time: 下午9:12
9. * To change this template use File | Settings | File Templates.
10. */
11. class Pdo_db
12. {
13. private $dns = null;
14. private $username = null;
15. private $password = null;
16. private $conn = null;
17. private static $_instance = null;

18. private function __construct($params = array())

19. {
20. $this->dns = $params['dns'];
21. $this->username = $params['username'];
22. $this->password = $params['password'];

23. $this->_connect();

24. }

25. private function __clone() { }

26. public function get_instance($params = array())

27. {
28. if(!(self::$_instance instanceof self))
29. {
30. self::$_instance = new self($params);
31. }

32. return self::$_instance;

33. }

34. private function _connect()

35. {
36. try
37. {
38. $this->conn = new PDO($this->dns, $this->username, $this->password);
39. $this->conn->query('set names utf8');
40. }
41. catch(PDOException $e)
42. {
43. exit('PDOException: ' . $e->getMessage());
44. }
45. }

46. /**

47. * 查询一条SQL语句
48. * @param string $sql
49. * @param array $parameters 需要绑定的参数
50. * @param int $option
51. * @return array
52. */
53. public function query($sql, $parameters = array(), $option = PDO::FETCH_ASSOC)
54. {
55. $stmt = $this->conn->prepare($sql);
56. $stmt->execute($parameters);

57. $tmp = array();

58. while($row = $stmt->fetch($option))
59. {
60. $tmp[] = $row;
61. }

62. return $tmp;

63. }

64. /**

65. * 插入一条数据
66. * @param string $sql
67. * @param array $parameters
68. * @return int 1 or 0 返回影响行数
69. */
70. public function insert($sql, $parameters = array())
71. {
72. $stmt = $this->conn->prepare($sql);
73. $stmt->execute($parameters);

74. return $stmt->rowCount();

75. }

76. /**

77. * 更新一条数据
78. * @param string $sql
79. * @param array $parameters
80. * @return int 1 or 0 返回影响行数
81. */ bbs.it-home.org
82. public function update($sql, $parameters = array())
83. {
84. $stmt = $this->conn->prepare($sql);
85. $stmt->execute($parameters);

86. return $stmt->rowCount();

87. }

88. /**

89. * 删除一条数据
90. * @param string $sql
91. * @param array $parameters
92. * @return int 1 or 0 返回影响行数
93. */
94. public function delete($sql, $parameters = array())
95. {
96. $stmt = $this->conn->prepare($sql);
97. $stmt->execute($parameters);

98. return $stmt->rowCount();

99. }
100. }

复制代码

代码链接地址：https://github.com/sumiaowen/mynotes/tree/master/pdo_mysql_class