這期內容當中小編將會給大家帶來有關Python基于pymysql的數據庫操作類的安裝運行過程，文章內容豐富且以專業的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

讓客戶滿意是我們工作的目標，不斷超越客戶的期望值來自于我們對這個行業的熱愛。我們立志把好的技術通過有效、簡單的方式提供給客戶，將通過不懈努力成為客戶在信息化領域值得信任、有價值的長期合作伙伴，公司提供的服務項目有：空間域名、網頁空間、營銷軟件、網站建設、黎城網站維護、網站推廣。

一 簡介
     Python和MySQL交互的模塊有 MySQLdb 和 PyMySQL(pymysql),MySQLdb是基于C 語言編寫的，而且Python3 不在支持MySQLdb 。PyMySQL是一個純Python寫的MySQL客戶端，它的目標是替代MySQLdb，可以在CPython、PyPy、IronPython和Jython環境下運行,PyMySQL在MIT許可下發布。
    在開發基于Python語言的項目中，為了以后系統能兼容Python3,我們使用了PyMySQL替換了MySQLdb。下面我們來熟悉一下pymysql的使用。
 
二 安裝方式
  pymsql的源碼 /tupian/20230522/PyMySQL ，目前還在持續更新。

1. 安裝要求:

2. Python -- one of the following:

3.      CPython >= 2.6 or >= 3.3

4.      PyPy >= 4.0

5.      IronPython 2.7

6. MySQL Server -- one of the following:

7.      MySQL >= 4.1 (tested with only 5.5~)

8.      MariaDB >= 5.1

9. 安裝

10.   pip install PyMySQL

 

三 基于pymysql的數據庫交互

1. #!/usr/bin/env python

2. # encoding: utf-8

3. """

4. author: yangyi@youzan

5. time:   2015/6/8 上午11:34

6. func: 基于pymysql的數據庫交互類，支持事務提交和回滾，返回結果記錄行數，和insert的最新id

7. """

8. import pymysql

9. from warnings import filterwarnings

10. filterwarnings('ignore', category=pymysql.Warning)

11. CONNECT_TIMEOUT = 100

12. IP = 'localhost'

13. PORT = 3306

14. USER = 'root'

15. PASSSWORD = ''

17. class QueryException(Exception):

18.     """

19.     """

22. class ConnectionException(Exception):

23.     """

24.     """

26. class MySQL_Utils():

27.     def __init__(

28.             self, ip=IP, port=PORT, user=USER, password=PASSSWORD,

29.             connect_timeout=CONNECT_TIMEOUT, remote=False, socket='', dbname='test'):

30.         self.__conn = None

31.         self.__cursor = None

32.         self.lastrowid = None

33.         self.connect_timeout = connect_timeout

34.         self.ip = ip

35.         self.port = port

36.         self.user = user

37.         self.password = password

38.         self.mysocket = socket

39.         self.remote = remote

40.         self.db = dbname

41.         self.rows_affected = 0

44.     def __init_conn(self):

45.         try:

46.             conn = pymysql.connect(

47.                     host=self.ip,

48.                     port=int(self.port),

49.                     user=self.user,

50.                     db=self.db,

51.                     connect_timeout=self.connect_timeout,

52.                     charset='utf8', unix_socket=self.mysocket)

53.         except pymysql.Error as e:

54.             raise ConnectionException(e)

55.         self.__conn = conn

58.     def __init_cursor(self):

59.         if self.__conn:

60.             self.__cursor = self.__conn.cursor(pymysql.cursors.DictCursor)

63.     def close(self):

64.         if self.__conn:

65.             self.__conn.close()

66.             self.__conn = None

68.     #專門處理select 語句

69.     def exec_sql(self, sql, args=None):

70.         try:

71.             if self.__conn is None:

72.                 self.__init_conn()

73.                 self.__init_cursor()

74.             self.__conn.autocommit = True

75.             self.__cursor.execute(sql, args)

76.             self.rows_affected = self.__cursor.rowcount

77.             results = self.__cursor.fetchall()

78.             return results

79.         except pymysql.Error as e:

80.             raise pymysql.Error(e)

81.         finally:

82.             if self.__conn:

83.                 self.close()

85.     # 專門處理dml語句 delete，updete，insert 

86.     def exec_txsql(self, sql, args=None):

87.         try:

88.             if self.__conn is None:

89.                 self.__init_conn()

90.                 self.__init_cursor()

91.             if self.__cursor is None:

92.                 self.__init_cursor()

95.             self.rows_affected=self.__cursor.execute(sql, args)

96.             self.lastrowid = self.__cursor.lastrowid

97.             return self.rows_affected

98.         except pymysql.Error as e:

99.             raise pymysql.Error(e)

100.         finally:

101.             if self.__cursor:

102.                 self.__cursor.close()

103.                 self.__cursor = None

105.     # 提交

106.     def commit(self):

107.         try:

108.             if self.__conn:

109.                 self.__conn.commit()

110.         except pymysql.Error as e:

111.             raise pymysql.Error(e)

112.         finally:

113.             if self.__conn:

114.                 self.close()

116.     #回滾操作

117.     def rollback(self):

118.         try:

119.             if self.__conn:

120.                 self.__conn.rollback()

121.         except pymysql.Error as e:

122.             raise pymysql.Error(e)

123.         finally:

124.             if self.__conn:

125.                 self.close()

126.     # 適用于需要獲取插入記錄的主鍵自增id

127.     def get_lastrowid(self):

128.         return self.lastrowid

     #獲取dml操作影響的行數
    def get_affectrows(self):
        return self.rows_affected
     #MySQL_Utils初始化的實例銷毀之后，自動提交
     def __del__(self):
        self.commit()

上述就是小編為大家分享的Python基于pymysql的數據庫操作類的安裝運行過程了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注創新互聯-成都網站建設公司行業資訊頻道。

本文名稱：Python基于pymysql的數據庫操作類的安裝運行過程-創新互聯
標題來源：http://vcdvsql.cn/article40/csgoeo.html

成都網站建設公司_創新互聯，為您提供網站建設、網站維護、商城網站、關鍵詞優化、服務器托管、全網營銷推廣

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯