diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/dao/ITestDao.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/dao/ITestDao.java index 696fda5..7d148b6 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/dao/ITestDao.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/dao/ITestDao.java @@ -1,6 +1,8 @@ package cn.estsh.i3plus.core.apiservice.dao; import cn.estsh.i3plus.pojo.base.common.Pager; +import cn.estsh.i3plus.pojo.platform.bean.SysTool; +import cn.estsh.i3plus.pojo.platform.platbean.SysLogSystem; import java.util.List; @@ -13,5 +15,19 @@ import java.util.List; **/ public interface ITestDao { + /** + * 批量新增 + * @param num + * @param waitTime + */ + void insertBatch(int num,int waitTime); + + /** + * mongodb批量新增 + * @param num + * @param waitTime + */ + void insertMongoDBBatch(int num,int waitTime); + List queryToolAndToolType(Pager pager); } diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/daoimpl/TestDaoImpl.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/daoimpl/TestDaoImpl.java index d788613..2f9a560 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/daoimpl/TestDaoImpl.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/daoimpl/TestDaoImpl.java @@ -1,7 +1,10 @@ package cn.estsh.i3plus.core.apiservice.daoimpl; import cn.estsh.i3plus.core.apiservice.dao.ITestDao; +import cn.estsh.i3plus.pojo.base.codemaker.SnowflakeIdMaker; import cn.estsh.i3plus.pojo.base.common.Pager; +import cn.estsh.i3plus.pojo.platform.bean.SysTool; +import org.apache.commons.lang3.RandomStringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; @@ -9,6 +12,7 @@ import org.springframework.stereotype.Service; import javax.persistence.EntityManager; import java.util.List; +import java.util.Random; /** * @Description : 多表测试 @@ -24,6 +28,39 @@ public class TestDaoImpl implements ITestDao { @Autowired private EntityManager entityManager; + public static final String TEXT = "党的十八大提出,倡导富强、民主、文明、和谐,倡导自由、平等、公正、法治,倡导爱国、敬业、诚信、友善,积极培育和践行社会主义核心价值观。富强、民主、文明、和谐是国家层面的价值目标,自由、平等、公正、法治是社会层面的价值取向,爱国、敬业、诚信、友善是公民个人层面的价值准则,这24个字是社会主义核心价值观的基本内容。"; + + @Override + public void insertBatch(int num, int waitTime) { + long t1 = System.currentTimeMillis(); + SysTool sysTool = new SysTool(); + StringBuffer sb = new StringBuffer(); + SnowflakeIdMaker snf = new SnowflakeIdMaker(); + for (int i = 0; i < num * 1000; i++) { + sysTool = new SysTool(); + sysTool.setId(snf.nextId() + System.currentTimeMillis()); + sysTool.setName(RandomStringUtils.random(10, TEXT)); + sysTool.setToolTypeNameRdd(RandomStringUtils.random(10, TEXT)); + sysTool.setToolTypeId(System.currentTimeMillis()); + sysTool.setToolIp(RandomStringUtils.random(10, TEXT)); + sysTool.setToolPort((int) (Math.random() * i)); + sysTool.setToolDescription(RandomStringUtils.random(10, TEXT)); + + sb.append("insert into sys_tool (id,name,tool_type_name_rdd,tool_type_id,tool_ip,tool_port,tool_description) "); + sb.append(" values("+sysTool.getId()+",'"+sysTool.getName()+"','"+sysTool.getToolTypeNameRdd()+"',"+sysTool.getToolTypeId()+",'" + +sysTool.getToolIp()+"',"+sysTool.getToolPort()+",'"+sysTool.getToolDescription()+"')"); + + + } + entityManager.createNativeQuery(sb.toString()); + LOGGER.info("插入耗时:" + (System.currentTimeMillis() - t1) ); + } + + @Override + public void insertMongoDBBatch(int num, int waitTime) { + + } + @Override public List queryToolAndToolType(Pager pager) { String hql = "select t,tt from SysTool as t " + diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysToolService.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysToolService.java index 0c60803..44a0cc8 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysToolService.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysToolService.java @@ -1,6 +1,7 @@ package cn.estsh.i3plus.core.apiservice.serviceimpl.busi; import cn.estsh.i3plus.core.api.iservice.busi.ISysToolService; +import cn.estsh.i3plus.core.apiservice.dao.ITestDao; import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.common.Pager; import cn.estsh.i3plus.pojo.base.common.PagerHelper; @@ -38,6 +39,9 @@ public class SysToolService implements ISysToolService { @Autowired private SysToolTypeRepository toolTypeRDao; + @Autowired + private ITestDao testDao; + @Override @ApiOperation(value = "新增硬件信息") public SysTool insertSysTool(SysTool tool) { @@ -75,27 +79,7 @@ public class SysToolService implements ISysToolService { @Override public void insertBatch(int num,int waitTime){ - long t1 = System.currentTimeMillis(); - SysTool sysTool = new SysTool(); - for (int i = 0; i < num * 1000; i++) { - sysTool = new SysTool(); - //sysTool.setId(System.currentTimeMillis()); - sysTool.setName("新增测试"); - sysTool.setToolTypeId(1073140662133723136L); - sysTool.setToolIp("192.168.1.35"); - sysTool.setToolPort(8888); - sysTool.setToolDescription("描述新增测试"); - - toolRDao.insert(sysTool); - - try { -// wait(waitTime); - Thread.sleep(waitTime); - } catch (InterruptedException e) { - e.printStackTrace(); - } - LOGGER.info("插入耗时:" + (System.currentTimeMillis() - t1) + ",idx:" + i); - } + testDao.insertBatch(num,waitTime); } @Override