怎么使用pandas库直接运行mysql的插入语句
时间: 2024-01-26 11:02:00 浏览: 71
您可以使用pandas库中的`read_sql_query()`方法执行MySQL的插入语句。具体操作步骤如下:
1. 导入必要的库和模块:
```
import pandas as pd
from sqlalchemy import create_engine
```
2. 建立到数据库的连接:
```
engine = create_engine('mysql+pymysql://user:password@host:port/database_name')
```
3. 使用`read_sql_query()`方法执行MySQL的插入语句:
```
sql_query = "INSERT INTO table_name (column1, column2, ...) VALUES (value1, value2, ...)"
df = pd.read_sql_query(sql_query, engine)
```
这里将MySQL的插入语句作为参数传递给`read_sql_query()`方法,然后将结果存储在DataFrame对象中。
4. 打印结果:
```
print(df)
```
这里将结果打印出来,以便确认插入操作是否成功。
完整的代码如下所示:
```
# 导入必要的库和模块
import pandas as pd
from sqlalchemy import create_engine
# 建立到数据库的连接
engine = create_engine('mysql+pymysql://user:password@host:port/database_name')
# 使用read_sql_query()方法执行MySQL的插入语句
sql_query = "INSERT INTO table_name (column1, column2, ...) VALUES (value1, value2, ...)"
df = pd.read_sql_query(sql_query, engine)
# 打印结果
print(df)
```
希望这个回答可以帮助您。
阅读全文