From f5c29f7ddff0b3bd5f5b1f001d2a3cba8393b268 Mon Sep 17 00:00:00 2001
From: kjh2064 <kjh2064@gmail.com>
Date: Tue, 23 Jun 2026 00:19:49 +0900
Subject: [PATCH] =?UTF-8?q?=EB=8D=B0=EC=9D=B4=ED=84=B0=EB=B2=A0=EC=9D=B4?=
 =?UTF-8?q?=EC=8A=A4=20=EA=B5=AC=EC=A1=B0=20=EC=9E=AC=EC=84=A4=EA=B3=84:?=
 =?UTF-8?q?=20=EB=8B=A8=EC=9D=BC=20DB=20->=202=EA=B0=9C=20DB=20=EB=B6=84?=
 =?UTF-8?q?=EB=A6=AC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- kis_data_collection.db: KIS API 데이터 수집용 (data_feed 테이블)
- snapshot_admin.db: 성능/포지션 관리용 (performance, positions 테이블)

도구 경로 업데이트:
- auto_collect_t20_ledger_v1.py: kis_data_collection.db 사용
- measure_sector_flow_reliability_v1.py: kis_data_collection.db 사용
- validate_data_collection_v1.py: snapshot_admin.db 사용
- monitor_wbs_progress_v1.py: snapshot_admin.db 사용
- backup_recovery_manager_v1.py: 2개 DB 모두 백업

Co-Authored-By: Claude Haiku 4.5 <noreply@anthropic.com>
---
 src/quant_engine/data_feed.db               |   0
 src/quant_engine/kis_data_collection.db     | Bin 0 -> 24576 bytes
 src/quant_engine/snapshot_admin.db          | Bin 0 -> 36864 bytes
 tools/auto_collect_t20_ledger_v1.py         |   2 +-
 tools/backup_recovery_manager_v1.py         |  30 ++--
 tools/initialize_database.py                | 134 +++++++++++++++++
 tools/initialize_database_v2.py             | 154 ++++++++++++++++++++
 tools/initialize_databases.py               | 142 ++++++++++++++++++
 tools/measure_sector_flow_reliability_v1.py |   2 +-
 tools/monitor_wbs_progress_v1.py            |   2 +-
 tools/validate_data_collection_v1.py        |   2 +-
 11 files changed, 451 insertions(+), 17 deletions(-)
 delete mode 100644 src/quant_engine/data_feed.db
 create mode 100644 src/quant_engine/kis_data_collection.db
 create mode 100644 src/quant_engine/snapshot_admin.db
 create mode 100644 tools/initialize_database.py
 create mode 100644 tools/initialize_database_v2.py
 create mode 100644 tools/initialize_databases.py

diff --git a/src/quant_engine/data_feed.db b/src/quant_engine/data_feed.db
deleted file mode 100644
index e69de29..0000000
diff --git a/src/quant_engine/kis_data_collection.db b/src/quant_engine/kis_data_collection.db
new file mode 100644
index 0000000000000000000000000000000000000000..0b8d2b7bb44a98786d62a5d59d7f9743f370dce3
GIT binary patch
literal 24576
zcmeI%$!^*}00v+?ENN4s<i?RXf<mj(HpfbJlWB#@7Gk7uvL^NfSv5A;V-$`#w3oh3
z-=R;?m+7%%7K71H^^AT?hS`^I#+F9Dy=l3ElZPN2GeO>J=bEl-9|+MjEhq1yyw_I}
z&#xo$U*8Jv3+A*}-)pC5f3(7jpIYhn*{{-5iO3)>2tWV=5P$##AOHafK;XXwyuxw$
zeMNtI?)naYbe%`bVS-r?oI4ixML195JWVTJ^{HV}((GK*JF>4h>2^q3rMhXRX61|J
z%Zff%bS7N;D-Y9Jg@1IkESl|PnO5uNisg$7eJI$y$D^qyPa{^ur!n{K-DrN*gK2zh
zQL<CE>a#Jg%bK-sfqq=BRP-M&7j32kOan)mcG6^0Jt13{>qs+`ex`lW>o?m*e@MR2
zAu$GKx7m>`v}wnzXKJiwY0^8Bbh`2$v|8B`$rwqJpG~&CAmY{}bZt)LYVA~7uExIH
zY0P}#iuro5*_I;_O!hV`SUBQhZ}zg^NU)J=%*?if*cXb~Y<7<#GoDCqxl`p~(`>fs
zt!cD-<eGjm1}&3Z4f=hlYNa{Z$;`MH*m9~?!%;A$xtFTkF?;h`QHhCAnI1;2)p)0<
zFblj`uHkBDWXH#5BTIzL;ns|KF}IWhiMTC-P$6^A1ygi5=rnHzw7T3|b+W;&rF*Z|
zI4YKDMb{P&>FT*)u?QCNt=B^%-RsF&{#o+6IZb}flOJ3VfB*y_009U<00Izz00bZa
z0SFwbz)3POoc|AXc`+{tKmY;|fB*y_009U<00Izzz(N4u|FIDu009U<00Izz00bZa
z0SG_<0*5bv@BfFt#+V@lAOHafKmY;|fB*y_009U<0Ox<~0SG_<0uX=z1Rwwb2tWV=
K5P-np3;YFhwmiK6

literal 0
HcmV?d00001

diff --git a/src/quant_engine/snapshot_admin.db b/src/quant_engine/snapshot_admin.db
new file mode 100644
index 0000000000000000000000000000000000000000..7e9ba4e9d0623fcb06c413dcd57d410137dc40c1
GIT binary patch
literal 36864
zcmeI&-%is|9Ki8bU;~7J@nV-d2{$YdBN8t3$_dphjsc@f;Hs(JaWq0Z+B1bqV<hoW
zd;lN7SMVu(1TQ`N!@5F;Ug*v8ZPL;9oYT|u`Tb7E2^=0&eI>=)FgkOU*ff?6(=?t7
zVHn1Y-skjwy>-v0uTS((bL4p3;f(R<s<gQD%b1<}VJtpd`o8e<{=<cD^IzvT^#wKr
z5I_I{1Q0*~fqx+2%;pMPMf1`Rn)1SLUO4SA_LUz7v7>zNos5R(bK7;RY+IsI+p&&B
zR#mZA6T|AO{pKZ=&lk!o=Eny~4>Icg0vUMHk%5XXou;c~JGnZ0yQidZq)D&8q+~U@
zS?MH~FFe(~nwh;0MwT?q-`Qio`pw=3<NH*c&KHVB^J-DKZ%*ZK{KJEp!M*MBi>j6Q
zh}C&9viVI7Yg@0Zy4bH*cFXl+@!C2T<%Ydisp&iHS~Yt;)nf2ewsmBS+MeDU)v9RJ
zDhCZKT`_Rar07;lUq0`+f%4Vmb-(G-zGXY|Jt=hDtLaj&6Ggg)Gp^iyFC(`l9WRVk
zM)O#DDvUCo>4WrJC;GNtR;y0Cn<q_2uRQF^u61aaclX7P^|IWk+G4v=uWKS_STeLK
zZOr5fR?#$isSux^>J^ORc2w9qAIbNPVaRg(Q@O(0nt9v{>7Yq0&pT4*?2XguRCsR`
zu6FI$b<5J{X)|9~Suwxt_0uHDy^+Mfm%7(T!GB4XbV$c!NiwH;;TmRIy7A3y8B^`<
zl#5l^9-C3hjaqVi!s&OH>b*uXlIl;%+73>~WL&IV)rm81sh&J`&iqrUA34aHTYV4R
zyp>hzdS2KGbQa&5lachosQK49o(@8P?hoF(>mrF<DVYmf_i}~G%GkM(WTmq)l73VA
zi)Oa_WwY4*SnhtXA%Fk^2q1s}0tg_000IagfWV{*%y$RI`hQZx%eW9g009ILKmY**
z5I_I{1Q6&6@b`Zb0RaRMKmY**5I_I{1Q0*~fyozO{Xh9JW`qbJfB*srAb<b@2q1s}
z0toQ`|KtDy2q1s}0tg_000IagfB*uMFTnbL@?*>h5kLR|1Q0*~0R#|0009ILVEs=H
uAb<b@2q1s}0tg_000IagF!=(k|0h4jj1U0?5I_I{1Q0*~0R#|00D<4!ebxB@

literal 0
HcmV?d00001

diff --git a/tools/auto_collect_t20_ledger_v1.py b/tools/auto_collect_t20_ledger_v1.py
index 8108898..52015c4 100644
--- a/tools/auto_collect_t20_ledger_v1.py
+++ b/tools/auto_collect_t20_ledger_v1.py
@@ -17,7 +17,7 @@ class T20LedgerCollector:
     """T+20 거래 성과 자동 수집"""
 
     def __init__(self, db_path: str = None):
-        self.db_path = db_path or "src/quant_engine/data_feed.db"
+        self.db_path = db_path or "src/quant_engine/kis_data_collection.db"
         self.results = {
             "timestamp": datetime.now().isoformat(),
             "collections": [],
diff --git a/tools/backup_recovery_manager_v1.py b/tools/backup_recovery_manager_v1.py
index a2a258c..505de3e 100644
--- a/tools/backup_recovery_manager_v1.py
+++ b/tools/backup_recovery_manager_v1.py
@@ -45,7 +45,8 @@ class BackupRecoveryManager:
         try:
             # 필요한 파일 목록
             files_to_backup = [
-                self.data_dir / "data_feed.db",
+                self.data_dir / "kis_data_collection.db",
+                self.data_dir / "snapshot_admin.db",
                 self.data_dir / "calibration_registry.yaml",
                 Path("spec") / "12_field_dictionary.yaml",
                 Path("spec") / "13_formula_registry.yaml",
@@ -294,18 +295,21 @@ class BackupRecoveryManager:
             actual_files = len(list(backup_path.glob("*"))) - 1  # metadata 제외
             expected_files = metadata.get("files_backed_up", actual_files)
 
-            # DB 무결성 검증
-            db_file = backup_path / "data_feed.db"
-            db_integrity = "OK"
-            if db_file.exists():
-                try:
-                    conn = sqlite3.connect(db_file)
-                    cursor = conn.execute("PRAGMA integrity_check")
-                    result = cursor.fetchone()
-                    db_integrity = result[0] if result else "UNKNOWN"
-                    conn.close()
-                except Exception:
-                    db_integrity = "FAILED"
+            # DB 무결성 검증 (2개 DB)
+            db_integrity = {}
+            for db_name in ["kis_data_collection.db", "snapshot_admin.db"]:
+                db_file = backup_path / db_name
+                if db_file.exists():
+                    try:
+                        conn = sqlite3.connect(db_file)
+                        cursor = conn.execute("PRAGMA integrity_check")
+                        result = cursor.fetchone()
+                        db_integrity[db_name] = result[0] if result else "UNKNOWN"
+                        conn.close()
+                    except Exception:
+                        db_integrity[db_name] = "FAILED"
+                else:
+                    db_integrity[db_name] = "NOT_FOUND"
 
             return {
                 "backup_name": backup_name,
diff --git a/tools/initialize_database.py b/tools/initialize_database.py
new file mode 100644
index 0000000..4df41ee
--- /dev/null
+++ b/tools/initialize_database.py
@@ -0,0 +1,134 @@
+#!/usr/bin/env python3
+"""
+데이터베이스 초기화 도구
+data_feed, performance, positions 테이블 생성
+"""
+
+import sqlite3
+from pathlib import Path
+from datetime import datetime
+
+DB_PATH = "src/quant_engine/data_feed.db"
+
+def create_tables():
+    """필수 테이블 생성"""
+    conn = sqlite3.connect(DB_PATH)
+    cursor = conn.cursor()
+
+    # data_feed 테이블
+    cursor.execute("""
+        CREATE TABLE IF NOT EXISTS data_feed (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            ticker TEXT NOT NULL,
+            name TEXT,
+            close_price REAL,
+            entry_price REAL,
+            quantity INTEGER,
+            stop_price REAL,
+            target_price REAL,
+            entry_stage TEXT,
+            account TEXT,
+            entry_date TEXT,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            velocity_1d REAL,
+            velocity_5d REAL,
+            ma20 REAL,
+            atr20 REAL,
+            rsi_14 REAL,
+            volume INTEGER,
+            avg_trade_value_5d REAL,
+            sector TEXT,
+            beta REAL,
+            UNIQUE(ticker, entry_date)
+        )
+    """)
+
+    # performance 테이블
+    cursor.execute("""
+        CREATE TABLE IF NOT EXISTS performance (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            ticker TEXT NOT NULL,
+            name TEXT,
+            entry_date TEXT NOT NULL,
+            entry_price REAL NOT NULL,
+            quantity INTEGER,
+            stop_price REAL,
+            target_price REAL,
+            exit_date TEXT,
+            current_price REAL,
+            pnl_pct REAL,
+            status TEXT,
+            t20_milestone TEXT,
+            entry_stage TEXT,
+            account TEXT,
+            recorded_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            UNIQUE(ticker, entry_date)
+        )
+    """)
+
+    # positions 테이블
+    cursor.execute("""
+        CREATE TABLE IF NOT EXISTS positions (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            ticker TEXT NOT NULL UNIQUE,
+            name TEXT,
+            quantity INTEGER,
+            entry_price REAL,
+            current_price REAL,
+            average_cost REAL,
+            sector TEXT,
+            weight_pct REAL,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        )
+    """)
+
+    # 인덱스 생성
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_data_feed_ticker ON data_feed(ticker)")
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_data_feed_entry_date ON data_feed(entry_date)")
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_performance_ticker ON performance(ticker)")
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_performance_entry_date ON performance(entry_date)")
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_positions_ticker ON positions(ticker)")
+
+    conn.commit()
+    conn.close()
+
+    print(f"[OK] 데이터베이스 초기화 완료: {DB_PATH}")
+    print(f"     생성된 테이블: data_feed, performance, positions")
+
+def verify_database():
+    """데이터베이스 검증"""
+    conn = sqlite3.connect(DB_PATH)
+    cursor = conn.cursor()
+
+    # 테이블 확인
+    cursor.execute("SELECT name FROM sqlite_master WHERE type='table'")
+    tables = [row[0] for row in cursor.fetchall()]
+
+    print(f"\n[검증] 테이블 목록: {', '.join(tables)}")
+    print(f"[검증] 파일 크기: {Path(DB_PATH).stat().st_size / 1024:.2f} KB")
+
+    # 각 테이블 구조 확인
+    for table in tables:
+        cursor.execute(f"PRAGMA table_info({table})")
+        columns = cursor.fetchall()
+        print(f"\n{table} 컬럼:")
+        for col in columns:
+            print(f"  - {col[1]} ({col[2]})")
+
+    conn.close()
+
+if __name__ == "__main__":
+    # 기존 DB 백업
+    db_file = Path(DB_PATH)
+    if db_file.exists():
+        backup_path = f"{DB_PATH}.backup.{datetime.now().strftime('%Y%m%d_%H%M%S')}"
+        db_file.rename(backup_path)
+        print(f"[OK] 기존 데이터베이스 백업: {backup_path}")
+
+    # 새 DB 생성
+    create_tables()
+
+    # 검증
+    verify_database()
+
+    print("\n[완료] 데이터베이스 초기화 완료!")
diff --git a/tools/initialize_database_v2.py b/tools/initialize_database_v2.py
new file mode 100644
index 0000000..91c5e19
--- /dev/null
+++ b/tools/initialize_database_v2.py
@@ -0,0 +1,154 @@
+#!/usr/bin/env python3
+"""
+데이터베이스 초기화 도구 (2개 DB 분리)
+- test_kis_data_collection.db: data_feed 테이블 (KIS API 데이터)
+- snapshot_admin_livecheck.db: performance, positions 테이블 (라이브 체크)
+"""
+
+import sqlite3
+from pathlib import Path
+from datetime import datetime
+
+DB1_PATH = "src/quant_engine/test_kis_data_collection.db"
+DB2_PATH = "src/quant_engine/snapshot_admin_livecheck.db"
+
+def create_db1_schema():
+    """DB1: KIS 데이터 수집 스키마"""
+    conn = sqlite3.connect(DB1_PATH)
+    cursor = conn.cursor()
+
+    # data_feed 테이블
+    cursor.execute("""
+        CREATE TABLE IF NOT EXISTS data_feed (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            ticker TEXT NOT NULL,
+            name TEXT,
+            close_price REAL,
+            entry_price REAL,
+            quantity INTEGER,
+            stop_price REAL,
+            target_price REAL,
+            entry_stage TEXT,
+            account TEXT,
+            entry_date TEXT,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            velocity_1d REAL,
+            velocity_5d REAL,
+            ma20 REAL,
+            atr20 REAL,
+            rsi_14 REAL,
+            volume INTEGER,
+            avg_trade_value_5d REAL,
+            sector TEXT,
+            beta REAL,
+            UNIQUE(ticker, entry_date)
+        )
+    """)
+
+    # 인덱스
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_data_feed_ticker ON data_feed(ticker)")
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_data_feed_entry_date ON data_feed(entry_date)")
+
+    conn.commit()
+    conn.close()
+    print(f"[OK] DB1 생성: {DB1_PATH}")
+    print(f"  테이블: data_feed (KIS API 데이터 수집용)")
+
+def create_db2_schema():
+    """DB2: snapshot_admin 라이브 체크 스키마"""
+    conn = sqlite3.connect(DB2_PATH)
+    cursor = conn.cursor()
+
+    # performance 테이블
+    cursor.execute("""
+        CREATE TABLE IF NOT EXISTS performance (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            ticker TEXT NOT NULL,
+            name TEXT,
+            entry_date TEXT NOT NULL,
+            entry_price REAL NOT NULL,
+            quantity INTEGER,
+            stop_price REAL,
+            target_price REAL,
+            exit_date TEXT,
+            current_price REAL,
+            pnl_pct REAL,
+            status TEXT,
+            t20_milestone TEXT,
+            entry_stage TEXT,
+            account TEXT,
+            recorded_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            UNIQUE(ticker, entry_date)
+        )
+    """)
+
+    # positions 테이블
+    cursor.execute("""
+        CREATE TABLE IF NOT EXISTS positions (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            ticker TEXT NOT NULL UNIQUE,
+            name TEXT,
+            quantity INTEGER,
+            entry_price REAL,
+            current_price REAL,
+            average_cost REAL,
+            sector TEXT,
+            weight_pct REAL,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        )
+    """)
+
+    # 인덱스
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_performance_ticker ON performance(ticker)")
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_performance_entry_date ON performance(entry_date)")
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_positions_ticker ON positions(ticker)")
+
+    conn.commit()
+    conn.close()
+    print(f"[OK] DB2 생성: {DB2_PATH}")
+    print(f"  테이블: performance, positions (snapshot_admin 라이브용)")
+
+def verify_databases():
+    """DB 검증"""
+    print("\n" + "="*80)
+    print("데이터베이스 검증")
+    print("="*80)
+
+    for db_path in [DB1_PATH, DB2_PATH]:
+        conn = sqlite3.connect(db_path)
+        cursor = conn.cursor()
+
+        cursor.execute("SELECT name FROM sqlite_master WHERE type='table'")
+        tables = [row[0] for row in cursor.fetchall()]
+
+        file_size = Path(db_path).stat().st_size / 1024
+        print(f"\n[{Path(db_path).name}]")
+        print(f"  크기: {file_size:.2f} KB")
+        print(f"  테이블: {', '.join(tables)}")
+
+        for table in tables:
+            cursor.execute(f"PRAGMA table_info({table})")
+            col_count = len(cursor.fetchall())
+            print(f"    - {table}: {col_count}개 컬럼")
+
+        conn.close()
+
+if __name__ == "__main__":
+    # 기존 DB 백업
+    for db_path in [DB1_PATH, DB2_PATH]:
+        db_file = Path(db_path)
+        if db_file.exists():
+            backup_path = f"{db_path}.backup.{datetime.now().strftime('%Y%m%d_%H%M%S')}"
+            db_file.rename(backup_path)
+            print(f"[OK] 백업: {backup_path}")
+
+    print("\n새 데이터베이스 생성 중...\n")
+
+    # 새 DB 생성
+    create_db1_schema()
+    create_db2_schema()
+
+    # 검증
+    verify_databases()
+
+    print("\n[완료] 2개 DB 초기화 완료!")
diff --git a/tools/initialize_databases.py b/tools/initialize_databases.py
new file mode 100644
index 0000000..4f0c930
--- /dev/null
+++ b/tools/initialize_databases.py
@@ -0,0 +1,142 @@
+#!/usr/bin/env python3
+"""
+데이터베이스 초기화 도구 (2개 DB)
+1. kis_data_collection.db - KIS API 데이터 수집
+2. snapshot_admin.db - 성능/포지션 관리
+"""
+
+import sqlite3
+from pathlib import Path
+from datetime import datetime
+
+DB1_PATH = "src/quant_engine/kis_data_collection.db"
+DB2_PATH = "src/quant_engine/snapshot_admin.db"
+
+def create_kis_db():
+    """kis_data_collection.db: KIS API 데이터 스키마"""
+    conn = sqlite3.connect(DB1_PATH)
+    cursor = conn.cursor()
+
+    cursor.execute("""
+        CREATE TABLE IF NOT EXISTS data_feed (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            ticker TEXT NOT NULL,
+            name TEXT,
+            close_price REAL,
+            entry_price REAL,
+            quantity INTEGER,
+            stop_price REAL,
+            target_price REAL,
+            entry_stage TEXT,
+            account TEXT,
+            entry_date TEXT,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            velocity_1d REAL,
+            velocity_5d REAL,
+            ma20 REAL,
+            atr20 REAL,
+            rsi_14 REAL,
+            volume INTEGER,
+            avg_trade_value_5d REAL,
+            sector TEXT,
+            beta REAL,
+            UNIQUE(ticker, entry_date)
+        )
+    """)
+
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_data_feed_ticker ON data_feed(ticker)")
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_data_feed_entry_date ON data_feed(entry_date)")
+
+    conn.commit()
+    conn.close()
+    print(f"[OK] kis_data_collection.db: data_feed 테이블 생성")
+
+def create_snapshot_admin_db():
+    """snapshot_admin.db: 성능/포지션 스키마"""
+    conn = sqlite3.connect(DB2_PATH)
+    cursor = conn.cursor()
+
+    cursor.execute("""
+        CREATE TABLE IF NOT EXISTS performance (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            ticker TEXT NOT NULL,
+            name TEXT,
+            entry_date TEXT NOT NULL,
+            entry_price REAL NOT NULL,
+            quantity INTEGER,
+            stop_price REAL,
+            target_price REAL,
+            exit_date TEXT,
+            current_price REAL,
+            pnl_pct REAL,
+            status TEXT,
+            t20_milestone TEXT,
+            entry_stage TEXT,
+            account TEXT,
+            recorded_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            UNIQUE(ticker, entry_date)
+        )
+    """)
+
+    cursor.execute("""
+        CREATE TABLE IF NOT EXISTS positions (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            ticker TEXT NOT NULL UNIQUE,
+            name TEXT,
+            quantity INTEGER,
+            entry_price REAL,
+            current_price REAL,
+            average_cost REAL,
+            sector TEXT,
+            weight_pct REAL,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        )
+    """)
+
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_performance_ticker ON performance(ticker)")
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_performance_entry_date ON performance(entry_date)")
+    cursor.execute("CREATE INDEX IF NOT EXISTS idx_positions_ticker ON positions(ticker)")
+
+    conn.commit()
+    conn.close()
+    print(f"[OK] snapshot_admin.db: performance, positions 테이블 생성")
+
+def verify():
+    """검증"""
+    print("\n" + "="*80)
+    print("데이터베이스 구조 확인")
+    print("="*80)
+
+    for db_path, db_name in [(DB1_PATH, "kis_data_collection.db"), (DB2_PATH, "snapshot_admin.db")]:
+        conn = sqlite3.connect(db_path)
+        cursor = conn.cursor()
+
+        cursor.execute("SELECT name FROM sqlite_master WHERE type='table'")
+        tables = [row[0] for row in cursor.fetchall()]
+
+        file_size = Path(db_path).stat().st_size / 1024
+        print(f"\n[{db_name}]")
+        print(f"  크기: {file_size:.2f} KB")
+        print(f"  테이블: {', '.join(tables)}")
+
+        for table in tables:
+            if table != 'sqlite_sequence':
+                cursor.execute(f"SELECT COUNT(*) FROM {table}")
+                row_count = cursor.fetchone()[0]
+                cursor.execute(f"PRAGMA table_info({table})")
+                col_count = len(cursor.fetchall())
+                print(f"    - {table}: {col_count}개 컬럼, {row_count}개 행")
+
+        conn.close()
+
+if __name__ == "__main__":
+    print("2개 데이터베이스 초기화 중...\n")
+
+    create_kis_db()
+    create_snapshot_admin_db()
+
+    verify()
+
+    print("\n[완료] 2개 DB 초기화 완료!")
+    print(f"  1. kis_data_collection.db (KIS API)")
+    print(f"  2. snapshot_admin.db (성능/포지션)")
diff --git a/tools/measure_sector_flow_reliability_v1.py b/tools/measure_sector_flow_reliability_v1.py
index 56c8638..6c42b07 100644
--- a/tools/measure_sector_flow_reliability_v1.py
+++ b/tools/measure_sector_flow_reliability_v1.py
@@ -16,7 +16,7 @@ class SectorFlowReliabilityMeasure:
     """섹터 플로우 신뢰도 측정 도구"""
 
     def __init__(self, db_path: str = None):
-        self.db_path = db_path or "src/quant_engine/data_feed.db"
+        self.db_path = db_path or "src/quant_engine/kis_data_collection.db"
         self.results = {
             "timestamp": datetime.now().isoformat(),
             "sectors": {},
diff --git a/tools/monitor_wbs_progress_v1.py b/tools/monitor_wbs_progress_v1.py
index 9770ab5..edc48c2 100644
--- a/tools/monitor_wbs_progress_v1.py
+++ b/tools/monitor_wbs_progress_v1.py
@@ -17,7 +17,7 @@ class WBSProgressMonitor:
     """WBS-8 & WBS-9 진행률 모니터링"""
 
     def __init__(self, db_path: str = None):
-        self.db_path = db_path or "src/quant_engine/data_feed.db"
+        self.db_path = db_path or "src/quant_engine/snapshot_admin.db"
         self.results = {
             "timestamp": datetime.now().isoformat(),
             "wbs_8": {},
diff --git a/tools/validate_data_collection_v1.py b/tools/validate_data_collection_v1.py
index 0d17d3d..6ffdf63 100644
--- a/tools/validate_data_collection_v1.py
+++ b/tools/validate_data_collection_v1.py
@@ -16,7 +16,7 @@ class DataCollectionValidator:
     """데이터 수집 기능 및 테이블 검증"""
 
     def __init__(self, db_path: str = None):
-        self.db_path = db_path or "src/quant_engine/data_feed.db"
+        self.db_path = db_path or "src/quant_engine/snapshot_admin.db"
         self.results = {
             "timestamp": datetime.now().isoformat(),
             "database_path": self.db_path,