Method execute_sql

bmtools/tools/database/utils/database.py:102–125

(self, sql)

    '''

    def execute_sql(self, sql):
        fail = 1
        self.conn = self.resetConn()
        cur = self.conn.cursor()
        i = 0
        cnt = 3 # retry times
        while fail == 1 and i < cnt:
            try:
                fail = 0
                cur.execute(sql)
            except BaseException:
                fail = 1
            res = []
            if fail == 0:
                res = cur.fetchall()
            i = i + 1
        logging.debug('database {}, return flag {}, execute sql {}\n'.format(self.args.dbname, 1 - fail, sql))
        if fail == 1:
            # raise RuntimeError("Database query failed")
            print("SQL Execution Fatal!!")
            return 0, ''
        elif fail == 0:
            # print("SQL Execution Succeed!!")
            return 1, res

    def pgsql_results(self, sql):
        try: