当前位置：Gxlcms > PHP教程 > phppdo封装类实现mysql数据增删查改

phppdo封装类实现mysql数据增删查改

时间：2021-07-01 10:21:17 帮助过：19人阅读

  3. define('DSN', 'mysql:host=127.0.0.1;dbname=baozhong_tour'); //数据库地址+数据库名的常量

  4. define('DB_USERNAME', 'root'); //数据库用户名
  5. define('DB_USERPWD', ''); //数据库密码
  6. ?>
  7. /**
  8. * @author shuimugan
  9. * @version 0.2
  10. * @return PDOStatement
  11. */
  12. function getConn() {
  13. try {
  14. $db = new PDO(DSN, DB_USERNAME, DB_USERPWD); //创建pdo对象,传入数据库参数信息
  15. $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); //设置数据库错误信息
  16. $db->query('set names utf8;'); //设置编码为utf8
  17. return $db;
  18. }
  19. catch (PDOException $e) {
  20. echo '数据处理出错,请联系网站管理员!';
  21. print_r($e);//超详细的报错信息,上线后必须注释这句话!
  22. return false;
  23. }
  24. }
  25. /**
  26. * @author shuimugan
  27. * @version 0.2
  28. * @param String $tablename 表名,类型为字符串
  29. * @param Array $column_name 列名,要数组的格式
  30. * @param String $condition 条件,如'where name=? and pws=?'或'name like?'
  31. * @param Array $condition_value 条件对应的数据,类型要求为数组,如'name=? and pws=?' 时,
  32. * @return Array 返回一个结果集 数组形式
  33. * @example $column_name=array('*');
  34. $condition_value=array('1');
  35. $limit='limit 0,10';
  36. $res=easy_select('user', $column_name, 'where id=? ', $condition_value,$limit);
  37. */
  38. function easy_select($tablename,$column_name,$condition,$condition_value,$limit) {
  39. try {
  40. $db=getConn();
  41. $sql='select ';//初始化sql语句
  42. foreach ($column_name as $col_name) {
  43. //动态追加列名进sql语句
  44. if($col_name=='*'){
  45. $sql.='*';
  46. break;
  47. }
  48. if($col_name==end($column_name))
  49. {
  50. $sql.=$col_name." ";//如果属于最后一个,语句不拼接逗号
  51. }else {
  52. $sql.=$col_name.", ";//拼接列名+逗号
  53. }
  54. }
  55. $sql.="from ".$tablename." ";//拼接表名
  56. $sql.=$condition.' ';//拼接条件语句
  57. if(strlen($limit)>0){
  58. $sql.=$limit;//拼接limit语句
  59. }
  60. $db = new PDO(DSN, DB_USERNAME, DB_USERPWD);//创建pdo对象,传入数据库参数信息
  61. $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//设置数据库错误信息
  62. $db->query('set names utf8;');//设置编码为utf8
  63. $stmt = $db->prepare($sql);
  64. $i=1;//开始计数,计算?的数量
  65. $j=count($condition_value);
  66. for (; $i <= $j; ) {
  67. $stmt->bindParam($i, $condition_value[$i-1]);// 绑定参数
  68. $i++;
  69. }
  70. // 查询
  71. $stmt->setFetchMode(PDO::FETCH_ASSOC);//设置通过字段获取数据
  72. $stmt->execute();
  73. // 获取数据
  74. return $stmt->fetchAll();
  75. //return $stmt->rowCount();
  76. } catch (PDOException $e) {
  77. return false;
  78. echo '数据处理出错,请联系网站管理员!';
  79. print_r($e);//超详细的报错信息,上线后必须注释这句话!
  80. }
  81. }
  82. /**
  83. * @author shuimugan
  84. * @version 0.2
  85. * @param String $tablename 表名,类型为字符串
  86. * @param Array $column_name 列名,要数组的格式
  87. * @param String $condition 条件,如'where name=? and pws=?'或'name like?'
  88. * @param Array $condition_value 条件对应的数据,类型要求为数组,如'name=? and pws=?' 时,
  89. * @return int 返回记录条数
  90. * @example $column_name=array('*');
  91. $condition_value=array('1');
  92. $limit='limit 0,10';
  93. $res=easy_selectCount('user', $column_name, 'where id=? ', $condition_value,$limit);
  94. */
  95. function easy_selectCount($tablename,$column_name,$condition,$condition_value,$limit) {
  96. try {
  97. $db=getConn();
  98. $sql='select ';//初始化sql语句
  99. foreach ($column_name as $col_name) {
  100. //动态追加列名进sql语句
  101. if($col_name=='*'){
  102. $sql.='*';
  103. break;
  104. }
  105. if($col_name==end($column_name))
  106. {
  107. $sql.=$col_name." ";//如果属于最后一个,语句不拼接逗号
  108. }else {
  109. $sql.=$col_name.", ";//拼接列名+逗号
  110. }
  111. }
  112. $sql.="from ".$tablename." ";//拼接表名
  113. $sql.=$condition.' ';//拼接条件语句
  114. if(strlen($limit)>0){
  115. $sql.=$limit;//拼接limit语句
  116. }
  117. ;
  118. $db = new PDO(DSN, DB_USERNAME, DB_USERPWD);//创建pdo对象,传入数据库参数信息
  119. $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//设置数据库错误信息
  120. $db->query('set names utf8;');//设置编码为utf8
  121. $stmt = $db->prepare($sql);
  122. $i=1;//开始计数,计算?的数量
  123. $j=count($condition_value);
  124. for (; $i <= $j; ) {
  125. $stmt->bindParam($i, $condition_value[$i-1]);// 绑定参数
  126. $i++;
  127. }
  128. // 查询
  129. //$stmt->setFetchMode(PDO::FETCH_ASSOC);//设置通过字段获取数据
  130. $stmt->execute();
  131. // 获取数据
  132. return $stmt->rowCount();
  133. } catch (PDOException $e) {
  134. return false;
  135. echo '数据处理出错,请联系网站管理员!';
  136. print_r($e);//超详细的报错信息,上线后必须注释这句话!
  137. }
  138. }
  139. /**
  140. * @author shuimugan
  141. * @version 0.2
  142. * @param String $tablename 表名,类型为字符串
  143. * @param Array $column_name 列名,要数组的格式
  144. * @param Array $column_value 对应的数据,要求数组的格式
  145. * @return int 返回最后自增的id
  146. * @example $column_name=array('pwd','ip','name');
  147. $column_value=array('1246','11.11.11.11','张三');
  148. echo easy_insert('user',$column_name,$column_value);
  149. */
  150. function easy_insert($tablename,$column_name,$column_value) {
  151. try {
  152. $db=getConn();
  153. $sql='INSERT INTO ';//初始化sql语句
  154. $sql.=$tablename.' (';//拼接表名
  155. foreach ($column_name as $col_name) {
  156. //动态追加列名进sql语句
  157. if($col_name==end($column_name))
  158. {
  159. $sql.=$col_name." )";//如果属于最后一个,拼接右括号
  160. }else {
  161. $sql.=$col_name.", ";//拼接列名+逗号
  162. }
  163. }
  164. $sql.=' VALUES (';//拼接$condition_value语句
  165. for ($i=0; $i < count($column_name); $i++) {//拼接问号?
  166. if ($i==count($column_name)-1) {
  167. $sql.='?) ;';
  168. }else {
  169. $sql.='?,';
  170. }
  171. }
  172. $db = new PDO(DSN, DB_USERNAME, DB_USERPWD);//创建pdo对象,传入数据库参数信息
  173. $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//设置数据库错误信息
  174. $db->query('set names utf8;');//设置编码为utf8
  175. $stmt = $db->prepare($sql);
  176. for ($i=1; $i <= count($column_name); $i++) {//拼接问号?
  177. $stmt->bindParam($i, $column_value[$i-1]);
  178. }
  179. // 查询
  180. //echo $sql;
  181. $stmt->setFetchMode(PDO::FETCH_ASSOC);//设置通过字段获取数据
  182. $stmt->execute();
  183. // 获取数据
  184. return $db->lastInsertId();
  185. } catch (PDOException $e) {
  186. return false;
  187. echo '数据处理出错,请联系网站管理员!';
  188. print_r($e);//超详细的报错信息,上线后必须注释这句话!
  189. }
  190. }
  191. /**
  192. * @author shuimugan
  193. * @version 0.2
  194. * @param String $tablename 表名,类型为字符串
  195. * @param Array $column_name 列名,要数组的格式
  196. * @param Array $column_value 对应的数据,要求数组的格式
  197. * @param String $condition 对应的的where语句 字符串 如 'where id=?'
  198. * @param Array $condition_value 对应where 后面问号的数据 类型要求为数组
  199. * @return int 返回影响的数据行数
  200. * @example $column_name=array('pwd','ip','name');
  201. $column_value=array('123456','127.152.123.132','张三');
  202. $condition_value=array('1');
  203. easy_update('user',$column_name,$column_value,'where id=?',$condition_value,null);
  204. */
  205. function easy_update($tablename,$column_name,$column_value,$condition,$condition_value,$limit) {
  206. try {
  207. $db=getConn();
  208. $sql='UPDATE ';//初始化sql语句
  209. $sql.=$tablename.' SET ';//拼接表名
  210. foreach ($column_name as $col_name) {
  211. //动态追加列名进sql语句
  212. if($col_name==end($column_name))
  213. {
  214. $sql.=$col_name." = ? ";//如果属于最后一个
  215. }else {
  216. $sql.=$col_name." = ?, ";//拼接列名+逗号
  217. }
  218. }
  219. $sql.=$condition;//拼接条件语句
  220. if(strlen($limit)>0){
  221. $sql.=$limit;//拼接limit语句
  222. }
  223. $db = new PDO(DSN, DB_USERNAME, DB_USERPWD);//创建pdo对象,传入数据库参数信息
  224. $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//设置数据库错误信息
  225. $db->query('set names utf8;');//设置编码为utf8
  226. $stmt = $db->prepare($sql);//准备语句
  227. $i=1;
  228. $total=count($column_name)+count($condition_value);
  229. for (;$i <= count($column_name);) {
  230. $stmt->bindParam($i, $column_value[$i-1]);//绑定列名对应数据参数
  231. $i++;
  232. }
  233. $j=1;
  234. for (;$i <= $total;) {
  235. $stmt->bindParam($i, $condition_value[$j-1]);//绑定条件对应数据参数
  236. $i++;
  237. $j++;
  238. }
  239. // 查询
  240. $stmt->setFetchMode(PDO::FETCH_ASSOC);//设置通过字段获取数据
  241. $stmt->execute();
  242. // 获取数据
  243. return $stmt->rowCount();
  244. } catch (PDOException $e) {
  245. return false;
  246. echo '数据处理出错,请联系网站管理员!';
  247. print_r($e);//超详细的报错信息,上线后必须注释这句话!
  248. }
  249. }
  250. /**
  251. * @author shuimugan
  252. * @version 0.2
  253. * @param String $tablename 表命名
  254. * @param String $condition 条件 如 'where id= ?'
  255. * @param Array $condition_value 条件对应的值 就是?对应的值
  256. * @param String $limit 限制语句 如'limit 0,1'
  257. * @return int 返回影响结果数
  258. * @example $condition_value=array('83');
  259. echo easy_delete('user', 'where id=?', $condition_value, null);
  260. */
  261. function easy_delete($tablename,$condition,$condition_value,$limit) {
  262. try {
  263. $db=getConn();
  264. $sql='DELETE FROM ';//初始化sql语句
  265. $sql.=$tablename.' ';//拼接表名
  266. $sql.=$condition;//拼接条件语句
  267. if(strlen($limit)>0){
  268. $sql.=$limit;//拼接limit语句
  269. }
  270. $db = new PDO(DSN, DB_USERNAME, DB_USERPWD);//创建pdo对象,传入数据库参数信息
  271. $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//设置数据库错误信息
  272. $db->query('set names utf8;');//设置编码为utf8
  273. $stmt = $db->prepare($sql);//准备语句
  274. for ($i=1;$i <= count($condition_value);) {
  275. $stmt->bindParam($i, $condition_value[$i-1]);//绑定条件对应数据参数
  276. $i++;
  277. }
  278. // 查询
  279. $stmt->setFetchMode(PDO::FETCH_ASSOC);//设置通过字段获取数据
  280. $stmt->execute();
  281. // 获取数据
  282. return $stmt->rowCount();
  283. } catch (PDOException $e) {
  284. return false;
  285. echo '数据处理出错,请联系网站管理员!';
  286. print_r($e);//超详细的报错信息,上线后必须注释这句话!

  287. }

  288. }
  289. ?>

人气教程排行

本站所有资源全部来源于网络，若本站发布的内容侵害到您的隐私或者利益，请联系我们删除！