首先需要導入驅動模塊

打開cmd導入模塊 pip install mysqldb(pymysql)

python2.x版本--------->mysqldb

python3.x版本---------->pymysql

python調用MySQL數據庫總共五步

1、導入模塊(驅動) pymysql? mysqldb

2、獲取連接 connect

3、獲取游標cursor

4、執行sql execute 并且返回結果

5、關閉資源

====================================================================

#python 調用mysql幫助類 ?連接數據庫 創建數據查詢更新的方法

#創建一個數據庫幫助類

#導入pymysql模塊

import pymysql

#創建類

class sqlHelper:

#初始化屬性

def __init__(self,host,db,user,pwd):

self.host = host

self.port = 3306

self.db = db

self.user = user

self.pwd = pwd

self.charset = 'utf8'

#創建數據庫連接 創建游標

def connection(self):

self.conn = pymysql.connect(host = self.host,port = self.port,db = self.db,user = self.user,

password = self.pwd,charset = self.charset)

self.cursor = self.conn.cursor()

return 'OK'

#創建查詢一條數據的方法

def queryOne(self,sql,params):

#首先連接數據庫 獲取游標

try:

self.connection()

#執行sql語句

count = self.cursor.execute(sql,params)

#返回執行結果

res = self.cursor.fetchone()

return? count,res

except Exception as? ex:

print('失敗,失敗信息是:',ex)

finally:

#調用關閉資源的方法

self.closes()

#創建查詢多條數據的方法

def queryAll(self,sql,params):

try:

#連接數據庫

self.connection()

#執行sql語句

count = self.cursor.execute(sql,params)

#獲取結果

res = self.cursor.fetchall()

return count,res

except Exception as e:

print('查詢失敗 失敗信息是：',e)

finally:

#調用關閉資源的方法

self.closes()

#創建修改數據庫的方法

def update(self,sql,params):

try:

# 連接數據庫

self.connection()

# 執行sql語句

count = self.cursor.execute(sql,params)

#把事物(更新的信息寫入數據庫)

self.conn.commit()

return count

except Exception as e:

print('查詢失敗 失敗信息是：', e)

#如果更新失敗 數據庫就返回到更新之前的數據

self.conn.rollback()

finally:

# 調用關閉資源的方法

self.closes()

#定義關閉資源的方法

def closes(self):

if self.cursor != None:

self.cursor.close()

if self.conn != None:

self.conn.close()

================================================================================================

測試數據庫幫助類的文檔：

'''

python調用mysql分為五個步驟

1、導入pymysql模塊

2、獲取連接 connect

3、獲取游標 curs

4、執行SQL execute 并返回結果

5、關閉資源

'''

#定義用戶操作數據庫的一些方法

import sqlHelper

import sys

#創建連接對象? host,db,user,pwd

helper = sqlHelper.sqlHelper('localhost','db_py1712','root','root')

#print(helper.connection())

# a,s = helper.queryOne('select * from t_stumessage',[])

# print(s)

# a = helper.update('insert into t_stumessage VALUES (uuid() ,%s,%s,%s,%s,%s)',['陳樂樂',123456,21,'男','萬方學院'])

# print(a)

# a,s = helper.queryAll('select * from t_stumessage',[])

# print(s)

#用戶注冊

def register(user):

#首先查詢數據庫中是否存在該用戶名

#查詢表中所有用戶名

count,res = helper.queryAll('select username from t_stumessage',[])

#遍歷元組 判斷輸入的用戶名是否存在

bn = False

for u in res:

# print(u)

# print(type(u))

if u[0] != user:

bn = True

if bn == False:

pwd = int(input('請輸入密碼'))

age = int(input('請輸入年齡'))

sex = input('請輸入性別')

school = input('請輸入學校名稱')

#把用戶輸入的信息寫如到數據庫表中

# s = helper.connection()

# print(s)

count = helper.update('insert into t_stumessage VALUES (uuid() ,%s,%s,%s,%s,%s)',[user,pwd,age,sex,school])

if count > 0:

print('注冊成功')

else:

print('注冊失敗')

else:

print('你輸入的用戶名已經存在，請重新輸入')

#register('王少松')

#用戶登錄

def login(user,pwd):

#查詢表中的用戶名和密碼 判斷與用戶輸入的信息是否匹配

count,res = helper.queryAll('select username,pwd from t_stumessage ',[])

return count,res

#遍歷res

# bn = False

# for u in res:

#? ? if u[0] == user and u[1] == pwd:

#? ? ? ? bn =True

# if bn == True:

#? ? print('登錄成功')

# else:

#? ? print('用戶名或密碼錯誤，登錄失敗')

# u = input()

# s = input()

# login(u,s)

#用戶列表 根據用戶名查看用戶自己的基本信息

def messages(user):

count,res = helper.queryOne('select * from t_stumessage where userName = %s',(user,))

return count,res

# if count > 0:

#? ? return res

# else:

#? ? print('查詢失敗')

#messages('趙嬌嬌')

#用戶修改? 根據用戶名修改密碼

def update(user,pwd):

count = helper.update('update t_stumessage set pwd = %s WHERE username = %s',[pwd,user])

#print(count)

if count > 0:

print('修改成功')

else:

print('修改失敗')

#update('趙嬌嬌','123123')

#用戶刪除 根據用戶名刪除用戶信息

def dels(user):

count = helper.update('delete from t_stumessage WHERE username = %s',(user,))

if count > 0:

print('刪除成功')

else:

print('刪除失敗')

#dels('趙嬌嬌')

#用戶退出

def exit():

print('退出')

sys.exit()

#exit()

========================================================================

總結

以上是生活随笔為你收集整理的python访问mysql_python连接mysql的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。