一、相關代碼
數據庫配置類 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")
新聞熱點