python数据库-MySQL与python的交互(52)

一、python3中安装PyMySQL模块命令安装:sudoapt-getinstallpython-mysql或者pipinstallpymysql2、使用在pyCharm中安装PyMySQL模块二、PyMysql对象说明1、Connection对象用于建立与数据库的连接创建对象:调用connect()方法conn=connect(参数列表)参数host:连接的mysql主机,如果本机是'loc...

python数据库-MySQL与python的交互(52)

一、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-8from 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.guoxiongfei.cn/cntech/21550.html