Update database/db.py

database/db.py

@@ -343,4 +343,46 @@ def read_game_outcomes(conn) -> pd.DataFrame:
         FROM game_outcomes
         ORDER BY graded_at DESC
         """
-    ).df()
+    ).df()
+
+def ensure_batter_prop_outcomes_table(conn) -> None:
+    conn.execute(
+        """
+        CREATE TABLE IF NOT EXISTS batter_prop_outcomes (
+            created_at TEXT,
+            graded_at TEXT,
+            game_pk TEXT,
+            away_team TEXT,
+            home_team TEXT,
+            slot TEXT,
+            batter_name TEXT,
+            pitcher_name TEXT,
+            market TEXT,
+            fair_hr_odds DOUBLE,
+            book_hr_odds DOUBLE,
+            adjusted_edge DOUBLE,
+            confidence DOUBLE,
+            recommendation_tier TEXT,
+            realized_hit INTEGER,
+            realized_hr INTEGER,
+            realized_tb2p INTEGER,
+            grade_status TEXT,
+            outcome_source TEXT
+        )
+        """
+    )
+
+
+def insert_batter_prop_outcomes(conn, df: pd.DataFrame) -> None:
+    if df is None or df.empty:
+        return
+
+    ensure_batter_prop_outcomes_table(conn)
+    conn.register("batter_prop_outcomes_df", df)
+    conn.execute(
+        """
+        INSERT INTO batter_prop_outcomes
+        SELECT * FROM batter_prop_outcomes_df
+        """
+    )
+    conn.unregister("batter_prop_outcomes_df")