python的mysql模块_python使用MySQLdb模块连接MySQL
1.安裝驅動
目前有兩個MySQL的驅動，我們可以選擇其中一個進行安裝：
MySQL-python：是封裝了MySQL C驅動的Python驅動；mysql-connector-python：是MySQL官方的純Python驅動。
MySQL-python：
mysql-connector-python：
2.測試連接
這里使用MySQL-python驅動，即MySQLdb模塊。
test_connect.py
1 #!/usr/bin/python
2 #-*- coding: UTF-8 -*-
3
4 importMySQLdb5
6 #打開數據庫連接
7 db = MySQLdb.connect("localhost", "root", "123456", "test")8
9 #使用cursor()方法獲取操作游標
10 cursor =db.cursor()11
12 #使用execute方法執行SQL語句
13 cursor.execute("SELECT VERSION()")14
15 #使用 fetchone() 方法獲取一條數據庫。
16 data =cursor.fetchone()17
18 print "Database version : %s" %data19
20 #關閉數據庫連接
21 db.close()
測試結果如下，連接成功：
3.創建數據庫表
測試成功后，我們可以在python中直接為MySQL創建表：
create_table.py
1 #!/usr/bin/python
2 #-*- coding: UTF-8 -*-
3
4 importMySQLdb5
6 #打開數據庫連接
7 db = MySQLdb.connect("localhost", "root", "123456", "test")8
9 #使用cursor()方法獲取操作游標
10 cursor =db.cursor()11
12 #如果數據表已經存在使用 execute() 方法刪除表。
13 cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")14
15 #創建數據表SQL語句
16 sql = """CREATE TABLE EMPLOYEE (17 FIRST_NAME CHAR(20) NOT NULL,18 LAST_NAME CHAR(20),19 AGE INT,20 SEX CHAR(1),21 INCOME FLOAT )"""
22
23 cursor.execute(sql)24
25 #關閉數據庫連接
26 db.close()
建表結果 如下：
4.操作數據庫表
注意點：MySQL中的占位符為%s
operate_table.js
1 #!/usr/bin/python
2 #-*- coding: UTF-8 -*-
3
4 importMySQLdb5
6 #打開數據庫連接
7 db = MySQLdb.connect("localhost", "root", "123456", "test")8
9 #使用cursor()方法獲取操作游標
10 cursor =db.cursor()11
12 #SQL插入語句
13 ins_sql = """INSERT INTO EMPLOYEE(FIRST_NAME,14 LAST_NAME, AGE, SEX, INCOME)15 VALUES ('yu', 'jie', 20, 'M', 8000)"""
16
17 ins_sql1 = 'insert into employee(first_name, last_name, age, sex, income) values (%s, %s, %s, %s, %s)'
18
19 #SQL查詢語句
20 sel_sql = 'select * from employee where first_name = %s'
21
22 #SQL更新語句
23 upd_sql = 'update employee set age = %s where sex = %s'
24
25 #SQL刪除語句
26 del_sql = 'delete from employee where first_name = %s'
27
28 try:29 #執行sql語句
30 #insert
31 cursor.execute(ins_sql)32 cursor.execute(ins_sql1, ('xu', 'f', 20, 'M', 8000))33 #select
34 cursor.execute(sel_sql, ('yu',))35 values =cursor.fetchall()36 printvalues37 #update
38 cursor.execute(upd_sql, (24, 'M',))39 #delete
40 cursor.execute(del_sql, ('xu',))41
42 #提交到數據庫執行
43 db.commit()44 except:45 #發生錯誤時回滾
46 db.rollback()47
48 #關閉數據庫連接
49 db.close()
執行插入操作
執行查詢操作
執行更新操作
執行刪除操作
查詢語句的知識點：
Python查詢Mysql使用 fetchone() 方法獲取單條數據, 使用fetchall() 方法獲取多條數據。
fetchone():?該方法獲取下一個查詢結果集。結果集是一個對象
fetchall():接收全部的返回結果行.
例如該例子：
1 sel_sql = 'select * from employee where first_name = %s'
2 cursor.execute(sel_sql, ('yu',))3 results =cursor.fetchall()4 for row inresults:5 fname =row[0]6 lname = row[1]7 age = row[2]8 sex = row[3]9 income = row[4]10 print "fname=%s, lname=%s,age=%d,sex=%s,income=%d" % (fname, lname, age, sex, income)
結果如下:
總結
以上是生活随笔為你收集整理的python的mysql模块_python使用MySQLdb模块连接MySQL的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： java 计算两个日期之间的天数_Jav
- 下一篇： 分布式缓存redis 方案_Redis缓