pymysql.connect()參數(shù)說明:（連接數(shù)據(jù)庫時需要添加的參數(shù)）
| 參數(shù) |
類型 |
描述 |
| host |
str |
MySQL服務(wù)器地址儡率，IP地址或域名 |
| port |
int |
MySQL服務(wù)器端口號 |
| user |
str |
用戶名 |
| passwd |
str |
密碼 |
| db |
str |
數(shù)據(jù)庫名稱 |
| charset |
str |
連接編碼 |
connect()對象支持的方法:
| 方法 |
描述 |
| cursor() |
使用該連接創(chuàng)建并返回游標(biāo) |
| commit() |
提交當(dāng)前事務(wù) |
| rollback() |
回滾當(dāng)前事務(wù) |
| close() |
關(guān)閉連接 |
cursor對象支持的方法:
| 方法 |
描述 |
| execute(op) |
執(zhí)行一個數(shù)據(jù)庫的查詢命令 |
| fetchone() |
取得結(jié)果集的下一行 |
| fetchmany(size) |
獲取結(jié)果集的下幾行 |
| fetchall() |
獲取結(jié)果集中的所有行 |
| rowcount() |
返回數(shù)據(jù)條數(shù)或影響行數(shù) |
| close() |
關(guān)閉游標(biāo)對象 |
代碼樣例
import pandas as pd
import pymysql
#創(chuàng)建數(shù)據(jù)庫連接
conn = pymysql.connect(host='sh-cdb-n9zp4qdr.sql.tencentcdb.com',
port=31060,#填寫真實數(shù)據(jù)庫外部訪問端口
user='root',
passwd='password*****',
db='dev_db',
charset='utf8')
#創(chuàng)建游標(biāo)
cursor = conn.cursor()
sql = "select *from t_bank " #SQL查詢語句
cursor.execute(sql) #執(zhí)行SQL語句
df = pd.read_sql(sql, conn) #使用pandas方法讀取DB中的數(shù)據(jù)
print(df['bank_branch_name'])
cursor.close() #關(guān)閉游標(biāo)
conn.close() #關(guān)閉數(shù)據(jù)庫連接
