Method execute_sql

bmtools/tools/db_diag/utils/database.py:102–135

(self, sql)

    '''

    def execute_sql(self, sql):
        fail = 1
        self.conn = self.resetConn(timeout=2)
        cur = self.conn.cursor()
        i = 0
        cnt = 5 # retry times
        while fail == 1 and i < cnt:
            try:
                fail = 0
                print("========== start execution time:", time.time())
                cur.execute(sql)
            except BaseException:
                fail = 1
                time.sleep(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))

        cur.close()
        self.conn.close()

        print("========== finish time:", time.time())

        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: