@classmethod
def query(cls,host,user,password,database,port,sql):
conn = cls.get_conn(host,user,password,database,port)
if conn is not None:
cursor = conn.cursor()
cursor.execute(sql)
result = cursor.fetchall()
cursor.close()
conn.close()
return result
else:
return None
@classmethod
def update(cls,host,user,password,database,port,sql):
conn = cls.get_conn(host, user, password, database, port)
if conn is not None:
cursor = conn.cursor()
try:
cursor.execute(sql)
conn.commit()
except Exception as e:
conn.rollback()
finally:
cursor.close()
conn.close()