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文件每運行一次裏面對數據庫的操做就會執行一次，例如建立表的操做只須要執行一次，當咱們建立表成功以後，就能夠把建立表的方法註釋掉，不用再建立了，一樣的，添加，刪除也是同樣。