diff --git a/pkg/sql/queue_schema_adapter_mysql.go b/pkg/sql/queue_schema_adapter_mysql.go
index 4f9a000..1dfb666 100644
--- a/pkg/sql/queue_schema_adapter_mysql.go
+++ b/pkg/sql/queue_schema_adapter_mysql.go
@@ -98,7 +98,7 @@ func (s MySQLQueueSchema) SelectQuery(params SelectQueryParams) (Query, error) {
 	if s.GenerateWhereClause != nil {
 		where, args = s.GenerateWhereClause(whereParams)
 		if where != "" {
-			where = "AND " + where
+			where = "AND (" + where + ")"
 		}
 	}