diff --git a/transferIndustryData_python.py b/transferIndustryData_python.py index f9c86a9..8e6e91f 100644 --- a/transferIndustryData_python.py +++ b/transferIndustryData_python.py @@ -1,42 +1,42 @@ #导入指数数据 import pymysql -# 数据库A的连接信息;NAS数据库 -# db_a_config = { -# 'host': '192.168.0.222', -# 'user': 'root', -# 'password': '1qazse42W3', -# 'db': 'ry', -# 'charset': 'utf8mb4', -# } - -# # 数据库B的连接信息;NAS数据库 -# db_b_config = { -# 'host': '192.168.0.222', -# 'user': 'root', -# 'password': '1qazse42W3', -# 'db': 'mojin', -# 'charset': 'utf8mb4', -# } - -# 数据库A的连接信息;腾讯云数据库 +#数据库A的连接信息;NAS数据库 db_a_config = { - 'host': '124.223.98.178', + 'host': '192.168.0.222', 'user': 'root', 'password': '1qazse42W3', 'db': 'ry', 'charset': 'utf8mb4', } -# 数据库B的连接信息;腾讯云数据库 +# 数据库B的连接信息;NAS数据库 db_b_config = { - 'host': '124.223.98.178', + 'host': '192.168.0.222', 'user': 'root', 'password': '1qazse42W3', 'db': 'mojin', 'charset': 'utf8mb4', } +# # 数据库A的连接信息;腾讯云数据库 +# db_a_config = { +# 'host': '124.223.98.178', +# 'user': 'root', +# 'password': '1qazse42W3', +# 'db': 'ry', +# 'charset': 'utf8mb4', +# } + +# # 数据库B的连接信息;腾讯云数据库 +# db_b_config = { +# 'host': '124.223.98.178', +# 'user': 'root', +# 'password': '1qazse42W3', +# 'db': 'mojin', +# 'charset': 'utf8mb4', +# } + try: # 连接数据库A db_a_conn = pymysql.connect(**db_a_config) @@ -58,7 +58,7 @@ try: trading_date,week,trade = row print('start transfer ',trading_date , ' data.') #查询日交易数据 - sql_stock_query = 'select code,trade_day, open,close,high,low,differrange,volumn,amount,limitupnum,limitdownnum,suspendnum,risenum,fallnum,flatnum,componentnum,mv,pettm,pettm_mid,liqmv,rcnthigh,rcntlow from stock_index where trade_day = %s' + sql_stock_query = 'select code,name,trade_day, open,close,high,low,differrange,volume,amount,limitupnum,limitdownnum,suspendnum,risenum,fallnum,flatnum,componentnum,mv,pettm,pettm_mid,liqmv,rcnthigh,rcntlow from stock_index where trade_day = %s' db_a_cursor.execute(sql_stock_query,trading_date) datas = db_a_cursor.fetchall() sortIndex = 1 @@ -92,8 +92,8 @@ try: pe_ttm= pettm pe_center_ttm = pettm_mid # create_time = - sql_insert = f"INSERT INTO dong_cai_secondary_industry (business_date,sort,security_code,security_name,security_type,number_ingredients,opening_price,closing_price,volume,turnover,total_capitalization,free_capitalization,change_percentage,highest_price,lowest_price,rise_number,losses_number,flat_number,rise_stop_number,losses_stop_number,stop_number,recently_high,recently_low,pe_ttm,pe_center_ttm rise_losses_current_day,dong_cai_industry_index_level2,dong_cai_industry_index_level3,range_rise_losses20,range_rise_losses10,range_rise_losses60,initial_listing_date,number_days_available,volume,turnover,dong_cai_industry_index_code2,free_capitalization,average_volume_day20,total_institutional_positions,rise_stop,losses_stop) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)" - db_b_cursor.execute(sql_insert, (business_date,sort,security_code,security_name,security_type,number_ingredients,opening_price,closing_price,volume,turnover,total_capitalization,free_capitalization,change_percentage,highest_price,lowest_price,rise_number,losses_number,flat_number,rise_stop_number,losses_stop_number,stop_number,recently_high,recently_low,pe_ttm,pe_center_ttm rise_losses_current_day,dong_cai_industry_index_level2,dong_cai_industry_index_level3,range_rise_losses20,range_rise_losses10,range_rise_losses60,initial_listing_date,number_days_available,volume,turnover,dong_cai_industry_index_code2,free_capitalization,average_volume_day20,total_institutional_positions,rise_stop,losses_stop)) + sql_insert = f"INSERT INTO dong_cai_secondary_industry (business_date,sort,security_code,security_name,security_type,number_ingredients,opening_price,closing_price,volume,turnover,total_capitalization,free_capitalization,change_percentage,highest_price,lowest_price,rise_number,losses_number,flat_number,rise_stop_number,losses_stop_number,stop_number,recently_high,recently_low,pe_ttm,pe_center_ttm) VALUES ( %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s)" + db_b_cursor.execute(sql_insert, (business_date,sort,security_code,security_name,security_type,number_ingredients,opening_price,closing_price,volume,turnover,total_capitalization,free_capitalization,change_percentage,highest_price,lowest_price,rise_number,losses_number,flat_number,rise_stop_number,losses_stop_number,stop_number,recently_high,recently_low,pe_ttm,pe_center_ttm)) #提交数据到数据库B中 db_b_conn.commit() print('successed transfer ',trading_date , ' data.' )