salmanoe/SC-be-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add PgStatActivityService

Browse Source 
Pembuatan service monitoring proses aktivitas database, service cancel backend, dan service terminate backend
This commit is contained in:
Salman Manoe 2022-01-14 08:18:41 +07:00
parent 16c8f44970
commit 86c4cb9295
5 changed files with 216 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
jasamedika-business/src/main/java/com/jasamedika/medifirst2000/dao/PgStatActivityDao.java Normal file
View File

@ -0,0 +1,32 @@
package com.jasamedika.medifirst2000.dao;
import java.util.List;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.PagingAndSortingRepository;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import com.jasamedika.medifirst2000.entities.PgStatActivity;
/**
* @author salmanoe
* @since Jan 12, 2022
*/
@Repository("pgStatActivityDao")
public interface PgStatActivityDao extends PagingAndSortingRepository<PgStatActivity, Integer> {
@Query(value = "select pid, "
+ "to_char(now() - pg_stat_activity.query_start, 'yyyy-MM-dd HH24:MI:SS.MS') as duration, " + "query, "
+ "state " + "from pg_stat_activity " + "where state != 'idle' "
+ "and (now() - pg_stat_activity.query_start) > interval '1 minutes' "
+ "order by pg_stat_activity.query_start", nativeQuery = true)
List<PgStatActivity> findByStateAndInterval();
@Query(value = "select pg_cancel_backend(:pid)", nativeQuery = true)
void callPgCancelBackend(@Param("pid") Integer pid);
@Query(value = "select pg_terminate_backend(:pid)", nativeQuery = true)
void callPgTerminateBackend(@Param("pid") Integer pid);
}

19
jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/PgStatActivityService.java Normal file
View File

@ -0,0 +1,19 @@
package com.jasamedika.medifirst2000.service;
import java.util.List;
import com.jasamedika.medifirst2000.entities.PgStatActivity;
/**
* @author salmanoe
* @since Jan 12, 2022
*/
public interface PgStatActivityService {
public List<PgStatActivity> findByStateAndInterval();
public Boolean callCancelBackend(Integer pid);
public Boolean callTerminateBackend(Integer pid);
}

43
jasamedika-business/src/main/java/com/jasamedika/medifirst2000/service/impl/PgStatActivityServiceImpl.java Normal file
View File

@ -0,0 +1,43 @@
package com.jasamedika.medifirst2000.service.impl;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.jasamedika.medifirst2000.dao.PgStatActivityDao;
import com.jasamedika.medifirst2000.entities.PgStatActivity;
import com.jasamedika.medifirst2000.service.PgStatActivityService;
/**
* @author salmanoe
* @since Jan 12, 2022
*/
@Service("pgStatActivityService")
public class PgStatActivityServiceImpl implements PgStatActivityService {
@Autowired
private PgStatActivityDao pgStatActivityDao;
@Override
public List<PgStatActivity> findByStateAndInterval() {
List<PgStatActivity> result = pgStatActivityDao.findByStateAndInterval();
return result;
}
@Override
public Boolean callCancelBackend(Integer pid) {
pgStatActivityDao.callPgCancelBackend(pid);
return true;
}
@Override
public Boolean callTerminateBackend(Integer pid) {
pgStatActivityDao.callPgTerminateBackend(pid);
return true;
}
}

46
jasamedika-domain/src/main/java/com/jasamedika/medifirst2000/entities/PgStatActivity.java Normal file
View File

@ -0,0 +1,46 @@
package com.jasamedika.medifirst2000.entities;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import org.hibernate.annotations.Immutable;
/**
* @author salmanoe
* @since Jan 12, 2022
*/
@Entity
@Immutable
public class PgStatActivity {
@Id
@Column(name = "pid", insertable = false, updatable = false)
private Integer pid;
@Column(name = "duration", insertable = false, updatable = false)
private String duration;
@Column(name = "query", insertable = false, updatable = false)
private String query;
@Column(name = "state", insertable = false, updatable = false)
private String state;
public Integer getPid() {
return pid;
}
public String getDuration() {
return duration;
}
public String getQuery() {
return query;
}
public String getState() {
return state;
}
}

76
jasamedika-sdm/src/main/java/com/jasamedika/medifirst2000/controller/IntegrationController.java
View File

@ -1,11 +1,28 @@
package com.jasamedika.medifirst2000.controller;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.orm.jpa.JpaSystemException;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import com.jasamedika.medifirst2000.constants.MessageResource;
import com.jasamedika.medifirst2000.controller.base.LocaleController;
import com.jasamedika.medifirst2000.core.web.WebConstants;
import com.jasamedika.medifirst2000.entities.PgStatActivity;
import com.jasamedika.medifirst2000.exception.ServiceVOException;
import com.jasamedika.medifirst2000.service.PgStatActivityService;
import com.jasamedika.medifirst2000.util.rest.RestUtil;
import com.jasamedika.medifirst2000.vo.LoginUserVO;
@RestController
@ -14,4 +31,63 @@ public class IntegrationController extends LocaleController<LoginUserVO> {
private static final Logger LOGGER = LoggerFactory.getLogger(IntegrationController.class);
@Autowired
private PgStatActivityService pgStatActivityService;
@RequestMapping(value = "/pg-stat-activity/in-state-for-minutes", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
public ResponseEntity<List<PgStatActivity>> getPgStatActivityInStateForMinutes(HttpServletRequest request) {
try {
List<PgStatActivity> result = pgStatActivityService.findByStateAndInterval();
mapHeaderMessage.put(WebConstants.HttpHeaderInfo.LABEL_SUCCESS,
getMessage(MessageResource.LABEL_SUCCESS, request));
return RestUtil.getJsonResponse(result, HttpStatus.OK, mapHeaderMessage);
} catch (ServiceVOException e) {
LOGGER.error("Got exception {} when get pg_stat_activity in state for minutes", e.getMessage());
mapHeaderMessage.put(WebConstants.HttpHeaderInfo.LABEL_SUCCESS, e.getMessage());
return RestUtil.getJsonResponse(HttpStatus.INTERNAL_SERVER_ERROR, mapHeaderMessage);
} catch (JpaSystemException jse) {
LOGGER.error("Got exception {} when get pg_stat_activity in state for minutes", jse.getMessage());
mapHeaderMessage.put(WebConstants.HttpHeaderInfo.LABEL_SUCCESS, jse.getMessage());
return RestUtil.getJsonResponse(HttpStatus.CONFLICT, mapHeaderMessage);
}
}
@RequestMapping(value = "/pg-stat-activity/cancel-backend", method = RequestMethod.POST)
public ResponseEntity<Boolean> callPgCancelBackend(HttpServletRequest request,
@RequestParam(value = "pid", required = true) Integer pid) {
try {
Boolean result = pgStatActivityService.callCancelBackend(pid);
mapHeaderMessage.put(WebConstants.HttpHeaderInfo.LABEL_SUCCESS,
getMessage(MessageResource.LABEL_SUCCESS, request));
return RestUtil.getJsonResponse(result, HttpStatus.OK, mapHeaderMessage);
} catch (ServiceVOException sve) {
LOGGER.error("Got exception {} when call pg_cancel_backend pid : {}", sve.getMessage(), pid);
mapHeaderMessage.put(WebConstants.HttpHeaderInfo.LABEL_SUCCESS, sve.getMessage());
return RestUtil.getJsonResponse(HttpStatus.INTERNAL_SERVER_ERROR, mapHeaderMessage);
} catch (JpaSystemException jse) {
LOGGER.error("Got exception {} when call pg_cancel_backend pid : {}", jse.getMessage(), pid);
mapHeaderMessage.put(WebConstants.HttpHeaderInfo.LABEL_SUCCESS, jse.getMessage());
return RestUtil.getJsonResponse(HttpStatus.CONFLICT, mapHeaderMessage);
}
}
@RequestMapping(value = "/pg-stat-activity/terminate-backend", method = RequestMethod.POST)
public ResponseEntity<Boolean> callPgTerminateBackend(HttpServletRequest request,
@RequestParam(value = "pid", required = true) Integer pid) {
try {
Boolean result = pgStatActivityService.callTerminateBackend(pid);
mapHeaderMessage.put(WebConstants.HttpHeaderInfo.LABEL_SUCCESS,
getMessage(MessageResource.LABEL_SUCCESS, request));
return RestUtil.getJsonResponse(result, HttpStatus.OK, mapHeaderMessage);
} catch (ServiceVOException sve) {
LOGGER.error("Got exception {} when call pg_terminate_backend pid : {}", sve.getMessage(), pid);
mapHeaderMessage.put(WebConstants.HttpHeaderInfo.LABEL_SUCCESS, sve.getMessage());
return RestUtil.getJsonResponse(HttpStatus.INTERNAL_SERVER_ERROR, mapHeaderMessage);
} catch (JpaSystemException jse) {
LOGGER.error("Got exception {} when call pg_terminate_backend pid : {}", jse.getMessage(), pid);
mapHeaderMessage.put(WebConstants.HttpHeaderInfo.LABEL_SUCCESS, jse.getMessage());
return RestUtil.getJsonResponse(HttpStatus.CONFLICT, mapHeaderMessage);
}
}
}