File tree Expand file tree Collapse file tree 1 file changed +14
-4
lines changed
Expand file tree Collapse file tree 1 file changed +14
-4
lines changed Original file line number Diff line number Diff line change 11import snowflake .connector
22import os
3+ import sys
34
45SNOWFLAKE_ACCOUNT = os .environ ['SF_ACCOUNT' ]
56SNOWFLAKE_USERNAME = os .environ ['SF_USERNAME' ]
3435query = "SELECT TABLE_NAME FROM WINE_DB.INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME LIKE '%%GD%%';"
3536cur .execute (query )
3637all_results = cur .fetchall ()
37- table_names = []
38+ table_names = "("
39+ count = 0
40+
41+ if len (all_results ) == 0 :
42+ print ("golden data tables not created" )
43+ sys .exit ()
44+
3845
3946for names in all_results :
40- table_names .append (names [0 ])
47+ table_names += names
48+ if (count != 0 and count != len (all_results - 1 )):
49+ table_names += ", "
50+ table_names += ")"
4151
42- print ("table names: " + str ( table_names ) )
52+ print ("table names: " + table_names )
4353
4454for table in table_names :
45- query = "INSERT INTO " + table + tuple ( column_names ) + " SELECT * FROM WHITE_WINE_QUALITY;"
55+ query = "INSERT INTO " + table + column_names + " SELECT * FROM WHITE_WINE_QUALITY;"
4656 print (query )
4757 cur .execute (query )
4858 query = "UPDATE " + table + " SET GD_MD5_VALUE=MD5(TO_VARCHAR(ARRAY_CONSTRUCT(" + column_names + ")));"
You can’t perform that action at this time.
0 commit comments