python3 連接mysql的模塊mysql-connector-python，純python驅動器，不再依賴C語言的庫，並且兼容python2和python3.
說明
本文的代碼允許環境 python3.6
安裝
pip install mysql-connector-python
連接數據庫
#coding:utf-8
import mysql.connector import time try: #連接數據庫 con=mysql.connector.connect(host='localhost',port=3306,user='root', password='root',database='test',charset='utf8') print(con.connection_id) time.sleep(5) #斷開 con.close() except mysql.connector.Error as e: print(e)
新增操作
一、通過字符串新增
#coding:utf-8
from mysql import connector #連接 try: #配置信息 config={ 'host':'localhost', 'port':3306, 'user':'root', 'password':'root', 'database':'test', 'charset':'utf8' } #連接數據庫 # con=mysql.connector.connect(host='localhost',port=3306,user='root', # password='root',database='test',charset='utf8') con=connector.connect(**config) cursor=con.cursor() #通過字符串直接插入 insert1=("insert into user(name,age) values('Tom',20)") cursor.execute(insert1) #提交 con.commit() # 自增id print(cursor.lastrowid) #關閉 cursor.close() con.close() except connector.Error as e: print(e)
二、通過元祖新增
#coding:utf-8
from mysql import connector #連接 try: #配置信息 config={ 'host':'localhost', 'port':3306, 'user':'root', 'password':'root', 'database':'test', 'charset':'utf8' } #連接數據庫 # con=mysql.connector.connect(host='localhost',port=3306,user='root', # password='root',database='test',charset='utf8') con=connector.connect(**config) cursor=con.cursor() #通過tuple方式插入（利用%s作為占位符） insert2=("insert into user(name,age) values(%s,%s)") data=('Tom',20) cursor.execute(insert2,data) #提交 con.commit() # 自增id print(cursor.lastrowid) #關閉 cursor.close() con.close() except connector.Error as e: print(e)
三、通過字典新增
#coding:utf-8
from mysql import connector #連接 try: #配置信息 config={ 'host':'localhost', 'port':3306, 'user':'root', 'password':'root', 'database':'test', 'charset':'utf8' } #連接數據庫 # con=mysql.connector.connect(host='localhost',port=3306,user='root', # password='root',database='test',charset='utf8') con=connector.connect(**config) cursor=con.cursor() #通過dict方式插入（利用%(字段)s作為占位符） insert3=("insert into user(name,age) values(%(name)s,%(age)s)") data={ 'name':'Tom', 'age':21 } cursor.execute(insert3,data) #提交 con.commit() # 自增id print(cursor.lastrowid) #關閉 cursor.close() con.close() except connector.Error as e: print(e)
四、批量新增
這是以元祖新增為例子，也可以用字典的方式的哦
#coding:utf-8
from mysql import connector #連接 try: #配置信息 config={ 'host':'localhost', 'port':3306, 'user':'root', 'password':'root', 'database':'test', 'charset':'utf8' } #連接數據庫 # con=mysql.connector.connect(host='localhost',port=3306,user='root', # password='root',database='test',charset='utf8') con=connector.connect(**config) cursor=con.cursor() #批量插入 insertmany=("insert into user(name,age) values(%s,%s)") data=[ ('Tom1',20), ('Tom2',21), ('Tom3',22) ] cursor.executemany(insertmany,data) #提交 con.commit() #關閉 cursor.close() con.close() except connector.Error as e: print(e)
刪除操作
與新增語法相似
#coding:utf-8
from mysql import connector try: #配置信息 config={ 'host':'localhost', 'port':3306, 'user':'root', 'password':'root', 'database':'test', 'charset':'utf8' } #連接數據庫 con=connector.connect(**config) cursor=con.cursor() #直接通過字符串方式 delete1=("delete from user where name='Tom'") cursor.execute(delete1) #通過tuple方式 delete2=("delete from user where name=%s and age=%s") data=('Tom',20) cursor.execute(delete2,data) #通過dict方式 delete3=("delete from user where name=%(name)s and age=%(age)s") data={ 'name':'Tom', 'age':20 } cursor.execute(delete3,data) #提交 con.commit() #關閉 cursor.close() con.close except connector.Error as e: print(e)
更新操作
語法相似，字符串、元祖、字典的方式
#coding:utf-8
from mysql import connector try: #配置信息 config={ 'host':'localhost', 'port':3306, 'user':'root', 'password':'root', 'database':'test', 'charset':'utf8' } #連接數據庫 con=connector.connect(**config) cursor=con.cursor() #通過字符串方式直接更新 update1=("update user set name='Tom1',age=20 where Id=81") cursor.execute(update1) #通過tuple方式 update2=("update user set name=%s,age=%s where Id=%s") data=('Tom2',21,81) cursor.execute(update2,data) #通過dict方式 update3=("update user set name=%(name)s,age=%(age)s where Id=%(Id)s") data={ 'name':'Tom3', 'age':29, 'Id':81 } cursor.execute(update3,data) #提交 con.commit() #關閉 cursor.close() con.close() except connector.Error as e: print(e)
查詢操作
也是三種查詢方式
#coding:utf-8
from mysql import connector try: #配置信息 config={ 'host':'localhost', 'port':3306, 'user':'root', 'password':'root', 'database':'test', 'charset':'utf8' } #連接 con=connector.connect(**config) cursor=con.cursor() #利用字符串方式查詢 query1=("select Id,name,age from user where Id>10") cursor.execute(query1) #取出字段名稱集合 columns=cursor.column_names #取出全部數據 result=cursor.fetchall() print '數據表字段名稱：{0}'.format(columns) print '查詢結果：{0}'.format(result) #關閉 cursor.close() con.close() except connector.Error as e: print(e)
上面的例子返回的是元祖的方式，如果需要返回字典，需要加上這段cursor=con.cursor(cursor_class=connector.cursor.MySQLCursorDict)
例如：
#coding:utf-8
from mysql import connector __author__ = 'kikay' try: #配置信息 config={ 'host':'localhost', 'port':3306, 'user':'root', 'password':'root', 'database':'test', 'charset':'utf8' } #連接 con=connector.connect(**config) cursor=con.cursor(cursor_class=connector.cursor.MySQLCursorDict) #利用字符串方式查詢 query1=("select Id,name,age from user where Id>10") cursor.execute(query1) #取出字段名稱集合 columns=cursor.column_names #取出全部數據 result=cursor.fetchall() print '數據表字段名稱：{0}'.format(columns) print '查詢結果：{0}'.format(result) #關閉 cursor.close() con.close() except connector.Error as e: print(e)