python数据库-MySQL与python的交互(52)
2019-07-24 09:20:56来源:博客园 阅读 ()
一、python3中安装PyMySQL模块
命令安装:
sudo apt-get install python-mysql
或者
pip install pymysql
2、使用在pyCharm中安装PyMySQL模块
二、PyMysql对象说明
1、Connection对象
- 用于建立与数据库的连接
- 创建对象:调用connect()方法
conn=connect(参数列表)
- 参数host:连接的mysql主机,如果本机是'localhost'
- 参数port:连接的mysql主机的端口,默认是3306
- 参数database:数据库的名称
- 参数user:连接的用户名
- 参数password:连接的密码
- 参数charset:通信采用的编码方式,默认是'gb2312',要求与数据库创建时指定的编码一致,否则中文会乱码
对象的方法
-
- close()关闭连接
- commit()事务,所以需要提交才会生效
- rollback()事务,放弃之前的操作
- cursor()返回Cursor对象,用于执行sql语句并获得结果
2、Cursor对象
- 执行sql语句
- 创建对象:调用Connection对象的cursor()方法
cursor1=conn.cursor()
对象的方法
- close()关闭
- execute(operation [, parameters ])执行语句,返回受影响的行数
- fetchone()执行查询语句时,获取查询结果集的第一个行数据,返回一个元组
- next()执行查询语句时,获取当前行的下一行
- fetchall()执行查询时,获取结果集的所有行,一行构成一个元组,再将这些元组装入一个元组返回
- scroll(value[,mode])将行指针移动到某个位置
- mode表示移动的方式
- mode的默认值为relative,表示基于当前行移动到value,value为正则向下移动,value为负则向上移动
- mode的值为absolute,表示基于第一条数据的位置,第一条数据的位置为0
对象的属性
- rowcount只读属性,表示最近一次execute()执行后受影响的行数
- connection获得当前连接对象
三、对Mysql基本操作的封装
1、我们创建MySQLManager.py模块,对Mysql的基本操作封装
# coding=utf-8; # 导入模块pymysql模块 import pymysql # 封装MySQL数据库管理类 class MySQL_Manager(object): # 初始化方法 def __init__(self,host,port,database,user,password,charset='utf8'): # 配置连接MySQL数据库的基本信息 self.host = host self.port = port self.database = database self.user = user self.password = password self.charset = charset # 使用python3链接MySQL数据库 def connect(self): # 链接 self.connect = pymysql.connect(host = self.host, port = self.port, database = self.database, user = self.user, password = self.password,charset = self.charset) # 得到一个可以执行SQL语句的光标对象 self.cursor = self.connect.cursor() # 操作完毕后关闭 def close(self): # 关闭执行语句 self.cursor.close() # 关闭连接 self.connect.close() # 创建表操作 def create_table(self,sql,params=()): # 先连接 self.connect() # 执行创建语句 self.cursor.execute(sql,params) # 关闭连接 self.close() # 查询一条数据 def select_one(self,sql,params=()): result = None try: self.connect() self.cursor.execute(sql,params) result = self.cursor.fetchone() self.close() except Exception as e: print(e) return result # 查询全部数据 def select_all(self,sql,params=()): list=() try: self.connect() self.cursor.execute(sql,params) list = self.cursor.fetchall() self.close() except Exception as e: print(e) return list # 插入 def insert(self, sql, params=()): return self.__edit(sql, params) # 修改 def update(self, sql, params=()): return self.__edit(sql, params) # 删除 def delete(self, sql, params=()): return self.__edit(sql, params) # 插入、修改、删除其实一样的,只是sql代码不同,但是为了代码的阅读性更高,还是分开写 def __edit(self, sql, params): count = 0 try: self.connect() count = self.cursor.execute(sql, params) self.connect.commit() self.close() except Exception as e: print(e) return count
2.创建testMySQL.py模块对我们创建的MySQLManager.py模块测试
# coding = utf-8 from MySQLManager import * mysql_manager = MySQL_Manager("192.168.100.114",3306,"Hero","root","123456") # 创建表 create_sql = "create table hero(id int auto_increment primary key,name varchar(20) not null unique,skill varchar(20) not null) engine=innodb default charset=utf8;" mysql_manager.create_table(create_sql) # 添加数据 insert_sql = "insert into hero(id,name,skill) values(1,'李白','青莲剑歌');" mysql_manager.insert(insert_sql) # 查询语句 select_sql = "select * from hero;" list = mysql_manager.select_all(select_sql) print(list) # 修改 update_sql = "update hero set name='韩信' where id=1;" mysql_manager.update(update_sql) # 删除语句 delete_sql = "delete from hero where id=1;" mysql_manager.delete(delete_sql)
说明:
- 为什么MySQLManager里面的方法都有params参数,这里却没用?因为这只是测试,我把所有的参数都直接写在了sql语句中,但是为了程序的可扩展性,建议大家还是使用参数params
- testMysql.py文件每运行一次里面对数据库的操作就会执行一次,例如创建表的操作只需要执行一次,当我们创建表成功之后,就可以把创建表的方法注释掉,不用再创建了,同样的,添加,删除也是一样。
原文链接:https://www.cnblogs.com/Se7eN-HOU/p/11173618.html
如有疑问请与原作者联系
标签:
版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有
- python3基础之“术语表(2)” 2019-08-13
- python3 之 字符串编码小结(Unicode、utf-8、gbk、gb2312等 2019-08-13
- Python3安装impala 2019-08-13
- 小白如何入门 Python 爬虫? 2019-08-13
- python_字符串方法 2019-08-13
IDC资讯: 主机资讯 注册资讯 托管资讯 vps资讯 网站建设
网站运营: 建站经验 策划盈利 搜索优化 网站推广 免费资源
网络编程: Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它
服务器技术: Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护
软件技巧: 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷
网页制作: FrontPages Dreamweaver Javascript css photoshop fireworks Flash