forked from community/device-mgt-core
Merge branch 'master' of ssh://repository.entgra.net:222/community/device-mgt-core into imprv/reporting-data-publish
commit
8d597ab310
@ -0,0 +1,431 @@
|
||||
package io.entgra.device.mgt.core.device.mgt.core.dao;
|
||||
|
||||
public interface TenantDAO {
|
||||
|
||||
/**
|
||||
* Delete device certificates of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceCertificateByTenantId(int tenantId)throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete groups of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteGroupByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete role-group mapping data of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteRoleGroupMapByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete devices of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device properties of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDevicePropertiesByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete group properties of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteGroupPropertiesByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device-group mapping details of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceGroupMapByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete operations of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteOperationByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete enrolments of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteEnrolmentByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device statuses of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceStatusByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete enrolment mapping of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteEnrolmentOpMappingByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device operation responses of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceOperationResponseByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete large-device operations responses of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceOperationResponseLargeByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
// Delete policy related tables
|
||||
|
||||
/**
|
||||
* Delete applications of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteApplicationByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete policy compliance features of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deletePolicyComplianceFeaturesByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete policy change management data of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deletePolicyChangeManagementByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete policy compliance statuses of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deletePolicyComplianceStatusByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete policy criteria properties of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deletePolicyCriteriaPropertiesByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete policy criteria of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deletePolicyCriteriaByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete policies of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deletePolicyByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete role policies of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteRolePolicyByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete user policies of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteUserPolicyByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device policies of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDevicePolicyAppliedByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete criteria of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteCriteriaByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device type properties of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceTypePolicyByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device policies of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDevicePolicyByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete profile features of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteProfileFeaturesByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete policy corrective actions of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deletePolicyCorrectiveActionByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete profiles of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteProfileByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete app icons of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteAppIconsByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device group policies of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceGroupPolicyByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete notifications of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteNotificationByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device information of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceInfoByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device location of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceLocationByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device history of last seven days of a tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceHistoryLastSevenDaysByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device details of a tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceDetailByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete metadata of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteMetadataByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete OTP data of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteOTPDataByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete geo fences of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteGeofenceByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete geo fence group mapping data of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteGeofenceGroupMappingByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device events of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceEventByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device event group mapping of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceEventGroupMappingByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete geo fence event mapping of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteGeofenceEventMappingByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete external group mapping of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteExternalGroupMappingByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete External device mapping of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteExternalDeviceMappingByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete external permission mapping of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteExternalPermissionMapping(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete dynamic tasks of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDynamicTaskByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete dynamic task properties of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDynamicTaskPropertiesByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device subtypes of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceSubTypeByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete traccar unsynced devices of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteTraccarUnsyncedDevicesByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete sub operation templates of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteSubOperationTemplate(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete device organizations of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteDeviceOrganizationByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
/**
|
||||
* Delete CEA policies of tenant
|
||||
*
|
||||
* @param tenantId Tenant ID
|
||||
* @throws DeviceManagementDAOException thrown if there is an error when deleting data
|
||||
*/
|
||||
void deleteCEAPoliciesByTenantId(int tenantId) throws DeviceManagementDAOException;
|
||||
|
||||
}
|
@ -0,0 +1,939 @@
|
||||
package io.entgra.device.mgt.core.device.mgt.core.dao.impl;
|
||||
|
||||
import io.entgra.device.mgt.core.device.mgt.core.dao.DeviceManagementDAOException;
|
||||
import io.entgra.device.mgt.core.device.mgt.core.dao.DeviceManagementDAOFactory;
|
||||
import io.entgra.device.mgt.core.device.mgt.core.dao.TenantDAO;
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
|
||||
import java.sql.Connection;
|
||||
import java.sql.PreparedStatement;
|
||||
import java.sql.SQLException;
|
||||
|
||||
|
||||
public class TenantDAOImpl implements TenantDAO {
|
||||
|
||||
private static final Log log = LogFactory.getLog(TenantDAOImpl.class);
|
||||
|
||||
|
||||
@Override
|
||||
public void deleteDeviceCertificateByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_CERTIFICATE WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting certificates for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteGroupByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_GROUP WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting groups for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteRoleGroupMapByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_ROLE_GROUP_MAP WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting role group mapping for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting devices for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDevicePropertiesByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_PROPERTIES WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device properties for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteGroupPropertiesByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM GROUP_PROPERTIES WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting group properties for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceGroupMapByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_GROUP_MAP WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device group mapping for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteOperationByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_OPERATION WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting operations for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteEnrolmentByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_ENROLMENT WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting enrolment for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceStatusByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_STATUS WHERE ENROLMENT_ID IN " +
|
||||
"(SELECT ID FROM DM_ENROLMENT WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device status for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteEnrolmentOpMappingByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_ENROLMENT_OP_MAPPING WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting enrolment op mapping for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceOperationResponseByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_OPERATION_RESPONSE WHERE ID IN " +
|
||||
"(SELECT ID FROM DM_ENROLMENT_OP_MAPPING WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device operation response for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceOperationResponseLargeByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_OPERATION_RESPONSE_LARGE WHERE EN_OP_MAP_ID IN "+
|
||||
"(SELECT ID FROM DM_ENROLMENT_OP_MAPPING WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device operation response large for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteApplicationByTenantId(int tenantId) throws DeviceManagementDAOException{
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_APPLICATION WHERE DEVICE_ID IN " +
|
||||
"(SELECT ID FROM DM_DEVICE WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting applications for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deletePolicyComplianceFeaturesByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_POLICY_COMPLIANCE_FEATURES WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting policy compliance features for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deletePolicyChangeManagementByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_POLICY_CHANGE_MGT WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting policy change management for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deletePolicyComplianceStatusByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_POLICY_COMPLIANCE_STATUS WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting policy compliance status for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deletePolicyCriteriaPropertiesByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_POLICY_CRITERIA_PROPERTIES WHERE POLICY_CRITERION_ID IN " +
|
||||
"(SELECT ID FROM DM_POLICY_CRITERIA WHERE POLICY_ID IN " +
|
||||
"(SELECT ID FROM DM_POLICY WHERE TENANT_ID = ?))";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting policy criteria properties for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deletePolicyCriteriaByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_POLICY_CRITERIA WHERE POLICY_ID IN " +
|
||||
"(SELECT ID FROM DM_POLICY WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting policy criteria for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deletePolicyByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_POLICY WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting policy for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteRolePolicyByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_ROLE_POLICY WHERE POLICY_ID IN " +
|
||||
"(SELECT ID FROM DM_POLICY WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting role policy for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteUserPolicyByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_USER_POLICY WHERE POLICY_ID IN " +
|
||||
"(SELECT ID FROM DM_POLICY WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting user policy for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDevicePolicyAppliedByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_POLICY_APPLIED WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting policy applied for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteCriteriaByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_CRITERIA WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting criteria for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceTypePolicyByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_TYPE_POLICY WHERE POLICY_ID IN " +
|
||||
"(SELECT ID FROM DM_POLICY WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device type policy for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDevicePolicyByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_POLICY WHERE POLICY_ID IN " +
|
||||
"(SELECT ID FROM DM_POLICY WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device policy for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteProfileFeaturesByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_PROFILE_FEATURES WHERE PROFILE_ID IN " +
|
||||
"(SELECT ID FROM DM_PROFILE WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting profile features for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deletePolicyCorrectiveActionByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_POLICY_CORRECTIVE_ACTION WHERE POLICY_ID IN " +
|
||||
"(SELECT ID FROM DM_POLICY WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting policy corrective action for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteProfileByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_PROFILE WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting profile for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteAppIconsByTenantId(int tenantId) throws DeviceManagementDAOException{
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_APP_ICONS WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting App Icons for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceGroupPolicyByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_GROUP_POLICY WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device group policy for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteNotificationByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_NOTIFICATION WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting notifications for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceInfoByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_INFO WHERE ENROLMENT_ID IN " +
|
||||
"(SELECT ID FROM DM_ENROLMENT WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device info for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceLocationByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_LOCATION WHERE ENROLMENT_ID IN " +
|
||||
"(SELECT ID FROM DM_ENROLMENT WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device location for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceHistoryLastSevenDaysByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_HISTORY_LAST_SEVEN_DAYS WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device history for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceDetailByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_DETAIL WHERE ENROLMENT_ID IN " +
|
||||
"(SELECT ID FROM DM_ENROLMENT WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device detail for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteMetadataByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_METADATA WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting metadata for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteOTPDataByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_OTP_DATA WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting OTP data for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteGeofenceByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_GEOFENCE WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting geo fence for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteGeofenceGroupMappingByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_GEOFENCE_GROUP_MAPPING WHERE FENCE_ID IN " +
|
||||
"(SELECT ID FROM DM_GEOFENCE WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting geo fence group mapping for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceEventByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_EVENT WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device event for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceEventGroupMappingByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_EVENT_GROUP_MAPPING WHERE EVENT_ID IN " +
|
||||
"(SELECT ID FROM DM_DEVICE_EVENT WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device event group mapping for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteGeofenceEventMappingByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_GEOFENCE_EVENT_MAPPING WHERE FENCE_ID IN " +
|
||||
"(SELECT ID FROM DM_GEOFENCE WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting geo fence event mapping for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteExternalGroupMappingByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_EXT_GROUP_MAPPING WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting external group mapping for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteExternalDeviceMappingByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_OTP_DATA WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting external device mapping for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteExternalPermissionMapping(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_EXT_PERMISSION_MAPPING WHERE TRACCAR_USER_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting ext permission mapping for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDynamicTaskByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DYNAMIC_TASK WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting dynamic task for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDynamicTaskPropertiesByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DYNAMIC_TASK_PROPERTIES WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting dynamic task properties for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceSubTypeByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_SUB_TYPE WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device sub types for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteTraccarUnsyncedDevicesByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_TRACCAR_UNSYNCED_DEVICES WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting Traccar unsynced devices for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteSubOperationTemplate(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM SUB_OPERATION_TEMPLATE WHERE SUB_TYPE_ID IN " +
|
||||
"(SELECT SUB_TYPE_ID FROM DM_DEVICE_SUB_TYPE WHERE TENANT_ID = ?)";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting sub operation template for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteDeviceOrganizationByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_DEVICE_ORGANIZATION WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting device organization for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteCEAPoliciesByTenantId(int tenantId) throws DeviceManagementDAOException {
|
||||
try {
|
||||
Connection conn = DeviceManagementDAOFactory.getConnection();
|
||||
String sql = "DELETE FROM DM_CEA_POLICIES WHERE TENANT_ID = ?";
|
||||
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
||||
stmt.setInt(1, tenantId);
|
||||
stmt.executeUpdate();
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
String msg = "Error occurred while deleting CEA policies for Tenant ID " + tenantId;
|
||||
log.error(msg, e);
|
||||
throw new DeviceManagementDAOException(msg, e);
|
||||
}
|
||||
|
||||
}
|
||||
}
|
Loading…
Reference in new issue