def execute_sql(sql):
connection, cursor = None, None
try:
connection = MySQLdb.connect(host=settings.inception_host,
user=settings.inception_user,
passwd=settings.inception_password,
port=settings.inception_port,
use_unicode=True, charset="utf8", connect_timeout=2)
cursor = connection.cursor()
cursor.execute(sql)
return cursor.fetchall()
finally:
if (cursor is not None):
cursor.close()
if (connection is not None):
connection.close()
return []
评论列表
文章目录