一、相关代码
数据库配置类 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()