File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
package egovframework.migration.service;
import java.util.ArrayList;
import java.util.List;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
@Service("MariaMigrationService")
public class MariaMigrationService {
@Resource(name = "KcdfNewDAO")
private KcdfNewDAO kcdfNewDAO;
@Resource(name = "NcmsDAO")
private NcmsDAO ncmsDAO;
public int selectOracleBasicCount() {
// TODO Auto-generated method stub
return 0;
}
public int selectMariaBasicCount() {
// TODO Auto-generated method stub
return 0;
}
public int selectOraclePublishCount() {
// TODO Auto-generated method stub
return 0;
}
public int selectMariaPublishCount() {
// TODO Auto-generated method stub
return 0;
}
public int selectOracleFileCount() {
// TODO Auto-generated method stub
return 0;
}
public int selectMariaFileCount() {
// TODO Auto-generated method stub
return 0;
}
public int selectOracleResrvationCount() {
// TODO Auto-generated method stub
return 0;
}
public int selectMariaResrvationCount() {
// TODO Auto-generated method stub
return 0;
}
public void selectOracleBasicList() {
// TODO Auto-generated method stub
}
public void selectOraclePublishList() {
// TODO Auto-generated method stub
}
public void selectOracleFileList() {
// TODO Auto-generated method stub
}
public void selectOracleResrvationList() {
// TODO Auto-generated method stub
}
public int selectKcdfBasicCount() {
return kcdfNewDAO.selectKcdfBasicCount();
}
public void kcdfMigration() {
try {
int selectKcdfBasicCount = kcdfNewDAO.selectKcdfBasicCount();
List<KcdfNewBbsVO> list = new ArrayList<KcdfNewBbsVO>();
KcdfNewBbsVO tempKcdfNewBbsVO = new KcdfNewBbsVO(); //limit 를 위해 사용
int enterval = 100;
int i = 0;
if(selectKcdfBasicCount > enterval){
for(i=0; i< selectKcdfBasicCount; i++){ //enterval 개씩 끊어서 insert
if (i % enterval == 0 ){ //0
tempKcdfNewBbsVO.setRecordCountPerPage(enterval);
tempKcdfNewBbsVO.setFirstIndex(i);
list = kcdfNewDAO.selectKcdfBbsList(tempKcdfNewBbsVO);
for(int j=0; j< list.size(); j++){
ncmsDAO.insertNcmsBbsInfo(list.get(j));
}
}
}
/*if(selectKcdfBasicCount != tempKcdfNewBbsVO.getFirstIndex()) { // enterval 개씩 끊어서 insert 후 남은 데이터 insert
tempKcdfNewBbsVO.setFirstIndex(selectKcdfBasicCount);
tempKcdfNewBbsVO.setRecordCountPerPage(enterval);
list = kcdfNewDAO.selectKcdfBbsList(tempKcdfNewBbsVO);
for(i=0; i< list.size(); i++){
kcdfNewDAO.insertNcmsBbsInfo(list.get(i));
}
}*/
}else{ //enterval 개 미만
tempKcdfNewBbsVO.setFirstIndex(0);
tempKcdfNewBbsVO.setRecordCountPerPage(enterval);
list = kcdfNewDAO.selectKcdfBbsList(tempKcdfNewBbsVO);
for(i=0; i< selectKcdfBasicCount; i++){
ncmsDAO.insertNcmsBbsInfo(list.get(i));
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
}