本文實例講述了Python實現將數據框數據寫入mongodb及mysql數據庫的方法。分享給大家供大家參考,具體如下:
主要內容:
1、數據框數據寫入mongdb方法
2、數據框數據寫入mysql方法
為了以后不重復造輪子,這里總結下,如何把數據框數據寫入mysql和mongodb的方法記錄下來,省得翻來翻去。下面記錄的都是精華。
寫入mongodb代碼片段(使用pymongo庫):
##########################寫入mongodb 數據庫#################################################python操作mongodb數據庫from pymongo import MongoClientcon=MongoClient() ##連接客戶端db = con.Class ##創建數據庫post=db.Classdata ##創建集合##插入數據(df是數據框)##循環寫入(以字典的方式一條一條插入)for i in range(0,len(df)): u=dict(Class =df.iloc[i,0], Course =df.iloc[i,1],Title=df.iloc[i,7],Section=df.iloc[i,5],Type=df.iloc[i,8], / Days=df.iloc[i,2],Time=df.iloc[i,6],Room=df.iloc[i,4],Location=df.iloc[i,3],instructors=df.iloc[i,9],status=df.iloc[i,10]) print u post.insert(u)
寫入mysql代碼片段(使用pymysql庫):
##############################寫入mysql數據庫#################################import pymysql## 加上字符集參數,防止中文亂碼dbconn=pymysql.connect( host="127.0.0.1", database="cgjr", user="root", password="12345", port=3306, charset='utf8' )# 執行sql語句try: with dbconn.cursor() as cursor: # 執行sql語句,插入記錄 sql = 'INSERT INTO t_tao_info (num, price, city, shop_name, title,number,link,sale) VALUES (%s, %s, %s, %s, %s,%s,%s,%s)' for i in range(0,len(data)): print "正在插入數據:" + str(i) cursor.execute(sql, (data.iloc[i,0], data.iloc[i,1], data.iloc[i,2],data.iloc[i,3],data.iloc[i,4],data.iloc[i,5],data.iloc[i,6],data.iloc[i,7])) # 沒有設置默認自動提交,需要主動提交,以保存所執行的語句 dbconn.commit()except dbconn.Error, e: print "Error %d: %s" % (e.args[0], e.args[1]) sys.exit(1)finally: dbconn.close() print ('數據已插入,插入數據庫成功!')希望本文所述對大家Python程序設計有所幫助。
新聞熱點
疑難解答