# -*- coding: UTF-8 -*-
#安装MYSQL DB for python
import MySQLdb as mdb
con = None
try:#连接mysql的方法：connect(host='localhost',user='root',passwd='root',db='test',port=3306)con = mdb.connect('localhost', 'root','root', 'test');#所有的查询，都在连接con的一个模块cursor上面运行的cur = con.cursor()#执行一个查询cur.execute("SELECT VERSION()")#取得上个查询的结果，是单个结果data = cur.fetchone()print "Database version : %s " % data
finally:if con:#无论如何，连接记得关闭con.close()

执行结果：

# -*- coding: UTF-8 -*-
import MySQLdb as mdb
import sys
#将con设定为全局连接
con = mdb.connect('localhost', 'root', 'root', 'test');
with con:#获取连接的cursor，只有获取了cursor，我们才能进行各种操作cur = con.cursor()#创建一个数据表 writers(id,name)cur.execute("CREATE TABLE IF NOT EXISTS \Writers(Id INT PRIMARY KEY AUTO_INCREMENT, Name VARCHAR(25))")#以下插入了5条数据cur.execute("INSERT INTO Writers(Name) VALUES('Jack London')")cur.execute("INSERT INTO Writers(Name) VALUES('Honore de Balzac')")cur.execute("INSERT INTO Writers(Name) VALUES('Lion Feuchtwanger')")cur.execute("INSERT INTO Writers(Name) VALUES('Emile Zola')")cur.execute("INSERT INTO Writers(Name) VALUES('Truman Capote')")

 1 import MySQLdb
 2 conn = MySQLdb.connect(host='127.0.0.1',user='root',passwd='123456',db='test2',)
 3 cur = conn.cursor()
 4 sql = "insert into admin (name,addres) values (%s,%s)"
 5 params = ('zhang','san')
 6 #sql = "insert into table(key1,key2,key3) values (%s,%s,%s)"%(value1,value2,value3)
 7 temp=cur.execute(sql,params)
 8 conn.commit()
 9 recount = cur.execute('select *from admin')
10 rows = cur.fetchall()
11
12 cur.close()
13 conn.close()
14 for time in rows:
15  #print temp #查看影响条目
16  #print rows #查看数据库表内容
17  print time  

View Code

结果：

(1L, 'hejin', 'USA')
(2L, 'jctang', 'usa')
(5L, 'zhang', 'san')

# -*- coding: UTF-8 -*-
import MySQLdb as mdb
import sys
#连接mysql，获取连接的对象
con = mdb.connect('localhost', 'root', 'root', 'test');
with con:#仍然是，第一步要获取连接的cursor对象，用于执行查询cur = con.cursor()#类似于其他语言的query函数，execute是python中的执行查询函数cur.execute("SELECT * FROM Writers")#使用fetchall函数，将结果集（多维元组）存入rows里面rows = cur.fetchall()#依次遍历结果集，发现每个元素，就是表中的一条记录，用一个元组来显示for row in rows:print row

import MySQLdb as mdb
import sys
#获得mysql查询的链接对象
con = mdb.connect('localhost', 'root', '123456', 'test2')
with con:
#获取连接上的字典cursor，注意获取的方法，
#每一个cursor其实都是cursor的子类
cur = con.cursor(mdb.cursors.DictCursor)
#执行语句不变
cur.execute("select *from admin")
#获取数据方法不变
rows = cur.fetchall()
#遍历数据也不变（比上一个更直接一点）
for row in rows:
#这里，可以使用键值对的方法，由键名字来获取数据print '%s %s %s' %(row['id'],row['name'],row['addres'])

View Code

结果：

10 zhang san
11 zhang san
12 zhang san
13 zhang san
14 zhang san
15 zhang san

# -*- coding: UTF-8 -*-
import MySQLdb as mdb
import sys
#获取数据库的链接对象
con = mdb.connect('localhost', 'root', 'root', 'test')
with con:#获取普通的查询cursorcur = con.cursor()cur.execute("SELECT * FROM Writers")rows = cur.fetchall()#获取连接对象的描述信息desc = cur.descriptionprint 'cur.description:',desc#打印表头，就是字段名字print "%s %3s" % (desc[0][0], desc[1][0])for row in rows:#打印结果print "%2s %3s" % row

# -*- coding: UTF-8 -*-
import MySQLdb as mdb
import sys
con = mdb.connect('localhost', 'root', 'root', 'test')
with con:cur = con.cursor()#我们看到，这里可以通过写一个可以组装的sql语句来进行cur.execute("UPDATE Writers SET Name = %s WHERE Id = %s",("Guy de Maupasant", "4"))#使用cur.rowcount获取影响了多少行print "Number of rows updated: %d" % cur.rowcount

import MySQLdb
conn = MySQLdb.connect(host='127.0.0.1',user='root',passwd='123456',db='test2',)
cur = conn.cursor()
sql = "delete from admin where id=%s"
params = ('2')
cur.execute(sql,params)
conn.commit()
cur.close()
conn.close()

View Code