[实例]php中PDO方式实现数据库的增删改查

整理的比较容易理解的PDO操作实例,注意,需要开启php的pdo支持,php5.1以上版本支持实现数据库连接单例化,有三要素 静态变量、静态实例化方法、私有构造函数 DPDO.php

//PDO操作类
//author http://www.lai18.com
class DPDO{
  private $DSN;
  private $DBUser;
  private $DBPwd;
  private $longLink;
  private $pdo;
  //私有构造函数 防止被直接实例化
  private function __construct($dsn, $DBUser, $DBPwd, $longLink = false) {
    $this->DSN = $dsn;
    $this->DBUser = $DBUser;
    $this->DBPwd = $DBPwd;
    $this->longLink = $longLink;
    $this->connect();
  }
  //私有 空克隆函数 防止被克隆
  private function __clone(){}
  //静态 实例化函数 返回一个pdo对象
  static public function instance($dsn, $DBUser, $DBPwd, $longLink = false){
    static $singleton = array();//静态函数 用于存储实例化对象
    $singIndex = md5($dsn . $DBUser . $DBPwd . $longLink);
    if (empty($singleton[$singIndex])) {
      $singleton[$singIndex] = new self($dsn, $DBUser, $DBPwd, $longLink = false);
    }
    return $singleton[$singIndex]->pdo;
  }

  private function connect(){
    try{
      if($this->longLink){
        $this->pdo = new PDO($this->DSN, $this->DBUser, $this->DBPwd, array(PDO::ATTR_PERSISTENT => true));
      }else{
        $this->pdo = new PDO($this->DSN, $this->DBUser, $this->DBPwd);
      }
      $this->pdo->query(‘SET NAMES UTF-8‘);
    } catch(PDOException $e) {
      die(‘Error:‘ . $e->getMessage() . ‘<br/>‘);
    }
  }
}

用于处理字段映射,使用pdo的字段映射,可以有效避免sql注入

//字段关联数组处理, 主要用于写入和更新数据、同and 或 or 的查询条件,产生sql语句和映射字段的数组
//author http://www.lai18.com
  public function FDFields($data, $link = ‘,‘, $judge = array(), $aliasTable = ‘‘){
    $sql = ‘‘;
    $mapData = array();
    foreach($data as $key => $value) {
      $mapIndex = ‘:‘ . ($link != ‘,‘ ? ‘c‘ : ‘‘) . $aliasTable . $key;
      $sql .= ‘ ‘ . ($aliasTable ? $aliasTable . ‘.‘ : ‘‘) . ‘`‘ . $key . ‘` ‘ . ($judge[$key] ? $judge[$key] : ‘=‘) . ‘ ‘ . $mapIndex . ‘ ‘ . $link;
      $mapData[$mapIndex] = $value;
    }
    $sql = trim($sql, $link);
    return array($sql, $mapData);
  }
  //用于处理单个字段处理
  public function FDField($field, $value, $judge = ‘=‘, $preMap = ‘cn‘, $aliasTable = ‘‘) {
    $mapIndex = ‘:‘ . $preMap . $aliasTable . $field;
    $sql = ‘ ‘ . ($aliasTable ? $aliasTable . ‘.‘ : ‘‘) . ‘`‘ . $field . ‘`‘ . $judge . $mapIndex;
    $mapData[$mapIndex] = $value;
    return array($sql, $mapData);
  }
  //使用刚方法可以便捷产生查询条件及对应数据数组
  public function FDCondition($condition, $mapData) {
    if(is_string($condition)) {
        $where = $condition;
    } else if (is_array($condition)) {
      if($condition[‘str‘]) {
        if (is_string($condition[‘str‘])) {
          $where = $condition[‘str‘];
        } else {
          return false;
        }
      }
      if(is_array($condition[‘data‘])) {
        $link = $condition[‘link‘] ? $condition[‘link‘] : ‘and‘;
        list($conSql, $mapConData) = $this->FDFields($condition[‘data‘], $link, $condition[‘judge‘]);
        if ($conSql) {
          $where .= ($where ? ‘ ‘ . $link : ‘‘) . $conSql;
          $mapData = array_merge($mapData, $mapConData);
        }
      }
    }
    return array($where, $mapData);
  }

增删改查的具体实现DB.php

//数据库的遍历
//author http://www.lai18.com
public function fetch($sql, $searchData = array(), $dataMode = PDO::FETCH_ASSOC, $preType = array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)) {
    if ($sql) {
      $sql .= ‘ limit 1‘;
      $pdoStatement = $this->pdo->prepare($sql, $preType);
      $pdoStatement->execute($searchData);
      return $data = $pdoStatement->fetch($dataMode);
    } else {
      return false;
    }
  }

  public function fetchAll($sql, $searchData = array(), $limit = array(0, 10), $dataMode = PDO::FETCH_ASSOC, $preType = array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)) {
    if ($sql) {
      $sql .= ‘ limit ‘ . (int) $limit[0] . ‘,‘ . (intval($limit[1]) > 0 ? intval($limit[1]) : 10);
      $pdoStatement = $this->pdo->prepare($sql, $preType);
      $pdoStatement->execute($searchData);
      return $data = $pdoStatement->fetchAll($dataMode);
    } else {
      return false;
    }
  }

  public function insert($tableName, $data, $returnInsertId = false, $replace = false) {
    if(!empty($tableName) && count($data) > 0){
      $sql = $replace ? ‘REPLACE INTO ‘ : ‘INSERT INTO ‘;
      list($setSql, $mapData) = $this->FDFields($data);
      $sql .= $tableName . ‘ set ‘ . $setSql;
      $pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
      $execRet = $pdoStatement->execute($mapData);
      return $execRet ? ($returnInsertId ? $this->pdo->lastInsertId() : $execRet) : false;
    } else {
      return false;
    }
  }

  public function update($tableName, $data, $condition, $mapData = array(), $returnRowCount = true) {
    if(!empty($tableName) && count($data) > 0) {
      $sql = ‘UPDATE ‘ . $tableName . ‘ SET ‘;
      list($setSql, $mapSetData) = $this->FDFields($data);
      $sql .= $setSql;
      $mapData = array_merge($mapData, $mapSetData);
      list($where, $mapData) = $this->FDCondition($condition, $mapData);
      $sql .= $where ? ‘ WHERE ‘ . $where : ‘‘;
      $pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
      $execRet = $pdoStatement->execute($mapData);
      return $execRet ? ($returnRowCount ? $pdoStatement->rowCount() : $execRet) : false;
    } else {
      return false;
    }
  }

  public function delete($tableName, $condition, $mapData = array()) {
    if(!empty($tableName) && $condition){
      $sql = ‘DELETE FROM ‘ . $tableName;
      list($where, $mapData) = $this->FDCondition($condition, $mapData);
      $sql .= $where ? ‘ WHERE ‘ . $where : ‘‘;
      $pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
      $execRet = $pdoStatement->execute($mapData);
      return $execRet;
    }
  }

测试文件test.php

//PDO操作类-测试PHP示例
//author http://www.lai18.com
header("Content-type: text/html; charset=utf-8");
define(‘APP_DIR‘, dirname(__FILE__));

if (function_exists(‘spl_autoload_register‘)) {
  spl_autoload_register(‘autoClass‘);
} else {
  function __auto_load($className){
    autoClass($className);
  }
}

function autoClass($className){
  try{
    require_once APP_DIR.‘/class/‘.$className.‘.php‘;
  } catch (Exception $e) {
    die(‘Error:‘ . $e->getMessage() . ‘<br />‘);
  }
}
$DB = new DB();
//插入
$inData[‘a‘] = rand(1, 100);
$inData[‘b‘] = rand(1, 1000);
$inData[‘c‘] = rand(1,200) . ‘.‘ . rand(1,100);
$ret = $DB->insert(‘a‘, $inData);
echo ‘插入‘ . ($ret ? ‘成功‘ : ‘失败‘) . ‘<br/>‘;
//更新
$upConData[‘a‘] = 100;
$upConJudge[‘a‘] = ‘<‘;
$upConData[‘b‘] = 30;
$upConJudge[‘b‘] = ‘>‘;
list($upConStr, $mapUpConData) = $DB->FDField(‘b‘, 200, ‘<‘, ‘gt‘);
$condition = array(
  ‘str‘ => $upConStr,
  ‘data‘ => $upConData,
  ‘judge‘ => $upConJudge,
  ‘link‘ => ‘and‘
);
$upData[‘a‘] = rand(1, 10);
$upData[‘b‘] = 1;
$upData[‘c‘] = 1.00;
$changeRows = $DB->update(‘a‘, $upData, $condition, $mapUpConData);
echo ‘更新行数:‘ . (int) $changeRows . ‘<br/>‘;
//删除
$delVal = rand(1, 10);
list($delCon, $mapDelCon) = $DB->FDField(‘a‘, $delVal);
$delRet = $DB->delete(‘a‘, $delCon, $mapDelCon);
echo ‘删除a=‘ . $delVal . ($delRet ? ‘成功‘ : ‘失败‘) . ‘<br/>‘;

//查询
$data[‘a‘] = ‘10‘;
$judge[‘a‘] = ‘>‘;
$data[‘b‘] = ‘400‘;
$judge[‘b‘] = ‘<‘;
list($conSql, $mapConData) = $DB->FDFields($data, ‘and‘, $judge);
$mData = $DB->fetch(‘select * from a where ‘ . $conSql . ‘ order by `a` desc‘, $mapConData);

var_dump($mData);

以上所述就是本文的全部内容了,希望大家能够喜欢。

参考来源:

php中PDO方式实现数据库的增删改查

http://www.lai18.com/content/422492.html

时间: 05-18

[实例]php中PDO方式实现数据库的增删改查的相关文章

利用API方式进行数据库的增删改查

1 /* 2 将数据库的增删改查单独放进一个包 3 */ 4 package com.itheima28.sqlitedemo.dao; 5 import java.util.ArrayList; 6 import java.util.List; 7 8 import android.content.ContentValues; 9 import android.content.Context; 10 import android.database.Cursor; 11 import andro

TP框架中 数据库的增删改查

框架会用到数据库的内容,这一篇就是关于数据库的增删改查. 数据库的操作,无疑就是连接数据库,然后对数据库中的表进行各种查询,然后就是对数据的增删改的操作, 想要操作数据库,第一步必然是要:链接数据库 一.链接数据库 (1)找到模块文件夹中的Conf文件夹,然后进行编写config.php文件 我这里是这样的文件路径 (2)打开这个config.php文件,然后找到父类配置文件convention.php文件,将关于"数据库"的部分复制粘贴到config.php配置文件中(父类的conv

java:JSP(JSPWeb.xml的配置,动态和静态导入JSP文件,重定项和请求转发,使用JSP实现数据库的增删改查实例)

1.JSP的配置: <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%> <% String path = request.getContextPath(); String basePath = request.getScheme() + "://" + request.getServerName() + ":&qu

Sqlserver 实际开发中常见的数据库操作增删改查----增

注意我说的常见查询,可不是简单到一个表得增删改查,做过实际开发得人都知道,在实际开发中,真正牵扯到一个表得增删改查只能说占很小得一部分,大多都是好几个表的关联操作的. 下面我就说一下我在实际开发中经常用到得一些增删改查方式.(首先我还要说一下,就是我虽然能写,但是我不知道这种查询方式叫什么类型查询,毕竟数据库这块以前都没干过,做.net开发也就一年左右,大家看我写的博客也会知道,以前搞前端U3D游戏开发的,不接触数据库,取数据调后台接口就行了,其他不用管.所以没做.net前,我也就是会大学时候学

java程序设计课期中考试——数据库的增删改查和简单的js界面

首先是设计思路,对于数据库的增删改查,我们借助Ecilipse来进行前端和后端的编写.Ecilipse是可以进行java web项目的操作的. 前端,我们选择用使用jsp,所谓的jsp就是可以嵌入其他语言的html,各种标识语言和html语法一致,但为了在本界面检测各种信息的正确性,需要嵌入java的语句进行判断. 对于数据库的增删改查,我们使用sql语句,并且导入了相应的mysql的jar包,方便我们用java对数据库进行操作. 整体来说,我们编写使用了MVC模式(model-view-con

android中SQLite数据库的增删改查

1.数据库帮助类PersonSQLiteOpenHelper package com.wzw.sqllitedemo.db; import android.content.Context; import android.database.sqlite.SQLiteDatabase; import android.database.sqlite.SQLiteDatabase.CursorFactory; import android.database.sqlite.SQLiteOpenHelper

【Mysql】Java中对Mysql数据库的增删改查、Java的System类

这部分也是所谓JDBC.网站数据源的内容,把名字弄得很高深似得,实际上只是Java中对Mysql数据库的增删改查的内容.非常简单,之前写了这么多Mysql的内容,没好好总结一下,实在是不应该.今天就实现一个Java中对Mysql数据库的增删改查,随便带点Java取出当前系统的系统名与系统时间的知识,完成一个还算有点意思的小例子. 一.基本目标 首先,在Mysql数据库中有一张名为testtable的空表,id为自增列,username,class都是文本列,但是class里面都存放数字,也就是整

mysql数据库的增删改查语句

连接命令:mysql -h[主机地址] -u[用户名] -p[用户密码] 创建数据库:create database [库名] 显示所有数据库: show databases; 打开数据库:use [库名] 当前选择的库状态:SELECT DATABASE(); 创建数据表:CREATE TABLE [表名]([字段名] [字段类型]([字段要求]) [字段参数], ......); 显示数据表字段:describe 表名; 当前库数据表结构:show tables; =============

MyBatis框架入门小案例(关于用mybatis框架对数据库的增删改查)

1.新建一个maven项目,建好相对应的包,在https://mvnrepository.com中导入MyBatis需要的依赖,复制到配置文件中 2.在resources文件下添加mybatis-config.xml文件和mapper文件夹,mybatis-config.xml是连接mysql的主要配置,mapper文件夹存放的是对数据库增删改查的映射 mybatis-config.xml配置如下: <?xml version="1.0" encoding="utf-8