Python使用Pandas庫實(shí)現(xiàn)MySQL數(shù)據(jù)庫的讀寫

pd.io.sql.to_sql(df1,tablename,con=conn,if_exists='repalce') 　

import pandas as pd
from sqlalchemy import create_engine
# 初始化數(shù)據(jù)庫連接，使用pymysql模塊
# MySQL的用戶：root, 密碼:147369, 端口：3306,數(shù)據(jù)庫：test
engine = create_engine('mysql+pymysql://root:123456@localhost:3306/test')
# 查詢語句，選出employee表中的所有數(shù)據(jù)
sql = ''' select * from employee; '''
# read_sql_query的兩個參數(shù): sql語句， 數(shù)據(jù)庫連接
df = pd.read_sql_query(sql, engine)
# 輸出employee表的查詢結(jié)果
print(df)

# 新建pandas中的DataFrame, 只有id,num兩列
df = pd.DataFrame({'id': [1, 2, 3, 4], 'name': ['zhangsan', 'lisi', 'wangwu', 'zhuliu']})
# 將新建的DataFrame儲存為MySQL中的數(shù)據(jù)表，儲存index列
df.to_sql('mydf', engine, index=True)
print('Read from and write to Mysql table successfully!')

# -*- coding: utf-8 -*-

# 導(dǎo)入必要模塊
import pandas as pd
from sqlalchemy import create_engine

# 初始化數(shù)據(jù)庫連接，使用pymysql模塊
db_info = {'user': 'root',
      'password': '123456',
      'host': 'localhost',
      'port': 3306,
      'database': 'test'
      }

engine = create_engine('mysql+pymysql://%(user)s:%(password)s@%(host)s:%(port)d/%(database)s?charset=utf8' % db_info, encoding='utf-8')
# 直接使用下一種形式也可以
# engine = create_engine('mysql+pymysql://root:123456@localhost:3306/test')

# 讀取本地CSV文件
df = pd.read_csv("C:/Users/fuqia/Desktop/example.csv", sep=',')
print(df)
# 將新建的DataFrame儲存為MySQL中的數(shù)據(jù)表，不儲存index列(index=False)
# if_exists:
# 1.fail:如果表存在，啥也不做
# 2.replace:如果表存在，刪了表，再建立一個新表，把數(shù)據(jù)插入
# 3.append:如果表存在，把數(shù)據(jù)插入，如果表不存在創(chuàng)建一個表??！
pd.io.sql.to_sql(df, 'example', con=engine, index=False, if_exists='replace')
# df.to_sql('example', con=engine, if_exists='replace')這種形式也可以
print("Write to MySQL successfully!")

from sqlalchemy import create_engine 
 
 engine = create_engine('mysql+pymysql://root:123456@localhost:3306/test')
sql = "DROP TABLE IF EXISTS example"
engine.execute(sql)

import pymysql
from sqlalchemy import create_engine

conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123456', db='test')
# engine = create_engine('mysql+pymysql://root:123456@localhost:3306/test')
sql = "DROP TABLE IF EXISTS test_input"
cursor = conn.cursor()
cursor.execute(sql)