diff --git a/transAllData.py b/transAllData.py index a2d71b1..e1d2213 100644 --- a/transAllData.py +++ b/transAllData.py @@ -32,7 +32,7 @@ def main() : db_b_conn = pymysql.connect(**db_b_config) db_b_cursor = db_b_conn.cursor() - trade_date = '2023-08-11' + trade_date = '2023-08-14' #传输ry库其他数据 trd.toTransRyOhterData(db_a_conn,db_a_cursor,db_b_conn,db_b_cursor,trade_date) diff --git a/transferOhterRyData_python.py b/transferOhterRyData_python.py index f2989ee..cc0222e 100644 --- a/transferOhterRyData_python.py +++ b/transferOhterRyData_python.py @@ -329,7 +329,7 @@ def toTransStocksNewRecord(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date) if code in mojin_stocksNeRecord_map: continue else: - sql_insert = f"INSERT INTO stocks_new_record (ode,trade_day,isHigh,isLow) VALUES ( %s, %s, %s, %s)" + sql_insert = f"INSERT INTO stocks_new_record (code,trade_day,isHigh,isLow) VALUES ( %s, %s, %s, %s)" db_mojin_cursor.execute(sql_insert, (code,trade_day,isHigh,isLow)) hasInsertData = True if hasInsertData: @@ -370,7 +370,7 @@ def toTransStocksTmp(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date): if code in mojin_stocksTmp_map: continue else: - sql_insert = f"INSERT INTO stocks_new_record (code,trade_day,differrange3,differrange5,differrange15,differrange30) VALUES ( %s, %s, %s, %s,%s,%s)" + sql_insert = f"INSERT INTO stocks_tmp (code,trade_day,differrange3,differrange5,differrange15,differrange30) VALUES ( %s, %s, %s, %s,%s,%s)" db_mojin_cursor.execute(sql_insert, (code,trade_day,differrange3,differrange5,differrange15,differrange30)) hasInsertData = True if hasInsertData: