@ -66,21 +66,20 @@ public class GroupDAOImpl implements GroupDAO {
}
@Override
public void updateGroup ( DeviceGroup deviceGroup , String oldGroupName , String oldOwner , int tenantId )
public void updateGroup ( DeviceGroup deviceGroup , int groupId , int tenantId )
throws GroupManagementDAOException {
PreparedStatement stmt = null ;
try {
Connection conn = GroupManagementDAOFactory . getConnection ( ) ;
String sql = "UPDATE DM_GROUP SET DESCRIPTION = ?, GROUP_NAME = ?, DATE_OF_LAST_UPDATE = ?, OWNER = ? "
+ "WHERE GROUP_NAME = ? AND OWNER = ? AND TENANT_ID = ?";
+ "WHERE ID = ? AND TENANT_ID = ?";
stmt = conn . prepareStatement ( sql ) ;
stmt . setString ( 1 , deviceGroup . getDescription ( ) ) ;
stmt . setString ( 2 , deviceGroup . getName ( ) ) ;
stmt . setLong ( 3 , deviceGroup . getDateOfLastUpdate ( ) ) ;
stmt . setString ( 4 , deviceGroup . getOwner ( ) ) ;
stmt . setString ( 5 , oldGroupName ) ;
stmt . setString ( 6 , oldOwner ) ;
stmt . setInt ( 7 , tenantId ) ;
stmt . setInt ( 5 , groupId ) ;
stmt . setInt ( 6 , tenantId ) ;
stmt . executeUpdate ( ) ;
} catch ( SQLException e ) {
throw new GroupManagementDAOException ( "Error occurred while updating deviceGroup '" +
@ -91,35 +90,31 @@ public class GroupDAOImpl implements GroupDAO {
}
@Override
public void deleteGroup ( String groupName , String owner , int tenantId ) throws GroupManagementDAOException {
public void deleteGroup ( int groupId , int tenantId ) throws GroupManagementDAOException {
Connection conn ;
PreparedStatement stmt = null ;
try {
conn = GroupManagementDAOFactory . getConnection ( ) ;
String sql = "DELETE FROM DM_DEVICE_GROUP_MAP WHERE GROUP_ID = (SELECT ID AS GROUP_ID FROM DM_GROUP WHERE GROUP_NAME = ? AND OWNER = ? AND TENANT_ID = ?) AND TENANT_ID = ?";
String sql = "DELETE FROM DM_DEVICE_GROUP_MAP WHERE GROUP_ID = ? AND TENANT_ID = ?";
stmt = conn . prepareStatement ( sql ) ;
stmt . setString ( 1 , groupName ) ;
stmt . setString ( 2 , owner ) ;
stmt . setInt ( 3 , tenantId ) ;
stmt . setInt ( 4 , tenantId ) ;
stmt . setInt ( 1 , groupId ) ;
stmt . setInt ( 2 , tenantId ) ;
stmt . executeUpdate ( ) ;
} catch ( SQLException e ) {
throw new GroupManagementDAOException ( "Error occurred while removing mappings for group '" + groupName +
"'" , e ) ;
throw new GroupManagementDAOException ( "Error occurred while removing mappings for group.'" , e ) ;
} finally {
GroupManagementDAOUtil . cleanupResources ( stmt , null ) ;
}
try {
conn = GroupManagementDAOFactory . getConnection ( ) ;
String sql = "DELETE FROM DM_GROUP WHERE GROUP_NAME = ? AND OWNER = ? AND TENANT_ID = ?";
String sql = "DELETE FROM DM_GROUP WHERE ID = ? AND TENANT_ID = ?";
stmt = conn . prepareStatement ( sql ) ;
stmt . setString ( 1 , groupName ) ;
stmt . setString ( 2 , owner ) ;
stmt . setInt ( 3 , tenantId ) ;
stmt . setInt ( 1 , groupId ) ;
stmt . setInt ( 2 , tenantId ) ;
stmt . executeUpdate ( ) ;
} catch ( SQLException e ) {
throw new GroupManagementDAOException ( "Error occurred while deleting group '" + groupName + " '", e ) ;
throw new GroupManagementDAOException ( "Error occurred while deleting group . '", e ) ;
} finally {
GroupManagementDAOUtil . cleanupResources ( stmt , null ) ;
}
@ -150,33 +145,6 @@ public class GroupDAOImpl implements GroupDAO {
}
}
@Override
public DeviceGroup getGroup ( String groupName , String owner , int tenantId )
throws GroupManagementDAOException {
PreparedStatement stmt = null ;
ResultSet resultSet = null ;
try {
Connection conn = GroupManagementDAOFactory . getConnection ( ) ;
String sql = "SELECT ID, DESCRIPTION, GROUP_NAME, DATE_OF_CREATE, DATE_OF_LAST_UPDATE, OWNER "
+ "FROM DM_GROUP WHERE GROUP_NAME = ? AND OWNER = ? AND TENANT_ID = ?" ;
stmt = conn . prepareStatement ( sql ) ;
stmt . setString ( 1 , groupName ) ;
stmt . setString ( 2 , owner ) ;
stmt . setInt ( 3 , tenantId ) ;
resultSet = stmt . executeQuery ( ) ;
if ( resultSet . next ( ) ) {
return GroupManagementDAOUtil . loadGroup ( resultSet ) ;
} else {
return null ;
}
} catch ( SQLException e ) {
throw new GroupManagementDAOException ( "Error occurred while obtaining information of Device Group '" +
groupName + "'" , e ) ;
} finally {
GroupManagementDAOUtil . cleanupResources ( stmt , resultSet ) ;
}
}
@Override
public List < DeviceGroup > getGroups ( int deviceId , int tenantId ) throws GroupManagementDAOException {
@ -281,114 +249,95 @@ public class GroupDAOImpl implements GroupDAO {
}
@Override
public boolean isGroupExist ( String groupName , String owner , int tenantId ) throws GroupManagementDAOException {
public boolean isGroupExist ( String groupName , int tenantId ) throws GroupManagementDAOException {
PreparedStatement stmt = null ;
ResultSet resultSet = null ;
try {
Connection conn = GroupManagementDAOFactory . getConnection ( ) ;
String sql = "SELECT GROUP_NAME FROM DM_GROUP WHERE GROUP_NAME = ? AND OWNER = ? AND TENANT_ID = ?";
String sql = "SELECT GROUP_NAME FROM DM_GROUP WHERE GROUP_NAME = ? AND TENANT_ID = ?";
stmt = conn . prepareStatement ( sql ) ;
stmt . setString ( 1 , groupName ) ;
stmt . setString ( 2 , owner ) ;
stmt . setInt ( 3 , tenantId ) ;
stmt . setInt ( 2 , tenantId ) ;
resultSet = stmt . executeQuery ( ) ;
return resultSet . next ( ) ;
} catch ( SQLException e ) {
throw new GroupManagementDAOException ( "Error occurred while group Id listing by group name '" +
groupName + "'" , e ) ;
throw new GroupManagementDAOException ( "Error occurred while group Id listing by group name.'" , e ) ;
} finally {
GroupManagementDAOUtil . cleanupResources ( stmt , resultSet ) ;
}
}
@Override
public void addDevice ( String groupName , String owner , int deviceId , int tenantId )
public void addDevice ( int groupId , int deviceId , int tenantId )
throws GroupManagementDAOException {
PreparedStatement stmt = null ;
try {
Connection conn = GroupManagementDAOFactory . getConnection ( ) ;
String sql = "INSERT INTO DM_DEVICE_GROUP_MAP(DEVICE_ID, GROUP_ID, TENANT_ID) " +
"VALUES (?, (SELECT ID as GROUP_ID FROM DM_GROUP " +
"WHERE GROUP_NAME = ? AND OWNER = ? AND TENANT_ID = ?), ?)" ;
String sql = "INSERT INTO DM_DEVICE_GROUP_MAP(DEVICE_ID, GROUP_ID, TENANT_ID) VALUES (?, ?, ?)" ;
stmt = conn . prepareStatement ( sql ) ;
stmt . setInt ( 1 , deviceId ) ;
stmt . setString ( 2 , groupName ) ;
stmt . setString ( 3 , owner ) ;
stmt . setInt ( 4 , tenantId ) ;
stmt . setInt ( 5 , tenantId ) ;
stmt . setInt ( 2 , groupId ) ;
stmt . setInt ( 3 , tenantId ) ;
stmt . executeUpdate ( ) ;
stmt . getGeneratedKeys ( ) ;
} catch ( SQLException e ) {
throw new GroupManagementDAOException ( "Error occurred while adding device to Group '" + groupName + "' ", e ) ;
throw new GroupManagementDAOException ( "Error occurred while adding device to Group . ", e ) ;
} finally {
GroupManagementDAOUtil . cleanupResources ( stmt , null ) ;
}
}
@Override
public void removeDevice ( String groupName , String owner , int deviceId , int tenantId )
public void removeDevice ( int groupId , int deviceId , int tenantId )
throws GroupManagementDAOException {
PreparedStatement stmt = null ;
try {
Connection conn = GroupManagementDAOFactory . getConnection ( ) ;
String sql = "DELETE FROM DM_DEVICE_GROUP_MAP WHERE DEVICE_ID = ? AND GROUP_ID = (SELECT ID as GROUP_ID " +
"FROM DM_GROUP WHERE GROUP_NAME = ? AND OWNER = ? AND TENANT_ID = ?) AND TENANT_ID = ?" ;
String sql = "DELETE FROM DM_DEVICE_GROUP_MAP WHERE DEVICE_ID = ? AND GROUP_ID = ? AND TENANT_ID = ?" ;
stmt = conn . prepareStatement ( sql ) ;
stmt . setInt ( 1 , deviceId ) ;
stmt . setString ( 2 , groupName ) ;
stmt . setString ( 3 , owner ) ;
stmt . setInt ( 4 , tenantId ) ;
stmt . setInt ( 5 , tenantId ) ;
stmt . setInt ( 2 , groupId ) ;
stmt . setInt ( 3 , tenantId ) ;
stmt . executeUpdate ( ) ;
stmt . getGeneratedKeys ( ) ;
} catch ( SQLException e ) {
throw new GroupManagementDAOException ( "Error occurred while removing device from Group '" +
groupName + "'" , e ) ;
throw new GroupManagementDAOException ( "Error occurred while removing device from Group." , e ) ;
} finally {
GroupManagementDAOUtil . cleanupResources ( stmt , null ) ;
}
}
@Override
public boolean isDeviceMappedToGroup ( String groupName , String owner , int deviceId , int tenantId )
public boolean isDeviceMappedToGroup ( int groupId , int deviceId , int tenantId )
throws GroupManagementDAOException {
PreparedStatement stmt = null ;
ResultSet resultSet = null ;
try {
Connection conn = GroupManagementDAOFactory . getConnection ( ) ;
String sql = "SELECT dm.ID FROM DM_DEVICE_GROUP_MAP dm, (SELECT ID as GROUP_ID FROM DM_GROUP " +
"WHERE GROUP_NAME = ? AND OWNER = ? AND TENANT_ID = ?) dg " +
"WHERE dm.GROUP_ID = dg.GROUP_ID AND dm.ID = ? AND dm.TENANT_ID = ?" ;
String sql = "SELECT ID FROM DM_DEVICE_GROUP_MAP WHERE GROUP_ID = ? AND DEVICE_ID = ? AND TENANT_ID = ?" ;
stmt = conn . prepareStatement ( sql ) ;
stmt . set String( 1 , groupName ) ;
stmt . set String( 2 , owner ) ;
stmt . setInt ( 1 , groupId ) ;
stmt . set Int( 2 , deviceId ) ;
stmt . setInt ( 3 , tenantId ) ;
stmt . setInt ( 4 , deviceId ) ;
stmt . setInt ( 5 , tenantId ) ;
resultSet = stmt . executeQuery ( ) ;
return resultSet . next ( ) ;
} catch ( SQLException e ) {
throw new GroupManagementDAOException ( "Error occurred while group Id listing by group name '" +
groupName + "'" , e ) ;
throw new GroupManagementDAOException ( "Error occurred while checking device mapping with group." , e ) ;
} finally {
GroupManagementDAOUtil . cleanupResources ( stmt , resultSet ) ;
}
}
@Override
public int getDeviceCount ( String groupName , String owner , int tenantId ) throws GroupManagementDAOException {
public int getDeviceCount ( int groupId , int tenantId ) throws GroupManagementDAOException {
PreparedStatement stmt = null ;
ResultSet resultSet = null ;
try {
Connection conn = GroupManagementDAOFactory . getConnection ( ) ;
String sql = "SELECT COUNT(gm.ID) AS DEVICE_COUNT FROM DM_DEVICE_GROUP_MAP gm, (SELECT ID " +
"FROM DM_GROUP WHERE GROUP_NAME = ? AND OWNER = ? AND TENANT_ID = ?) dg " +
"WHERE gm.GROUP_ID = dg.ID AND gm.TENANT_ID = ?" ;
String sql = "SELECT COUNT(ID) AS DEVICE_COUNT FROM DM_DEVICE_GROUP_MAP WHERE GROUP_ID = ? AND TENANT_ID = ?" ;
stmt = conn . prepareStatement ( sql ) ;
stmt . setString ( 1 , groupName ) ;
stmt . setString ( 2 , owner ) ;
stmt . setInt ( 3 , tenantId ) ;
stmt . setInt ( 4 , tenantId ) ;
stmt . setInt ( 1 , groupId ) ;
stmt . setInt ( 2 , tenantId ) ;
resultSet = stmt . executeQuery ( ) ;
if ( resultSet . next ( ) ) {
return resultSet . getInt ( "DEVICE_COUNT" ) ;
@ -396,54 +345,14 @@ public class GroupDAOImpl implements GroupDAO {
return 0 ;
}
} catch ( SQLException e ) {
throw new GroupManagementDAOException ( "Error occurred while group Id listing by group name '" +
groupName + "'" , e ) ;
throw new GroupManagementDAOException ( "Error occurred while getting device count from the group." , e ) ;
} finally {
GroupManagementDAOUtil . cleanupResources ( stmt , resultSet ) ;
}
}
@Override
public List < Device > getDevices ( String groupName , String owner , int tenantId ) throws GroupManagementDAOException {
Connection conn ;
PreparedStatement stmt = null ;
ResultSet rs = null ;
List < Device > devices = null ;
try {
conn = GroupManagementDAOFactory . getConnection ( ) ;
String sql = "SELECT d1.DEVICE_ID, d1.DESCRIPTION, d1.NAME AS DEVICE_NAME, d1.DEVICE_TYPE, " +
"d1.DEVICE_IDENTIFICATION, e.OWNER, e.OWNERSHIP, e.STATUS, e.DATE_OF_LAST_UPDATE, " +
"e.DATE_OF_ENROLMENT, e.ID AS ENROLMENT_ID FROM DM_ENROLMENT e, " +
"(SELECT gd.DEVICE_ID, gd.DESCRIPTION, gd.NAME, gd.DEVICE_IDENTIFICATION, " +
"t.NAME AS DEVICE_TYPE FROM (SELECT d.ID AS DEVICE_ID, d.DESCRIPTION, d.NAME, " +
"d.DEVICE_IDENTIFICATION, d.DEVICE_TYPE_ID FROM DM_DEVICE d, (SELECT dgm.DEVICE_ID " +
"FROM DM_DEVICE_GROUP_MAP dgm, DM_GROUP dg WHERE dgm.GROUP_ID = dg.ID AND dg.GROUP_NAME = ? " +
"AND dg.OWNER = ? AND dg.TENANT_ID = ?) dgm1 WHERE d.ID = dgm1.DEVICE_ID " +
"AND d.TENANT_ID = ?) gd, DM_DEVICE_TYPE t WHERE gd.DEVICE_TYPE_ID = t.ID) d1 " +
"WHERE d1.DEVICE_ID = e.DEVICE_ID AND TENANT_ID = ?" ;
stmt = conn . prepareStatement ( sql ) ;
stmt . setString ( 1 , groupName ) ;
stmt . setString ( 2 , owner ) ;
stmt . setInt ( 3 , tenantId ) ;
stmt . setInt ( 4 , tenantId ) ;
stmt . setInt ( 5 , tenantId ) ;
rs = stmt . executeQuery ( ) ;
devices = new ArrayList < > ( ) ;
while ( rs . next ( ) ) {
Device device = DeviceManagementDAOUtil . loadDevice ( rs ) ;
devices . add ( device ) ;
}
} catch ( SQLException e ) {
throw new GroupManagementDAOException ( "Error occurred while retrieving information of all " +
"registered devices" , e ) ;
} finally {
DeviceManagementDAOUtil . cleanupResources ( stmt , rs ) ;
}
return devices ;
}
@Override
public List < Device > getDevices ( String groupName , String owner , int startIndex , int rowCount , int tenantId )
public List < Device > getDevices ( int groupId , int startIndex , int rowCount , int tenantId )
throws GroupManagementDAOException {
Connection conn ;
PreparedStatement stmt = null ;
@ -454,24 +363,20 @@ public class GroupDAOImpl implements GroupDAO {
String sql = "SELECT d1.DEVICE_ID, d1.DESCRIPTION, d1.NAME AS DEVICE_NAME, d1.DEVICE_TYPE, " +
"d1.DEVICE_IDENTIFICATION, e.OWNER, e.OWNERSHIP, e.STATUS, e.DATE_OF_LAST_UPDATE, " +
"e.DATE_OF_ENROLMENT, e.ID AS ENROLMENT_ID FROM DM_ENROLMENT e, " +
"(SELECT gd.DEVICE_ID, gd.DESCRIPTION, gd.NAME, gd.DEVICE_IDENTIFICATION, " +
"t.NAME AS DEVICE_TYPE FROM (SELECT d.ID AS DEVICE_ID, d.DESCRIPTION, d.NAME, " +
"d.DEVICE_IDENTIFICATION, d.DEVICE_TYPE_ID FROM DM_DEVICE d, (SELECT dgm.DEVICE_ID " +
"FROM DM_DEVICE_GROUP_MAP dgm, DM_GROUP dg WHERE dgm.GROUP_ID = dg.ID AND dg.GROUP_NAME = ? " +
"AND dg.OWNER = ? AND dg.TENANT_ID = ?) dgm1 WHERE d.ID = dgm1.DEVICE_ID " +
"AND d.TENANT_ID = ?) gd, DM_DEVICE_TYPE t WHERE gd.DEVICE_TYPE_ID = t.ID) d1 " +
"WHERE d1.DEVICE_ID = e.DEVICE_ID AND TENANT_ID = ? LIMIT ?, ?" ;
"(SELECT gd.DEVICE_ID, gd.DESCRIPTION, gd.NAME, gd.DEVICE_IDENTIFICATION, t.NAME AS DEVICE_TYPE FROM " +
"(SELECT d.ID AS DEVICE_ID, d.DESCRIPTION, d.NAME, d.DEVICE_IDENTIFICATION, d.DEVICE_TYPE_ID FROM DM_DEVICE d, (" +
"SELECT dgm.DEVICE_ID FROM DM_DEVICE_GROUP_MAP dgm WHERE dgm.GROUP_ID = ?) dgm1 " +
"WHERE d.ID = dgm1.DEVICE_ID AND d.TENANT_ID = ?) gd, DM_DEVICE_TYPE t " +
"WHERE gd.DEVICE_TYPE_ID = t.ID) d1 WHERE d1.DEVICE_ID = e.DEVICE_ID AND TENANT_ID = ? LIMIT ? , ?" ;
stmt = conn . prepareStatement ( sql ) ;
stmt . set String( 1 , groupName ) ;
stmt . set String( 2 , owner ) ;
stmt . set Int( 1 , groupId ) ;
stmt . set Int( 2 , tenantId ) ;
stmt . setInt ( 3 , tenantId ) ;
stmt . setInt ( 4 , tenantId ) ;
stmt . setInt ( 5 , tenantId ) ;
//noinspection JpaQueryApiInspection
stmt . setInt ( 6 , startIndex ) ;
stmt . setInt ( 4 , startIndex ) ;
//noinspection JpaQueryApiInspection
stmt . setInt ( 7 , rowCount ) ;
stmt . setInt ( 5 , rowCount ) ;
rs = stmt . executeQuery ( ) ;
devices = new ArrayList < > ( ) ;
while ( rs . next ( ) ) {
charitha
8 years ago