cursor.execute() 操作数据库 这里写sql语句commit() 写入数据库cursor.close() 关闭这次操作,或者说终止self.conn.close() 关闭连接数据库,conn 是自定义的方法,看下面
class DB(): def __init__(self): # self.DB_HOST = DB_HOST # self.DB_PORT = DB_PORT # self.DB_USER = DB_USER # self.DB_PWD = DB_PWD # self.DB_NAME = DB_NAME self.conn = self.getConnection() def getConnection(self): return MySQLdb.Connect( host=‘127.0.0.1‘, #设置MYSQL地址 port=3306, #设置端口号 user=‘root‘, #设置用户名 passwd=‘root‘, #设置密码 db=‘mydb‘, #数据库名 charset=‘utf8‘ #设置编码 ) def query(self, sqlString): cursor=self.conn.cursor() cursor.execute(sqlString) returnData=cursor.fetchall() cursor.close() self.conn.close() return returnData def update(self, sqlString): cursor=self.conn.cursor() cursor.execute(sqlString) self.conn.commit() cursor.close() self.conn.close() if __name__=="__main__": db=DB() print db.query("show tables;")
可以自己添加常用的方法
时间: 2024-10-16 16:24:21