Skip to content

Commit

Permalink
Fix auto commit in jdbc adapter
Browse files Browse the repository at this point in the history
  • Loading branch information
FlyingZC committed Oct 7, 2023
1 parent 0fee295 commit b897989
Show file tree
Hide file tree
Showing 29 changed files with 60 additions and 60 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -34,8 +34,8 @@
@TransactionTestCase(adapters = TransactionTestConstants.PROXY, scenario = "addResource")
public final class AddResourceTestCase extends BaseTransactionTestCase {

public AddResourceTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public AddResourceTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,8 +33,8 @@
@Slf4j
public final class CloseResourceTestCase extends BaseTransactionTestCase {

public CloseResourceTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public CloseResourceTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,8 @@
*/
public abstract class AutoCommitTestCase extends BaseTransactionTestCase {

protected AutoCommitTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
protected AutoCommitTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

protected void assertAutoCommitWithStatement() throws SQLException {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,8 +36,8 @@
@TransactionTestCase(dbTypes = TransactionTestConstants.MYSQL)
public final class MySQLAutoCommitTestCase extends AutoCommitTestCase {

public MySQLAutoCommitTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public MySQLAutoCommitTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,8 +36,8 @@
@TransactionTestCase(dbTypes = TransactionTestConstants.POSTGRESQL)
public final class PostgreSQLAutoCommitTestCase extends AutoCommitTestCase {

public PostgreSQLAutoCommitTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public PostgreSQLAutoCommitTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@
@Slf4j
public abstract class BaseTransactionTestCase {

private final TransactionTestCaseParameter parameters;
private final TransactionTestCaseParameter testCaseParam;

/**
* Execute test cases.
Expand Down Expand Up @@ -143,14 +143,14 @@ public static class TransactionTestCaseParameter {
}

protected DataSource getDataSource() {
return parameters.getDataSource();
return testCaseParam.getDataSource();
}

protected TransactionBaseE2EIT getBaseTransactionITCase() {
return parameters.getBaseTransactionITCase();
return testCaseParam.getBaseTransactionITCase();
}

protected TransactionType getTransactionType() {
return parameters.getTransactionType();
return testCaseParam.getTransactionType();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -43,8 +43,8 @@
@TransactionTestCase
public final class ClassicTransferTestCase extends BaseTransactionTestCase {

public ClassicTransferTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public ClassicTransferTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,8 +33,8 @@ public final class BroadcastTableTransactionTestCase extends BaseTransactionTest

private static final String T_ADDRESS = "t_address";

public BroadcastTableTransactionTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public BroadcastTableTransactionTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,8 +37,8 @@
@Slf4j
public final class ExceptionInTransactionTestCase extends BaseTransactionTestCase {

public ExceptionInTransactionTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public ExceptionInTransactionTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,8 +36,8 @@ public final class ImplicitCommitTransactionTestCase extends BaseTransactionTest

private static final String T_ADDRESS = "t_address";

public ImplicitCommitTransactionTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public ImplicitCommitTransactionTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,8 +33,8 @@
@TransactionTestCase(dbTypes = TransactionTestConstants.MYSQL, transactionTypes = TransactionType.XA)
public final class MultiJDBCConnectionsTestCase extends BaseTransactionTestCase {

public MultiJDBCConnectionsTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public MultiJDBCConnectionsTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,8 @@
@TransactionTestCase
public final class MultiOperationsCommitAndRollbackTestCase extends BaseTransactionTestCase {

public MultiOperationsCommitAndRollbackTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public MultiOperationsCommitAndRollbackTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,8 +34,8 @@ public final class MultiTableCommitAndRollbackTestCase extends BaseTransactionTe

private static final String T_ORDER_ITEM = "t_order_item";

public MultiTableCommitAndRollbackTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public MultiTableCommitAndRollbackTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,8 @@
@TransactionTestCase
public final class MultiTransactionInConnectionTestCase extends BaseTransactionTestCase {

public MultiTransactionInConnectionTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public MultiTransactionInConnectionTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,8 @@
@TransactionTestCase
public final class SingleTableCommitAndRollbackTestCase extends BaseTransactionTestCase {

public SingleTableCommitAndRollbackTestCase(TransactionTestCaseParameter parameters) {
super(parameters);
public SingleTableCommitAndRollbackTestCase(TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,8 +44,8 @@ public final class OpenGaussCursorTestCase extends BaseTransactionTestCase {

private final CursorSQLCommand cursorSQLCommand;

public OpenGaussCursorTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public OpenGaussCursorTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
this.cursorSQLCommand = loadCursorSQLCommand();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,8 +47,8 @@ public final class TransactionDeadlockTestCase extends BaseTransactionTestCase {

private final ExecutorService executor = Executors.newFixedThreadPool(2);

public TransactionDeadlockTestCase(TransactionTestCaseParameter parameters) {
super(parameters);
public TransactionDeadlockTestCase(TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,8 +35,8 @@
@TransactionTestCase(transactionTypes = TransactionType.LOCAL, adapters = TransactionTestConstants.JDBC)
public final class NestedTransactionTestCase extends BaseTransactionTestCase {

public NestedTransactionTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public NestedTransactionTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,8 +36,8 @@
@Slf4j
public final class MySQLSetReadOnlyTestCase extends SetReadOnlyTestCase {

public MySQLSetReadOnlyTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public MySQLSetReadOnlyTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,8 @@
@Slf4j
public final class PostgreSQLSetReadOnlyTestCase extends SetReadOnlyTestCase {

public PostgreSQLSetReadOnlyTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public PostgreSQLSetReadOnlyTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,8 @@
*/
public abstract class SetReadOnlyTestCase extends BaseTransactionTestCase {

protected SetReadOnlyTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
protected SetReadOnlyTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

void assertNotSetReadOnly() throws SQLException {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,8 +35,8 @@
@TransactionTestCase(dbTypes = TransactionTestConstants.MYSQL, scenario = "readwrite-splitting", adapters = TransactionTestConstants.PROXY)
public final class ReadwriteSplittingInTransactionTestCase extends BaseTransactionTestCase {

public ReadwriteSplittingInTransactionTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public ReadwriteSplittingInTransactionTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,8 @@
*/
public abstract class BaseSavePointTestCase extends BaseTransactionTestCase {

protected BaseSavePointTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
protected BaseSavePointTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

void assertRollbackToSavepoint() throws SQLException {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,8 +33,8 @@
@TransactionTestCase(dbTypes = TransactionTestConstants.MYSQL)
public final class MySQLSavePointTestCase extends BaseSavePointTestCase {

public MySQLSavePointTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public MySQLSavePointTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,8 +36,8 @@
@TransactionTestCase(dbTypes = TransactionTestConstants.OPENGAUSS)
public final class OpenGaussSavePointTestCase extends BaseSavePointTestCase {

public OpenGaussSavePointTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public OpenGaussSavePointTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,8 +37,8 @@
@TransactionTestCase(dbTypes = TransactionTestConstants.POSTGRESQL)
public final class PostgreSQLSavePointTestCase extends BaseSavePointTestCase {

public PostgreSQLSavePointTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public PostgreSQLSavePointTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,8 @@
@TransactionTestCase(dbTypes = TransactionTestConstants.MYSQL, transactionTypes = TransactionType.LOCAL)
public final class MySQLLocalTruncateTestCase extends BaseTransactionTestCase {

public MySQLLocalTruncateTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public MySQLLocalTruncateTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,8 +37,8 @@
@Slf4j
public final class MySQLXATruncateTestCase extends BaseTransactionTestCase {

public MySQLXATruncateTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public MySQLXATruncateTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,8 @@
@TransactionTestCase(dbTypes = {TransactionTestConstants.POSTGRESQL, TransactionTestConstants.OPENGAUSS})
public final class PostgreSQLAndOpenGaussTruncateTestCase extends BaseTransactionTestCase {

public PostgreSQLAndOpenGaussTruncateTestCase(final TransactionTestCaseParameter parameters) {
super(parameters);
public PostgreSQLAndOpenGaussTruncateTestCase(final TransactionTestCaseParameter testCaseParam) {
super(testCaseParam);
}

@Override
Expand Down

0 comments on commit b897989

Please sign in to comment.