pymysql.connect()参数说明:（连接数据库时需要添加的参数）
| 参数 |
类型 |
描述 |
| host |
str |
MySQL服务器地址，IP地址或域名 |
| port |
int |
MySQL服务器端口号 |
| user |
str |
用户名 |
| passwd |
str |
密码 |
| db |
str |
数据库名称 |
| charset |
str |
连接编码 |
connect()对象支持的方法:
| 方法 |
描述 |
| cursor() |
使用该连接创建并返回游标 |
| commit() |
提交当前事务 |
| rollback() |
回滚当前事务 |
| close() |
关闭连接 |
cursor对象支持的方法:
| 方法 |
描述 |
| execute(op) |
执行一个数据库的查询命令 |
| fetchone() |
取得结果集的下一行 |
| fetchmany(size) |
获取结果集的下几行 |
| fetchall() |
获取结果集中的所有行 |
| rowcount() |
返回数据条数或影响行数 |
| close() |
关闭游标对象 |
代码样例
import pandas as pd
import pymysql
#创建数据库连接
conn = pymysql.connect(host='sh-cdb-n9zp4qdr.sql.tencentcdb.com',
port=31060,#填写真实数据库外部访问端口
user='root',
passwd='password*****',
db='dev_db',
charset='utf8')
#创建游标
cursor = conn.cursor()
sql = "select *from t_bank " #SQL查询语句
cursor.execute(sql) #执行SQL语句
df = pd.read_sql(sql, conn) #使用pandas方法读取DB中的数据
print(df['bank_branch_name'])
cursor.close() #关闭游标
conn.close() #关闭数据库连接
