一、相关代码
数据库配置类 MysqlDBConn.py

复制代码 代码如下:

encoding=utf-8

'''
Created on 2012-11-12

Mysql Conn连接类
'''

import MySQLdb

class DBConn:

conn = None  

#建立和数据库系统的连接  
def connect(self):  
    self.conn = MySQLdb.connect(host="localhost",port=3306,user="house", passwd="house" ,db="house",charset="utf8")  

#获取操作游标  
def cursor(self):  
    try:  
        return self.conn.cursor()  
    except (AttributeError, MySQLdb.OperationalError):  
        self.connect()  
        return self.conn.cursor()  

def commit(self):  
    return self.conn.commit()  

#关闭连接  
def close(self):  
    return self.conn.close()  

MysqlDemo.py类

复制代码 代码如下:

encoding=utf-8

'''
Created on 2012-11-12

@author: Steven

Mysql操作Demo
Done:创建表，删除表，数据增、删、改，批量插入
'''
import MysqlDBConn

dbconn = MysqlDBConn.DBConn()

def process():

建立连接

dbconn.connect()  
#删除表  
dropTable()  
#创建表  
createTable()  
#批量插入数据  
insertDatas()  
#单条插入  
insertData()  
#更新数据  
updateData()  
#删除数据  
deleteData()  
#查询数据  
queryData()  
#释放连接  
dbconn.close()  

def insertDatas():
sql = "insert into lifeba_users(name, realname, age) values(%s, %s, %s)"
tmp = (('steven1', '测试1',26), ('steven2', '测试2',25))
executemany(sql, tmp)

def updateData():
sql = "update lifeba_users set realname = '%s' where name ='steven1'"%("测试1修改")
execute(sql)

def deleteData():
sql = "delete from lifeba_users where id=2"
execute(sql)

def queryData():
sql = "select * from lifeba_users"
rows = query(sql)
printResult(rows)

def insertData():
sql = "insert into lifeba_users(name, realname, age) values('%s', '%s', %s)"%("steven3","测试3","26")
print sql
execute(sql)

def executemany(sql, tmp):
'''插入多条数据'''
conn=dbconn.cursor()
conn.executemany(sql, tmp)

def execute(sql):
'''执行sql'''
conn=dbconn.cursor()
conn.execute(sql)

def query(sql):
'''查询sql'''
conn=dbconn.cursor()
conn.execute(sql)
rows = conn.fetchmany(10)
return rows

def createTable():
'''创建表'''
conn=dbconn.cursor()
conn.execute('''
CREATE TABLE lifeba_users (
ID int(11) NOT NULL auto_increment,
name varchar(50) default NULL,
realName varchar(50) default NULL,
age int(11) default NULL,
PRIMARY KEY (ID)
) ENGINE=MyISAM DEFAULT CHARSET=utf8;
''')

dbconn.commit()

def dropTable():
'''删除表'''
conn=dbconn.cursor()
conn.execute('''
DROP TABLE IF EXISTS lifeba_users
''')

dbconn.commit()

def printResult(rows):
for row in rows:
for i in range(0,len(row)):#遍历数组
print row[i], #加, 不换行打印
print ''

if name == 'main':

process()