Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

feature: support mysql update join sql #4914

Merged
merged 16 commits into from
Oct 18, 2022
Merged

feature: support mysql update join sql #4914

Changes from 1 commit
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
7ce659d
support mysql update join sql
renliangyu857 Sep 6, 2022
245d59f
bugfix:compatible with multi update executor
renliangyu857 Sep 7, 2022
42c6eb5
Merge branch 'develop' into feature_support_mysql_updatejoin
funky-eyes Sep 13, 2022
1b357c0
disable local mysql test
renliangyu857 Sep 22, 2022
f2296b7
Merge remote-tracking branch 'origin/feature_support_mysql_updatejoin…
renliangyu857 Sep 22, 2022
2c73223
add MySQLUpdateJoinExecutor
renliangyu857 Sep 29, 2022
f9314c6
Merge branch 'develop' into feature_support_mysql_updatejoin
renliangyu857 Sep 29, 2022
c27ee3e
Merge branch 'seata:develop' into feature_support_mysql_updatejoin
renliangyu857 Oct 3, 2022
02cb4fa
repair code view
renliangyu857 Oct 3, 2022
343c700
determine which tables are updated according to fields
renliangyu857 Oct 7, 2022
047677e
solve mysql pwd leak
renliangyu857 Oct 7, 2022
5db6257
Merge branch 'develop' into feature_support_mysql_updatejoin
funky-eyes Oct 8, 2022
d54404b
Merge branch 'develop' into feature_support_mysql_updatejoin
funky-eyes Oct 11, 2022
b44f778
Merge branch 'develop' into feature_support_mysql_updatejoin
renliangyu857 Oct 13, 2022
0af1292
resolve conflict with #4985
renliangyu857 Oct 13, 2022
725b94b
resolve code review
renliangyu857 Oct 15, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
bugfix:compatible with multi update executor
  • Loading branch information
@renliangyu857
renliangyu857 committed Sep 7, 2022
commit 245d59fce8cf3a3cc34fa50b2c0a5ca377f744dc
3 changes: 2 additions & 1 deletion rm-datasource/src/main/java/io/seata/rm/datasource/exec/UpdateExecutor.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -155,7 +155,8 @@ protected TableRecords afterImage(TableRecords beforeImage) throws SQLException
int itemTableIndex = tableItems.length == 1 ? 0 : 1; // if length > 1,consider update join sql
String unionTable = tableItems[0];
for (int i = itemTableIndex; i < tableItems.length; i++) {
TableRecords tableBeforeImage = beforeImagesMap.get(tableItems[i]);
//consider MultiUpdateExecutor regenerates updateExecutor object every time when doing afterImage
TableRecords tableBeforeImage = beforeImagesMap.get(tableItems[i]) == null ? beforeImage : beforeImagesMap.get(tableItems[i]);
String selectSQL = buildAfterImageSQL(unionTable, tableItems[i], tableBeforeImage);
ResultSet rs = null;
try (PreparedStatement pst = statementProxy.getConnection().prepareStatement(selectSQL)) {
Expand Down