本篇文章給大家分享的是有關(guān)Python中怎么操作MySQL數(shù)據(jù)庫(kù)，小編覺得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說(shuō)，跟著小編一起來(lái)看看吧。
第一種 使用pymysql
代碼如下：
import pymysql #打開數(shù)據(jù)庫(kù)連接 db=pymysql.connect(host='1.1.1.1',port=3306,user='root',passwd='123123',db='test',charset='utf8') cursor=db.cursor()#使用cursor()方法獲取操作游標(biāo) sql = "select * from test0811" cursor.execute(sql) info = cursor.fetchall() db.commit() cursor.close() #關(guān)閉游標(biāo) db.close()#關(guān)閉數(shù)據(jù)庫(kù)連接
數(shù)據(jù)表test0811的內(nèi)容和上邊的代碼讀出來(lái)的內(nèi)容分別是
pymysql是Python操作MySQL數(shù)據(jù)庫(kù)的模塊。首先引入pymysql模塊
import pymysql
使用pymysql的connect()方法連接數(shù)據(jù)庫(kù)，connect的幾個(gè)參數(shù)解釋如下：
host：MySQL服務(wù)的地址，若數(shù)據(jù)庫(kù)在本地上，使用localhost或者127.0.0.1。如果在其它的服務(wù)器上，應(yīng)該寫IP地址。
port：服務(wù)的端口號(hào)，默認(rèn)為3306，如果不寫，為默認(rèn)值。
user：登錄數(shù)據(jù)庫(kù)的用戶名
passwd：user賬戶登錄MySQL的密碼
db：將要操作的數(shù)據(jù)庫(kù)的名字
charset：設(shè)置為utf8編碼，這樣就可以存入漢字沒有亂碼
注意：除了port=3306不用引號(hào)，其它項(xiàng)的值都有用引號(hào)括起來(lái)
代碼中的db就架起了Python和MySQL通信的橋梁，db.cursor()表示返回連接的游標(biāo)對(duì)象，通過(guò)游標(biāo)執(zhí)行SQL語(yǔ)句。還有幾個(gè)常用的方法是commit()表示提交數(shù)據(jù)庫(kù)修改，rollback()表示回滾，就是取消當(dāng)前的操作，close()表示關(guān)閉連接。
上面講的是連接對(duì)象db的一些方法，游標(biāo)對(duì)象的一些方法也很重要，利用游標(biāo)對(duì)象的方法就可以對(duì)數(shù)據(jù)庫(kù)進(jìn)行操作了，游標(biāo)對(duì)象的常用方法如下表：
| 名稱 | 描述 |
|---|---|
| close() | 關(guān)閉游標(biāo)，之后游標(biāo)不可用 |
| execute(query[,args]) | 執(zhí)行一條SQL語(yǔ)句，可以帶參數(shù) |
| executemany(query,pseq) | 對(duì)序列pseq中的每個(gè)參數(shù)執(zhí)行SQL語(yǔ)句 |
| fetchone() | 返回一條查詢結(jié)果 |
| fetchall() | 返回所有查詢結(jié)果 |
| fetchmany([size]) | 返回size條查詢結(jié)果 |
| nextset() | 移動(dòng)到下一條結(jié)果 |
| scroll(value,mode='relative') | 移動(dòng)游標(biāo)到指定行，如果mode='relative'，則表示從當(dāng)前行移動(dòng)value條，如果mode=‘a(chǎn)bsolute'，則表示從結(jié)果集的第一行移動(dòng)value條 |
到這里就基本把pymysql的基本用法講清楚了，剩下的對(duì)數(shù)據(jù)庫(kù)的操作（增刪改查）就是SQL語(yǔ)句的事情了。雖然SQL語(yǔ)句很強(qiáng)大，但有時(shí)候也會(huì)顯得力不從心，Python的靈活加上SQL的強(qiáng)大才可以做更多的事情，而pymysql只是充當(dāng)工具、橋梁的作用。從代碼運(yùn)行的結(jié)果中（第二幅圖）發(fā)現(xiàn)讀出來(lái)的結(jié)果是存放在二維元組中的，即((1, '小紅', '80'),(2, '小明', '90'),(3, '小美', '87'),(4, 'GG', '67'),(5, 'MM', '78'))，但是元組不可改變，只能讀出，對(duì)于數(shù)據(jù)處理還有些不便，下面第二種方法就是把數(shù)據(jù)讀出存放在DataFrame中，便于處理。
第二種 使用pandas
代碼如下：
重慶分公司
重慶分公司
import pandas as pd
from sqlalchemy import create_engine
from sqlalchemy.types import CHAR,INT
connect_info = 'mysql+pymysql://username:passwd@host:3306/dbname?charset=utf8'
engine = create_engine(connect_info) #use sqlalchemy to build link-engine
sql = "SELECT * FROM test0811" #SQL query
df = pd.read_sql(sql=sql, con=engine) #read data to DataFrame 'df'
#write df to table 'test1'
df.to_sql(name = 'test1',
con = engine,
if_exists = 'append',
index = False,
dtype = {'id': INT(),
'name': CHAR(length=2),
'score': CHAR(length=2)
}
)pandas的DataFrame數(shù)據(jù)格式有行索引和列索引，使用DataFrame來(lái)存儲(chǔ)數(shù)據(jù)庫(kù)表中的數(shù)據(jù)會(huì)十分方便。使用pandas中的read_sql和to_sql函數(shù)從MySQL數(shù)據(jù)庫(kù)中讀寫數(shù)據(jù)。兩個(gè)函數(shù)介紹如下。
pandas.read_sql
復(fù)制代碼 代碼如下:
pandas.read_sql(sql, con, index_col=None, coerce_float=True, params=None, parse_dates=None, columns=None, chunksize=None)
pandas.read_sql的文檔中有詳細(xì)的各個(gè)參數(shù)的英文介紹（不要排斥看英文，虛心向老外學(xué)習(xí)），參考資料http://pandas.pydata.org/pandas-docs/stable/generated/pandas.read_sql.html
常用的參數(shù)是sql：SQL命令或者表名字，con：連接數(shù)據(jù)庫(kù)的引擎，可以用SQLAlchemy或者pymysql建立，從數(shù)據(jù)庫(kù)讀數(shù)據(jù)的基本用法給出sql和con就可以了。其它都是默認(rèn)參數(shù)，有特殊需求才會(huì)用到，有興趣的話可以查看文檔。
代碼中的con是使用SQLAlchem構(gòu)建數(shù)據(jù)庫(kù)連接引擎，即sqlalchemy.create_engine( )。這個(gè)函數(shù)基于一個(gè)URL來(lái)產(chǎn)生一個(gè)引擎對(duì)象，URL通常包含了數(shù)據(jù)庫(kù)的相關(guān)信息，典型的形式是：
dialect+driver://username:password@host:port/database
dialect表示數(shù)據(jù)庫(kù)的名字，比如sqlite，mysql，postgresql，oracle，mssql等，driver是用于連接數(shù)據(jù)庫(kù)的DBAPI的名字，這里用的是pymysql（Python 3.x，在Python 2.x中用的是mysqldb），如果這一項(xiàng)不指定，將使用默認(rèn)的DBAPI。
除了使用SQLAlchemy創(chuàng)建engine外，還可以直接使用DBAPI創(chuàng)建engine，代碼如下：
con = pymysql.connect(host=localhost, user=username, password=password, database=dbname, charset='utf8') df = pd.read_sql(sql, con)
pandas.DataFrame.to_sql
復(fù)制代碼 代碼如下:
DataFrame.to_sql(name, con, schema=None, if_exists='fail', index=True, index_label=None, chunksize=None, dtype=None)
主要參數(shù)介紹如下
name：輸出的表名
con：連接數(shù)據(jù)庫(kù)的引擎
if_exists：三種模式{“fail”,“replace”,"append"}，默認(rèn)是"fail"。fail：若表存在，引發(fā)一個(gè)ValueError；replace：若表存在，覆蓋原來(lái)表內(nèi)數(shù)據(jù)；append：若表存在，將數(shù)據(jù)寫到原表數(shù)據(jù)的后面。
index：是否將DataFrame的index單獨(dú)寫到一列中，默認(rèn)為“True”
index_label：當(dāng)index為True時(shí)，指定列作為DataFrame的index輸出
dtype：指定列的數(shù)據(jù)類型，字典形式存儲(chǔ){column_name: sql_dtype}，常見數(shù)據(jù)類型是sqlalchemy.types.INT()和sqlalchemy.types.CHAR(length=x)。注意：INT和CHAR都需要大寫，INT()不用指定長(zhǎng)度。
以上就是Python中怎么操作MySQL數(shù)據(jù)庫(kù)，小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘９ぷ鲿?huì)見到或用到的。希望你能通過(guò)這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
