|
@@ -128,9 +128,9 @@ def create(config_file: str = "database/CARLO.json"):
|
|
|
table_client = f'{current_table["dest"]}_{client_db}'
|
|
|
select_query = select_queries[table_client]
|
|
|
if "WHERE" in select_query:
|
|
|
- select_query = select_query.replace("WHERE", "WHERE T1.[timestamp] > %TS% AND")
|
|
|
+ select_query = select_query.replace("WHERE", "WHERE T1.[timestamp] > convert(timestamp, '%TS%') AND")
|
|
|
elif "ORDER" in select_query:
|
|
|
- select_query = select_query.replace("ORDER", "WHERE T1.[timestamp] > %TS% ORDER")
|
|
|
+ select_query = select_query.replace("ORDER", "WHERE T1.[timestamp] > convert(timestamp, '%TS%') ORDER")
|
|
|
else:
|
|
|
print("Dont know where to put WHERE")
|
|
|
f.write(f' call sql_timestamp.bat "{table_client}" "{full_table_name}" "{client_db}"\n')
|