导航:首页 > 编程大全 > php数据库封装类

php数据库封装类

 发布时间：2023-01-08 07:33:06

1. 求PHP数据库封装类操作代码

<?php
class MySQL{
private $host; //服务器地址
private $name; //登录账号
private $pwd; //登录密码
private $dBase; //数据库名称
private $conn; //数据库链接资源
private $result; //结果集
private $msg; //返回结果
private $fields; //返回字段
private $fieldsNum; //返回字段数
private $rowsNum; //返回结果数
private $rowsRst; //返回单条记录的字段数组
private $filesArray = array(); //返回字段数组
private $rowsArray = array(); //返回结果数组
private $charset='utf8'; //设置操作的字符集
private $query_count=0; //查询结果次数
static private $_instance; //存储对象
//初始化类
private function __construct($host='',$name='',$pwd='',$dBase=''){
if($host != '') $this->host = $host;
if($name != '') $this->name = $name;
if($pwd != '') $this->pwd = $pwd;
if($dBase != '') $this->dBase = $dBase;
$this->init_conn();
}
//防止被克隆
private function __clone(){}
public static function getInstance($host='',$name='',$pwd='',$dBase=''){
if(FALSE == (self::$_instance instanceof self)){
self::$_instance = new self($host,$name,$pwd,$dBase);
}
return self::$_instance;
}
public function __set($name,$value){
$this->$name=$value;
}
public function __get($name){
return $this->$name;
}
//链接数据库
function init_conn(){
$this->conn=@mysql_connect($this->host,$this->name,$this->pwd) or die('connect db fail !');
@mysql_select_db($this->dBase,$this->conn) or die('select db fail !');
mysql_query("set names ".$this->charset);
}
//查询结果
function mysql_query_rst($sql){
if($this->conn == '') $this->init_conn();
$this->result = @mysql_query($sql,$this->conn);
$this->query_count++;
}
//取得字段数
function getFieldsNum($sql){
$this->mysql_query_rst($sql);
$this->fieldsNum = @mysql_num_fields($this->result);
}
//取得查询结果数
function getRowsNum($sql){
$this->mysql_query_rst($sql);
if(mysql_errno() == 0){
return @mysql_num_rows($this->result);
}else{
return '';
}
}
//取得记录数组（单条记录）
function getRowsRst($sql,$type=MYSQL_BOTH){
$this->mysql_query_rst($sql);
if(empty($this->result)) return '';
if(mysql_error() == 0){
$this->rowsRst = mysql_fetch_array($this->result,$type);
return $this->rowsRst;
}else{
return '';
}
}
//取得记录数组（多条记录）
function getRowsArray($sql,$type=MYSQL_BOTH){
!empty($this->rowsArray) ? $this->rowsArray=array() : '';
$this->mysql_query_rst($sql);
if(mysql_errno() == 0){
while($row = mysql_fetch_array($this->result,$type)) {
$this->rowsArray[] = $row;
}
return $this->rowsArray;
}else{
return '';
}
}
//更新、删除、添加记录数
function uidRst($sql){
if($this->conn == ''){
$this->init_conn();
}
@mysql_query($sql);
$this->rowsNum = @mysql_affected_rows();
if(mysql_errno() == 0){
return $this->rowsNum;
}else{
return '';
}
}
//返回最近插入的一条数据库的id值
function returnRstId($sql){
if($this->conn == ''){
$this->init_conn();
}
@mysql_query($sql);
if(mysql_errno() == 0){
return mysql_insert_id();
}else{
return '';
}
}
//获取对应的字段值
function getFields($sql,$fields){
$this->mysql_query_rst($sql);
if(mysql_errno() == 0){
if(mysql_num_rows($this->result) > 0){
$tmpfld = @mysql_fetch_row($this->result);
$this->fields = $tmpfld[$fields];

}
return $this->fields;
}else{
return '';
}
}
//错误信息
function msg_error(){
if(mysql_errno() != 0) {
$this->msg = mysql_error();
}
return $this->msg;
}
//释放结果集
function close_rst(){
mysql_free_result($this->result);
$this->msg = '';
$this->fieldsNum = 0;
$this->rowsNum = 0;
$this->filesArray = '';
$this->rowsArray = '';
}
//关闭数据库
function close_conn(){
$this->close_rst();
mysql_close($this->conn);
$this->conn = '';
}
//取得数据库版本
function db_version() {
return mysql_get_server_info();
}
}

2. php跪求封装好的pdo预处理类,在线等

<?php
//数据库连接类，不建议直接使用DB，而是对DB封装一层
//这个类不会被污染，不会被直接调用
classDB{
//pdo对象
private$_pdo=null;
//用于存放实例化的对象
staticprivate$_instance=null;

//公共静态方法获取实例化的对象
(){
if(!(self::$_instanceinstanceofself)){
self::$_instance=newself();
}
returnself::$_instance;
}

//私有克隆
privatefunction__clone(){}

//私有构造
privatefunction__construct(){
try{
$this->_pdo=newPDO(DB_DNS,DB_USER,DB_PASS,array(PDO::MYSQL_ATTR_INIT_COMMAND=>'SETNAMES'.DB_CHARSET));
$this->_pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
}catch(PDOException$e){
exit($e->getMessage());
}
}

//新增
protectedfunctionadd($_tables,Array$_addData){
$_addFields=array();
$_addValues=array();
foreach($_addDataas$_key=>$_value){
$_addFields[]=$_key;
$_addValues[]=$_value;
}
$_addFields=implode(',',$_addFields);
$_addValues=implode("','",$_addValues);
$_sql="INSERTINTO$_tables[0]($_addFields)VALUES('$_addValues')";
return$this->execute($_sql)->rowCount();
}

//修改
protectedfunctionupdate($_tables,Array$_param,Array$_updateData){
$_where=$_setData='';
foreach($_paramas$_key=>$_value){
$_where.=$_value.'AND';
}
$_where='WHERE'.substr($_where,0,-4);
foreach($_updateDataas$_key=>$_value){
if(Validate::isArray($_value)){
$_setData.="$_key=$_value[0],";
}else{
$_setData.="$_key='$_value',";
}
}
$_setData=substr($_setData,0,-1);
$_sql="UPDATE$_tables[0]SET$_setData$_where";
return$this->execute($_sql)->rowCount();
}

//验证一条数据
protectedfunctionisOne($_tables,Array$_param){
$_where='';
foreach($_paramas$_key=>$_value){
$_where.=$_value.'AND';
}
$_where='WHERE'.substr($_where,0,-4);
$_sql="SELECTidFROM$_tables[0]$_whereLIMIT1";
return$this->execute($_sql)->rowCount();
}

//删除
protectedfunctiondelete($_tables,Array$_param){
$_where='';
foreach($_paramas$_key=>$_value){
$_where.=$_value.'AND';
}
$_where='WHERE'.substr($_where,0,-4);
$_sql="DELETEFROM$_tables[0]$_whereLIMIT1";
return$this->execute($_sql)->rowCount();
}

//查询
protectedfunctionselect($_tables,Array$_fileld,Array$_param=array()){
$_limit=$_order=$_where=$_like='';
if(Validate::isArray($_param)&&!Validate::isNullArray($_param)){
$_limit=isset($_param['limit'])?'LIMIT'.$_param['limit']:'';
$_order=isset($_param['order'])?'ORDERBY'.$_param['order']:'';
if(isset($_param['where'])){
foreach($_param['where']as$_key=>$_value){
$_where.=$_value.'AND';
}
$_where='WHERE'.substr($_where,0,-4);
}
if(isset($_param['like'])){
foreach($_param['like']as$_key=>$_value){
$_like="WHERE$_keyLIKE'%$_value%'";
}
}
}
$_selectFields=implode(',',$_fileld);
$_table=isset($_tables[1])?$_tables[0].','.$_tables[1]:$_tables[0];
$_sql="SELECT$_selectFieldsFROM$_table$_where$_like$_order$_limit";
$_stmt=$this->execute($_sql);
$_result=array();
while(!!$_objs=$_stmt->fetchObject()){
$_result[]=$_objs;
}
returnTool::setHtmlString($_result);
}

//总记录
protectedfunctiontotal($_tables,Array$_param=array()){
$_where='';
if(isset($_param['where'])){
foreach($_param['where']as$_key=>$_value){
$_where.=$_value.'AND';
}
$_where='WHERE'.substr($_where,0,-4);
}
$_sql="SELECTCOUNT(*)ascountFROM$_tables[0]$_where";
$_stmt=$this->execute($_sql);
return$_stmt->fetchObject()->count;
}

//得到下一个ID
protectedfunctionnextId($_tables){
$_sql="SHOWTABLESTATUSLIKE'$_tables[0]'";
$_stmt=$this->execute($_sql);
return$_stmt->fetchObject()->Auto_increment;
}


//执行SQL
privatefunctionexecute($_sql){
try{
$_stmt=$this->_pdo->prepare($_sql);
$_stmt->execute();
}catch(PDOException$e){
exit('SQL语句：'.$_sql.'<br/>错误信息：'.$e->getMessage());
}
return$_stmt;
}
}
?>

3. php中的pdo是什么

PDO扩展为PHP访问数据库定义了一个轻量级的、一致性的接口，它提供了一个数据访问抽象层，这样，无论使用什么数据库，都可以通过一致的函数执行查询和获取数据。PDO随PHP5.1发行，在PHP5.0的PECL扩展中也可以使用。

4. PHP 继承、封装、多态

-子类只能继承父类的非私有属性
-子类继承父类后，相当于将父类的属性和方法到子类，可以直接使用$this调用该属性；
-php只能单继承，不支持一个类继承多个类。但是一个类可以进行多层继承

类实现封装是为了不让外面的类随意修改一个类的成员变量，所以在定义一个类的成员的时候，我们使用private关键字设置这个成员的访问权限只能被这个类的其他成员方法调用，而不能被其他类中的方法调用，即通过本类中提供的方法来访问本类中的私有属性
-所以在该类中我们会提供一个访问私有属性的方法
-然后我们一般会定义两个方法来实现对一个变量的操作，即__get()和__set()方法

一个类被多个子类继承，如果这个类的某个方法，在多个子类中，表现出不同的功能，我们称这种行为为多态（同一个类的不同子类表现出不同的形态）
-子类继承父类->子类重写父类的方法->父类引用指向子类对象

5. ThinkPHP中怎么使用自定义的封装类

  1. 类文件都是以.class.php为后缀（这里是指的ThinkPHP内部使用的类库文件，不代表外部加载的类库文件），使用驼峰法命名，并且首字母大写，例如 DbMysql.class.php；

  2. 类的命名空间地址和所在的路径地址一致，例如 HomeControllerUserController类所在的路径应该是 Application/Home/Controller/UserController.class.php；

  3. 确保文件的命名和调用大小写一致，是由于在类Unix系统上面，对大小写是敏感的（而ThinkPHP在调试模式下面，即使在Windows平台也会严格检查大小写）；

  4. 类名和文件名一致（包括上面说的大小写一致），例如 UserController类的文件命名是UserController.class.php， InfoModel类的文件名是InfoModel.class.php， 并且不同的类库的类命名有一定的规范；

类的导入加载可以参考手册的命名空间和自动加载，下面是地址：
命名空间：http://document.thinkphp.cn/manual_3_2.html#namespace
自动加载：http://document.thinkphp.cn/manual_3_2.html#autoload

6. PHP访问MYSQL数据库封装类(附函数说明)

复制代码
代码如下:
<?php
/*
MYSQL
数据库访问封装类
MYSQL
数据访问方式，php4支持以mysql_开头的过程访问方式，php5开始支持以mysqli_开头的过程和mysqli面向对象
访问方式，本封装类以mysql_封装
数据访问的一般流程：
1,连接数据库
mysql_connect
or
mysql_pconnect
2,选择数据库
mysql_select_db
3,执行SQL查询
mysql_query
4,处理返回的数据
mysql_fetch_array
mysql_num_rows
mysql_fetch_assoc
mysql_fetch_row
etc
*/
class
db_mysql
{
var
$querynum
=
0
;
//当前页面进程查询数据库的次数
var
$dblink
;
//数据库连接资源
//链接数据库
function
connect($dbhost,$dbuser,$dbpw,$dbname='',$dbcharset='utf-8',$pconnect=0
,
$halt=true)
{
$func
=
empty($pconnect)
?
'mysql_connect'
:
'mysql_pconnect'
;
$this->dblink
=
@$func($dbhost,$dbuser,$dbpw)
;
if
($halt
&&
!$this->dblink)
{
$this->halt("无法链接数据库！");
}
//设置查询字符集
mysql_query("SET
character_set_connection={$dbcharset},character_set_results={$dbcharset},character_set_client=binary",$this->dblink)
;
//选择数据库
$dbname
&&
@mysql_select_db($dbname,$this->dblink)
;
}
//选择数据库
function
select_db($dbname)
{
return
mysql_select_db($dbname,$this->dblink);
}
//执行SQL查询
function
query($sql)
{
$this->querynum++
;
return
mysql_query($sql,$this->dblink)
;
}
//返回最近一次与连接句柄关联的INSERT，UPDATE
或DELETE
查询所影响的记录行数
function
affected_rows()
{
return
mysql_affected_rows($this->dblink)
;
}
//取得结果集中行的数目,只对select查询的结果集有效
function
num_rows($result)
{
return
mysql_num_rows($result)
;
}
//获得单格的查询结果
function
result($result,$row=0)
{
return
mysql_result($result,$row)
;
}
//取得上一步
INSERT
操作产生的
ID,只对表有AUTO_INCREMENT
ID的操作有效
function
insert_id()
{
return
($id
=
mysql_insert_id($this->dblink))
>=
0
?
$id
:
$this->result($this->query("SELECT
last_insert_id()"),
0);
}
//从结果集提取当前行，以数字为key表示的关联数组形式返回
function
fetch_row($result)
{
return
mysql_fetch_row($result)
;
}
//从结果集提取当前行，以字段名为key表示的关联数组形式返回
function
fetch_assoc($result)
{
return
mysql_fetch_assoc($result);
}
//从结果集提取当前行，以字段名和数字为key表示的关联数组形式返回
function
fetch_array($result)
{
return
mysql_fetch_array($result);
}
//关闭链接
function
close()
{
return
mysql_close($this->dblink)
;
}
//输出简单的错误html提示信息并终止程序
function
halt($msg)
{
$message
=
"<html>\n<head>\n"
;
$message
.=
"<meta
content='text/html;charset=gb2312'>\n"
;
$message
.=
"</head>\n"
;
$message
.=
"<body>\n"
;
$message
.=
"数据库出错：".htmlspecialchars($msg)."\n"
;
$message
.=
"</body>\n"
;
$message
.=
"</html>"
;
echo
$message
;
exit
;
}
}
?>

7. PHP里封装的一个mysql insert函数，还有一个update函数

谈一下个人的几点认识，供参考：


封装，网络的解释：即隐藏对象的属性和实现细节，仅对外公开接口，控制在程序中属性的读和修改的访问级别；将抽象得到的数据和行为（或功能）相结合，形成一个有机的整体，也就是将数据与操作数据的源代码进行有机的结合，形成“类”，其中数据和函数都是类的成员。


简单点说，封装就是将某块功能抽取出来，写到一个函数里，供重复调用。封装，通常是指类函数、类的成员。


就你上面的代码，就个人理解，你完全可以将之理解为功能函数，这也算是一种“封装”（但貌似与面向对象思想里的类的封装有些区别）。


update 函数，其功能是对数据库CURD四种基本操作里 U 的实现，其原理是通过对传入的数组（据判断，貌似是用“字段名”为键名，修改的值为 Value），通过对数组遍历，进行组合，进一步得到 SQL 语句（update），并予以执行。

$str.=$sep.$key."='".$val."'";


$sep 是不同数据库字段名之间的分隔符，$key 是数据库字段名，$val 是修改的值。上面的代码通过多次循环之后，就会形成合乎 SQL 语法的 Update 数据修改语句，例如：

updatetable1setLastDate='ddd',SssName='ddd'whereUserID="aasdd"

8. php实现mysql封装类示例

php封装mysql类
复制代码
代码如下:
<?php
class
Mysql
{
private
$host;
private
$user;
private
$pwd;
private
$dbName;
private
$charset;
private
$conn
=
null;
public
function
__construct()
{
$this->host
=
'localhost';
$this->user
=
'root';
$this->pwd
=
'root';
$this->dbName
=
'test';
$this->connect($this->host,$this->user,$this->pwd);
$this->switchDb($this->dbName);
$this->setChar($this->charset);
}
//负责链接
private
function
connect($h,$u,$p)
{
$conn
=
mysql_connect($h,$u,$p);
$this->conn
=
$conn;
}
//负责切换数据库
public
function
switchDb($db)
{
$sql
=
'use'
.
$db;
$this->query($sql);
}
//负责设置字符集
public
function
setChar($char)
{
$sql
=
'set
names'
.
$char;
$this->query($sql);
}
//负责发送sql查询
public
function
query($sql)
{
return
mysql_query($sql,$this->conn);
}
//负责获取多行多列的select结果
public
function
getAll($sql)
{
$list
=
array();
$rs
=
$this->query($sql);
if
(!$rs)
{
return
false;
}
while
($row
=
mysql_fetch_assoc($rs))
{
$list[]
=
$row;
}
return
$list;
}
public
function
getRow($sql)
{
$rs
=
$this->query($sql);
if(!$rs)
{
return
false;
}
return
mysql_fetch_assoc($rs);
}
public
function
getOne($sql)
{
$rs
=
$this->query($sql);
if
(!$rs)
{
return
false;
}
return
mysql_fetch_assoc($rs);
return
$row[0];
}
public
function
close()
{
mysql_close($this->conn);
}
}
echo
'<pre>';
$mysql
=
new
Mysql();
print_r($mysql);
$sql
=
"insert
into
stu
values
(4,'wangwu','99998')";
if($mysql->query($sql)){
echo
"query成功";
}else
{
echo
"失败";
}
echo
"<br
/>";
$sql
=
"select
*
from
stu";
$arr
=
$mysql->getAll($sql);
print_r($arr);
?>

9. php封装一个用户类,里面有登录注册方法,这个要怎么写

第一步：login.php

//登陆方法
public function login(){
//如果用户名和密码为空，则返回登陆页面
if(empty($_POST['username']) || empty($_POST['password'])){
$data['verifycode'] = rand(1000,9999);//生成一个四位数字的验证码
//将验证码放入session中,注意：参数是数组的格式
$this->session->set_userdata($data);
//注意：CI框架默认模板引擎解析的模板文件中变量不需要$符号
//$this->parser->parse("admin/login",$data);
//smarty模板变量赋值
$this->tp->assign("verifycode",$data['verifycode']);
//ci框架在模板文件中使用原生态的PHP语法输出数据
//$this->load->view('login',$data);//登陆页面，注意：参数2需要以数组的形式出现
//显示smarty模板引擎设定的模板文件
$this->tp->display("admin/login.php");
}else{
$username = isset($_POST['username'])&&!empty($_POST['username'])?trim($_POST['username']):'';//用户名
$password = isset($_POST['password'])&&!empty($_POST['password'])?trim($_POST['password']):'';//密码
$verifycode = isset($_POST['verifycode'])&&!empty($_POST['verifycode'])?trim($_POST['verifycode']):'';//验证码

//做验证码的校验
if($verifycode == $this->session->userdata('verifycode')){
//根据用户名及密码获取用户信息，注意：参数2是加密的密码
$user_info=$this->user_model->check_user_login($username,md5($password));
if($user_info['user_id'] > 0){
//将用户id、username、password放入cookie中
//第一种设置cookie的方式：采用php原生态的方法设置的cookie的值
//setcookie("user_id",$user_info['user_id'],86500);
//setcookie("username",$user_info['username'],86500);
//setcookie("password",$user_info['password'],86500);
//echo $_COOKIE['username'];

//第二种设置cookie的方式：通过CI框架的input类库
$this->input->set_cookie("username",$user_info['username'],3600);
$this->input->set_cookie("password",$user_info['password'],3600);
$this->input->set_cookie("user_id",$user_info['user_id'],3600);
//echo $this->input->cookie("password");//适用于控制器
//echo $this->input->cookie("username");//适用于控制器
//echo $_COOKIE['username'];//在模型类中可以通过这种方式获取cookie值
//echo $_COOKIE['password'];//在模型类中可以通过这种方式获取cookie值

//第三种设置cookie的方式：通过CI框架的cookie_helper.php函数库文件
//这种方式不是很灵验，建议大家采取第二种方式即可
//set_cookie("username",$user_info['username'],3600);
//echo get_cookie("username");

//session登陆时使用：将用户名和用户id存入session中
//$data['username']=$user_info['username'];
//$data['user_id']=$user_info['user_id'];
//$this->session->set_userdata($data);

//跳转到指定页面
//注意：site_url()与base_url()的区别，前者带index.php,后者不带index.php
header("location:".site_url("index/index"));
}
}else{
//跳转到登陆页面
header("location:".site_url("common/login"));
}
}
}
}

第二步：User_model.php

//cookie登陆：检测用户是否登陆，如果cookie值失效，则返回false，如果cookie值未失效，则根据cookie中的用户名和密码从数据库中获取用户信息，如果能获取到用户信息，则返回查询到的用户信息，如果没有查询到用户信息，则返回0
public function is_login(){
//获取cookie中的值
if(empty($_COOKIE['username']) || empty($_COOKIE['password'])){
$user_info = false;
}else{
$user_info=$this->check_user_login($_COOKIE['username'],$_COOKIE['password']);
}
return $user_info;
}

//根据用户名及加密密码从数据库中获取用户信息，如果能获取到，则返回获取到的用户信息，否则返回false，注意：密码为加密密码
public function check_user_login($username,$password){
//这里大家要注意：$password为md5加密后的密码
//$this->db->query("select * from ");
//快捷查询类的使用：能为我们提供快速获取数据的方法
//此数组为查询条件
//注意：关联数组
$arr=array(
'username'=>$username,//用户名
'password'=>$password,//加密密码
'status'=>1 //账户为开启状态
);
//在database.php文件中已经设置了数据表的前缀，所以此时数据表无需带前缀
$query = $this->db->get_where("users",$arr);
//返回二维数组
//$data=$query->result_array();
//返回一维数组
$user_info=$query->row_array();
if(!empty($user_info)){
return $user_info;
}else{
return false;
}
}

第三步：其它控制器：

public function __construct(){

//调用父类的构造函数
parent::__construct();
$this->load->library('tp'); //smarty模板解析类
$this->load->helper('url'); //url函数库文件
$this->load->model("user_model");//User_model模型类实例化对象
$this->cur_user=$this->user_model->is_login();
if($this->cur_user === false){
header("location:".site_url("common/login"));
}else{
//如果已经登陆，则重新设置cookie的有效期
$this->input->set_cookie("username",$this->cur_user['username'],3600);
$this->input->set_cookie("password",$this->cur_user['password'],3600);
$this->input->set_cookie("user_id",$this->cur_user['user_id'],3600);
}

$this->load->library('pagination');//分页类库
$this->load->model("role_model");//member_model模型类
$this->load->model("operation_model");//引用operation_model模型
$this->load->model("object_model");//引用object_model模型
$this->load->model("permission_model");//引用permission_model模型
}

阅读全文

与php数据库封装类相关的资料

热点内容
cs6裁切工具 浏览：235
数据库超过多少数据会卡 浏览：858
CAD落图文件 浏览：125
怎样翻译文件内容 浏览：679
戴尔r910安装linux 浏览：69
有线电视升级失败 浏览：560
火绒安全把文件删掉了在哪里找 浏览：503
手机qq网络状态方框 浏览：225
哪里有文件纸袋 浏览：873
复制的东西能不能粘贴到空文件夹 浏览：876
酒店没有网络如何缴费 浏览：380
win10开机滚动很久 浏览：520
可对元数据实例进行的操作有什么 浏览：934
什么后缀的文件kit 浏览：295
word行书字体库下载 浏览：579
iosuc版本历史版本 浏览：14
电影字幕文件制作软件 浏览：723
windows10免密码登录 浏览：762
iphone5s跑步记步 浏览：978
手机网站设计怎么做好 浏览：322

友情链接