python3 pandas 读取MySQL数据和插入的实例
python代码如下:
#-*-coding:utf-8-*-
importpandasaspd
importpymysql
importsys
fromsqlalchemyimportcreate_engine
defread_mysql_and_insert():
try:
conn=pymysql.connect(host='localhost',user='user1',password='123456',db='test',charset='utf8')
exceptpymysql.err.OperationalErrorase:
print('Erroris'+str(e))
sys.exit()
try:
engine=create_engine('mysql+pymysql://user1:123456@localhost:3306/test')
exceptsqlalchemy.exc.OperationalErrorase:
print('Erroris'+str(e))
sys.exit()
exceptsqlalchemy.exc.InternalErrorase:
print('Erroris'+str(e))
sys.exit()
try:
sql='select*fromsum_case'
df=pd.read_sql(sql,con=conn)
exceptpymysql.err.ProgrammingErrorase:
print('Erroris'+str(e))
sys.exit()
print(df.head())
df.to_sql(name='sum_case_1',con=engine,if_exists='append',index=False)
conn.close()
print('ok')
if__name__=='__main__':
df=read_mysql_and_insert()
另外需要注意的还有。
1)test数据库里有两个表,建表语句如下:
CREATETABLE`sum_case`( `type_id`tinyint(2)DEFAULTNULL, `type_name`varchar(5)DEFAULTNULL, KEY`b`(`type_name`) )ENGINE=InnoDBDEFAULTCHARSET=utf8;
CREATETABLE`sum_case_1`( `type_id`tinyint(2)DEFAULTNULL, `type_name`varchar(5)DEFAULTNULL, KEY`b`(`type_name`) )ENGINE=InnoDBDEFAULTCHARSET=utf8;
插入初始数据
insertintosum_case(type_id,type_name)values(1,'a'),(2,'b'),(3,'c')
2)创建user1用户
grantselect,update,insertontest.*to'user1'@'localhost'identifiedby'123456'
以上这篇python3pandas读取MySQL数据和插入的实例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持毛票票。
热门推荐
10 毛笔哥哥结婚祝福语简短
11 向国庆送祝福语简短
12 建队节祝福语简短
13 朋友喜得外孙简短祝福语
14 小店营业的祝福语简短
15 餐饮生日祝福语简短独特
16 鲜花英语祝福语卡片简短
17 男朋友暴富祝福语简短
18 婶婶拜年祝福语大全简短