智能控制器,宜兴市人力资源和社会保障局,女子职业技术学院
def __executesql__(self,sql):
self.__connect__()
self.__executor = self.__conn.cursor(cursorclass = mysqldb.cursors.dictcursor)
self.__executor.execute('use '+self.__database) #切换数据库
return self.__executor.execute(sql)
def executequeryforobject(self , sql):
self.__executesql__(sql)
return self.__executor.fetchone()
'''
返回key=value 字典
'''
def executequeryall(self , sql):
self.__executesql__(sql)
return self.__executor.fetchall()
def executeupdate(self ,sql='' , isautocommit=false):
c = self.__executesql__(sql)
if isautocommit == true:
self.commit() #提交事务
return c
'''
#提交事务
'''
def commit(self):
self.__conn.commit() #提交事务
'''
#关闭数据库,释放资源
'''
def closedb(self):
if not self.__conn is none:
print 'close db...'
self.__conn.commit() #提交事务
self.__conn.close()
def print_parameters(self):
print self.__user
print self.__passwd
print self.__host
print self.__port
'''
if __name__ == '__main__':
db=db(database='tb2013')
#db.print_parameters()
#db.executesql('select * from tb_user')
print db.executequeryforobject('select count(*) as count from tb_user')
_rows = db.executequeryall('select userid,nick from tb_user limit 10');
print _rows
for row in _rows:
print row
print 'nick:%s' % str(row['nick'])
print db.executeupdate(sql='update tb_user set nick=\'test\' where userid=95084397',isautocommit=true)
db.closedb()
'''
如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复
Python爬虫:Request Payload和Form Data的简单区别说明
浅谈Python中threading join和setDaemon用法及区别说明
Python3-异步进程回调函数(callback())介绍
python继承threading.Thread实现有返回值的子类实例
Python中使用threading.Event协调线程的运行详解
网友评论