blob: 196db26cde434eed8c53f02ea8a93202bf3e6614 [file] [log] [blame]
// package databasetest;
// import database.Database2;
// import entity.*;
// import org.junit.jupiter.api.*;
// import javax.persistence.*;
// import java.util.*;
// import java.util.stream.Collectors;
// public class database2Test {
// private static EntityManagerFactory emf;
// private static EntityManager em;
// private static Database2 db;
// @BeforeAll
// static void setup() throws Exception {
// // 强制加载 MySQL 驱动
// Class.forName("com.mysql.cj.jdbc.Driver");
// entity.config cfg = new entity.config();
// Map<String, Object> props = new HashMap<>();
// String jdbcUrl = String.format(
// "jdbc:mysql://%s/%s?useSSL=false&serverTimezone=UTC",
// cfg.SqlURL, cfg.TestDatabase);
// props.put("javax.persistence.jdbc.url", jdbcUrl);
// props.put("javax.persistence.jdbc.user", cfg.SqlUsername);
// props.put("javax.persistence.jdbc.password", cfg.SqlPassword);
// props.put("javax.persistence.jdbc.driver", "com.mysql.cj.jdbc.Driver");
// emf = Persistence.createEntityManagerFactory("myPersistenceUnit", props);
// em = emf.createEntityManager();
// // 修改此处:传入配置好的EntityManagerFactory给Database2
// db = new Database2(emf);
// }
// @AfterAll
// static void teardown() {
// if (em != null && em.isOpen())
// em.close();
// if (emf != null && emf.isOpen())
// emf.close();
// }
// @TestFactory
// Collection<DynamicTest> testAddBegSeed() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String begId = "test_beg_" + UUID.randomUUID().toString();
// BegInfo beg = new BegInfo();
// beg.begid = begId;
// beg.begnumbers = 1;
// beg.magic = 100;
// beg.endtime = new Date();
// beg.hasseed = false;
// return List.of(
// DynamicTest.dynamicTest("AddBegSeed success", () -> {
// int ret = db.AddBegSeed(beg);
// Assertions.assertEquals(0, ret, "AddBegSeed应返回0");
// BegInfo inserted = em.find(BegInfo.class, begId);
// Assertions.assertNotNull(inserted, "求种信息应已插入");
// Assertions.assertFalse(inserted.hasseed, "新求种默认未完成");
// }),
// DynamicTest.dynamicTest("AddBegSeed duplicate", () -> {
// int ret = db.AddBegSeed(beg);
// Assertions.assertEquals(1, ret, "重复插入应返回1");
// }),
// DynamicTest.dynamicTest("AddBegSeed invalid param", () -> {
// Assertions.assertEquals(2, db.AddBegSeed(null));
// BegInfo invalidBeg = new BegInfo();
// invalidBeg.begid = "";
// Assertions.assertEquals(2, db.AddBegSeed(invalidBeg));
// }));
// }
// @TestFactory
// Collection<DynamicTest> testUpdateBegSeed() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String begId = "test_beg_update_" + UUID.randomUUID().toString();
// // 先插入一条求种记录
// BegInfo beg = new BegInfo();
// beg.begid = begId;
// beg.begnumbers = 1;
// beg.magic = 100;
// beg.endtime = new Date();
// db.AddBegSeed(beg);
// return List.of(
// DynamicTest.dynamicTest("UpdateBegSeed success", () -> {
// BegInfo update = new BegInfo();
// update.begid = begId;
// update.begnumbers = 2;
// update.magic = 200;
// int ret = db.UpdateBegSeed(update);
// Assertions.assertEquals(0, ret, "UpdateBegSeed应返回0");
// BegInfo updated = em.find(BegInfo.class, begId);
// Assertions.assertEquals(200, updated.magic, "魔力值应已更新");
// Assertions.assertEquals(2, updated.begnumbers, "求种人数应已更新");
// }),
// DynamicTest.dynamicTest("UpdateBegSeed not exist", () -> {
// BegInfo notExist = new BegInfo();
// notExist.begid = "not_exist_beg";
// notExist.begnumbers = 1;
// int ret = db.UpdateBegSeed(notExist);
// Assertions.assertEquals(1, ret, "不存在的求种应返回1");
// }),
// DynamicTest.dynamicTest("UpdateBegSeed invalid param", () -> {
// Assertions.assertEquals(2, db.UpdateBegSeed(null));
// BegInfo invalid = new BegInfo();
// invalid.begid = "";
// Assertions.assertEquals(2, db.UpdateBegSeed(invalid));
// }));
// }
// @TestFactory
// Collection<DynamicTest> testDeleteBegSeed() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String begId = "test_beg_delete_" + UUID.randomUUID().toString();
// // 先插入一条求种记录
// BegInfo beg = new BegInfo();
// beg.begid = begId;
// beg.begnumbers = 1;
// beg.magic = 100;
// beg.endtime = new Date();
// beg.hasseed = false;
// db.AddBegSeed(beg);
// return List.of(
// DynamicTest.dynamicTest("DeleteBegSeed success", () -> {
// int ret = db.DeleteBegSeed(begId);
// Assertions.assertEquals(0, ret, "DeleteBegSeed应返回0");
// BegInfo deleted = em.find(BegInfo.class, begId);
// Assertions.assertNull(deleted, "求种信息应已删除");
// }),
// DynamicTest.dynamicTest("DeleteBegSeed not exist", () -> {
// int ret = db.DeleteBegSeed("not_exist_beg");
// Assertions.assertEquals(1, ret, "不存在的求种应返回1");
// }),
// DynamicTest.dynamicTest("DeleteBegSeed invalid param", () -> {
// Assertions.assertEquals(2, db.DeleteBegSeed(null));
// Assertions.assertEquals(2, db.DeleteBegSeed(""));
// }));
// }
// @TestFactory
// Collection<DynamicTest> testVoteSeed() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String uid = userIds.get(0);
// String begId = "test_beg_vote_" + UUID.randomUUID().toString();
// String seedId = "test_seed_" + UUID.randomUUID().toString();
// // 插入求种记录
// BegInfo beg = new BegInfo();
// beg.begid = begId;
// beg.begnumbers = 1;
// beg.magic = 100;
// beg.endtime = new Date();
// beg.hasseed = false;
// db.AddBegSeed(beg);
// // 插入种子记录
// Seed seed = new Seed();
// seed.seedid = seedId;
// seed.seeduserid = uid;
// seed.title = "测试种子";
// em.getTransaction().begin();
// em.persist(seed);
// em.getTransaction().commit();
// // 提交种子
// db.SubmitSeed(begId, seed);
// return List.of(
// DynamicTest.dynamicTest("VoteSeed success", () -> {
// int ret = db.VoteSeed(begId, seedId, uid);
// Assertions.assertEquals(0, ret, "VoteSeed应返回0");
// }),
// DynamicTest.dynamicTest("VoteSeed duplicate", () -> {
// int ret = db.VoteSeed(begId, seedId, uid);
// Assertions.assertEquals(1, ret, "重复投票应返回1");
// }),
// DynamicTest.dynamicTest("VoteSeed invalid param", () -> {
// Assertions.assertEquals(2, db.VoteSeed(null, seedId, uid));
// Assertions.assertEquals(2, db.VoteSeed(begId, null, uid));
// Assertions.assertEquals(2, db.VoteSeed(begId, seedId, null));
// }));
// }
// @TestFactory
// Collection<DynamicTest> testSubmitSeed() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String uid = userIds.get(0);
// String begId = "test_beg_submit_" + UUID.randomUUID().toString();
// String seedId = "test_seed_submit_" + UUID.randomUUID().toString();
// // 插入求种记录
// BegInfo beg = new BegInfo();
// beg.begid = begId;
// beg.begnumbers = 1;
// beg.magic = 100;
// beg.endtime = new Date();
// beg.hasseed = false;
// db.AddBegSeed(beg);
// Seed seed = new Seed();
// seed.seedid = seedId;
// seed.seeduserid = uid;
// seed.title = "测试种子";
// return List.of(
// DynamicTest.dynamicTest("SubmitSeed success", () -> {
// int ret = db.SubmitSeed(begId, seed);
// Assertions.assertEquals(0, ret, "SubmitSeed应返回0");
// }),
// DynamicTest.dynamicTest("SubmitSeed duplicate", () -> {
// int ret = db.SubmitSeed(begId, seed);
// Assertions.assertEquals(1, ret, "重复提交应返回1");
// }),
// DynamicTest.dynamicTest("SubmitSeed invalid param", () -> {
// Assertions.assertEquals(2, db.SubmitSeed(null, seed));
// Assertions.assertEquals(2, db.SubmitSeed(begId, null));
// }));
// }
// @Test
// void testSettleBeg() {
// // 准备测试数据
// String uid = em.createQuery("select u.userid from User u", String.class)
// .setMaxResults(1)
// .getSingleResult();
// String begId = "test_beg_settle_" + UUID.randomUUID().toString();
// String seedId = "test_seed_settle_" + UUID.randomUUID().toString();
// // 创建求种记录(已过期)
// BegInfo beg = new BegInfo();
// beg.begid = begId;
// beg.begnumbers = 1;
// beg.magic = 100;
// Calendar cal = Calendar.getInstance();
// cal.add(Calendar.DAY_OF_MONTH, -15); // 15天前
// beg.endtime = cal.getTime();
// beg.hasseed = false;
// db.AddBegSeed(beg);
// // 创建种子并提交
// Seed seed = new Seed();
// seed.seedid = seedId;
// seed.seeduserid = uid;
// seed.title = "测试种子";
// db.SubmitSeed(begId, seed);
// // 投票
// db.VoteSeed(begId, seedId, uid);
// // 执行结算
// db.SettleBeg();
// // 验证结算结果
// BegInfo settled = em.find(BegInfo.class, begId);
// Assertions.assertTrue(settled.hasseed, "求种应已完成");
// UserPT userPT = em.find(UserPT.class, uid);
// Assertions.assertTrue(userPT.magic >= 100, "用户应获得魔力值奖励");
// }
// @TestFactory
// Collection<DynamicTest> testAddPost() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String uid = userIds.get(0);
// String postid = "test_post_" + UUID.randomUUID();
// Post post = new Post();
// post.postid = postid;
// post.postuserid = uid;
// post.posttitle = "单元测试帖子";
// post.postcontent = "内容";
// post.posttime = new Date();
// return List.of(
// DynamicTest.dynamicTest("AddPost success", () -> {
// int ret = db.AddPost(post);
// Assertions.assertEquals(0, ret, "AddPost 应返回0");
// Post inserted = em.find(Post.class, postid);
// Assertions.assertNotNull(inserted, "帖子应已插入");
// }),
// DynamicTest.dynamicTest("AddPost duplicate", () -> {
// int ret = db.AddPost(post);
// Assertions.assertEquals(1, ret, "重复插入应返回1");
// }),
// DynamicTest.dynamicTest("AddPost user not exist", () -> {
// Post p2 = new Post();
// p2.postid = "test_post_" + UUID.randomUUID();
// p2.postuserid = "not_exist_user";
// p2.posttitle = "无效用户";
// p2.postcontent = "内容";
// p2.posttime = new Date();
// int ret = db.AddPost(p2);
// Assertions.assertEquals(2, ret, "用户不存在应返回2");
// }),
// DynamicTest.dynamicTest("AddPost invalid param", () -> {
// Assertions.assertEquals(2, db.AddPost(null));
// Post p3 = new Post();
// p3.postid = null;
// p3.postuserid = uid;
// Assertions.assertEquals(2, db.AddPost(p3));
// Post p4 = new Post();
// p4.postid = "";
// p4.postuserid = uid;
// Assertions.assertEquals(2, db.AddPost(p4));
// }));
// }
// @TestFactory
// Collection<DynamicTest> testUpdatePost() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String uid = userIds.get(0);
// String postid = "test_post_update_" + UUID.randomUUID();
// Post post = new Post();
// post.postid = postid;
// post.postuserid = uid;
// post.posttitle = "原始标题";
// post.postcontent = "原始内容";
// post.posttime = new Date();
// db.AddPost(post);
// return List.of(
// DynamicTest.dynamicTest("UpdatePost success", () -> {
// Post update = new Post();
// update.postid = postid;
// update.postuserid = uid; // 实际实现会忽略此字段
// update.posttitle = "新标题";
// update.postcontent = "新内容";
// update.posttime = post.posttime;
// int ret = db.UpdatePost(update);
// Assertions.assertEquals(0, ret, "UpdatePost 应返回0");
// Post updated = em.find(Post.class, postid);
// Assertions.assertEquals("新标题", updated.posttitle);
// Assertions.assertEquals("新内容", updated.postcontent);
// }),
// DynamicTest.dynamicTest("UpdatePost not exist", () -> {
// Post notExist = new Post();
// notExist.postid = "not_exist_post";
// notExist.postuserid = uid;
// notExist.posttitle = "xxx";
// notExist.postcontent = "xxx";
// int ret = db.UpdatePost(notExist);
// Assertions.assertEquals(1, ret, "不存在的帖子应返回1");
// }),
// DynamicTest.dynamicTest("UpdatePost invalid param", () -> {
// Assertions.assertEquals(2, db.UpdatePost(null));
// Post p2 = new Post();
// p2.postid = null;
// Assertions.assertEquals(2, db.UpdatePost(p2));
// Post p3 = new Post();
// p3.postid = "";
// Assertions.assertEquals(2, db.UpdatePost(p3));
// }));
// }
// @TestFactory
// Collection<DynamicTest> testDeletePost() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String uid = userIds.get(0);
// String postid = "test_post_delete_" + UUID.randomUUID();
// Post post = new Post();
// post.postid = postid;
// post.postuserid = uid;
// post.posttitle = "待删除帖子";
// post.postcontent = "内容";
// post.posttime = new Date();
// db.AddPost(post);
// return List.of(
// DynamicTest.dynamicTest("DeletePost success", () -> {
// int ret = db.DeletePost(postid);
// Assertions.assertEquals(0, ret, "DeletePost 应返回0");
// Post deleted = em.find(Post.class, postid);
// Assertions.assertNull(deleted, "帖子应已删除");
// }),
// DynamicTest.dynamicTest("DeletePost not exist", () -> {
// int ret = db.DeletePost("not_exist_post");
// Assertions.assertEquals(1, ret, "不存在的帖子应返回1");
// }),
// DynamicTest.dynamicTest("DeletePost invalid param", () -> {
// Assertions.assertEquals(2, db.DeletePost(null));
// Assertions.assertEquals(2, db.DeletePost(""));
// }));
// }
// @TestFactory
// Collection<DynamicTest> testAddComment() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// List<String> postIds = em.createQuery("select p.postid from Post p",
// String.class).getResultList();
// if (userIds.isEmpty() || postIds.isEmpty()) {
// return Collections.emptyList();
// }
// String comment = "单元测试评论";
// return userIds.stream().flatMap(uid -> postIds.stream()
// .map(pid -> DynamicTest.dynamicTest("AddComment for user=" + uid + ", post="
// + pid, () -> {
// int ret = db.AddComment(pid, uid, comment);
// Assertions.assertEquals(0, ret, "AddComment 应返回0");
// // 验证评论已插入
// List<PostReply> replies = em.createQuery(
// "SELECT r FROM PostReply r WHERE r.postid = :pid AND r.authorid = :uid AND
// r.content = :c",
// PostReply.class)
// .setParameter("pid", pid)
// .setParameter("uid", uid)
// .setParameter("c", comment)
// .getResultList();
// Assertions.assertFalse(replies.isEmpty(), "评论应已插入");
// }))).collect(Collectors.toList());
// }
// @TestFactory
// Collection<DynamicTest> testDeleteComment() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// List<String> postIds = em.createQuery("select p.postid from Post p",
// String.class).getResultList();
// if (userIds.isEmpty() || postIds.isEmpty()) {
// return Collections.emptyList();
// }
// String comment = "待删除评论";
// List<DynamicTest> tests = new ArrayList<>();
// for (String uid : userIds) {
// for (String pid : postIds) {
// // 插入评论
// db.AddComment(pid, uid, comment);
// // 查询评论id
// List<PostReply> replies = em.createQuery(
// "SELECT r FROM PostReply r WHERE r.postid = :pid AND r.authorid = :uid AND
// r.content = :c",
// PostReply.class)
// .setParameter("pid", pid)
// .setParameter("uid", uid)
// .setParameter("c", comment)
// .getResultList();
// if (replies.isEmpty())
// continue;
// PostReply reply = replies.get(0);
// String replyid = reply.replyid;
// tests.add(DynamicTest.dynamicTest("DeleteComment for post=" + pid + ",
// replyid=" + replyid, () -> {
// int ret = db.DeleteComment(pid, replyid);
// Assertions.assertEquals(0, ret, "DeleteComment 应返回0");
// PostReply deleted = em.find(PostReply.class, replyid);
// Assertions.assertNull(deleted, "评论应已删除");
// }));
// }
// }
// return tests;
// }
// @TestFactory
// Collection<DynamicTest> testExchangeMagicToUpload() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String uid = userIds.get(0);
// final UserPT testUserPT;
// // 确保用户有足够的魔力值用于测试
// EntityTransaction tx = em.getTransaction();
// tx.begin();
// UserPT tempUserPT = em.find(UserPT.class, uid);
// if (tempUserPT == null) {
// tempUserPT = new UserPT();
// tempUserPT.userid = uid;
// tempUserPT.magic = 1000;
// tempUserPT.upload = 1000;
// tempUserPT.download = 1000;
// em.persist(tempUserPT);
// } else {
// tempUserPT.magic = 1000;
// em.merge(tempUserPT);
// }
// testUserPT = tempUserPT;
// tx.commit();
// return List.of(
// DynamicTest.dynamicTest("ExchangeMagicToUpload success", () -> {
// int magic = 100;
// long beforeUpload = testUserPT.upload;
// int beforeMagic = testUserPT.magic;
// boolean ret = db.ExchangeMagicToUpload(uid, magic);
// Assertions.assertTrue(ret, "兑换上传量应成功");
// em.clear();
// UserPT after = em.find(UserPT.class, uid);
// Assertions.assertEquals(beforeMagic - magic, after.magic, "魔力值应减少");
// Assertions.assertEquals(beforeUpload + magic, after.upload, "上传量应增加");
// }),
// DynamicTest.dynamicTest("ExchangeMagicToUpload insufficient magic", () -> {
// boolean ret = db.ExchangeMagicToUpload(uid, 2000);
// Assertions.assertFalse(ret, "魔力值不足时应返回false");
// }),
// DynamicTest.dynamicTest("ExchangeMagicToUpload invalid params", () -> {
// Assertions.assertFalse(db.ExchangeMagicToUpload(null, 100));
// Assertions.assertFalse(db.ExchangeMagicToUpload("", 100));
// Assertions.assertFalse(db.ExchangeMagicToUpload(uid, 0));
// Assertions.assertFalse(db.ExchangeMagicToUpload(uid, -1));
// }));
// }
// @TestFactory
// Collection<DynamicTest> testExchangeMagicToDownload() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String uid = userIds.get(0);
// final UserPT testUserPT;
// // 确保用户有足够的魔力值和下载量用于测试
// EntityTransaction tx = em.getTransaction();
// tx.begin();
// UserPT tempUserPT = em.find(UserPT.class, uid);
// if (tempUserPT == null) {
// tempUserPT = new UserPT();
// tempUserPT.userid = uid;
// tempUserPT.magic = 1000;
// tempUserPT.upload = 1000;
// tempUserPT.download = 1000;
// em.persist(tempUserPT);
// } else {
// tempUserPT.magic = 1000;
// em.merge(tempUserPT);
// }
// testUserPT = tempUserPT;
// tx.commit();
// return List.of(
// DynamicTest.dynamicTest("ExchangeMagicToDownload success", () -> {
// int magic = 100;
// long beforeDownload = testUserPT.download;
// int beforeMagic = testUserPT.magic;
// boolean ret = db.ExchangeMagicToDownload(uid, magic);
// Assertions.assertTrue(ret, "兑换下载量应成功");
// em.clear();
// UserPT after = em.find(UserPT.class, uid);
// Assertions.assertEquals(beforeMagic - magic, after.magic, "魔力值应减少");
// Assertions.assertEquals(beforeDownload - magic, after.download, "下载量应减少");
// }),
// DynamicTest.dynamicTest("ExchangeMagicToDownload insufficient magic", () -> {
// boolean ret = db.ExchangeMagicToDownload(uid, 2000);
// Assertions.assertFalse(ret, "魔力值不足时应返回false");
// }),
// DynamicTest.dynamicTest("ExchangeMagicToDownload invalid params", () -> {
// Assertions.assertFalse(db.ExchangeMagicToDownload(null, 100));
// Assertions.assertFalse(db.ExchangeMagicToDownload("", 100));
// Assertions.assertFalse(db.ExchangeMagicToDownload(uid, 0));
// Assertions.assertFalse(db.ExchangeMagicToDownload(uid, -1));
// }));
// }
// @TestFactory
// Collection<DynamicTest> testExchangeMagicToVip() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String uid = userIds.get(0);
// final UserPT testUserPT;
// // 确保用户有足够的魔力值用于测试
// EntityTransaction tx = em.getTransaction();
// tx.begin();
// UserPT tempUserPT = em.find(UserPT.class, uid);
// if (tempUserPT == null) {
// tempUserPT = new UserPT();
// tempUserPT.userid = uid;
// tempUserPT.magic = 1000;
// tempUserPT.upload = 1000;
// tempUserPT.download = 1000;
// em.persist(tempUserPT);
// } else {
// tempUserPT.magic = 1000;
// em.merge(tempUserPT);
// }
// testUserPT = tempUserPT;
// tx.commit();
// return List.of(
// DynamicTest.dynamicTest("ExchangeMagicToVip success", () -> {
// int magic = 100;
// int beforeVip = testUserPT.viptime;
// int beforeMagic = testUserPT.magic;
// boolean ret = db.ExchangeMagicToVip(uid, magic);
// Assertions.assertTrue(ret, "兑换VIP次数应成功");
// em.clear();
// UserPT after = em.find(UserPT.class, uid);
// Assertions.assertEquals(beforeMagic - magic, after.magic, "魔力值应减少");
// Assertions.assertEquals(beforeVip + magic, after.viptime, "VIP次数应增加");
// }),
// DynamicTest.dynamicTest("ExchangeMagicToVip insufficient magic", () -> {
// boolean ret = db.ExchangeMagicToVip(uid, 2000);
// Assertions.assertFalse(ret, "魔力值不足时应返回false");
// }),
// DynamicTest.dynamicTest("ExchangeMagicToVip invalid params", () -> {
// Assertions.assertFalse(db.ExchangeMagicToVip(null, 100));
// Assertions.assertFalse(db.ExchangeMagicToVip("", 100));
// Assertions.assertFalse(db.ExchangeMagicToVip(uid, 0));
// Assertions.assertFalse(db.ExchangeMagicToVip(uid, -1));
// }));
// }
// @TestFactory
// Collection<DynamicTest> testUploadTransmitProfile() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String uid = userIds.get(0);
// String profileId = "test_profile_" + UUID.randomUUID();
// Profile profile = new Profile();
// profile.profileurl = profileId;
// profile.userid = uid;
// profile.magictogive = "100";
// profile.uploadtogive = "1000";
// profile.downloadtogive = "500";
// return List.of(
// DynamicTest.dynamicTest("UploadTransmitProfile success", () -> {
// boolean ret = db.UploadTransmitProfile(profile);
// Assertions.assertTrue(ret, "上传迁移信息应成功");
// Profile inserted = em.find(Profile.class, profileId);
// Assertions.assertNotNull(inserted, "迁移信息应已插入");
// Assertions.assertFalse(inserted.exampass, "新迁移信息默认未审核");
// Assertions.assertEquals("0", inserted.magicgived, "已发放魔力值应为0");
// Assertions.assertEquals("0", inserted.uploadgived, "已发放上传量应为0");
// }),
// DynamicTest.dynamicTest("UploadTransmitProfile duplicate", () -> {
// boolean ret = db.UploadTransmitProfile(profile);
// Assertions.assertFalse(ret, "重复上传应返回false");
// }),
// DynamicTest.dynamicTest("UploadTransmitProfile invalid params", () -> {
// Assertions.assertFalse(db.UploadTransmitProfile(null));
// Profile invalidProfile = new Profile();
// Assertions.assertFalse(db.UploadTransmitProfile(invalidProfile));
// }));
// }
// @TestFactory
// Collection<DynamicTest> testGetTransmitProfile() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String uid = userIds.get(0);
// String profileId = "test_profile_get_" + UUID.randomUUID();
// Profile profile = new Profile();
// profile.profileurl = profileId;
// profile.userid = uid;
// profile.magictogive = "100";
// profile.uploadtogive = "1000";
// profile.exampass = false;
// // 先插入测试数据
// EntityTransaction tx = em.getTransaction();
// tx.begin();
// em.persist(profile);
// tx.commit();
// return List.of(
// DynamicTest.dynamicTest("GetTransmitProfile success", () -> {
// Profile ret = db.GetTransmitProfile(profileId);
// Assertions.assertNotNull(ret, "应成功获取迁移信息");
// Assertions.assertEquals(uid, ret.userid, "用户ID应匹配");
// Assertions.assertEquals("100", ret.magictogive, "待发放魔力值应匹配");
// Assertions.assertEquals("1000", ret.uploadtogive, "待发放上传量应匹配");
// }),
// DynamicTest.dynamicTest("GetTransmitProfile not exist", () -> {
// Profile ret = db.GetTransmitProfile("not_exist_profile");
// Assertions.assertNull(ret, "不存在的迁移信息应返回null");
// }),
// DynamicTest.dynamicTest("GetTransmitProfile invalid params", () -> {
// Assertions.assertNull(db.GetTransmitProfile(null));
// Assertions.assertNull(db.GetTransmitProfile(""));
// }));
// }
// @TestFactory
// Collection<DynamicTest> testExamTransmitProfile() {
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class).getResultList();
// if (userIds.isEmpty())
// return Collections.emptyList();
// String uid = userIds.get(0);
// String profileId = "test_profile_exam_" + UUID.randomUUID();
// Profile profile = new Profile();
// profile.profileurl = profileId;
// profile.userid = uid;
// profile.magictogive = "100";
// profile.uploadtogive = "1000";
// profile.exampass = false;
// // 先插入测试数据
// EntityTransaction tx = em.getTransaction();
// tx.begin();
// em.persist(profile);
// UserPT userPT = em.find(UserPT.class, uid);
// if (userPT == null) {
// userPT = new UserPT();
// userPT.userid = uid;
// userPT.magic = 0;
// userPT.upload = 0;
// em.persist(userPT);
// }
// tx.commit();
// return List.of(
// DynamicTest.dynamicTest("ExamTransmitProfile approve", () -> {
// boolean ret = db.ExamTransmitProfile(profileId, true);
// Assertions.assertTrue(ret, "审核通过应成功");
// em.clear();
// Profile examined = em.find(Profile.class, profileId);
// Assertions.assertTrue(examined.exampass, "迁移信息应已审核通过");
// Assertions.assertEquals("100", examined.magicgived, "应记录已发放魔力值");
// Assertions.assertEquals("1000", examined.uploadgived, "应记录已发放上传量");
// UserPT afterPT = em.find(UserPT.class, uid);
// Assertions.assertEquals(100, afterPT.magic, "用户魔力值应增加");
// Assertions.assertEquals(1000, afterPT.upload, "用户上传量应增加");
// }),
// DynamicTest.dynamicTest("ExamTransmitProfile reject", () -> {
// String rejectId = "test_profile_reject_" + UUID.randomUUID();
// Profile rejectProfile = new Profile();
// rejectProfile.profileurl = rejectId;
// rejectProfile.userid = uid;
// rejectProfile.magictogive = "100";
// rejectProfile.uploadtogive = "1000";
// rejectProfile.exampass = false;
// tx.begin();
// em.persist(rejectProfile);
// tx.commit();
// boolean ret = db.ExamTransmitProfile(rejectId, false);
// Assertions.assertTrue(ret, "审核拒绝应成功");
// em.clear();
// Profile examined = em.find(Profile.class, rejectId);
// Assertions.assertFalse(examined.exampass, "迁移信息应已审核拒绝");
// Assertions.assertEquals("0", examined.magicgived, "不应发放魔力值");
// Assertions.assertEquals("0", examined.uploadgived, "不应发放上传量");
// }),
// DynamicTest.dynamicTest("ExamTransmitProfile invalid params", () -> {
// Assertions.assertFalse(db.ExamTransmitProfile(null, true));
// Assertions.assertFalse(db.ExamTransmitProfile("", true));
// Assertions.assertFalse(db.ExamTransmitProfile("not_exist_profile", true));
// }));
// }
// @Test
// void testGetTransmitProfileList() {
// // 清空已有数据
// em.getTransaction().begin();
// em.createQuery("DELETE FROM Profile").executeUpdate();
// em.getTransaction().commit();
// // 插入测试数据
// List<String> userIds = em.createQuery("select u.userid from User u",
// String.class)
// .setMaxResults(3)
// .getResultList();
// if (userIds.isEmpty()) {
// return;
// }
// EntityTransaction tx = em.getTransaction();
// tx.begin();
// for (int i = 0; i < userIds.size(); i++) {
// Profile profile = new Profile();
// profile.profileurl = "test_profile_list_" + i;
// profile.userid = userIds.get(i);
// profile.magictogive = String.valueOf(100 * (i + 1));
// profile.uploadtogive = String.valueOf(1000 * (i + 1));
// profile.exampass = false;
// em.persist(profile);
// }
// tx.commit();
// // 测试获取列表
// Profile[] profiles = db.GetTransmitProfileList();
// Assertions.assertEquals(userIds.size(), profiles.length, "应返回所有迁移申请");
// Arrays.stream(profiles)
// .forEach(p ->
// Assertions.assertTrue(p.profileurl.startsWith("test_profile_list_"),
// "应为测试数据"));
// }
// }