#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()

#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()