autumn/JChargePointProtocol
1
0
Fork 0
mirror of https://gitee.com/san-bing/JChargePointProtocol synced 2026-05-05 02:19:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

生成10万根桩做压测

Browse Source
This commit is contained in:
三丙
2024-10-15 16:18:01 +08:00
parent b6193d2d7a
commit 26588112a3
1 changed files with 33 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
jcpp-app-bootstrap/src/test/java/sanbing/jcpp/app/dal/mapper/PileMapperIT.java
View File

@@ -17,7 +17,10 @@ import sanbing.jcpp.infrastructure.util.jackson.JacksonUtil;
import java.text.DecimalFormat; import java.text.DecimalFormat;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
import java.util.UUID; import java.util.UUID;
import java.util.concurrent.atomic.AtomicInteger;
import static sanbing.jcpp.app.dal.mapper.StationMapperIT.NORMAL_STATION_ID; import static sanbing.jcpp.app.dal.mapper.StationMapperIT.NORMAL_STATION_ID;
import static sanbing.jcpp.app.dal.mapper.UserMapperIT.NORMAL_USER_ID; import static sanbing.jcpp.app.dal.mapper.UserMapperIT.NORMAL_USER_ID;
@@ -68,7 +71,36 @@ class PileMapperIT extends AbstractTestBase {
pileMapper.insertOrUpdate(pile); pileMapper.insertOrUpdate(pile);
log.info("{}", pileMapper.selectById(pileId)); log.info("{}", pileMapper.selectById(pileId));
} }
} }
@Test
void generate100KPiles() {
AtomicInteger number = new AtomicInteger(1);
for (int i = 0; i < 100; i++) {
List<Pile> piles = new ArrayList<>();
for (int j = 0; j < 1000; j++, number.incrementAndGet()) {
Pile pile = Pile.builder()
.id(UUID.randomUUID())
.createdTime(LocalDateTime.now())
.additionalInfo(JacksonUtil.newObjectNode())
.pileName(String.format("三丙家的%d号充电桩", number.get()))
.pileCode("20241015" + new DecimalFormat("000000").format(number.get()))
.protocol("yunkuaichongV150")
.stationId(NORMAL_STATION_ID)
.ownerId(NORMAL_USER_ID)
.ownerType(OwnerTypeEnum.C)
.brand("星星")
.model("10A")
.manufacturer("星星")
.status(PileStatusEnum.IDLE)
.type(PileTypeEnum.AC)
.build();
piles.add(pile);
}
pileMapper.insert(piles);
}
log.info("{}", pileMapper.selectCount(Wrappers.lambdaQuery()));
}
} }