在Python中，通過pymysql模塊，編寫簡短的腳本，即方便快捷地控制MySQL數(shù)據(jù)庫

一、連接數(shù)據(jù)庫

使用的函數(shù)：pymysql.connect

語法：db=pymysql.connect(host=’localhost’,user=’root’,port=3306,password=’Your password’,db=’database_name’)

參數(shù)說明：host：MySQL服務器地址 user：用戶名 password：MySQL登錄密碼 port：MySQL服務器端口號 db：需要連接的數(shù)據(jù)庫名通常服務器地址、用戶名、端口號都是上述的默認值

二、創(chuàng)建表

連接完數(shù)據(jù)庫后，我們需要使用db.cursor()獲取數(shù)據(jù)庫的操作游標

cur=db.cursor()

接著使用execute()語句即可執(zhí)行SQL語句.我們以創(chuàng)建學生成績表來進行演示：

import pymysqldb=pymysql.connect(host=’localhost’,user=’root’,password=’123456’,port=3306,db=’work1’)cur=db.cursor() ##獲取游標sql=’create table grade(id varchar(10),name varchar(10),age int,score int,class varchar(10))’cur.execute(sql)

打開Navicat查看表的情況如下：

學生成績表創(chuàng)建成功！

三、批量插入數(shù)據(jù)

創(chuàng)建完表后，接下來就是插入數(shù)據(jù)…而插入數(shù)據(jù)又可以分為兩種方式：按行插入和一次性，我們將依次介紹。

按行插入

id=[’101’,’102’,’103’,’104’,’105’,’106’,’107’,’108’,’109’,’110’]name=[’諸葛亮’,’劉備’,’周瑜’,’張飛’,’關羽’,’呂布’,’貂蟬’,’黃忠’,’馬超’,’典韋’]age=[28,30,27,26,28,28,24,26,23,18]score=[89,56,78,60,40,33,90,95,86,82]class_=[’一班’,’一班’,’一班’,’二班’,’二班’,’二班’,’三班’,’三班’,’三班’,’三班’]sql=’insert into grade values(%s,%s,%s,%s,%s)’for i in range(0,len(id)): cur.execute(sql,(id[i],name[i],age[i],score[i],class_[i]))db.commit() #一定要提交數(shù)據(jù)!!不然在數(shù)據(jù)庫中是沒有數(shù)據(jù)顯示的

一次性插入

data=((id[i],name[i],age[i],score[i],class_[i]) for i in range(0,len(id)))sql=’insert into grade values(%s,%s,%s,%s,%s)’cur.executemany(sql,data)db.commit()

插入數(shù)據(jù)后，表grade內(nèi)容如下：

四、更多

根據(jù)以上步驟，我們可知只要在execute語句中放入相應的SQL語句，即可實現(xiàn)對數(shù)據(jù)庫的各種操作。而在pymysql中實現(xiàn)查詢數(shù)據(jù)操作后，還需通過對游標對象使用.fetchall()方法來返回查詢結果。

查詢目標：篩選出各班的平均分并以降序進行排列

sql=’select class,avg(score) from grade group by class order by avg(score) desc’cur.execute(sql)rst=cur.fetchall()print(rst)

從輸出結果可知，元素是以tuple的方式進行儲存的。我們可以轉(zhuǎn)為更多規(guī)范的格式查看：

import pandas as pddf=pd.DataFrame(list(rst),columns=[’班級’,’平均分’])df

完成各項操作后，不要忘記斷開與數(shù)據(jù)庫的連接：

db.close()

以上就是本次分享的全部內(nèi)容~

附錄：python MySQL 批量插入

在現(xiàn)實生活中，經(jīng)常會使用到Python 將信息清洗完后插入數(shù)據(jù)庫，但一條條插入勢必速度效率跟不上，此時將需要使用批量插入的思維。

# coding:utf-8import pymysql # 打開數(shù)據(jù)庫連接db = pymysql.connect(host=’localhost’, port=3306, user=’username’, passwd=’password’, db=’database_name’, charset=’utf8’) # 使用cursor()方法獲取操作游標cursor = db.cursor() # SQL 插入語句sql = 'INSERT INTO EMPLOYEE(FIRST_NAME, AGE, SEX) VALUES (%s,%s,%s)'# 一個tuple或者listT = ((’xiaoming’, 31, ’boy’), (’hong’, 22, ’girl’), (’wang’, 90, ’man’)) try: # 執(zhí)行sql語句 cursor.executemany(sql, T) # 提交到數(shù)據(jù)庫執(zhí)行 db.commit()except : # 如果發(fā)生錯誤則回滾 db.rollback()# 關閉游標cursor.close()# 關閉數(shù)據(jù)庫連接db.close()

到此這篇關于Python操控mysql批量插入數(shù)據(jù)的實現(xiàn)方法的文章就介紹到這了,更多相關Python mysql批量插入數(shù)據(jù)內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持好吧啦網(wǎng)！