diff --git a/db/nexrad.sql b/db/nexrad.sql
index 0dcd2db..a161384 100644
--- a/db/nexrad.sql
+++ b/db/nexrad.sql
@@ -49,6 +49,7 @@ create table nexrad_afos_message (
     timestamp_start  TIMESTAMP NOT NULL,
     timestamp_end    TIMESTAMP NOT NULL,
     serial           INTEGER NOT NULL,
+    product          TEXT NOT NULL,
     vtec_type        TEXT NOT NULL,
     actions          TEXT NOT NULL,
     wfo              TEXT NOT NULL,
@@ -62,6 +63,7 @@ create table nexrad_afos_message (
 );
 
 create index nexrad_afos_message_timestamp_idx on nexrad_afos_message (timestamp_start, timestamp_end);
+create index nexrad_afos_message_product_idx   on nexrad_afos_message (product);
 create index nexrad_afos_message_wfo_idx       on nexrad_afos_message (wfo);
 create index nexrad_afos_message_phenom_idx    on nexrad_afos_message (phenom);
 create index nexrad_afos_message_sig_idx       on nexrad_afos_message (sig);