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

 

1、python3中安装PyMySQL模块

命令安装：

sudo apt-get install python-mysql

或者

pip install pymysql

二、使用在pyCharm中安装PyMySQL模块

 

2、PyMysql对象说明

一、Connection对象

• 用于创建与数据库的链接
• 建立对象：调用connect()方法

conn=connect(参数列表)

• 参数host：链接的mysql主机，若是本机是'localhost'
• 参数port：链接的mysql主机的端口，默认是3306
• 参数database：数据库的名称
• 参数user：链接的用户名
• 参数password：链接的密码
• 参数charset：通讯采用的编码方式，默认是'gb2312'，要求与数据库建立时指定的编码一致，不然中文会乱码

　　对象的方法

• • close()关闭链接
  • commit()事务，因此须要提交才会生效
  • rollback()事务，放弃以前的操做
  • cursor()返回Cursor对象，用于执行sql语句并得到结果

二、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得到当前链接对象

 

3、对Mysql基本操做的封装

一、咱们建立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文件每运行一次里面对数据库的操做就会执行一次，例如建立表的操做只须要执行一次，当咱们建立表成功以后，就能够把建立表的方法注释掉，不用再建立了，一样的，添加，删除也是同样。