m_load_update_data.py 文件源码

def get_all_stick_inf(self):
        try:
            df = ts.get_stock_basics()
        except Exception as e:
            print('Err:',e)
            return

        cnt = 0;
        print('begin====== ??????? ????????????? ===============')
        while cnt < 3:
            try:
                self.cur.execute("select count(*) from t_all_stickcode; ")
                rs = self.cur.fetchall()
                print('rs:',rs[0][0],len(df))
                if rs[0][0] == len(df) :
                    break
                print('delete')
                self.cur.execute("delete from t_all_stickcode; ")
                self.sqlconn.commit()
                print('insert')
                df.to_sql('t_all_stickcode',self.engine,if_exists='append')
            except:
                print('err')
                df.to_sql('t_all_stickcode',self.engine,if_exists='append')
            cnt += 1;

        #df = ts.get_
        self.sqlconn.commit()
        return