diff --git a/server/src/main/java/com/cloud/api/query/dao/DiskOfferingJoinDao.java b/server/src/main/java/com/cloud/api/query/dao/DiskOfferingJoinDao.java
index 639cb5c7083..3d612c63d38 100644
--- a/server/src/main/java/com/cloud/api/query/dao/DiskOfferingJoinDao.java
+++ b/server/src/main/java/com/cloud/api/query/dao/DiskOfferingJoinDao.java
@@ -28,6 +28,8 @@ public interface DiskOfferingJoinDao extends GenericDao<DiskOfferingJoinVO, Long
 
     List<DiskOfferingJoinVO> findByDomainId(long domainId);
 
+    List<DiskOfferingJoinVO> findByZoneId(long zoneId);
+
     DiskOfferingResponse newDiskOfferingResponse(DiskOfferingJoinVO dof);
 
     DiskOfferingJoinVO newDiskOfferingView(DiskOffering dof);
diff --git a/server/src/main/java/com/cloud/api/query/dao/DiskOfferingJoinDaoImpl.java b/server/src/main/java/com/cloud/api/query/dao/DiskOfferingJoinDaoImpl.java
index 31aef932c96..9220974897c 100644
--- a/server/src/main/java/com/cloud/api/query/dao/DiskOfferingJoinDaoImpl.java
+++ b/server/src/main/java/com/cloud/api/query/dao/DiskOfferingJoinDaoImpl.java
@@ -59,6 +59,17 @@ public class DiskOfferingJoinDaoImpl extends GenericDaoBase<DiskOfferingJoinVO,
         return listBy(sc);
     }
 
+    @Override
+    public List<DiskOfferingJoinVO> findByZoneId(long zoneId) {
+        SearchBuilder<DiskOfferingJoinVO> sb = createSearchBuilder();
+        sb.and("zoneId", sb.entity().getZoneId(), SearchCriteria.Op.FIND_IN_SET);
+        sb.done();
+
+        SearchCriteria<DiskOfferingJoinVO> sc = sb.create();
+        sc.setParameters("zoneId", String.valueOf(zoneId));
+        return listBy(sc);
+    }
+
     @Override
     public DiskOfferingResponse newDiskOfferingResponse(DiskOfferingJoinVO offering) {