mysql-11336335

lijm1522

def sql_init(self):　　conn = MySQLdb.connect("localhost", "root", "", "test", charset='utf8' )
　　cur = conn.cursor()
　　return conn, cur
　　@classmethod
　　def query_sql(cls, sql):
　　res = cls().sql_init()
　　conn = res[0]
　　cur = res[1]
　　try:
　　cur.execute(sql)
　　data = cur.fetchall()
　　except Exception:
　　data = None
　　print 'SQL ERROR!!'
　　conn.close()
　　return data
　　@classmethod
　　def insert_sql(cls, sql):
　　res = cls().sql_init()
　　conn = res[0]
　　cur = res[1]
　　try:
　　cur.execute(sql)
　　conn.commit()
　　result = True
　　except:
　　conn.rollback()
　　result = False
　　conn.close()
　　return result
　　@classmethod
　　def delete_sql(cls, sql):
　　res = cls().sql_init()
　　conn = res[0]
　　cur = res[1]
　　try:
　　cur.execute(sql)
　　conn.commit()
　　result = True
　　except:
　　conn.rollback()
　　result = False
　　conn.close()
　　return result
　　@classmethod
　　def update_sql(cls, sql):
　　res = cls().sql_init()
　　conn = res[0]
　　cur = res[1]
　　try:
　　cur.execute(sql)
　　conn.commit()
　　result = True
　　except:
　　conn.rollback()
　　result = False
　　conn.close()
　　return result
　　@classmethod
　　def do_mysql(cls, sql):
　　"""
　　其他任意的SQL语句，如创建表
　　"""
　　res = cls().sql_init()
　　conn = res[0]
　　cur = res[1]
　　try:
　　cur.execute(sql)
　　result = True
　　except:
　　result = False
　　conn.close()
　　return result