快捷導(dǎo)航

python連接mysql數(shù)據(jù)庫并讀取數(shù)據(jù)的實(shí)現(xiàn)

更新時(shí)間：2020年09月25日 10:04:14 作者：Silenceyezi

這篇文章主要介紹了python連接mysql數(shù)據(jù)庫并讀取數(shù)據(jù)的實(shí)現(xiàn)，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

1、安裝pymysql包

pip install pymysql

注：
MySQLdb只支持python2，pymysql支持python3

2、連接數(shù)據(jù)

import pymysql 
import pandas as pd
from pandas import DataFrame as df
conn = pymysql.Connect(
  host = 'IP地址', 
  port = 端口號, 
  user = '用戶名', 
  passwd = '用戶密碼', 
  db = '數(shù)據(jù)庫名稱', 
  charset = 'utf8'
  )

注：

查看本機(jī)IP地址：cmd輸入：ipconfig，IPv4 地址

pymysql.Connect參數(shù)中的 host 服務(wù)器地址，本機(jī)可用'localhost'

3、讀取數(shù)據(jù)

（1）使用read_sql讀取數(shù)據(jù)

sql = 'select * from testa'
data = pd.read_sql(sql, conn)

（2）使用cursor讀取數(shù)據(jù)

sql = 'select * from testa'
cur = conn.cursor() 
try: # 使用異常處理，以防程序無法正常運(yùn)行
  cur.execute(sql) 
  data = df(cur.fetchall(), columns = [col[0] for col in cur.description]) 
except Exception as e:
  conn.rollback() # 發(fā)生錯(cuò)誤時(shí)回滾
  print('事務(wù)處理失敗', e)
else:
  # conn.commit() # 事務(wù)提交
  print('事務(wù)處理成功', cur.rowcount)
cur.close()

注：

read_sql、cursor游標(biāo)區(qū)別：

read_sql ：只能執(zhí)行查詢數(shù)據(jù)
cursor游標(biāo) ：可以執(zhí)行查詢、插入、更新、刪除等操作

cur.execute(sql) ：

執(zhí)行具體數(shù)據(jù)庫的操作

cur.fetchone() ：

獲取單條數(shù)據(jù)

cur.fetchmany(3) ：

獲取前3條數(shù)據(jù)

cur.fetchall() ：

獲取所有數(shù)據(jù)

查詢結(jié)果中含字段名稱：

 # 法1：
 cur = conn.cursor(cursor = pymysql.cursors.DictCursor) # 設(shè)置成DictCursor，結(jié)果包含字段名稱
 cur.execute(sql) 
 data = df(cur.fetchall()) 
 
 # 法2：
 cur = conn.cursor()
 cur.execute(sql) 
 data = df(cur.fetchall(),columns = [col[0] for col in cur.description])

conn.commit() ：

插入、更新、刪除等操作需用該語句；查詢、創(chuàng)建數(shù)據(jù)庫、數(shù)據(jù)表則不需要

cur.rowcount ：

返回執(zhí)行的操作條數(shù)

4、關(guān)閉數(shù)據(jù)庫

conn.close()

到此這篇關(guān)于python連接mysql數(shù)據(jù)庫并讀取數(shù)據(jù)的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)python連接mysql內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: