当前位置: 开发笔记 > 编程语言 > 正文

php连接mysql的封装类（php与mysql集成）

作者：霞霞123321 | 来源：互联网 | 2023-09-08 18:33

本文目录一览：1、python如何使用pymysql连接数据库封装类

本文目录一览：

1、python如何使用pymysql连接数据库封装类

2、php实现mysql封装类示例

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

4、求个好用的php mysql封装类

python如何使用pymysql连接数据库封装类

1、python安装目录设定为d:/python34

2、pymysql安装方法为：解压下载的文件，在cmd中运行: python setup.py install。

检验安装安装是否成功的方法：import pymysql 。如果不报错说明安装成功。

3、mysql安装目录为D:/phpStudy/MySQL。为避免更多配置问题，可在启动phpstudy后，将其设为系统服务

4、基本操作：

（1）导入pymysql: import pymysql

（2）连接数据库：

cOnn=pymysql.connect(host='localhost',user='root',passwd='root',db='ere'，charset='utf8')

务必注意各等号前面的内容！charset参数可避免中文乱码

（3）获取操作游标：cur=conn.cursor()

（4）执行sql语句,插入记录：sta=cur.execute("insert 语句") 执行成功后sta值为1。更新、删除语句与此类似。

（5）执行sql语句，查询记录：cur.execute("select语句") 执行成功后cur变量中保存了查询结果记录集，然后再用循环打印结果：

for each in cur:

print(each[1].decode('utf-8')) # each[1] 表示当前游标所在行的的第2列值，如果是中文则需要处理编码

php连接mysql的封装类（php与mysql集成）

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);

(!$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);

(!$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);

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

代码如下:

?php

MYSQL

数据库访问封装类

MYSQL

数据访问方式，php4支持以mysql_开头的过程访问方式，php5开始支持以mysqli_开头的过程和mysqli面向对象

访问方式，本封装类以mysql_封装

数据访问的一般流程：

1,连接数据库

mysql_connect

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

;

//当前页面进程查询数据库的次数

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)

;

($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))

$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\nhead\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

;

}

求个好用的php mysql封装类

?php

class MMysql {

protected static $_dbh = null; //静态属性,所有数据库实例共用,避免重复连接数据库

protected $_dbType = 'mysql';

protected $_pconnect = true; //是否使用长连接

protected $_host = 'localhost';

protected $_port = 3306;

protected $_user = 'root';

protected $_pass = 'root';

protected $_dbName = null; //数据库名

protected $_sql = false; //最后一条sql语句

protected $_where = '';

protected $_order = '';

protected $_limit = '';

protected $_field = '*';

protected $_clear = 0; //状态，0表示查询条件干净，1表示查询条件污染

protected $_trans = 0; //事务指令数

/**

* 初始化类

* @param array $conf 数据库配置

public function __construct(array $conf) {

class_exists('PDO') or die("PDO: class not exists.");

$this-_host = $conf['host'];

$this-_port = $conf['port'];

$this-_user = $conf['user'];

$this-_pass = $conf['passwd'];

$this-_dbName = $conf['dbname'];

//连接数据库

if ( is_null(self::$_dbh) ) {

$this-_connect();

}

/**

* 连接数据库的方法

protected function _connect() {

$dsn = $this-_dbType.':host='.$this-_host.';port='.$this-_port.';dbname='.$this-_dbName;

$options = $this-_pconnect ? array(PDO::ATTR_PERSISTENT=true) : array();

try {

$dbh = new PDO($dsn, $this-_user, $this-_pass, $options);

$dbh-setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); //设置如果sql语句执行错误则抛出异常，事务会自动回滚

$dbh-setAttribute(PDO::ATTR_EMULATE_PREPARES, false); //禁用prepared statements的仿真效果(防SQL注入)

} catch (PDOException $e) {

die('Connection failed: ' . $e-getMessage());

}

$dbh-exec('SET NAMES utf8');

self::$_dbh = $dbh;

}

/**

* 字段和表名添加 `符号

* 保证指令中使用关键字不出错针对mysql

* @param string $value

* @return string

protected function _addChar($value) {

if ('*'==$value || false!==strpos($value,'(') || false!==strpos($value,'.') || false!==strpos($value,'`')) {

//如果包含* 或者使用了sql方法则不作处理

} elseif (false === strpos($value,'`') ) {

$value = '`'.trim($value).'`';

}

return $value;

}

/**

* 取得数据表的字段信息

* @param string $tbName 表名

* @return array

protected function _tbFields($tbName) {

$sql = 'SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME="'.$tbName.'" AND TABLE_SCHEMA="'.$this-_dbName.'"';

$stmt = self::$_dbh-prepare($sql);

$stmt-execute();

$result = $stmt-fetchAll(PDO::FETCH_ASSOC);

$ret = array();

foreach ($result as $key=$value) {

$ret[$value['COLUMN_NAME']] = 1;

}

return $ret;

}

/**

* 过滤并格式化数据表字段

* @param string $tbName 数据表名

* @param array $data POST提交数据

* @return array $newdata

protected function _dataFormat($tbName,$data) {

if (!is_array($data)) return array();

$table_column = $this-_tbFields($tbName);

$ret=array();

foreach ($data as $key=$val) {

if (!is_scalar($val)) continue; //值不是标量则跳过

if (array_key_exists($key,$table_column)) {

$key = $this-_addChar($key);

if (is_int($val)) {

$val = intval($val);

} elseif (is_float($val)) {

$val = floatval($val);

} elseif (preg_match('/^$\w*(\+|\-|\*|\/)?\w*$$/i', $val)) {

// 支持在字段的值里面直接使用其它字段 ,例如 (score+1) (name) 必须包含括号

$val = $val;

} elseif (is_string($val)) {

$val = '"'.addslashes($val).'"';

}

$ret[$key] = $val;

}

return $ret;

}

/**

* 执行查询主要针对 SELECT, SHOW 等指令

* @param string $sql sql指令

* @return mixed

protected function _doQuery($sql='') {

$this-_sql = $sql;

$pdostmt = self::$_dbh-prepare($this-_sql); //prepare或者query 返回一个PDOStatement

$pdostmt-execute();

$result = $pdostmt-fetchAll(PDO::FETCH_ASSOC);

return $result;

}

/**

* 执行语句针对 INSERT, UPDATE 以及DELETE,exec结果返回受影响的行数

* @param string $sql sql指令

* @return integer

protected function _doExec($sql='') {

$this-_sql = $sql;

return self::$_dbh-exec($this-_sql);

}

/**

* 执行sql语句，自动判断进行查询或者执行操作

* @param string $sql SQL指令

* @return mixed

public function doSql($sql='') {

if (preg_match('/^\s*"?(' . $queryIps . ')\s+/i', $sql)) {

return $this-_doExec($sql);

}

else {

//查询操作

return $this-_doQuery($sql);

}

/**

* 获取最近一次查询的sql语句

* @return String 执行的SQL

public function getLastSql() {

return $this-_sql;

}

/**

* 插入方法

* @param string $tbName 操作的数据表名

* @param array $data 字段-值的一维数组

* @return int 受影响的行数

public function insert($tbName,array $data){

$data = $this-_dataFormat($tbName,$data);

if (!$data) return;

$sql = "insert into ".$tbName."(".implode(',',array_keys($data)).") values(".implode(',',array_values($data)).")";

return $this-_doExec($sql);

}

/**

* 删除方法

* @param string $tbName 操作的数据表名

* @return int 受影响的行数

public function delete($tbName) {

//安全考虑,阻止全表删除

if (!trim($this-_where)) return false;

$sql = "delete from ".$tbName." ".$this-_where;

$this-_clear = 1;

$this-_clear();

return $this-_doExec($sql);

}

/**

* 更新函数

* @param string $tbName 操作的数据表名

* @param array $data 参数数组

* @return int 受影响的行数

public function update($tbName,array $data) {

//安全考虑,阻止全表更新

if (!trim($this-_where)) return false;

$data = $this-_dataFormat($tbName,$data);

if (!$data) return;

$valArr = '';

foreach($data as $k=$v){

$valArr[] = $k.'='.$v;

}

$valStr = implode(',', $valArr);

$sql = "update ".trim($tbName)." set ".trim($valStr)." ".trim($this-_where);

return $this-_doExec($sql);

}

/**

* 查询函数

* @param string $tbName 操作的数据表名

* @return array 结果集

public function select($tbName='') {

$sql = "select ".trim($this-_field)." from ".$tbName." ".trim($this-_where)." ".trim($this-_order)." ".trim($this-_limit);

$this-_clear = 1;

$this-_clear();

return $this-_doQuery(trim($sql));

}

/**

* @param mixed $option 组合条件的二维数组，例：$option['field1'] = array(1,'=','or')

* @return $this

public function where($option) {

if ($this-_clear0) $this-_clear();

$this-_where = ' where ';

$logic = 'and';

if (is_string($option)) {

$this-_where .= $option;

}

elseif (is_array($option)) {

foreach($option as $k=$v) {

if (is_array($v)) {

$relative = isset($v[1]) ? $v[1] : '=';

$logic = isset($v[2]) ? $v[2] : 'and';

$condition = ' ('.$this-_addChar($k).' '.$relative.' '.$v[0].') ';

}

else {

$logic = 'and';

$condition = ' ('.$this-_addChar($k).'='.$v.') ';

}

$this-_where .= isset($mark) ? $logic.$condition : $condition;

$mark = 1;

}

return $this;

}

/**

* 设置排序

* @param mixed $option 排序条件数组例:array('sort'='desc')

* @return $this

public function order($option) {

if ($this-_clear0) $this-_clear();

$this-_order = ' order by ';

if (is_string($option)) {

$this-_order .= $option;

}

elseif (is_array($option)) {

foreach($option as $k=$v){

$order = $this-_addChar($k).' '.$v;

$this-_order .= isset($mark) ? ','.$order : $order;

$mark = 1;

}

return $this;

}

/**

* 设置查询行数及页数

* @param int $page pageSize不为空时为页数，否则为行数

* @param int $pageSize 为空则函数设定取出行数，不为空则设定取出行数及页数

* @return $this

public function limit($page,$pageSize=null) {

if ($this-_clear0) $this-_clear();

if ($pageSize===null) {

$this-_limit = "limit ".$page;

}

else {

$pageval = intval( ($page - 1) * $pageSize);

$this-_limit = "limit ".$pageval.",".$pageSize;

}

return $this;

}

/**

* 设置查询字段

* @param mixed $field 字段数组

* @return $this

public function field($field){

if ($this-_clear0) $this-_clear();

if (is_string($field)) {

$field = explode(',', $field);

}

$nField = array_map(array($this,'_addChar'), $field);

$this-_field = implode(',', $nField);

return $this;

}

/**

* 清理标记函数

protected function _clear() {

$this-_where = '';

$this-_order = '';

$this-_limit = '';

$this-_field = '*';

$this-_clear = 0;

}

/**

* 手动清理标记

* @return $this

public function clearKey() {

$this-_clear();

return $this;

}

/**

* 启动事务

* @return void

public function startTrans() {

//数据rollback 支持

if ($this-_trans==0) self::$_dbh-beginTransaction();

$this-_trans++;

return;

}

/**

* 用于非自动提交状态下面的查询提交

* @return boolen

public function commit() {

$result = true;

if ($this-_trans0) {

$result = self::$_dbh-commit();

$this-_trans = 0;

}

return $result;

}

/**

* 事务回滚

* @return boolen

public function rollback() {

$result = true;

if ($this-_trans0) {

$result = self::$_dbh-rollback();

$this-_trans = 0;

}

return $result;

}

/**

* 关闭连接

* PHP 在脚本结束时会自动关闭连接。

public function close() {

if (!is_null(self::$_dbh)) self::$_dbh = null;

}

推荐阅读

get
MySQL语句大全：创建、授权、查询、修改等【MySQL】的使用方法详解

本文详细介绍了MySQL语句的使用方法，包括创建用户、授权、查询、修改等操作。通过连接MySQL数据库，可以使用命令创建用户，并指定该用户在哪个主机上可以登录。同时，还可以设置用户的登录密码。通过本文，您可以全面了解MySQL语句的使用方法。 ... [详细]

蜡笔小新 2023-12-11 15:34:14
js
延迟注入工具（python）的SQL脚本

本文介绍了一个延迟注入工具（python）的SQL脚本，包括使用urllib2、time、socket、threading、requests等模块实现延迟注入的方法。该工具可以通过构造特定的URL来进行注入测试，并通过延迟时间来判断注入是否成功。 ... [详细]

蜡笔小新 2023-12-12 10:36:42
list
eclipse学习（第三章：ssh中的Hibernate）——11.Hibernate的缓存（2级缓存，get和load）

本文介绍了eclipse学习中的第三章内容，主要讲解了ssh中的Hibernate的缓存，包括2级缓存和get方法、load方法的区别。文章还涉及了项目实践和相关知识点的讲解。 ... [详细]

蜡笔小新 2023-12-14 00:31:35
list
PHPMailer邮件类邮件发送功能的使用教学及注意事项

本文介绍了使用国外开源码PHPMailer邮件类实现邮件发送功能的简单教学，同时提供了一些注意事项。文章涵盖了字符集设置、发送HTML格式邮件、群发邮件以及避免类的重定义等方面的内容。此外，还提供了一些与PHP相关的资源和服务，如传奇手游游戏源码下载、vscode字体调整、数据恢复、Ubuntu实验环境搭建、北京爬虫市场、进阶PHP和SEO人员需注意的内容。 ... [详细]

蜡笔小新 2023-12-13 11:56:08
get
南邮ctf-web的writeup

本文介绍了南邮ctf-web的writeup，包括签到题和md5 collision。在CTF比赛和渗透测试中，可以通过查看源代码、代码注释、页面隐藏元素、超链接和HTTP响应头部来寻找flag或提示信息。利用PHP弱类型，可以发现md5('QNKCDZO')='0e830400451993494058024219903391'和md5('240610708')='0e462097431906509019562988736854'。 ... [详细]

蜡笔小新 2023-12-13 10:58:55
version
FileNotFoundException: File does not exist

ubuntu用sqoop将数据从hive导入mysql时，命令： ... [详细]

蜡笔小新 2023-12-12 18:56:13
get
web.py开发web 第八章 Formalchemy 服务端验证方法

本文介绍了在web.py开发中使用Formalchemy进行服务端表单数据验证的方法。以User表单为例，详细说明了对各字段的验证要求，包括必填、长度限制、唯一性等。同时介绍了如何自定义验证方法来实现验证唯一性和两个密码是否相等的功能。该文提供了相关代码示例。 ... [详细]

蜡笔小新 2023-12-12 16:36:00
cmd
phpcomposer 那个中文镜像是不是凉了

phpcomposer 那个中文镜像是不是凉了 ... [详细]

蜡笔小新 2023-12-12 16:01:05
list
Day2列表、字典、集合操作详解

本文详细介绍了列表、字典、集合的操作方法，包括定义列表、访问列表元素、字符串操作、字典操作、集合操作、文件操作、字符编码与转码等内容。内容详实，适合初学者参考。 ... [详细]

蜡笔小新 2023-12-12 14:14:34
list
使用cacti监控mssql 2005运行资源情况的操作步骤

本文介绍了使用cacti监控mssql 2005运行资源情况的操作步骤，包括安装必要的工具和驱动，测试mssql的连接，配置监控脚本等。通过php连接mssql来获取SQL 2005性能计算器的值，实现对mssql的监控。详细的操作步骤和代码请参考附件。 ... [详细]

蜡笔小新 2023-12-12 13:57:58
text
基于dlib的人脸68特征点提取(眨眼张嘴检测)python版本

文章目录引言开发环境和库流程设计张嘴和闭眼的检测引言(1)利用Dlib官方训练好的模型“shape_predictor_68_face_landmarks.dat”进行68个点标定 ... [详细]

蜡笔小新 2023-12-12 13:27:42
text
RouterOS 5.16软路由安装图解教程

本文介绍了如何安装RouterOS 5.16软路由系统，包括系统要求、安装步骤和登录方式。同时提供了详细的图解教程，方便读者进行操作。 ... [详细]

蜡笔小新 2023-12-12 10:22:22
js
数据库知识点复习及命令使用

本文主要复习了数据库的一些知识点，包括环境变量设置、表之间的引用关系等。同时介绍了一些常用的数据库命令及其使用方法，如创建数据库、查看已存在的数据库、切换数据库、创建表等操作。通过本文的学习，可以加深对数据库的理解和应用能力。 ... [详细]

蜡笔小新 2023-12-11 16:27:44
get
文件压缩解压的哈夫曼树实现

本文介绍了使用哈夫曼树实现文件压缩和解压的方法。首先对数据结构课程设计中的代码进行了分析，包括使用时间调用、常量定义和统计文件中各个字符时相关的结构体。然后讨论了哈夫曼树的实现原理和算法。最后介绍了文件压缩和解压的具体步骤，包括字符统计、构建哈夫曼树、生成编码表、编码和解码过程。通过实例演示了文件压缩和解压的效果。本文的内容对于理解哈夫曼树的实现原理和应用具有一定的参考价值。 ... [详细]

蜡笔小新 2023-12-11 14:13:46
get
如何在HTML中获取鼠标的当前位置

本文介绍了在HTML中获取鼠标当前位置的三种方法，分别是相对于屏幕的位置、相对于窗口的位置以及考虑了页面滚动因素的位置。通过这些方法可以准确获取鼠标的坐标信息。 ... [详细]

蜡笔小新 2023-12-11 13:04:00

霞霞123321

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章