新增多数据源并发单元测试

web/src/test/java/com/jeesite/test/MultiDataSourceTest.java

@@ -0,0 +1,68 @@
+/**
+ * Copyright (c) 2013-Now http://jeesite.com All rights reserved.
+ */
+package com.jeesite.test;
+
+import java.util.List;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+import org.junit.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.ActiveProfiles;
+
+import com.jeesite.common.collect.ListUtils;
+import com.jeesite.common.idgen.IdGen;
+import com.jeesite.common.tests.BaseSpringContextTests;
+import com.jeesite.modules.Application;
+import com.jeesite.modules.test.entity.TestData;
+import com.jeesite.modules.test.entity.TestDataChild;
+import com.jeesite.modules.test.service.TestDataService;
+
+/**
+ * 多数据源并发测试，将 TestDataChildDao 的数据源设置为 ds2
+ * @author ThinkGem
+ * @version 2019-6-26
+ */
+@ActiveProfiles("test")
+@SpringBootTest(classes=Application.class)
+public class MultiDataSourceTest extends BaseSpringContextTests {
+	
+	@Autowired
+	private TestDataService testDataService;
+	
+	@Test
+	public void testData() throws Exception{
+		ExecutorService pool = Executors.newCachedThreadPool();
+		CountDownLatch latch = new CountDownLatch(10);
+		Runnable runnable = new Runnable() {
+			@Override
+			public void run() {
+				try{
+					Thread.sleep(IdGen.randomInt(1000, 3000));
+					TestData testData = new TestData();
+					testData.setTestDataChildList(ListUtils.newArrayList(
+							new TestDataChild(), new TestDataChild(), new TestDataChild()));
+					testDataService.save(testData);
+					List<TestData> list = testDataService.findList(new TestData());
+					System.out.println(list.size());
+					list.forEach(e -> {
+						System.out.println(testDataService.get(e));
+					});
+				} catch (Exception e) {
+					e.printStackTrace();
+				} finally {
+					latch.countDown();
+                }
+			}
+		};
+		for (int i = 0; i < latch.getCount(); i++) {
+			pool.execute(runnable);
+		}
+		latch.await();
+		pool.shutdown();
+	}
+	
+}