diff --git a/Lite/Database/Schema.cs b/Lite/Database/Schema.cs
index 90ac349..1672e19 100644
--- a/Lite/Database/Schema.cs
+++ b/Lite/Database/Schema.cs
@@ -92,8 +92,8 @@ CREATE TABLE IF NOT EXISTS query_stats (
     max_physical_reads BIGINT,
     min_rows BIGINT,
     max_rows BIGINT,
-    min_dop INTEGER,
-    max_dop INTEGER,
+    min_dop BIGINT,
+    max_dop BIGINT,
     min_grant_kb BIGINT,
     max_grant_kb BIGINT,
     min_used_grant_kb BIGINT,
diff --git a/Lite/Services/RemoteCollectorService.QueryStats.cs b/Lite/Services/RemoteCollectorService.QueryStats.cs
index cb0f535..2708e52 100644
--- a/Lite/Services/RemoteCollectorService.QueryStats.cs
+++ b/Lite/Services/RemoteCollectorService.QueryStats.cs
@@ -276,8 +276,8 @@ qs.total_elapsed_time DESC
                        .AppendValue(reader.IsDBNull(19) ? 0L : reader.GetInt64(19))                         /* max_physical_reads */
                        .AppendValue(reader.IsDBNull(20) ? 0L : reader.GetInt64(20))                         /* min_rows */
                        .AppendValue(reader.IsDBNull(21) ? 0L : reader.GetInt64(21))                         /* max_rows */
-                       .AppendValue(reader.IsDBNull(22) ? 0 : Convert.ToInt32(reader.GetValue(22)))         /* min_dop */
-                       .AppendValue(reader.IsDBNull(23) ? 0 : Convert.ToInt32(reader.GetValue(23)))         /* max_dop */
+                       .AppendValue(reader.IsDBNull(22) ? 0L : Convert.ToInt64(reader.GetValue(22)))        /* min_dop */
+                       .AppendValue(reader.IsDBNull(23) ? 0L : Convert.ToInt64(reader.GetValue(23)))        /* max_dop */
                        .AppendValue(reader.IsDBNull(24) ? 0L : reader.GetInt64(24))                         /* min_grant_kb */
                        .AppendValue(reader.IsDBNull(25) ? 0L : reader.GetInt64(25))                         /* max_grant_kb */
                        .AppendValue(reader.IsDBNull(26) ? 0L : reader.GetInt64(26))                         /* min_used_grant_kb */