1.mysql读写
一.数据库读取(mysql)
参数 | 接受 | 作用 | 默认 |
---|---|---|---|
sql or table_name | string | 读取的表名,或sql语句 | 无 |
con | 数据库连接 | 数据库连接信息 | 无 |
index_col | Int/sequence/False | 设定列作行名,(一个数列为多重索引) | None |
coerce_float | Boolean | 将数据库中decimal类型转换为pandas的float64 | True |
1.连通器: 连接mysql
“数据库类型+数据库驱动名称://用户名:口令@机器地址:端口号/数据库名”
from sqlalchemy import create_engine
连通器=create_engine("mysql+pymysql://root:root密码@127.0.0.1:3306/库名?charset=utf8")
示例
2.读sql
(1)read_sql_query
只能使用sql语言进行读取操作
pd.read_sql_query("sql语言",con=data_1)
示例
(2)read_sql_table
无法使用sql语句
pd.read_sql_table("数据表名",con=连通器)
示例
(3)read_sql
同时兼顾read_sql_table,read_sql_query的操作
pd.read_sql("数据表名",con=连通器)
pd.read_sql("sql语言",con=data_1)
示例
二.mysql写入
to_sql()
参数名 | 接收 | 作用 | 默认 |
---|---|---|---|
name | string | 数据库名 | 无 |
con | 数据库链接 | 数据库链接信息 | 无 |
If_exists | fail/replace/append | Fail同表名取消写入,replace同图表名覆盖,append 同表名追加数据 | fail |
Index | Boolean | 是否将索引作为数据传入 | true |
Lindex_label | String/sequence | 是否引用索引名称 | |
Dtype | Dict | 写入数据类型(列名key,数据格式values) | None |
to_sql