From 92538f0819ffe09b5b8cfe1d98d80a1b03c1d32c Mon Sep 17 00:00:00 2001
From: Oleg Sheynin <osheynin@gmail.com>
Date: Fri, 6 Dec 2024 20:08:53 -0500
Subject: [PATCH] fix: prepare eqt simdata script

---
 release_version.txt                | 2 +-
 research/prepare_crypto_simdata.sh | 6 +++---
 research/prepare_eqt_simdata.sh    | 6 +++---
 3 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/release_version.txt b/release_version.txt
index faa6944..022fd7b 100644
--- a/release_version.txt
+++ b/release_version.txt
@@ -1 +1 @@
-1.9.2.F1,fix: prepare eqt simdata script
+1.9.2.F2,fix: prepare eqt simdata script
diff --git a/research/prepare_crypto_simdata.sh b/research/prepare_crypto_simdata.sh
index 72b3c67..eb6a899 100755
--- a/research/prepare_crypto_simdata.sh
+++ b/research/prepare_crypto_simdata.sh
@@ -152,7 +152,7 @@ sqlite3  ${ResultDbFile} <<EOF
 ATTACH '${SourceDbFile}' AS source_db;
 BEGIN;
 INSERT OR IGNORE INTO md_trades SELECT
-	datetime(exchange_ts_ns / 1000000000, 'unixepoch') || '.' ||  printf('%06d', (exchange_ts_ns % 1000000000) / 1000)  as tstmp,
+	datetime(exchange_ts_ns / 1000000000, 'unixepoch') || '.' ||  printf('%06d', (exchange_ts_ns % 1000000000) / 1000)  as tstamp,
 	time as tstamp_ns,
 	exchange_id,
 	instrument_id,
@@ -168,7 +168,7 @@ COMMIT;
 BEGIN;
 INSERT OR IGNORE INTO md_trades
 SELECT
-	datetime(exchange_ts_ns / 1000000000, 'unixepoch') || '.' ||  printf('%06d', (exchange_ts_ns % 1000000000) / 1000)  as tstmp,
+	datetime(exchange_ts_ns / 1000000000, 'unixepoch') || '.' ||  printf('%06d', (exchange_ts_ns % 1000000000) / 1000)  as tstamp,
 	time as tstamp_ns,
 	exchange_id,
 	instrument_id,
@@ -189,7 +189,7 @@ sqlite3  ${ResultDbFile} <<EOF
 ATTACH '${SourceDbFile}' AS source_db;
 BEGIN;
 INSERT OR IGNORE INTO md_quotes SELECT
-	datetime(exchange_ts_ns / 1000000000, 'unixepoch') || '.' ||  printf('%06d', (exchange_ts_ns % 1000000000) / 1000)  as tstmp,
+	datetime(exchange_ts_ns / 1000000000, 'unixepoch') || '.' ||  printf('%06d', (exchange_ts_ns % 1000000000) / 1000)  as tstamp,
 	time as tstamp_ns,
 	exchange_id,
 	instrument_id,
diff --git a/research/prepare_eqt_simdata.sh b/research/prepare_eqt_simdata.sh
index 415cd89..52882de 100755
--- a/research/prepare_eqt_simdata.sh
+++ b/research/prepare_eqt_simdata.sh
@@ -168,7 +168,7 @@ for sym in ${Symbols[@]}; do
     sqlite3  ${ResultDbFile} <<EOF
 ATTACH '${src_qat_db}' AS source_db;
 BEGIN;
-INSERT INTO md_trades SELECT
+INSERT OR IGNORE INTO md_trades SELECT
 	tstamp,
 	tstamp_ns,
 	exchange_id,
@@ -183,7 +183,7 @@ FROM source_db.md_trades;
 COMMIT;
 
 BEGIN;
-INSERT INTO md_quotes SELECT
+INSERT OR IGNORE INTO md_quotes SELECT
 	tstamp,
 	tstamp_ns,
 	exchange_id,
@@ -202,7 +202,7 @@ EOF
     sqlite3  ${ResultDbFile} <<EOF
 ATTACH '${src_hbar_db}' AS source_db;
 BEGIN;
-INSERT INTO md_1min_bars SELECT
+INSERT OR IGNORE INTO md_1min_bars SELECT
 	tstamp,
 	tstamp_ns,
 	exchange_id,