修订表名查询

.idea/modules.xml

@@ -2,6 +2,7 @@
 <project version="4">
   <component name="ProjectModuleManager">
     <modules>
+      <module fileurl="file://$USER_HOME$/PycharmProjects/pythonProject/.idea/pythonProject.iml" filepath="$USER_HOME$/PycharmProjects/pythonProject/.idea/pythonProject.iml" />
       <module fileurl="file://$USER_HOME$/Library/CloudStorage/OneDrive-个人/个人/python_stocks/quantify01/.idea/quantify01.iml" filepath="$USER_HOME$/Library/CloudStorage/OneDrive-个人/个人/python_stocks/quantify01/.idea/quantify01.iml" />
       <module fileurl="file://$PROJECT_DIR$/.idea/stock.iml" filepath="$PROJECT_DIR$/.idea/stock.iml" />
       <module fileurl="file://$USER_HOME$/Library/CloudStorage/OneDrive-个人/个人/python_stocks/stocks_to_sql/.idea/stocks_to_sql.iml" filepath="$USER_HOME$/Library/CloudStorage/OneDrive-个人/个人/python_stocks/stocks_to_sql/.idea/stocks_to_sql.iml" />

.idea/stock.iml

@@ -6,5 +6,6 @@
     <orderEntry type="sourceFolder" forTests="false" />
     <orderEntry type="module" module-name="stocks_to_sql" />
     <orderEntry type="module" module-name="quantify01" />
+    <orderEntry type="module" module-name="pythonProject" />
   </component>
 </module>

hlfx.py

@@ -19,7 +19,7 @@ fre = '30m'
 
 cursor = db.cursor()
 # cursor.execute("select table_name from information_schema.tables where table_schema='qbh_hlfx_backup' and table_name like {}".format('\'%{}\''.format(fre)))
-cursor.execute('show tables like {}'.format('\'%{}\''.format(fre)))
+cursor.execute("show tables like '%%%s%%' "% fre)
 table_list = [tuple[0] for tuple in cursor.fetchall()]
 
 # print(table_list)

real_time_signal.py

@@ -21,7 +21,7 @@ engine2 = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/hlfx?c
 
 # 获取所有表名——确定计算范围
 cursor = db.cursor()
-cursor.execute('show tables like {}'.format('\'%{}\''.format(fre)))
+cursor.execute("show tables like '%%%s%%' "% fre)
 # stocks = [tuple[0] for tuple in cursor.fetchall()]
 stocks = list(get_all_securities(['stock'], date='2021-12-31').index)
 stocks = ['301058.XSHE']

real_time_signal_30m.py

@@ -21,7 +21,7 @@ engine2 = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/hlfx?c
 
 # 获取所有表名——确定计算范围
 cursor = db.cursor()
-cursor.execute('show tables like {}'.format('\'%{}\''.format(fre)))
+cursor.execute("show tables like '%%%s%%' "% fre)
 # stocks = [tuple[0] for tuple in cursor.fetchall()]
 stocks = list(get_all_securities(['stock'], date='2021-12-31').index)
 # stocks = stocks[0:500]

updata_qbh_hlfx.py

@@ -24,7 +24,7 @@ db = pymysql.connect(host='localhost',
 engine2 = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/hlfx?charset=utf8')
 engine = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/stocks?charset=utf8')
 cursor = db.cursor()
-cursor.execute('show tables like {}'.format('\'%{}\''.format(fre)))
+cursor.execute("show tables like '%%%s%%' "% fre)
 table_list = [tuple[0] for tuple in cursor.fetchall()]
 
 print(table_list)

update_data_tosql.py

@@ -10,7 +10,7 @@ engine = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/stocks?
 fre = '30m'
 
 print('ready to write to mysql')
-for stock in stocks[0:80]:
+for stock in stocks:
     print(stock)
     try:
         index_len = pd.read_sql_table('stk%s_%s' % (stock, fre), con=engine).iloc[-1, 0]