From 3a98060078753649ccdb41d300a14b75da0302d2 Mon Sep 17 00:00:00 2001 From: psh Date: Fri, 7 Jun 2024 13:38:16 +0900 Subject: [PATCH] =?UTF-8?q?=EC=9B=90=EC=B2=9C=EB=8D=B0=EC=9D=B4=ED=84=B0?= =?UTF-8?q?=20insert=20=EC=83=98=ED=94=8C=20=EC=BB=A4=EB=B0=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../comtsrcdata/mapper/ComtsrcdataMapper.java | 11 ++++++ .../service/ComtsrcdataService.java | 37 +------------------ .../service/impl/ComtsrcdataServiceImpl.java | 5 +-- .../web/ComtsrcdataController.java | 35 ++++++++++-------- .../mappers/comtsrcdata/Comtsrcdata_SQL.xml | 11 +++++- 5 files changed, 45 insertions(+), 54 deletions(-) diff --git a/src/main/java/egovframework/com/mtdata/comtsrcdata/mapper/ComtsrcdataMapper.java b/src/main/java/egovframework/com/mtdata/comtsrcdata/mapper/ComtsrcdataMapper.java index 300e13f..f762775 100644 --- a/src/main/java/egovframework/com/mtdata/comtsrcdata/mapper/ComtsrcdataMapper.java +++ b/src/main/java/egovframework/com/mtdata/comtsrcdata/mapper/ComtsrcdataMapper.java @@ -36,6 +36,17 @@ public interface ComtsrcdataMapper { public int insertComtTabledataInfo(ComtTableVO vo) throws Exception; + /** + * 원천데이터 테이블을 [comtsrcdatameta]테이블에 저장 + * + * @param vo + * @return + * @throws Exception + */ + public int insertComtSrcdata(ComtsrcdataVO vo) throws Exception; + + + // 원천데이터 jsonb type 테스트 용 샘플 public int updateDatasrc(ComtsrcdataVO vo) throws Exception; /** diff --git a/src/main/java/egovframework/com/mtdata/comtsrcdata/service/ComtsrcdataService.java b/src/main/java/egovframework/com/mtdata/comtsrcdata/service/ComtsrcdataService.java index 80fc1e2..c32cb85 100644 --- a/src/main/java/egovframework/com/mtdata/comtsrcdata/service/ComtsrcdataService.java +++ b/src/main/java/egovframework/com/mtdata/comtsrcdata/service/ComtsrcdataService.java @@ -23,7 +23,7 @@ public interface ComtsrcdataService { * @return * @throws Exception */ - public int insertComtSrcdataInfo(ComtsrcdataVO vo) throws Exception; + public int insertComtSrcdata(ComtsrcdataVO vo) throws Exception; /** @@ -36,6 +36,7 @@ public interface ComtsrcdataService { public int insertComtTabledataInfo(ComtTableVO vo) throws Exception; + /** * test * @@ -49,38 +50,4 @@ public interface ComtsrcdataService { ComtsrcdataDTO selectComtSrcData(ComtsrcdataVO vo) throws Exception; -// /** -// * Yaml 파일을 업데이트하기 위해 목록을 조회한다(pg_chameleon yaml용이나 차후 다른 용도로 쓰임이 있다 판단되면 수정) -// * -// * @param vo -// * @return -// */ -// List selectSysDbConnList(DatabaseInfoVO vo); -// -// /** -// * DB 연결 정보 검증(중복확인) -// * -// * @param vo -// * @return -// */ -// int checkDbConnInfo(DatabaseInfoVO vo); -// -// /** -// * 스키마 내 테이블정보를 [inst_db_tbl_info] 테이블에 저장한다. -// * -// * @param tbVo -// * @return -// */ -// int insertDbTblInfo(TableInfoVO tbVo) throws Exception; -// -// -// -// /** -// * 컬럼 정보를 [inst_tbl_col_info] 테이블에 저장한다. -// * -// * @param colVo -// * @return -// */ -// public int insertTblColInfo(ColumnInfoVO colVo) throws Exception; - } diff --git a/src/main/java/egovframework/com/mtdata/comtsrcdata/service/impl/ComtsrcdataServiceImpl.java b/src/main/java/egovframework/com/mtdata/comtsrcdata/service/impl/ComtsrcdataServiceImpl.java index 78bd568..fa121ec 100644 --- a/src/main/java/egovframework/com/mtdata/comtsrcdata/service/impl/ComtsrcdataServiceImpl.java +++ b/src/main/java/egovframework/com/mtdata/comtsrcdata/service/impl/ComtsrcdataServiceImpl.java @@ -25,15 +25,14 @@ public class ComtsrcdataServiceImpl extends EgovAbstractServiceImpl implements C } @Override - public int insertComtSrcdataInfo(ComtsrcdataVO vo) throws Exception { - return comtsrcdataMapper.insertComtSrcdataInfo(vo); + public int insertComtSrcdata(ComtsrcdataVO vo) throws Exception { + return comtsrcdataMapper.insertComtSrcdata(vo); } @Override public int insertComtTabledataInfo(ComtTableVO vo) throws Exception { return comtsrcdataMapper.insertComtTabledataInfo(vo); } - @Override public int updateDatasrc(ComtsrcdataVO vo) throws Exception { return comtsrcdataMapper.updateDatasrc(vo); diff --git a/src/main/java/egovframework/com/mtdata/comtsrcdata/web/ComtsrcdataController.java b/src/main/java/egovframework/com/mtdata/comtsrcdata/web/ComtsrcdataController.java index 1a9daab..406abd4 100644 --- a/src/main/java/egovframework/com/mtdata/comtsrcdata/web/ComtsrcdataController.java +++ b/src/main/java/egovframework/com/mtdata/comtsrcdata/web/ComtsrcdataController.java @@ -4,7 +4,7 @@ import egovframework.com.mtdata.comtsrcdata.dto.ComtsrcdataDTO; import egovframework.com.mtdata.comtsrcdata.service.ComtsrcdataService; import egovframework.com.mtdata.comtsrcdata.vo.ComtsrcdataVO; import egovframework.com.mtdata.database.vo.DatabaseInfoVO; -//import org.json.simple.JSONObject; +import org.json.simple.JSONObject; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.http.HttpStatus; @@ -14,6 +14,8 @@ import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import java.sql.*; +import java.util.HashMap; +import java.util.Map; @RestController @RequestMapping("/api") @@ -26,12 +28,12 @@ public class ComtsrcdataController { private static final Logger log = LoggerFactory.getLogger(ComtsrcdataController.class); + // jsonb 데이터 업데이트 테스트 샘플 @RequestMapping("/comtsrcdataTest.do") @Transactional(rollbackFor = Exception.class) public String insertDbConn(@ModelAttribute DatabaseInfoVO vo) throws Exception { try { - // jsonb 데이터 업데이트 테스트 ComtsrcdataVO comtvo = new ComtsrcdataVO(); comtvo.setSrcDataVl("{\"id\":\"1\", \"field1\":\"ccc\"}"); int test = service.updateDatasrc(comtvo); @@ -44,8 +46,8 @@ public class ComtsrcdataController { } - - @RequestMapping("/selectComtsrcdata.do") + // jsonb 데이터 insert 테스트 샘플 + @RequestMapping("/insertComtsrcdata.do") @Transactional(rollbackFor = Exception.class) public String selectComtsrcdata( ) throws Exception { @@ -55,19 +57,22 @@ public class ComtsrcdataController { String selectTableSql = "SELECT * FROM smku.test_table1"; Statement stmt = conn.createStatement(); ResultSet datas = stmt.executeQuery(selectTableSql); + JSONObject obj = new JSONObject(); while (datas.next()){ - -// JSONObject obj = new JSONObject(); -// ResultSetMetaData rsmd = datas.getMetaData(); -// int coCnt = rsmd.getColumnCount(); -// for (int i=0; i resultMap = new HashMap<>(); + ResultSetMetaData rsmd = datas.getMetaData(); + int colCnt = rsmd.getColumnCount(); + for (int i=0; i + + + SELECT nextval('comtsrcdata_extr_tbl_id_seq') as srcDataId + + insert into comtsrcdata (src_data_id, extr_id, src_data_vl) + values (#{srcDataId}, #{extrId}, ( (#{srcDataVl})::jsonb ) ) + + + update comtsrcdata - set src_data_vl= ((#{srcDataVl})::jsonb) + set src_data_vl= ( (#{srcDataVl})::jsonb ) where src_data_id= 2