99efb5bde96f6b83763c398d6319c18185d076a7
\345\205\263\344\272\216\351\224\201\350\266\205\346\227\266\351\227\256\351\242\230\346\216\222\346\237\245.md
... | ... | @@ -13,6 +13,123 @@ UPDATE `rbac_user` t SET t.`login_count` = 0, `pwd_expire_day` = 90, `last_login |
13 | 13 | 2024-10-25 10:39:18.685 [pool-8-thread-1] ERROR c.s.snest.engine.db.relationdb.RelationDBAccessor -数据源:main,执行SQL失败:Lock wait timeout exceeded; try restarting transaction |
14 | 14 | |
15 | 15 | |
16 | + |
|
17 | + |
|
18 | +示例代码 |
|
19 | + |
|
20 | +/** |
|
21 | + * 创建用户服务 |
|
22 | + * |
|
23 | + * @param user |
|
24 | + * @throws InterruptedException |
|
25 | + */ |
|
26 | + @MethodService(description = "创建用户") |
|
27 | + public void createUser() throws InterruptedException { |
|
28 | + |
|
29 | + |
|
30 | + |
|
31 | + String sql="replace\r\n" |
|
32 | + + "into\r\n" |
|
33 | + + " test_user (\r\n" |
|
34 | + + "id,\r\n" |
|
35 | + + " name,\r\n" |
|
36 | + + " age,\r\n" |
|
37 | + + " `password`,\r\n" |
|
38 | + + " create_user,\r\n" |
|
39 | + + " create_date,\r\n" |
|
40 | + + " update_user,\r\n" |
|
41 | + + " update_date\r\n" |
|
42 | + + ")\r\n" |
|
43 | + + "select\r\n" |
|
44 | + + " d.id,\r\n" |
|
45 | + + " d.name,\r\n" |
|
46 | + + " d.age,\r\n" |
|
47 | + + " d.tenant_id,\r\n" |
|
48 | + + " u1.name,\r\n" |
|
49 | + + " d.create_date,\r\n" |
|
50 | + + " u2.name,\r\n" |
|
51 | + + " d.update_date\r\n" |
|
52 | + + "from\r\n" |
|
53 | + + " edo_user d,\r\n" |
|
54 | + + " rbac_user u1,\r\n" |
|
55 | + + " rbac_user u2\r\n" |
|
56 | + + "where\r\n" |
|
57 | + + " u1.id = d.create_user\r\n" |
|
58 | + + " and u2.id = d.update_user"; |
|
59 | + |
|
60 | + |
|
61 | + |
|
62 | + |
|
63 | + |
|
64 | + BussModelDataAccess bussModelDataAccess = (BussModelDataAccess) ModelDataAccessFactory.getDataAccess(ModelTypeEnum.Buss); |
|
65 | + RelationDBAccessor dataAccessor = bussModelDataAccess.getRelationDBAccessor(); |
|
66 | + dataAccessor.execute(sql); |
|
67 | + |
|
68 | + |
|
69 | + |
|
70 | +// |
|
71 | +// TestUser user=new TestUser(); |
|
72 | +// user.setId("10000"); |
|
73 | +// user.setName(System.currentTimeMillis()+""); |
|
74 | +// user.setAge(32); |
|
75 | +// user.setEmail(System.currentTimeMillis()+"@qq.com"); |
|
76 | +// user.setPassword("123456"); |
|
77 | +// user.create(); |
|
78 | + |
|
79 | + TestUser testUser = super.selectById("10000"); |
|
80 | + if (testUser != null) { |
|
81 | + testUser.setEmail("cdchencw@120.com"); |
|
82 | + testUser.setAge(5); |
|
83 | + testUser.update(); |
|
84 | + } |
|
85 | + |
|
86 | + |
|
87 | + |
|
88 | + TestRole role = new TestRole(); |
|
89 | + role.setRoleName("test"); |
|
90 | + role.set("remark", "测试"); |
|
91 | + role.create(); |
|
92 | + |
|
93 | + Thread.sleep(11000); |
|
94 | + System.out.println("执行完毕: #0001"); |
|
95 | + } |
|
96 | + |
|
97 | + |
|
98 | + |
|
99 | + |
|
100 | +``` |
|
101 | +replace |
|
102 | +into |
|
103 | + test_user ( |
|
104 | +id, |
|
105 | + name, |
|
106 | + age, |
|
107 | + `password`, |
|
108 | + create_user, |
|
109 | + create_date, |
|
110 | + update_user, |
|
111 | + update_date |
|
112 | +) |
|
113 | +select |
|
114 | + d.id, |
|
115 | + d.name, |
|
116 | + d.age, |
|
117 | + d.tenant_id, |
|
118 | + u1.name, |
|
119 | + d.create_date, |
|
120 | + u2.name, |
|
121 | + d.update_date |
|
122 | +from |
|
123 | + edo_user d, |
|
124 | + rbac_user u1, |
|
125 | + rbac_user u2 |
|
126 | +where |
|
127 | + u1.id = d.create_user |
|
128 | + and u2.id = d.update_user; |
|
129 | +``` |
|
130 | + |
|
131 | + |
|
132 | + |
|
16 | 133 | ``` |
17 | 134 | |
18 | 135 |