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