//package com.iplatform.api;
|
//
|
//import com.iplatform.base.service.CodeServiceImpl;
|
//import com.iplatform.gather.LocalAddress;
|
//import com.iplatform.gather.SingleTableGatherScheduler;
|
//import com.iplatform.gather.TestFileTableScheduler;
|
//import com.iplatform.gather.support.DefaultDatabaseStore;
|
//import com.iplatform.model.po.S_code;
|
//import com.iplatform.model.po.S_scheduler;
|
//import com.iplatform.scheduler.PlatformSchedulerManager;
|
//import com.iplatform.scheduler.service.SchedulerServiceImpl;
|
//import com.walker.connector.Address;
|
//import com.walker.db.DatabaseType;
|
//import com.walker.db.page.GenericPager;
|
//import com.walker.db.page.ListPageContext;
|
//import com.walker.infrastructure.utils.StringUtils;
|
//import com.walker.store.AbstractMetaDataEngine;
|
//import com.walker.store.repo.DatabaseRepository;
|
//import com.walker.store.strategy.SingleDatabaseTableStrategy;
|
//import org.slf4j.Logger;
|
//import org.slf4j.LoggerFactory;
|
//import org.springframework.beans.factory.annotation.Autowired;
|
//import org.springframework.web.bind.annotation.RequestMapping;
|
//import org.springframework.web.bind.annotation.RestController;
|
//
|
//import java.util.ArrayList;
|
//import java.util.List;
|
//
|
//@RestController
|
//@RequestMapping("/test/scheduler")
|
//public class TestSchedulerApi {
|
//
|
// private final transient Logger logger = LoggerFactory.getLogger(this.getClass());
|
//
|
// private SchedulerServiceImpl schedulerService;
|
//
|
// private PlatformSchedulerManager schedulerManager;
|
//
|
// private AbstractMetaDataEngine metaDataEngine;
|
//
|
// private LocalAddress localAddress;
|
//
|
// @Autowired
|
// private CodeServiceImpl codeService;
|
//
|
// @Autowired
|
// public TestSchedulerApi(SchedulerServiceImpl service
|
// , PlatformSchedulerManager schedulerManager, AbstractMetaDataEngine metaDataEngine, LocalAddress localAddress){
|
// this.schedulerService = service;
|
// this.schedulerManager = schedulerManager;
|
// this.metaDataEngine = metaDataEngine;
|
// this.localAddress = localAddress;
|
// }
|
//
|
// @RequestMapping("/list_code")
|
// public String testPageInfo(int pageIndex){
|
// ListPageContext.setCurrentPageIndex(pageIndex);
|
// ListPageContext.setCurrentPageSize(5);
|
//// GenericPager<S_code> pager = this.codeService.selectSplit(new S_code(), null, null);
|
// GenericPager<S_code> pager = this.codeService.selectSplit("select * from s_code order by id asc", new Object[]{}, new S_code());
|
// List<S_code> list = pager.getDatas();
|
// logger.info("-----------------> s_code list, page = " + pageIndex);
|
// logger.info("getFirstRowIndex = " + pager.getFirstRowIndexInPage() + ", getEndRowIndex = " + pager.getEndRowIndexPage());
|
// if(!StringUtils.isEmptyList(list)){
|
// for(S_code e : list){
|
// logger.info(e.toString());
|
// }
|
// }
|
// return "ok";
|
// }
|
//
|
// @RequestMapping("/test_create_scheduler")
|
// public String testCreateScheduler() {
|
// logger.info("--------> 创建调度器");
|
// String storeId = "test_store";
|
//
|
// List<Address> addressList = new ArrayList<>(2);
|
// addressList.add(this.localAddress);
|
//
|
// DatabaseRepository repository = new DatabaseRepository();
|
// repository.setId(storeId);
|
// repository.setDefineName("yunjing");
|
// repository.setAddressList(addressList);
|
//
|
// TestTableStrategy tableStrategy = new TestTableStrategy();
|
// tableStrategy.setMetaDataEngine(this.metaDataEngine);
|
// tableStrategy.setStoreId(storeId);
|
// tableStrategy.setRepository(repository);
|
//
|
// DefaultDatabaseStore databaseStore = new DefaultDatabaseStore();
|
// databaseStore.setId(storeId);
|
// databaseStore.setDatabaseType(DatabaseType.MYSQL);
|
// databaseStore.setSupportUpdate(false);
|
// databaseStore.setMetaDataEngine(this.metaDataEngine);
|
// databaseStore.setStoreStrategy(tableStrategy);
|
// databaseStore.initialize();
|
//
|
// SingleTableGatherScheduler scheduler = new TestFileTableScheduler(999, "测试单表调度器", databaseStore);
|
// scheduler.setTimeInterval(5000);
|
// scheduler.setScheduleEngine(this.schedulerManager.getScheduleEngine());
|
// scheduler.setAllowIdleSleep(true);
|
//
|
// this.schedulerManager.startScheduler(scheduler);
|
// return "scheduler started! name=" + scheduler.getName();
|
// }
|
//
|
// @RequestMapping("/test_transaction")
|
// public String testTransaction(){
|
// this.schedulerService.execTestTransaction(true);
|
// return "数据都不能更新，id=1、2，请检查";
|
// }
|
//
|
// @RequestMapping("/query_split")
|
// public String querySplit(int page){
|
//// SplitPageInfo splitPageInfo = new DefaultSplitPageInfo();
|
//// splitPageInfo.setCurrentPage(page);
|
// GenericPager<S_scheduler> pager = this.schedulerService.queryPageSchedulerList(-1);
|
// this.printList(pager.getDatas());
|
// return "ok";
|
// }
|
//
|
// @RequestMapping("/query_running")
|
// public String queryRunning(){
|
// List<S_scheduler> data = this.schedulerService.queryRunningSchedulers();
|
// this.printList(data);
|
// return "ok";
|
// }
|
//
|
// @RequestMapping("/task_start")
|
// public String updateStart(int id){
|
// this.schedulerService.execUpdateSchedulerStarted(id);
|
// return "started!";
|
// }
|
//
|
// private void printList(List<S_scheduler> data){
|
// if(!StringUtils.isEmptyList(data)){
|
// for(S_scheduler e : data){
|
// logger.info(e.toString());
|
// }
|
// }
|
// }
|
//
|
// private class TestTableStrategy extends SingleDatabaseTableStrategy{
|
// @Override
|
// protected String doQueryTableName(Address address, String srcTable, Object parameter) {
|
// // 获得当前日期，把表名拼上日期
|
// return srcTable + StringUtils.UNDERLINE + "test";
|
// }
|
// }
|
//}
|
