首页 / PHP / 封装一个PDO数据库操作类代码_PHP教程

封装一个PDO数据库操作类代码_PHP教程

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了封装一个PDO数据库操作类代码_PHP教程，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含17914字，纯文字阅读大概需要26分钟。

内容图文

代码如下:
/**
　* 数据库PDO操作
　*/
class MysqlPdo {
public static $PDOStatement = null;
/**
* 数据库的连接参数配置
* @var array
* @access public
*/
public static $config = array();
/**
* 是否使用永久连接
* @var bool
* @access public
*/
public static $pconnect = false;
/**
* 错误信息
* @var string
* @access public
*/
public static $error = '';
/**
* 单件模式,保存Pdo类唯一实例,数据库的连接资源
* @var object
* @access public
*/
protected static $link;
/**
* 是否已经连接数据库
* @var bool
* @access public
*/
public static $connected = false;
/**
* 数据库版本
* @var string
* @access public
*/
public static $dbVersion = null;
/**
* 当前SQL语句
* @var string
* @access public
*/
public static $queryStr = '';
/**
* 最后插入记录的ID
* @var integer
* @access public
*/
public static $lastInsertId = null;
/**
* 返回影响记录数
* @var integer
* @access public
*/
public static $numRows = 0;
// 事务指令数
public static $transTimes = 0;
/**
* 构造函数，
* @param $dbconfig 数据库连接相关信息，array('ServerName', 'UserName', 'Password', 'DefaultDb', 'DB_Port', 'DB_TYPE')
*/
public function __construct($dbConfig=''){
if (!class_exists('PDO')) throw_exception("不支持:PDO");
//若没有传输任何参数，则使用默认的数据定义
if (!is_array($dbConfig)) {
$dbConfig = array(
'hostname' => DB_HOST,
'username' => DB_USER,
'password' => DB_PWD,
'database' => DB_NAME,
'hostport' => DB_PORT,
'dbms' => DB_TYPE,
'dsn' => DB_TYPE.":host=".DB_HOST.";dbname=".DB_NAME
);
}
if(empty($dbConfig['hostname'])) throw_exception("没有定义数据库配置");
self::$config = $dbConfig;
if(empty(self::$config['params'])) self::$config['params'] = array();
/*************************************华丽分隔线*******************************************/
if (!isset(self::$link) ) {
$configs = self::$config;
if(self::$pconnect) {
$configs['params'][constant('PDO::ATTR_PERSISTENT')] = true;
}
try {
self::$link = new PDO( $configs['dsn'], $configs['username'], $configs['password'],$configs['params']);
} catch (PDOException $e) {
throw_exception($e->getMessage());
//exit('连接失败:'.$e->getMessage());
}
if(!self::$link) {
throw_exception('PDO CONNECT ERROR');
return false;
}
self::$link->exec('SET NAMES '.DB_CHARSET);
self::$dbVersion = self::$link->getAttribute(constant("PDO::ATTR_SERVER_INFO"));
// 标记连接成功
self::$connected = true;
// 注销数据库连接配置信息
unset($configs);
}
return self::$link;
}
/**
* 释放查询结果
* @access function
*/
static function free() {
self::$PDOStatement = null;
}
/*********************************************************************************************************/
/* 数据库操作 */
/*********************************************************************************************************/
/**
* 获得所有的查询数据
* @access function
* @return array
*/
static function getAll($sql=null) {
self::query($sql);
//返回数据集
$result = self::$PDOStatement->fetchAll(constant('PDO::FETCH_ASSOC'));
return $result;
}
/**
* 获得一条查询结果
* @access function
* @param string $sql SQL指令
* @param integer $seek 指针位置
* @return array
*/
static function getRow($sql=null) {
self::query($sql);
// 返回数组集
$result = self::$PDOStatement->fetch(constant('PDO::FETCH_ASSOC'),constant('PDO::FETCH_ORI_NEXT'));
return $result;
}
/**
* 执行sql语句，自动判断进行查询或者执行操作
* @access function
* @param string $sql SQL指令
* @return mixed
*/
static function doSql($sql='') {
if(self::isMainIps($sql)) {
return self::execute($sql);
}else {
return self::getAll($sql);
}
}
/**
* 根据指定ID查找表中记录(仅用于单表操作)
* @access function
* @param integer $priId 主键ID
* @param string $tables 数据表名
* @param string $fields 字段名
* @return ArrayObject 表记录
*/
static function findById($tabName,$priId,$fields='*'){
$sql = 'SELECT %s FROM %s WHERE id=%d';
return self::getRow(sprintf($sql, self::parseFields($fields), $tabName, $priId));
}
/**
* 查找记录
* @access function
* @param string $tables 数据表名
* @param mixed $where 查询条件
* @param string $fields 字段名
* @param string $order 排序
* @param string $limit 取多少条数据
* @param string $group 分组
* @param string $having
* @param boolean $lock 是否加锁
* @return ArrayObject
*/
static function find($tables,$where="",$fields='*',$order=null,$limit=null,$group=null,$having=null) {
$sql = 'SELECT '.self::parseFields($fields)
.' FROM '.$tables
.self::parseWhere($where)
.self::parseGroup($group)
.self::parseHaving($having)
.self::parseOrder($order)
.self::parseLimit($limit);
$dataAll = self::getAll($sql);
if(count($dataAll)==1){$rlt=$dataAll[0];}else{$rlt=$dataAll;}
return $rlt;
}
/**
* 插入（单条）记录
* @access function
* @param mixed $data 数据
* @param string $table 数据表名
* @return false | integer
*/
static function add($data,$table) {
//过滤提交数据
$data=self::filterPost($table,$data);
foreach ($data as $key=>$val){
if(is_array($val) && strtolower($val[0]) == 'exp') {
$val = $val[1]; // 使用表达式 ???
}elseif (is_scalar($val)){
$val = self::fieldFormat($val);
}else{
// 去掉复合对象
continue;
}
$data[$key] = $val;
}
$fields = array_keys($data);
array_walk($fields, array($this, 'addSpecialChar'));
$fieldsStr = implode(',', $fields);
$values = array_values($data);
$valuesStr = implode(',', $values);
$sql = 'INSERT INTO '.$table.' ('.$fieldsStr.') VALUES ('.$valuesStr.')';
return self::execute($sql);
}
/**
* 更新记录
* @access function
* @param mixed $sets 数据
* @param string $table 数据表名
* @param string $where 更新条件
* @param string $limit
* @param string $order
* @return false | integer
*/
static function update($sets,$table,$where,$limit=0,$order='') {
$sets = self::filterPost($table,$sets);
$sql = 'UPDATE '.$table.' SET '.self::parseSets($sets).self::parseWhere($where).self::parseOrder($order).self::parseLimit($limit);
return self::execute($sql);
}
/**
* 保存某个字段的值
* @access function
* @param string $field 要保存的字段名
* @param string $value 字段值
* @param string $table 数据表
* @param string $where 保存条件
* @param boolean $asString 字段值是否为字符串
* @return void
*/
static function setField($field, $value, $table, $condition="", $asString=false) {
// 如果有'(' 视为 SQL指令更新否则更新字段内容为纯字符串
if(false === strpos($value,'(') || $asString) $value = '"'.$value.'"';
$sql = 'UPDATE '.$table.' SET '.$field.'='.$value.self::parseWhere($condition);
return self::execute($sql);
}
/**
* 删除记录
* @access function
* @param mixed $where 为条件Map、Array或者String
* @param string $table 数据表名
* @param string $limit
* @param string $order
* @return false | integer
*/
static function remove($where,$table,$limit='',$order='') {
$sql = 'DELETE FROM '.$table.self::parseWhere($where).self::parseOrder($order).self::parseLimit($limit);
return self::execute($sql);
}
/**
+----------------------------------------------------------
* 修改或保存数据(仅用于单表操作)
* 有主键ID则为修改，无主键ID则为增加
* 修改记录：
+----------------------------------------------------------
* @access function
+----------------------------------------------------------
* @param $tabName 表名
* @param $aPost 提交表单的 $_POST
* @param $priId 主键ID
* @param $aNot 要排除的一个字段或数组
* @param $aCustom 自定义的一个数组，附加到数据库中保存
* @param $isExits 是否已经存在存在：true, 不存在：false
+----------------------------------------------------------
* @return Boolean 修改或保存是否成功
+----------------------------------------------------------
*/
static function saveOrUpdate($tabName, $aPost, $priId="", $aNot="", $aCustom="", $isExits=false) {
if(empty($tabName) || !is_array($aPost) || is_int($aNot)) return false;
if(is_string($aNot) && !empty($aNot)) $aNot = array($aNot);
if(is_array($aNot) && is_int(key($aNot))) $aPost = array_diff_key($aPost, array_flip($aNot));
if(is_array($aCustom) && is_string(key($aCustom))) $aPost = array_merge($aPost,$aCustom);
if (empty($priId) && !$isExits) { //新增
$aPost = array_filter($aPost, array($this, 'removeEmpty'));
return self::add($aPost, $tabName);
} else { //修改
return self::update($aPost, $tabName, "id=".$priId);
}
}
/**
* 获取最近一次查询的sql语句
* @access function
* @param
* @return String 执行的SQL
*/
static function getLastSql() {
$link = self::$link;
if ( !$link ) return false;
return self::$queryStr;
}
/**
* 获取最后插入的ID
* @access function
* @param
* @return integer 最后插入时的数据ID
*/
static function getLastInsId(){
$link = self::$link;
if ( !$link ) return false;
return self::$lastInsertId;
}
/**
* 获取DB版本
* @access function
* @param
* @return string
*/
static function getDbVersion(){
$link = self::$link;
if ( !$link ) return false;
return self::$dbVersion;
}
/**
* 取得数据库的表信息
* @access function
* @return array
*/
static function getTables() {
$info = array();
if(self::query("SHOW TABLES")) {
$result = self::getAll();
foreach ($result as $key => $val) {
$info[$key] = current($val);
}
}
return $info;
}
/**
* 取得数据表的字段信息
* @access function
* @return array
*/
static function getFields($tableName) {
// 获取数据库联接
$link = self::$link;
$sql = "SELECT
ORDINAL_POSITION ,COLUMN_NAME, COLUMN_TYPE, DATA_TYPE,
IF(ISNULL(CHARACTER_MAXIMUM_LENGTH), (NUMERIC_PRECISION + NUMERIC_SCALE), CHARACTER_MAXIMUM_LENGTH) AS MAXCHAR,
IS_NULLABLE, COLUMN_DEFAULT, COLUMN_KEY, EXTRA, COLUMN_COMMENT
FROM
INFORMATION_SCHEMA.COLUMNS
WHERE
TABLE_NAME = :tabName AND TABLE_SCHEMA='".DB_NAME."'";
self::$queryStr = sprintf($sql, $tableName);
$sth = $link->prepare($sql);
$sth->bindParam(':tabName', $tableName);
$sth->execute();
$result = $sth->fetchAll(constant('PDO::FETCH_ASSOC'));
$info = array();
foreach ($result as $key => $val) {
$info[$val['COLUMN_NAME']] = array(
'postion' => $val['ORDINAL_POSITION'],
'name' => $val['COLUMN_NAME'],
'type' => $val['COLUMN_TYPE'],
'd_type' => $val['DATA_TYPE'],
'length' => $val['MAXCHAR'],
'notnull' => (strtolower($val['IS_NULLABLE']) == "no"),
'default' => $val['COLUMN_DEFAULT'],
'primary' => (strtolower($val['COLUMN_KEY']) == 'pri'),
'autoInc' => (strtolower($val['EXTRA']) == 'auto_increment'),
'comment' => $val['COLUMN_COMMENT']
);
}
// 有错误则抛出异常
self::haveErrorThrowException();
return $info;
}
/**
* 关闭数据库
* @access function
*/
static function close() {
self::$link = null;
}
/**
* SQL指令安全过滤
* @access function
* @param string $str SQL指令
* @return string
*/
static function escape_string($str) {
return addslashes($str);
}
/*********************************************************************************************************/
/* 内部操作方法 */
/*********************************************************************************************************/
/**
* 有出错抛出异常
* @access function
* @return
*/
static function haveErrorThrowException() {
$obj = empty(self::$PDOStatement) ? self::$link : self::$PDOStatement;
$arrError = $obj->errorInfo();
if(count($arrError) > 1) { // 有错误信息
//$this->rollback();
self::$error = $arrError[2]. "

[ SQL语句 ] : ".self::$queryStr;
//throw_exception($this->error);
throw_exception(self::$error);
return false;
}
//主要针对execute()方法抛出异常
if(self::$queryStr=='')throw_exception('Query was empty

[ SQL语句 ] :');
}
/**
* where分析
* @access function
* @param mixed $where 查询条件
* @return string
*/
static function parseWhere($where) {
$whereStr = '';
if(is_string($where) || is_null($where)) {
$whereStr = $where;
}
return empty($whereStr)?'':' WHERE '.$whereStr;
}
/**
* order分析
* @access function
* @param mixed $order 排序
* @return string
*/
static function parseOrder($order) {
$orderStr = '';
if(is_array($order))
$orderStr .= ' ORDER BY '.implode(',', $order);
else if(is_string($order) && !empty($order))
$orderStr .= ' ORDER BY '.$order;
return $orderStr;
}
/**
* limit分析
* @access function
* @param string $limit
* @return string
*/
static function parseLimit($limit) {
$limitStr = '';
if(is_array($limit)) {
if(count($limit)>1)
$limitStr .= ' LIMIT '.$limit[0].' , '.$limit[1].' ';
else
$limitStr .= ' LIMIT '.$limit[0].' ';
} else if(is_string($limit) && !empty($limit)) {
$limitStr .= ' LIMIT '.$limit.' ';
}
return $limitStr;
}
/**
* group分析
* @access function
* @param mixed $group
* @return string
*/
static function parseGroup($group) {
$groupStr = '';
if(is_array($group))
$groupStr .= ' GROUP BY '.implode(',', $group);
else if(is_string($group) && !empty($group))
$groupStr .= ' GROUP BY '.$group;
return empty($groupStr)?'':$groupStr;
}
/**
* having分析
* @access function
* @param string $having
* @return string
*/
static function parseHaving($having) {
$havingStr = '';
if(is_string($having) && !empty($having))
$havingStr .= ' HAVING '.$having;
return $havingStr;
}
/**
* fields分析
* @access function
* @param mixed $fields
* @return string
*/
static function parseFields($fields) {
if(is_array($fields)) {
array_walk($fields, array($this, 'addSpecialChar'));
$fieldsStr = implode(',', $fields);
}else if(is_string($fields) && !empty($fields)) {
if( false === strpos($fields,'`') ) {
$fields = explode(',',$fields);
array_walk($fields, array($this, 'addSpecialChar'));
$fieldsStr = implode(',', $fields);
}else {
$fieldsStr = $fields;
}
}else $fieldsStr = '*';
return $fieldsStr;
}
/**
* sets分析,在更新数据时调用
* @access function
* @param mixed $values
* @return string
*/
private function parseSets($sets) {
$setsStr = '';
if(is_array($sets)){
foreach ($sets as $key=>$val){
$key = self::addSpecialChar($key);
$val = self::fieldFormat($val);
$setsStr .= "$key = ".$val.",";
}
$setsStr = substr($setsStr,0,-1);
}else if(is_string($sets)) {
$setsStr = $sets;
}
return $setsStr;
}
/**
* 字段格式化
* @access function
* @param mixed $value
* @return mixed
*/
static function fieldFormat(&$value) {
if(is_int($value)) {
$value = intval($value);
} else if(is_float($value)) {
$value = floatval($value);
} elseif(preg_match('/^$\w*(\+|\-|\*|\/)?\w*$$/i',$value)){
// 支持在字段的值里面直接使用其它字段
// 例如 (score+1) (name) 必须包含括号
$value = $value;
}else if(is_string($value)) {
$value = '\''.self::escape_string($value).'\'';
}
return $value;
}
/**
* 字段和表名添加` 符合
* 保证指令中使用关键字不出错针对mysql
* @access function
* @param mixed $value
* @return mixed
*/
static function addSpecialChar(&$value) {
if( '*' == $value || false !== strpos($value,'(') || false !== strpos($value,'.') || false !== strpos($value,'`')) {
//如果包含* 或者使用了sql方法则不作处理
} elseif(false === strpos($value,'`') ) {
$value = '`'.trim($value).'`';
}
return $value;
}
/**
+----------------------------------------------------------
* 去掉空元素
+----------------------------------------------------------
* @access function
+----------------------------------------------------------
* @param mixed $value
+----------------------------------------------------------
* @return mixed
+----------------------------------------------------------
*/
static function removeEmpty($value){
return !empty($value);
}
/**
* 执行查询主要针对 SELECT, SHOW 等指令
* @access function
* @param string $sql sql指令
* @return mixed
*/
static function query($sql='') {
// 获取数据库联接
$link = self::$link;
if ( !$link ) return false;
self::$queryStr = $sql;
//释放前次的查询结果
if ( !empty(self::$PDOStatement) ) self::free();
self::$PDOStatement = $link->prepare(self::$queryStr);
$bol = self::$PDOStatement->execute();
// 有错误则抛出异常
self::haveErrorThrowException();
return $bol;
}
/**
* 数据库操作方法
* @access function
* @param string $sql 执行语句
* @param boolean $lock 是否锁定(默认不锁定)
* @return void
public function execute($sql='',$lock=false) {
if(empty($sql)) $sql = $this->queryStr;
return $this->_execute($sql);
}*/
/**
* 执行语句针对 INSERT, UPDATE 以及DELETE
* @access function
* @param string $sql sql指令
* @return integer
*/
static function execute($sql='') {
// 获取数据库联接
$link = self::$link;
if ( !$link ) return false;
self::$queryStr = $sql;
//释放前次的查询结果
if ( !empty(self::$PDOStatement) ) self::free();
$result = $link->exec(self::$queryStr);
// 有错误则抛出异常
self::haveErrorThrowException();
if ( false === $result) {
return false;
} else {
self::$numRows = $result;
self::$lastInsertId = $link->lastInsertId();
return self::$numRows;
}
}
/**
* 是否为数据库更改操作
* @access private
* @param string $query SQL指令
* @return boolen 如果是查询操作返回false
*/
static function isMainIps($query) {
$queryIps = 'INSERT|UPDATE|DELETE|REPLACE|CREATE|DROP|LOAD DATA|SELECT .* INTO|COPY|ALTER|GRANT|REVOKE|LOCK|UNLOCK';
if (preg_match('/^\s*"?(' . $queryIps . ')\s+/i', $query)) {
return true;
}
return false;
}
/**
* 过滤POST提交数据
* @access private
* @param mixed $data POST提交数据
* @param string $table 数据表名
* @return mixed $newdata
*/
static function filterPost($table,$data) {
$table_column = self::getFields($table);
$newdata=array();
foreach ($table_column as $key=>$val){
if(array_key_exists($key,$data) && ($data[$key])!==''){
$newdata[$key] = $data[$key];
}
}
return $newdata;
}
/**
* 启动事务
* @access function
* @return void
*/
static function startTrans() {
//数据rollback 支持
$link = self::$link;
if ( !$link ) return false;
if (self::$transTimes == 0) {
$link->beginTransaction();
}
self::$transTimes++;
return ;
}
/**
* 用于非自动提交状态下面的查询提交
* @access function
* @return boolen
*/
static function commit() {
$link = self::$link;
if ( !$link ) return false;
if (self::$transTimes > 0) {
$result = $link->commit();
self::$transTimes = 0;
if(!$result){
throw_exception(self::$error());
return false;
}
}
return true;
}
/**
* 事务回滚
* @access function
* @return boolen
*/
public function rollback() {
$link = self::$link;
if ( !$link ) return false;
if (self::$transTimes > 0) {
$result = $link->rollback();
self::$transTimes = 0;
if(!$result){
throw_exception(self::$error());
return false;
}
}
return true;
}
}
?>

http://www.bkjia.com/PHPjc/320493.htmlwww.bkjia.comtruehttp://www.bkjia.com/PHPjc/320493.htmlTechArticle 代码如下:

?php /** * 数据库PDO操作 */ class MysqlPdo { public static $PDOStatement = null; /** * 数据库的连接参数配置 * @var array * @access public...

内容总结

以上是互联网集市为您收集整理的封装一个PDO数据库操作类代码_PHP教程全部内容，希望文章能够帮你解决封装一个PDO数据库操作类代码_PHP教程所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/167655.html

来源：【匿名】

【上一篇】PHP变量定义和变量替换的方法_PHP教程【下一篇】PHP 5 数据对象 (PDO) 抽象层与 Oracle

更多 ►

【封装一个PDO数据库操作类代码_PHP教程】教程文章相关的互联网学习教程文章

F3-fatfree小型php框架教程（六）数据库篇【代码】

既然是讲数据库的，那首先自然是连接数据库了。这里举两个例子，mysql数据库：$db=new DB\SQL( ‘mysql:host=localhost;port=3306;dbname=mysqldb‘, ‘admin‘, ‘p455w0rD‘);sqlite数据库：$db=new DB\SQL(‘sqlite:/absolute/path/to/your/database.sqlite‘));数据库查询：很简单的，fatfree的数据库是不用配置的，很多东西都是内置的，当你需要改再去改就行，我们首先学习查询，就一步：$f3->set(‘result‘,$db...

PHPexcel 将excel表格数据导入数据库

// index.php<form name="frm1" enctype="multipart/form-data" action="insertdb.php" method="post"> <input name="filename" type="file" /><input name="submit" type="submit" value="import" /></form>//insertdb.php<?phpheader("Content-type:text/html;charset:utf-8");//全局变量$succ_result=0;$error_result=0;@$file=$_FILES[‘filename‘];$max_size="2000000"; //最大文件限制（单位：byte）$fname=$file[‘name‘...

ThinkPHP学习（三）配置PHP5支持MySQL，连接MySQL数据库【图】

配置PHP5支持MySQL打开PHP配置文件“F:\PHP\php5328Win32\php.ini”，查找“extension=php_mysql.dll”，把前面的分号去掉，保存文件，启动服务；却提示“PHP startup: Unable to load dynamic library :F:\PHP\php_mysql.dll”错误，解决办法，打开PHP配置文件“F:\PHP\php5328Win32\php.ini”，查找“extension_dir = "ext"”，把前面的分号去掉，保存文件，启动服务，问题解决；准备测试数据如果你还没有安装MySQL，请先安装MyS...

php+mysql实现数据库随机重排实例

本文实例实现了php+mysql数据库随机重排的方法，可将表中的所有数据随机读出来一次之后再进行随机保存到另一个表，从而达到了记录随机的功能。主要实现代码如下：复制代码代码如下:<?php //数据库连接就不写在这里面了 $s = isset( $_GET[‘s‘] )?$_GET[‘s‘]:0; $e = isset( $_GET[‘e‘])?$_GET[‘e‘]:50; $count =85000; if( $s < $count ) { $sql = "select * from 表前缀_info where isget =0 order by id desc limit $s...

PHp连接数据库实现增删改查【图】

首页删除添加添加处理页面修改修改处理页面原文：http://www.cnblogs.com/yongjiapei/p/5582153.html

PHP导出数据库sql文件，add和update【代码】

/*** 导出sql文件*/public function exportSql(){ //需要导出的数据库表存入到数组当中 $tables =array("T_CRM_QUEUE_FAIL","T_CRM_QUEUE"); //定义一个变量存放sql语句 $content = ‘‘; //打开并写入sql文件 $fp = fopen("./Upload/exportSql/".date(‘Ymd‘).".sql",‘w+‘); foreach ($tables as $k=>$v){ $content .= "\r\n-- ".$v."-- \r\n"; $sql = "SELECT * FROM ".$v; $tablesInfo=...

PHP Laravel框架多数据库连接方法【代码】【图】

1. 在config 下database.php中配置数据库连接然后在使用时直接用connection指向该连接即可 DB::connection(‘connections-theatre‘)->table(‘tb_order_ticket‘)->insert($data); 2. 在model中重定向到指定数据库连接 <?phpnamespace App\ModelTh;class ThBase extends Base {protected$connection = ‘connections-theatre‘; publicstaticfunction ******(){......}} 原文：https://www.cnblogs.com/dereckbu/p/9293668.html

PHP基础知识总结（三）流程控制、函数、类对象和数据库【代码】

PHP基础语法1、流程控制　　条件语句：if elseif else / switchif($a == 1){……} elseif ($a == 2){……} else{……} 循环语句：for foreachfor ($i = 1; $i <= 10; $i++) {echo$i; }foreach($arras$key => $value){ //一维数组循环键和值 …… }foreach($arras$key => $value){ //二维数组循环键和值foreach($valueas$value2){ //可以在循环中直接取值 ……} } 2、函数：一次...

PHP将Excel导入数据库以及数据库数据导出至Excel【代码】

一.导入导入需要使用能读取Excel的组件，网上也有比较好的组件，这里分享我使用的：下载提取码：vxyn。(注意两个文件有引用关系)<?php //传入要导入的Excel的文件名function import_to_DB($filename) {require_once‘reader.php‘;$data = new Spreadsheet_Excel_Reader(); //创建读取Excel的对象$data->setOutputEncoding(‘utf-8‘); //设置读取Excel内容后输出的字符编码$data->read("data/Excel/{$filename}.xls");$d...

F3-fatfree小型php框架教程（六）数据库篇【代码】

既然是讲数据库的，那首先自然是连接数据库了。这里举两个例子，mysql数据库：$db=newDB\SQL(‘mysql:host=localhost;port=3306;dbname=mysqldb‘,‘admin‘,‘p455w0rD‘); sqlite数据库：$db=newDB\SQL(‘sqlite:/absolute/path/to/your/database.sqlite‘));数据库查询：很简单的，fatfree的数据库是不用配置的，很多东西都是内置的，当你需要改再去改就行，我们首先学习查询，就一步：$f3->set(‘result‘,$db->exec(‘SELECT ...

php+mysql将大数据sql文件导入数据库【代码】

<?php$file_name = "d:test.sql";$dbhost = "localhost";$dbuser = "root";$dbpass = "123456";$dbname = "test";set_time_limit(0);$fp = @fopen($file_name,"r") or die("sql文件打不开");//打开文件$pdo = new PDO("mysql:host=localhost;dbname=test","root","123456");//连接数据库$pdo->query(‘set names utf8‘);//设置编码echo "正在执行导入操作";while($SQL = GetNextSQL()){if(!$pdo->query($SQL)){echo "执行出错";ec...

[PHP] 生成数据库字典的PHP代码支持PDO扩展【代码】【图】

有时候没有数据库字典设计文档，根据现有的数据库注释进行生成一份<?php header(‘content-type:text/html;charset=utf-8‘); define(‘DB_HOST‘,‘192.168.11.7‘); define(‘DB_USER‘,‘root‘); define(‘DB_PASS‘,‘centos‘); define(‘DB_NAME‘,‘new_admin‘); define(‘DB_PORT‘,3306); define(‘DB_CHAR‘,‘utf8‘); define(‘APPNAME‘,‘new_admin‘); $dbh = new PDO("mysql:host=".DB_HOST.":".DB_PORT.";dbnam...

PHP操作MYSQL数据库【代码】

一、连接及断开数据库　　1、使用mysqli 扩展（推荐），只针对mysql数据库　　　　面向对象的方式$con = new mysqli(ip,user,password);if($con->connect_error){dir("连接失败".$con->connect_error);} else{echo "连接成功";}　　　　　　$con->cloase();　　　　直接方法（面向过程）$con = mysqli_connect(ip,user,password);if($con){echomysqli_connect_error();} else {echo "连接成功";}　　　　　　mysqli_close($con) 　...

关于我的php 框架，数据库层使用方法【代码】

框架中，数据库包含两层，一个zz_db.php , 一个zz_model.php使用：项目入口定义数据库参数：//mysqldefine (‘ZZ_MYSQL_HOST‘ , ‘127.0.0.1‘);define (‘ZZ_MYSQL_USER‘ , ‘root‘);define (‘ZZ_MYSQL_PW‘ , ‘‘);define (‘ZZ_MYSQL_DB‘ , ‘microblog_home‘);　　//暂时只有一个数据库操作define (‘ZZ_MYSQL_TABLE_PRE‘ , ‘mh_‘);自己在项目的模型层中建立比如：UserModel.php extends zz_model.php 具体的各个方法...

CentOS 6.9编译方式搭建LTMP环境，并部署phpMyAdmin数据库管理工具【图】

一、演示环境：IP安装的程序包版本下载地址192.168.199.7Tenginetengine-2.2.2.tar.gzhttp://tengine.taobao.org/download_cn.htmlPHPphp-7.0.29.tar.gzhttp://www.php.net/downloads.phpphpMyAdminphpMyAdmin-4.8.0.1-all-languages.ziphttps://www.phpmyadmin.net/downloads/192.168.199.8mariadbmariadb-10.2.14-linux-x86_64.tar.gzhttps://downloads.mariadb.org/备注：Tengine是由淘宝网发起的Web服务器项目。它在Nginx的基础...

首页 / PHP / 封装一个PDO数据库操作类代码_PHP教程

封装一个PDO数据库操作类代码_PHP教程

内容导读

内容图文

内容总结

内容备注

内容手机端

【封装一个PDO数据库操作类代码_PHP教程】教程文章相关的互联网学习教程文章

F3-fatfree小型php框架教程（六）数据库篇【代码】

PHPexcel 将excel表格数据导入数据库

ThinkPHP学习（三）配置PHP5支持MySQL，连接MySQL数据库【图】

php+mysql实现数据库随机重排实例

PHp连接数据库实现增删改查【图】

PHP导出数据库sql文件，add和update【代码】

PHP Laravel框架多数据库连接方法【代码】【图】

PHP基础知识总结（三）流程控制、函数、类对象和数据库【代码】

PHP将Excel导入数据库以及数据库数据导出至Excel【代码】

F3-fatfree小型php框架教程（六）数据库篇【代码】

php+mysql将大数据sql文件导入数据库【代码】

[PHP] 生成数据库字典的PHP代码支持PDO扩展【代码】【图】

PHP操作MYSQL数据库【代码】

关于我的php 框架，数据库层使用方法【代码】

CentOS 6.9编译方式搭建LTMP环境，并部署phpMyAdmin数据库管理工具【图】

PHP - 相关标签

数据库 - 相关标签

封装 - 相关标签

PHP - 技术教程分类

PHP - 最新教程

PHP - 最热教程