将指定地址的csv文件读入MySql数据库中的代码函数
时间: 2024-03-20 14:41:09 浏览: 70
以下是Python中将指定地址的CSV文件读入MySQL数据库中的代码函数:
```python
import pandas as pd
from sqlalchemy import create_engine
def csv_to_mysql(csv_file_path, db_name, table_name, host='localhost', port='3306', user='root', password='password'):
"""
读取指定地址的CSV文件,并将其导入到MySQL数据库中
:param csv_file_path: CSV文件的路径
:param db_name: 数据库名称
:param table_name: 表名称
:param host: 数据库主机地址,默认为localhost
:param port: 数据库端口号,默认为3306
:param user: 数据库用户名,默认为root
:param password: 数据库密码,默认为password
"""
# 读取CSV文件
df = pd.read_csv(csv_file_path)
# 建立MySQL数据库连接
engine = create_engine(f'mysql+pymysql://{user}:{password}@{host}:{port}/{db_name}')
# 导入数据到MySQL数据库中
df.to_sql(name=table_name, con=engine, if_exists='replace', index=False)
```
使用方式:
```python
csv_to_mysql('path/to/your/csv/file.csv', 'your_db_name', 'your_table_name')
```
其中,`path/to/your/csv/file.csv`是CSV文件的路径,`your_db_name`是你想要将数据导入的MySQL数据库名称,`your_table_name`是你想要将数据导入的MySQL表名称。可以根据需要修改其他参数。
阅读全文