-
Notifications
You must be signed in to change notification settings - Fork 6.8k
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.
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
Support distributed transactions across multiple logical database(#19… #20114
Support distributed transactions across multiple logical database(#19… #20114
Conversation
Codecov Report
@@ Coverage Diff @@
## master #20114 +/- ##
============================================
+ Coverage 60.54% 60.96% +0.42%
+ Complexity 2422 2418 -4
============================================
Files 3874 3873 -1
Lines 54796 54442 -354
Branches 7679 7626 -53
============================================
+ Hits 33176 33191 +15
+ Misses 18761 18390 -371
- Partials 2859 2861 +2
📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@FlyingZC Please fix ci error first.
I will check. |
@@ -34,8 +35,10 @@ public final class ResourceDataSource { | |||
private final DataSource dataSource; | |||
|
|||
public ResourceDataSource(final String originalName, final DataSource dataSource) { | |||
final String[] databaseAndDataSourceName = originalName.split("\\."); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please remove final here.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
You ar right.
@@ -46,6 +48,7 @@ public ConnectionTransaction(final String databaseName, final TransactionRule ru | |||
} | |||
|
|||
public ConnectionTransaction(final String databaseName, final TransactionType transactionType, final TransactionRule rule) { | |||
this.databaseName = databaseName; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should databaseName be extracted from SQL?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I will check.
Fixes #19894.
Changes proposed in this pull request:
use xx_db
in transaction