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

python如何使用pymysql连接数据库封装类,第1张

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

数据库访问封装类

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/htmlcharset=gb2312'>\n"

$message

.=

"</head>\n"

$message

.=

"<body>\n"

$message

.=

"数据库出错:".htmlspecialchars($msg)."\n"

$message

.=

"</body>\n"

$message

.=

"</html>"

echo

$message

exit

}

}

?>

存储过程不存在 *** 作或是不 *** 作触发器的问题,要先理解触发器的含义。

触发器分两类,一类是基于表数据的触发,一类是基于数据库对象的触发。

实际应用中第一类比较常用,它是在对表数据进行 插入 修改 删除 的 *** 作时触发,执行触发器中的脚本,换言之,就是如果你的存储过程有涉及到对该表的 插入 修改 删除 数据 *** 作,而且该表也存在这些 *** 作对应的触发器,那么肯定会触发也就是执行这个触发器,反之,不会执行。


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/sjk/6734902.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-03-27
下一篇 2023-03-27

发表评论

登录后才能评论

评论列表(0条)

保存